X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=plugins%2FMeteor%2FMeteorPlugin.php;h=5b345d7c2fa339af694f7bcb5d613789992c46aa;hb=409ce3556d07f66e5a65e035f9d52b8421441911;hp=291c4e3a2a9c29d78fe5525a0e7bd15148759248;hpb=cc317b169fa43ebf9c12b695d51cee88b8551ef4;p=quix0rs-gnu-social.git diff --git a/plugins/Meteor/MeteorPlugin.php b/plugins/Meteor/MeteorPlugin.php index 291c4e3a2a..5b345d7c2f 100644 --- a/plugins/Meteor/MeteorPlugin.php +++ b/plugins/Meteor/MeteorPlugin.php @@ -1,6 +1,6 @@ . * * @category Plugin - * @package Laconica - * @author Evan Prodromou - * @copyright 2009 Control Yourself, Inc. + * @package StatusNet + * @author Evan Prodromou + * @copyright 2009 StatusNet, Inc. * @license http://www.fsf.org/licensing/licenses/agpl-3.0.html GNU Affero General Public License version 3.0 - * @link http://laconi.ca/ + * @link http://status.net/ */ -if (!defined('LACONICA')) { +if (!defined('STATUSNET') && !defined('LACONICA')) { exit(1); } +require_once INSTALLDIR.'/plugins/Realtime/RealtimePlugin.php'; + /** - * Plugin to do realtime updates using Comet + * Plugin to do realtime updates using Meteor * * @category Plugin - * @package Laconica - * @author Evan Prodromou + * @package StatusNet + * @author Evan Prodromou * @license http://www.fsf.org/licensing/licenses/agpl-3.0.html GNU Affero General Public License version 3.0 - * @link http://laconi.ca/ + * @link http://status.net/ */ -class MeteorPlugin extends Plugin +class MeteorPlugin extends RealtimePlugin { - var $webserver = null; - var $webport = null; - var $controlport = null; - var $controlserver = null; - var $channelbase = null; - var $_socket = null; + public $webserver = null; + public $webport = null; + public $controlport = null; + public $controlserver = null; + public $channelbase = null; + protected $_socket = null; function __construct($webserver=null, $webport=4670, $controlport=4671, $controlserver=null, $channelbase='') { @@ -63,177 +65,56 @@ class MeteorPlugin extends Plugin parent::__construct(); } - function onEndShowScripts($action) + function _getScripts() { - $timeline = null; - - $this->log(LOG_DEBUG, 'got action ' . $action->trimmed('action')); - - switch ($action->trimmed('action')) { - case 'public': - $timeline = '/timelines/public'; - break; - case 'tag': - $tag = $action->trimmed('tag'); - if (!empty($tag)) { - $timeline = '/timelines/tag/'.$tag; - } else { - return true; - } - break; - default: - return true; - } - - $action->element('script', array('type' => 'text/javascript', - 'src' => 'http://'.$this->webserver.(($this->webport == 80) ? '':':'.$this->webport).'/meteor.js'), - ' '); - - foreach (array('meteorupdater.js', 'json2.js') as $script) { - $action->element('script', array('type' => 'text/javascript', - 'src' => common_path('plugins/Meteor/'.$script)), - ' '); - } - - $user = common_current_user(); - - if (!empty($user->id)) { - $user_id = $user->id; - } else { - $user_id = 0; - } - - $replyurl = common_local_url('newnotice'); - $favorurl = common_local_url('favor'); - // FIXME: need to find a better way to pass this pattern in - $deleteurl = common_local_url('deletenotice', - array('notice' => '0000000000')); - - $action->elementStart('script', array('type' => 'text/javascript')); - $action->raw("$(document).ready(function() { MeteorUpdater.init(\"$this->webserver\", $this->webport, \"{$this->channelbase}$timeline\", $user_id, \"$replyurl\", \"$favorurl\", \"$deleteurl\"); });"); - $action->elementEnd('script'); - - return true; + $scripts = parent::_getScripts(); + $scripts[] = 'http://'.$this->webserver.(($this->webport == 80) ? '':':'.$this->webport).'/meteor.js'; + $scripts[] = common_path('plugins/Meteor/meteorupdater.js'); + return $scripts; } - function onEndNoticeSave($notice) + function _updateInitialize($timeline, $user_id) { - $this->log(LOG_INFO, "Called for save notice."); - - $timelines = array(); - - // XXX: Add other timelines; this is just for the public one - - if ($notice->is_local || - ($notice->is_local == 0 && !common_config('public', 'localonly'))) { - $timelines[] = '/timelines/public'; - } - - $tags = $this->getNoticeTags($notice); - - if (!empty($tags)) { - foreach ($tags as $tag) { - $timelines[] = '/timelines/tag/' . $tag; - } - } - - if (count($timelines) > 0) { - - $json = json_encode($this->noticeAsJson($notice)); - - $this->log(LOG_DEBUG, $json); - - $this->_connect(); - - foreach ($timelines as $timeline) { - $this->_addMessage($timeline, $json); - } - - $this->_disconnect(); - } - - return true; + $script = parent::_updateInitialize($timeline, $user_id); + return $script." MeteorUpdater.init(\"$this->webserver\", $this->webport, \"{$timeline}\");"; } function _connect() { + $controlserver = (empty($this->controlserver)) ? $this->webserver : $this->controlserver; // May throw an exception. - $this->_socket = @stream_socket_client("tcp://{$this->controlserver}:{$this->controlport}", - $errno, $errstr, $timeout, $conflag); + $this->_socket = stream_socket_client("tcp://{$controlserver}:{$this->controlport}"); if (!$this->_socket) { - throw new Exception("Couldn't connect to {$this->controlserver} on {$this->controlport}"); + throw new Exception("Couldn't connect to {$controlserver} on {$this->controlport}"); } } - function _addMessage($channel, $message) + function _publish($channel, $message) { - $cmd = "ADDMESSAGE {$this->channelbase}$channel $message\n"; - $this->log(LOG_DEBUG, $cmd); - @fwrite($this->_socket, "COMMAND: $cmd"); + $message = json_encode($message); + $message = addslashes($message); + $cmd = "ADDMESSAGE $channel $message\n"; + $cnt = fwrite($this->_socket, $cmd); $result = fgets($this->_socket); - $this->log(LOG_DEBUG, "RESULT: $result"); + if (preg_match('/^ERR (.*)$/', $result, $matches)) { + throw new Exception('Error adding meteor message "'.$matches[1].'"'); + } // TODO: parse and deal with result } function _disconnect() { + $cnt = fwrite($this->_socket, "QUIT\n"); @fclose($this->_socket); } - function noticeAsJson($notice) - { - // FIXME: this code should be abstracted to a neutral third - // party, like Notice::asJson(). I'm not sure of the ethics - // of refactoring from within a plugin, so I'm just abusing - // the TwitterApiAction method. Don't do this unless you're me! - - require_once(INSTALLDIR.'/lib/twitterapi.php'); - - $act = new TwitterApiAction('/dev/null'); - - $arr = $act->twitter_status_array($notice, true); - $arr['url'] = $notice->bestUrl(); - $arr['html'] = htmlspecialchars($notice->rendered); - $arr['source'] = htmlspecialchars($arr['source']); - - if (!empty($notice->reply_to)) { - $reply_to = Notice::staticGet('id', $notice->reply_to); - if (!empty($reply_to)) { - $arr['in_reply_to_status_url'] = $reply_to->bestUrl(); - } - $reply_to = null; - } + // Meteord flips out with default '/' separator - $profile = $notice->getProfile(); - $arr['user']['profile_url'] = $profile->profileurl; - - return $arr; - } - - function getNoticeTags($notice) + function _pathToChannel($path) { - $tags = null; - - $nt = new Notice_tag(); - $nt->notice_id = $notice->id; - - if ($nt->find()) { - $tags = array(); - while ($nt->fetch()) { - $tags[] = $nt->tag; - } + if (!empty($this->channelbase)) { + array_unshift($path, $this->channelbase); } - - $nt->free(); - $nt = null; - - return $tags; - } - - // Push this up to Plugin - - function log($level, $msg) - { - common_log($level, get_class($this) . ': '.$msg); + return implode('-', $path); } }