<?
/*
 *
 * 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);
        }
    }
?>