* @author Stephan Wentz * @author Michael Garvin * @copyright 2008 Nathanael C. Fritz */ /** XMPPHP_XMLStream */ require_once "XMPP.php"; /** * XMPPHP Main Class * * @category xmpphp * @package XMPPHP * @author Nathanael C. Fritz * @author Stephan Wentz * @author Michael Garvin * @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('version','1.6'); $body->addAttribute('wait', strval($wait)); $body->addAttribute('ack','1'); $body->addAttribute('xmlns:xmpp','urn:xmpp:xbosh'); $buff = ""; xml_parse($this->parser, $buff, false); $response = $this->__sendBody($body); $rxml = new SimpleXMLElement($response); $this->sid = $rxml['sid']; } else { $buff = ""; 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(""); $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 = ""; $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; } }