123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128 |
- <?php
- if (!defined('GNUSOCIAL') && !defined('STATUSNET')) {
- exit(1);
- }
- require_once INSTALLDIR . DIRECTORY_SEPARATOR . 'lib/modules/Realtime/RealtimePlugin.php';
- class CometPlugin extends RealtimePlugin
- {
- const PLUGIN_VERSION = '2.0.0';
- public $server = null;
- public $username = null;
- public $password = null;
- public $prefix = null;
- protected $bay = null;
- public function __construct(
- ?string $server = null,
- ?string $username = null,
- ?string $password = null,
- ?string $prefix = null
- ) {
- $this->server = $server;
- $this->username = $username;
- $this->password = $password;
- $this->prefix = $prefix;
- parent::__construct();
- }
- public function _getScripts(): array
- {
- $scripts = parent::_getScripts();
- $ours = ['js/jquery.comet.js', 'js/cometupdate.js'];
- foreach ($ours as $script) {
- $scripts[] = $this->path($script);
- }
- return $scripts;
- }
- public function _updateInitialize($timeline, int $user_id)
- {
- $script = parent::_updateInitialize($timeline, $user_id);
- return $script." CometUpdate.init(\"$this->server\", \"$timeline\", $user_id, \"$this->replyurl\", \"$this->favorurl\", \"$this->deleteurl\");";
- }
- public function _connect(): void
- {
- require_once __DIR__. DIRECTORY_SEPARATOR . 'extlib/Bayeux/Bayeux.class.php';
-
- $this->bay = new Bayeux($this->server, $this->user, $this->password);
- }
- public function _publish($timeline, $json): void
- {
- $this->bay->publish($timeline, $json);
- }
- public function _disconnect(): void
- {
- unset($this->bay);
- }
- public function _pathToChannel(array $path): string
- {
- if (!empty($this->prefix)) {
- array_unshift($path, $this->prefix);
- }
- return '/' . implode('/', $path);
- }
- public function onPluginVersion(array &$versions): bool
- {
- $versions[] = [
- 'name' => 'Comet',
- 'version' => self::PLUGIN_VERSION,
- 'author' => 'Evan Prodromou',
- 'homepage' => GNUSOCIAL_ENGINE_REPO_URL . 'tree/master/plugins/Comet',
- 'rawdescription' =>
-
-
- _m('Plugin to make updates using Comet and Bayeux.')
- ];
- return true;
- }
- }
|