Gecko [ admjudic.com.br ]

Name	Size	Permission
BOSH.php	7.22 KB	-rw-r--r--
Exception.php	1.54 KB	-rw-r--r--
Log.php	3.17 KB	-rw-r--r--
Roster.php	4.64 KB	-rw-r--r--
XMLObj.php	3.58 KB	-rw-r--r--
XMLStream.php	20.05 KB	-rw-r--r--
XMPP.php	12.19 KB	-rw-r--r--

Code Editor : BOSH.php

<?php

namespace BirknerAlex\XMPPHP;

/**
     * XMPPHP: The PHP XMPP Library
     * Copyright (C) 2008  Nathanael C. Fritz
     * This file is part of SleekXMPP.
     *
     * XMPPHP is free software; you can redistribute it and/or modify
     * it under the terms of the GNU General Public License as published by
     * the Free Software Foundation; either version 2 of the License, or
     * (at your option) any later version.
     *
     * XMPPHP 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 General Public License for more details.
     *
     * You should have received a copy of the GNU General Public License
     * along with XMPPHP; if not, write to the Free Software
     * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
     *
     * @category   xmpphp
     * @package    XMPPHP
     * @author     Nathanael C. Fritz <JID: fritzy@netflint.net>
     * @author     Stephan Wentz <JID: stephan@jabber.wentz.it>
     * @author     Michael Garvin <JID: gar@netflint.net>
     * @author     Alexander Birkner (https://github.com/BirknerAlex)
     * @copyright  2008 Nathanael C. Fritz
     */

/**
 * XMPPHP Main Class
 *
 * @category   xmpphp
 * @package    XMPPHP
 * @author     Nathanael C. Fritz <JID: fritzy@netflint.net>
 * @author     Stephan Wentz <JID: stephan@jabber.wentz.it>
 * @author     Michael Garvin <JID: gar@netflint.net>
 * @copyright  2008 Nathanael C. Fritz
 * @version    $Id$
 */
class BOSH extends XMPP
{
    protected $rid;
    protected $sid;
    protected $http_server;
    protected $http_buffer = Array();
    protected $session = false;

public function connect($server, $wait = '1', $session = false)
    {
        $this->http_server = $server;
        $this->use_encryption = false;
        $this->session = $session;

$this->rid = 3001;
        $this->sid = null;
        if ($session) {
            $this->loadSession();
        }
        if (!$this->sid) {
            $body = $this->__buildBody();
            $body->addAttribute('hold', '1');
            $body->addAttribute('to', $this->host);
            $body->addAttribute('route', "xmpp:{$this->host}:{$this->port}");
            $body->addAttribute('secure', 'true');
            $body->addAttribute('xmpp:version', '1.6', 'urn:xmpp:xbosh');
            $body->addAttribute('wait', strval($wait));
            $body->addAttribute('ack', '1');
            $body->addAttribute('xmlns:xmpp', 'urn:xmpp:xbosh');
            $buff = "<stream:stream xmlns='jabber:client' xmlns:stream='http://etherx.jabber.org/streams'>";
            xml_parse($this->parser, $buff, false);
            $response = $this->__sendBody($body);
            $rxml = new \SimpleXMLElement($response);
            $this->sid = $rxml['sid'];

} else {
            $buff = "<stream:stream xmlns='jabber:client' xmlns:stream='http://etherx.jabber.org/streams'>";
            xml_parse($this->parser, $buff, false);
        }
    }

public function __sendBody($body = null, $recv = true)
    {
        if (!$body) {
            $body = $this->__buildBody();
        }
        $ch = curl_init($this->http_server);
        curl_setopt($ch, CURLOPT_HEADER, 0);
        curl_setopt($ch, CURLOPT_POST, 1);
        curl_setopt($ch, CURLOPT_POSTFIELDS, $body->asXML());
        curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);
        $header = array('Accept-Encoding: gzip, deflate', 'Content-Type: text/xml; charset=utf-8');
        curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
        curl_setopt($ch, CURLOPT_VERBOSE, 0);
        $output = '';
        if ($recv) {
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
            $output = curl_exec($ch);
            $this->http_buffer[] = $output;
        }
        curl_close($ch);
        return $output;
    }

