189 lines
6.3 KiB
PHP
189 lines
6.3 KiB
PHP
|
<?php
|
||
|
|
/**
|
||
|
|
* 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>
|
||
|
|
* @copyright 2008 Nathanael C. Fritz
|
||
|
|
*/
|
||
|
|
|
||
|
|
/** XMPPHP_XMLStream */
|
||
|
|
require_once "XMPP.php";
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 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 XMPPHP_BOSH extends XMPPHP_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", XMPPHP_Log::LEVEL_VERBOSE);
|
||
|
|
xml_parse($this->parser, $buff, false);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public function send($msg) {
|
||
|
|
$this->log->log("SEND: $msg", XMPPHP_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;
|
||
|
|
}
|
||
|
|
}
|