1 files changed, 123 insertions, 0 deletions
diff --git a/plugins/Comet/bayeux.class.inc.phps b/plugins/Comet/bayeux.class.inc.phps
new file mode 100644
index 000000000..ea004a453
--- /dev/null
+++ b/plugins/Comet/bayeux.class.inc.phps
@@ -0,0 +1,123 @@
+<?php
+/*
+ *
+ * Phomet: a php comet client
+ *
+ * Copyright (C) 2008 Morgan 'ARR!' Allen <morganrallen@gmail.com> http://morglog.alleycatracing.com
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 2.1 of the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, write to the Free Software
+ * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
+ *
+ */
+
+class Bayeux
+	{
+		private $oCurl = '';
+		private $nNextId = 0;
+
+		public $sUrl = '';
+
+		function __construct($sUrl)
+		{
+			$this->sUrl = $sUrl;
+
+			$this->oCurl = curl_init();
+
+			$aHeaders = array();
+			$aHeaders[] = 'Connection: Keep-Alive';
+
+			curl_setopt($this->oCurl, CURLOPT_URL, $sUrl);
+			curl_setopt($this->oCurl, CURLOPT_HTTPHEADER, $aHeaders);
+			curl_setopt($this->oCurl, CURLOPT_HEADER, 0);
+			curl_setopt($this->oCurl, CURLOPT_POST, 1);
+			curl_setopt($this->oCurl, CURLOPT_RETURNTRANSFER,1);
+
+			$this->handShake();
+		}
+
+		function __destruct()
+		{
+			$this->disconnect();
+		}
+
+		function handShake()
+		{
+			$msgHandshake = array();
+			$msgHandshake['channel'] = '/meta/handshake';
+			$msgHandshake['version'] = "1.0";
+			$msgHandshake['minimumVersion'] = "0.9";
+			$msgHandshake['id'] = $this->nNextId++;
+
+			curl_setopt($this->oCurl, CURLOPT_POSTFIELDS, "message=".urlencode(str_replace('\\', '', json_encode(array($msgHandshake)))));
+
+			$data = curl_exec($this->oCurl);
+
+			if(curl_errno($this->oCurl))
+				die("Error: " . curl_error($this->oCurl));
+
+			$oReturn = json_decode($data);
+			$oReturn = $oReturn[0];
+
+			$bSuccessful = ($oReturn->successful) ? true : false;
+
+			if($bSuccessful)
+			{
+				$this->clientId = $oReturn->clientId;
+
+				$this->connect();
+			}
+		}
+
+		public function connect()
+		{
+			$aMsg['channel'] = '/meta/connect';
+			$aMsg['id'] = $this->nNextId++;
+			$aMsg['clientId'] = $this->clientId;
+			$aMsg['connectionType'] = 'long-polling';
+
+			curl_setopt($this->oCurl, CURLOPT_POSTFIELDS, "message=".urlencode(str_replace('\\', '', json_encode(array($aMsg)))));
+
+			$data = curl_exec($this->oCurl);
+		}
+
+		function disconnect()
+		{
+			$msgHandshake = array();
+			$msgHandshake['channel'] = '/meta/disconnect';
+			$msgHandshake['id'] = $this->nNextId++;
+			$msgHandshake['clientId'] = $this->clientId;
+
+			curl_setopt($this->oCurl, CURLOPT_POSTFIELDS, "message=".urlencode(str_replace('\\', '', json_encode(array($msgHandshake)))));
+
+			curl_exec($this->oCurl);
+		}
+
+		public function publish($sChannel, $oData)
+		{
+			if(!$sChannel || !$oData)
+				return;
+
+			$aMsg = array();
+
+			$aMsg['channel'] = $sChannel;
+			$aMsg['id'] = $this->nNextId++;
+			$aMsg['data'] = $oData;
+			$aMsg['clientId'] = $this->clientId;
+
+			curl_setopt($this->oCurl, CURLOPT_POSTFIELDS, "message=".urlencode(str_replace('\\', '', json_encode(array($aMsg)))));
+
+			$data = curl_exec($this->oCurl);
+//			var_dump($data);
+		}
+	}