public function __buildBody($sub = null)
    {
        $xml = new \SimpleXMLElement("<body xmlns='http://jabber.org/protocol/httpbind' xmlns:xmpp='urn:xmpp:xbosh' />");
        $xml->addAttribute('content', 'text/xml; charset=utf-8');
        $xml->addAttribute('rid', $this->rid);
        $this->rid += 1;
        if ($this->sid) $xml->addAttribute('sid', $this->sid);
        #if($this->sid) $xml->addAttribute('xmlns', 'http://jabber.org/protocol/httpbind');
        $xml->addAttribute('xml:lang', 'en');
        if ($sub) { // ok, so simplexml is lame
            $p = dom_import_simplexml($xml);
            $c = dom_import_simplexml($sub);
            $cn = $p->ownerDocument->importNode($c, true);
            $p->appendChild($cn);
            $xml = simplexml_import_dom($p);
        }
        return $xml;
    }

public function __process()
    {
        if ($this->http_buffer) {
            $this->__parseBuffer();
        } else {
            $this->__sendBody();
            $this->__parseBuffer();
        }
    }

public function __parseBuffer()
    {
        while ($this->http_buffer) {
            $idx = key($this->http_buffer);
            $buffer = $this->http_buffer[$idx];
            unset($this->http_buffer[$idx]);
            if ($buffer) {
                $xml = new \SimpleXMLElement($buffer);
                $children = $xml->xpath('child::node()');
                foreach ($children as $child) {
                    $buff = $child->asXML();
                    $this->log->log("RECV: $buff", Log::LEVEL_VERBOSE);
                    xml_parse($this->parser, $buff, false);
                }
            }
        }
    }

public function send($msg)
    {
        $this->log->log("SEND: $msg", Log::LEVEL_VERBOSE);
        $msg = new \SimpleXMLElement($msg);
        #$msg->addAttribute('xmlns', 'jabber:client');
        $this->__sendBody($this->__buildBody($msg), true);
        #$this->__parseBuffer();
    }

public function reset()
    {
        $this->xml_depth = 0;
        unset($this->xmlobj);
        $this->xmlobj = array();
        $this->setupParser();
        #$this->send($this->stream_start);
        $body = $this->__buildBody();
        $body->addAttribute('to', $this->host);
        $body->addAttribute('xmpp:restart', 'true', 'urn:xmpp:xbosh');
        $buff = "<stream:stream xmlns='jabber:client' xmlns:stream='http://etherx.jabber.org/streams'>";
        $response = $this->__sendBody($body);
        $this->been_reset = true;
        xml_parse($this->parser, $buff, false);
    }

public function loadSession()
    {
        if (isset($_SESSION['XMPPHP_BOSH_RID'])) $this->rid = $_SESSION['XMPPHP_BOSH_RID'];
        if (isset($_SESSION['XMPPHP_BOSH_SID'])) $this->sid = $_SESSION['XMPPHP_BOSH_SID'];
        if (isset($_SESSION['XMPPHP_BOSH_authed'])) $this->authed = $_SESSION['XMPPHP_BOSH_authed'];
        if (isset($_SESSION['XMPPHP_BOSH_jid'])) $this->jid = $_SESSION['XMPPHP_BOSH_jid'];
        if (isset($_SESSION['XMPPHP_BOSH_fulljid'])) $this->fulljid = $_SESSION['XMPPHP_BOSH_fulljid'];
    }

public function saveSession()
    {
        $_SESSION['XMPPHP_BOSH_RID'] = (string)$this->rid;
        $_SESSION['XMPPHP_BOSH_SID'] = (string)$this->sid;
        $_SESSION['XMPPHP_BOSH_authed'] = (boolean)$this->authed;
        $_SESSION['XMPPHP_BOSH_jid'] = (string)$this->jid;
        $_SESSION['XMPPHP_BOSH_fulljid'] = (string)$this->fulljid;
    }
}

${this.title}

Code Editor : BOSH.php