+++ /dev/null
-<?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);
- }
- }