From 3da84feabd10c93211d1dc8aadb82d4faeaee79b Mon Sep 17 00:00:00 2001 From: Evan Prodromou Date: Wed, 15 Jul 2009 15:31:06 -0400 Subject: [PATCH] Build channel strings in Meteor plugin --- plugins/Meteor/MeteorPlugin.php | 15 ++++++++++++--- 1 file changed, 12 insertions(+), 3 deletions(-) diff --git a/plugins/Meteor/MeteorPlugin.php b/plugins/Meteor/MeteorPlugin.php index 89c79e7dec..d54d565bda 100644 --- a/plugins/Meteor/MeteorPlugin.php +++ b/plugins/Meteor/MeteorPlugin.php @@ -76,7 +76,7 @@ class MeteorPlugin extends RealtimePlugin function _updateInitialize($timeline, $user_id) { $script = parent::_updateInitialize($timeline, $user_id); - return $script." MeteorUpdater.init(\"$this->webserver\", $this->webport, \"{$this->channelbase}{$timeline}\");"; + return $script." MeteorUpdater.init(\"$this->webserver\", $this->webport, \"{$timeline}\");"; } function _connect() @@ -93,8 +93,7 @@ class MeteorPlugin extends RealtimePlugin { $message = json_encode($message); $message = addslashes($message); - common_debug("Message = $message\n"); - $cmd = "ADDMESSAGE {$this->channelbase}{$channel} $message\n"; + $cmd = "ADDMESSAGE $channel $message\n"; $cnt = fwrite($this->_socket, $cmd); $result = fgets($this->_socket); if (preg_match('/^ERR (.*)$/', $result, $matches)) { @@ -108,4 +107,14 @@ class MeteorPlugin extends RealtimePlugin $cnt = fwrite($this->_socket, "QUIT\n"); @fclose($this->_socket); } + + // Meteord flips out with default '/' separator + + function _pathToChannel($path) + { + if (!empty($this->channelbase)) { + array_unshift($path, $this->channelbase); + } + return implode('-', $path); + } } -- 2.39.5