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); } }