summaryrefslogtreecommitdiff
path: root/plugins/Orbited/OrbitedPlugin.php
diff options
context:
space:
mode:
authorEvan Prodromou <evan@status.net>2009-10-04 03:02:04 -0400
committerEvan Prodromou <evan@status.net>2009-10-04 03:15:59 -0400
commit035978270d609b650b8e32f252366e0e75b12507 (patch)
tree5d49a7fd92f376c110e27e1950ec288c1c04cadf /plugins/Orbited/OrbitedPlugin.php
parent9c2d0879e9064fe3b9cf9af2c7eabe869966bd92 (diff)
Update OrbitedPlugin to work with RealtimePlugin framework
Diffstat (limited to 'plugins/Orbited/OrbitedPlugin.php')
-rw-r--r--plugins/Orbited/OrbitedPlugin.php43
1 files changed, 39 insertions, 4 deletions
diff --git a/plugins/Orbited/OrbitedPlugin.php b/plugins/Orbited/OrbitedPlugin.php
index cf6e5de13..ad7d1d276 100644
--- a/plugins/Orbited/OrbitedPlugin.php
+++ b/plugins/Orbited/OrbitedPlugin.php
@@ -52,34 +52,49 @@ class OrbitedPlugin extends RealtimePlugin
public $webport = null;
public $channelbase = null;
public $stompserver = null;
+ public $stompport = null;
public $username = null;
public $password = null;
+ public $webuser = null;
+ public $webpass = null;
protected $con = null;
function _getScripts()
{
$scripts = parent::_getScripts();
- $root = 'http://'.$this->webserver.(($this->webport == 80) ? '':':'.$this->webport);
+
+ $port = (is_null($this->webport)) ? 8000 : $this->webport;
+
+ $server = (is_null($this->webserver)) ? common_config('site', 'server') : $this->webserver;
+
+ $root = 'http://'.$server.(($port == 80) ? '':':'.$port);
+
$scripts[] = $root.'/static/Orbited.js';
$scripts[] = $root.'/static/protocols/stomp/stomp.js';
$scripts[] = common_path('plugins/Orbited/orbitedupdater.js');
+
return $scripts;
}
function _updateInitialize($timeline, $user_id)
{
$script = parent::_updateInitialize($timeline, $user_id);
- return $script." OrbitedUpdater.init(\"$this->stompserver\", $this->stompport, \"{$timeline}\");";
+
+ $server = $this->_getStompServer();
+ $port = $this->_getStompPort();
+
+ return $script." OrbitedUpdater.init(\"$server\", $port, ".
+ "\"{$timeline}\", \"{$this->webuser}\", \"{$this->webpass}\");";
}
function _connect()
{
require_once(INSTALLDIR.'/extlibs/Stomp.php');
- $stompserver = (empty($this->stompserver)) ? "tcp://{$this->webserver}:61613/" : $this->stompserver;
+ $url = $this->_getStompUrl();
- $this->con = new Stomp($stompserver);
+ $this->con = new Stomp($url);
if ($this->con->connect($this->username, $this->password)) {
$this->_log(LOG_INFO, "Connected.");
@@ -110,4 +125,24 @@ class OrbitedPlugin extends RealtimePlugin
}
return '/' . implode('/', $path);
}
+
+ function _getStompServer()
+ {
+ $server = (!is_null($this->stompserver)) ? $this->stompserver :
+ (!is_null($this->webserver)) ? $this->webserver :
+ common_config('site', 'server');
+ return $server;
+ }
+
+ function _getStompPort()
+ {
+ $port = (!is_null($this->stompport)) ? $this->stompport : 61613;
+ }
+
+ function _getStompUrl()
+ {
+ $server = $this->_getStompServer();
+ $port = $this->_getStompPort();
+ return "tcp://$server:$port/";
+ }
}