[Summary view] [Print] [Text view]

   1  <?php
   2  /**
   3   * XMPPHP: The PHP XMPP Library
   4   * Copyright (C) 2008  Nathanael C. Fritz
   5   * This file is part of SleekXMPP.
   6   * 
   7   * XMPPHP is free software; you can redistribute it and/or modify
   8   * it under the terms of the GNU General Public License as published by
   9   * the Free Software Foundation; either version 2 of the License, or
  10   * (at your option) any later version.
  11   * 
  12   * XMPPHP is distributed in the hope that it will be useful,
  13   * but WITHOUT ANY WARRANTY; without even the implied warranty of
  14   * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  15   * GNU General Public License for more details.
  16   * 
  17   * You should have received a copy of the GNU General Public License
  18   * along with XMPPHP; if not, write to the Free Software
  19   * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
  20   *
  21   * @category   xmpphp 
  22   * @package    XMPPHP
  23   * @author     Nathanael C. Fritz <JID: fritzy@netflint.net>
  24   * @author     Stephan Wentz <JID: stephan@jabber.wentz.it>
  25   * @author     Michael Garvin <JID: gar@netflint.net>
  26   * @copyright  2008 Nathanael C. Fritz
  27   */
  28  
  29  /** XMPPHP_XMLStream */
  30  require_once dirname(__FILE__) . "/XMPP.php";
  31  
  32  /**
  33   * XMPPHP Main Class
  34   * 
  35   * @category   xmpphp 
  36   * @package    XMPPHP
  37   * @author     Nathanael C. Fritz <JID: fritzy@netflint.net>
  38   * @author     Stephan Wentz <JID: stephan@jabber.wentz.it>
  39   * @author     Michael Garvin <JID: gar@netflint.net>
  40   * @copyright  2008 Nathanael C. Fritz
  41   * @version    $Id$
  42   */
  43  class XMPPHP_BOSH extends XMPPHP_XMPP {
  44  
  45          protected $rid;
  46          protected $sid;
  47          protected $http_server;
  48          protected $http_buffer = Array();
  49          protected $session = false;
  50  
  51  		public function connect($server, $wait='1', $session=false) {
  52              $this->http_server = $server;
  53              $this->use_encryption = false;
  54              $this->session = $session;
  55  
  56              $this->rid = 3001;
  57              $this->sid = null;
  58              if($session)
  59              {
  60                  $this->loadSession();
  61              }
  62              if(!$this->sid) {
  63                  $body = $this->__buildBody();
  64                  $body->addAttribute('hold','1');
  65                  $body->addAttribute('to', $this->host);
  66                  $body->addAttribute('route', "xmpp:{$this->host}:{$this->port}");
  67                  $body->addAttribute('secure','true');
  68                  $body->addAttribute('xmpp:version','1.6', 'urn:xmpp:xbosh');
  69                  $body->addAttribute('wait', strval($wait));
  70                  $body->addAttribute('ack','1');
  71                  $body->addAttribute('xmlns:xmpp','urn:xmpp:xbosh');
  72                  $buff = "<stream:stream xmlns='jabber:client' xmlns:stream='http://etherx.jabber.org/streams'>";
  73                  xml_parse($this->parser, $buff, false);
  74                  $response = $this->__sendBody($body);
  75                  $rxml = new SimpleXMLElement($response);
  76                  $this->sid = $rxml['sid'];
  77  
  78              } else {
  79                  $buff = "<stream:stream xmlns='jabber:client' xmlns:stream='http://etherx.jabber.org/streams'>";
  80                  xml_parse($this->parser, $buff, false);
  81              }
  82          }
  83  
  84  		public function __sendBody($body=null, $recv=true) {
  85              if(!$body) {
  86                  $body = $this->__buildBody();
  87              }
  88              $ch = curl_init($this->http_server);
  89              curl_setopt($ch, CURLOPT_HEADER, 0);
  90              curl_setopt($ch, CURLOPT_POST, 1);
  91              curl_setopt($ch, CURLOPT_POSTFIELDS, $body->asXML());
  92              curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);
  93              $header = array('Accept-Encoding: gzip, deflate','Content-Type: text/xml; charset=utf-8');
  94              curl_setopt($ch, CURLOPT_HTTPHEADER, $header );
  95              curl_setopt($ch, CURLOPT_VERBOSE, 0);
  96              $output = '';
  97              if($recv) {
  98                  curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
  99                  $output = curl_exec($ch);
 100                  $this->http_buffer[] = $output;
 101              }
 102              curl_close($ch);
 103              return $output;
 104          }
 105  
 106  		public function __buildBody($sub=null) {
 107              $xml = new SimpleXMLElement("<body xmlns='http://jabber.org/protocol/httpbind' xmlns:xmpp='urn:xmpp:xbosh' />");
 108              $xml->addAttribute('content', 'text/xml; charset=utf-8');
 109              $xml->addAttribute('rid', $this->rid);
 110              $this->rid += 1;
 111              if($this->sid) $xml->addAttribute('sid', $this->sid);
 112              #if($this->sid) $xml->addAttribute('xmlns', 'http://jabber.org/protocol/httpbind');
 113              $xml->addAttribute('xml:lang', 'en');
 114              if($sub) { // ok, so simplexml is lame
 115                  $p = dom_import_simplexml($xml);
 116                  $c = dom_import_simplexml($sub);
 117                  $cn = $p->ownerDocument->importNode($c, true);
 118                  $p->appendChild($cn);
 119                  $xml = simplexml_import_dom($p);
 120              }
 121              return $xml;
 122          }
 123  
 124  		public function __process() {
 125              if($this->http_buffer) {
 126                  $this->__parseBuffer();
 127              } else {
 128                  $this->__sendBody();
 129                  $this->__parseBuffer();
 130              }
 131          }
 132  
 133  		public function __parseBuffer() {
 134              while ($this->http_buffer) {
 135                  $idx = key($this->http_buffer);
 136                  $buffer = $this->http_buffer[$idx];
 137                  unset($this->http_buffer[$idx]);
 138                  if($buffer) {
 139                      $xml = new SimpleXMLElement($buffer);
 140                      $children = $xml->xpath('child::node()');
 141                      foreach ($children as $child) {
 142                          $buff = $child->asXML();
 143                          $this->log->log("RECV: $buff",  XMPPHP_Log::LEVEL_VERBOSE);
 144                          xml_parse($this->parser, $buff, false);
 145                      }
 146                  }
 147              }
 148          }
 149  
 150  		public function send($msg) {
 151              $this->log->log("SEND: $msg",  XMPPHP_Log::LEVEL_VERBOSE);
 152              $msg = new SimpleXMLElement($msg);
 153              #$msg->addAttribute('xmlns', 'jabber:client');
 154              $this->__sendBody($this->__buildBody($msg), true);
 155              #$this->__parseBuffer();
 156          }
 157  
 158  		public function reset() {
 159              $this->xml_depth = 0;
 160              unset($this->xmlobj);
 161              $this->xmlobj = array();
 162              $this->setupParser();
 163              #$this->send($this->stream_start);
 164              $body = $this->__buildBody();
 165              $body->addAttribute('to', $this->host);
 166              $body->addAttribute('xmpp:restart', 'true', 'urn:xmpp:xbosh');
 167              $buff = "<stream:stream xmlns='jabber:client' xmlns:stream='http://etherx.jabber.org/streams'>";
 168              $response = $this->__sendBody($body);
 169              $this->been_reset = true;
 170              xml_parse($this->parser, $buff, false);
 171          }
 172  
 173  		public function loadSession() {
 174              if(isset($_SESSION['XMPPHP_BOSH_RID'])) $this->rid = $_SESSION['XMPPHP_BOSH_RID'];
 175              if(isset($_SESSION['XMPPHP_BOSH_SID'])) $this->sid = $_SESSION['XMPPHP_BOSH_SID'];
 176              if(isset($_SESSION['XMPPHP_BOSH_authed'])) $this->authed = $_SESSION['XMPPHP_BOSH_authed'];
 177              if(isset($_SESSION['XMPPHP_BOSH_jid'])) $this->jid = $_SESSION['XMPPHP_BOSH_jid'];
 178              if(isset($_SESSION['XMPPHP_BOSH_fulljid'])) $this->fulljid = $_SESSION['XMPPHP_BOSH_fulljid'];
 179          }
 180  
 181  		public function saveSession() {
 182              $_SESSION['XMPPHP_BOSH_RID'] = (string) $this->rid;
 183              $_SESSION['XMPPHP_BOSH_SID'] = (string) $this->sid;
 184              $_SESSION['XMPPHP_BOSH_authed'] = (boolean) $this->authed;
 185              $_SESSION['XMPPHP_BOSH_jid'] = (string) $this->jid;
 186              $_SESSION['XMPPHP_BOSH_fulljid'] = (string) $this->fulljid;
 187          }
 188  }