code:
<?php

// include_paths.php @generated by Composer

$vendorDir = dirname(dirname(__FILE__));
$baseDir = dirname($vendorDir);

return array(
    $vendorDir . '/openid/php-openid',
    $vendorDir . '/pear/console_getopt',
);

license: mit


apereo/phpcas

type: git

type: zip

type: library

installation-source: dist

description: Provides a simple API for authenticating users against a CAS server

keywords: apereo cas jasig

composer/ca-bundle

Composer\CaBundle\: src

description: Lets you find a path to the system CA bundle, and includes a fallback to the Mozilla CA bundle.

keywords: cabundle cacert certificate ssl tls

diogocomposer/xmpphp

XMPPHP\: XMPPHP

description: XMPP PHP Library

keywords: jabber xmpp xmpphp

embed/embed

Embed\: src

Oscar Otero

role: Developer

description: PHP library to retrieve page info using oembed, opengraph, etc

keywords:
embed
embedly
oembed
opengraph
twitter cards

ezyang/htmlpurifier

HTMLPurifier: library/

description: Standards compliant HTML filter written in PHP

zendframework/zend-httphandlerrunner: Emit PSR-7 responses

GuzzleHttp\Psr7\: src/

description: PSR-7 message implementation that also provides common utility methods

keywords: http message psr-7 request response stream uri url

hoa/consistency

description: The Hoa\Consistency library.

keywords: autoloader callable consistency entity flex keyword library

hoa/event

description: The Hoa\Event library.

keywords: event library listener observer

hoa/exception

description: The Hoa\Exception library.

keywords: exception library

intervention/image

ext-gd: to use GD library based image processing.

ext-imagick: to use Imagick based image processing.

intervention/imagecache: Caching extension for the Intervention Image library

Image: Intervention\Image\Facades\Image

Intervention\Image\: src/Intervention/Image

description: Image handling and manipulation library with support for Laravel integration

keywords: gd image imagick laravel thumbnail watermark

Masterminds\: src

description: An HTML5 parser and serializer.

keywords: HTML5 dom html parser querypath serializer xml

barnabywalters/mf-cleaner: To more easily handle the canonical data php-mf2 gives you

masterminds/html5: Alternative HTML parser for PHP, for better HTML5 support.

description: A pure, generic microformats2 parser — makes HTML as easy to consume as a JSON API

keywords:
html
microformats
microformats 2
parser
semantic

michelf/php-markdown

Michelf\: Michelf/

description: PHP Markdown

openid/php-openid

description: OpenID library for PHP5

keywords: Authentication OpenId auth yadis

ParagonIE\ConstantTime\: src/

Paragon Initiative Enterprises

role: Maintainer

Steve 'Sc00bz' Thomas

role: Original Developer

description: Constant-time Implementations of RFC 4648 Encoding (Base-64, Base-32, Base-16)

ext-libsodium: Provides a modern crypto API that can be used to generate random bytes.

description: PHP 5.x polyfill for random_bytes() and random_int() from PHP 7

keywords: csprng polyfill pseudorandom random

Greg Beaver

role: Helper

Andrei Zmievski

role: Lead

description: More info available on: http://pear.php.net/package/Console_Getopt

phpseclib/phpseclib

version: dev-master

ext-gmp: Install the GMP (GNU Multiple Precision) extension in order to speed up arbitrary precision integer arithmetic operations.

ext-libsodium: SSH2/SFTP can make use of some algorithms provided by the libsodium-php extension.

ext-mcrypt: Install the Mcrypt extension in order to speed up a few other cryptographic operations.

ext-openssl: Install the OpenSSL extension in order to speed up a wide variety of cryptographic operations.

phpseclib\: phpseclib/

description: PHP Secure Communications Library - Pure-PHP implementations of RSA, AES, SSH2, SFTP, X.509 etc.

keywords: BigInteger aes asn.1 asn1 blowfish crypto cryptography encryption rsa security sftp signature signing ssh twofish x.509 x509

psr/http-message

description: Common interface for HTTP messages

keywords: http http-message psr psr-7 request response

ralouphie/getallheaders

description: A polyfill for getallheaders.

stomp-php/stomp-php

description: stomp support for PHP

keywords: activeMQ apollomq jms messaging rabbitmq stomp


code:
composer.phar
/vendor/

# Commit your application's lock file https://getcomposer.org/doc/01-basic-usage.md#commit-your-composer-lock-file-to-version-control
# You may choose to ignore a library lock file http://getcomposer.org/doc/02-libraries.md#lock-file
# composer.lock


code:
README
======

About XMPPHP
------------

XMPPHP is an elegant PHP library for XMPP (aka Jabber, Google Talk, etc).

* Homepage: [http://code.google.com/p/xmpphp]
* Chatroom: [xmpphp@conference.psi-im.org] (XMPP MUC)
* Author: Nathan Fritz, jabber id: fritzy [at] netflint.net
* Co-Author: Stephan Wentz, jabber id: stephan [at] wentz.it
* This fork: https://github.com/diogogithub/xmpphp
* Maintainer of this fork: Diogo Cordeiro <diogo@fc.up.pt>

Requirements
------------

* PHP 7.0
* SSL Support Compiled


code:
<?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>
 * @author     Alexander Birkner (https://github.com/BirknerAlex)
 * @author     zorn-v (https://github.com/zorn-v/xmpphp/)
 * @author     GNU social
 * @copyright  2008 Nathanael C. Fritz
 */

namespace XMPPHP;

use SimpleXMLElement;

/** XMPPHP_XMLStream */
require_once __DIR__ . "/XMPP.php";

/**
 * XMPPHP BOSH
 *
 * @property int lat
 * @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
{
    /**
     * @var integer
     */
    protected $rid;

    /**
     * @var string
     */
    protected $sid;

    /**
     * @var string
     */
    protected $http_server;

    /**
     * @var array
     */
    protected $http_buffer = array();

    /**
     * @var string
     */
    protected $session = false;

    /**
     * @var integer
     */
    protected $inactivity;

    /**
     * Connect
     *
     * @param $server
     * @param $wait
     * @param $session
     * @throws Exception
     * @throws Exception
     */
    public function connect($server = null, $wait = '1', $session = false)
    {

        if (is_null($server)) {

            // If we aren't given the server http url, try and guess it
            $port_string = ($this->port AND $this->port != 80) ? ':' . $this->port : '';
            $this->http_server = 'http://' . $this->host . $port_string . '/http-bind/';
        } else {
            $this->http_server = $server;
        }

        $this->use_encryption = false;
        $this->session = $session;
        $this->rid = 3001;
        $this->sid = null;
        $this->inactivity = 0;

        if ($session) {
            $this->loadSession();
        }

        if (!$this->sid) {

            $body = $this->__buildBody();
            $body->addAttribute('hold', '1');
            $body->addAttribute('to', $this->server);
            $body->addAttribute('route', 'xmpp:' . $this->host . ':' . $this->port);
            $body->addAttribute('secure', 'true');
            $body->addAttribute('xmpp:version', '1.0', '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'];
            $this->inactivity = $rxml['inactivity'];
        } else {
            $buff = '<stream:stream xmlns="jabber:client" xmlns:stream="http://etherx.jabber.org/streams">';
            xml_parse($this->parser, $buff, false);
        }
    }

    /**
     * Load session
     *
     */
    public function loadSession()
    {

        if ($this->session == 'ON_FILE') {

            // Session not started so use session_file
            $session_file = $this->getSessionFile();

            // manage multiple accesses
            if (!file_exists($session_file)) {
                file_put_contents($session_file, '');
            }
            $session_file_fp = fopen($session_file, 'r');
            flock($session_file_fp, LOCK_EX);
            $session_serialized = file_get_contents($session_file, null, null, 6);
            flock($session_file_fp, LOCK_UN);
            fclose($session_file_fp);

            $this->log->log('SESSION: reading ' . $session_serialized . ' from ' . $session_file, Log::LEVEL_VERBOSE);
            if ($session_serialized != '') {
                $_SESSION['XMPPHP_BOSH'] = unserialize($session_serialized);
            }
        }

        if (isset($_SESSION['XMPPHP_BOSH']['inactivity'])) {
            $this->inactivity = $_SESSION['XMPPHP_BOSH']['inactivity'];
        }

        $this->lat = (time() - (isset($_SESSION['XMPPHP_BOSH']['lat']))) ? $_SESSION['XMPPHP_BOSH']['lat'] : 0;

        if ($this->lat < $this->inactivity) {

            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']['basejid'])) {
                $this->basejid = $_SESSION['XMPPHP_BOSH']['basejid'];
            }
            if (isset($_SESSION['XMPPHP_BOSH']['fulljid'])) {
                $this->fulljid = $_SESSION['XMPPHP_BOSH']['fulljid'];
            }
        }
    }

    /**
     * Get the session file
     *
     */
    public function getSessionFile()
    {
        return sys_get_temp_dir() . '/' . $this->user . '_' . $this->server . '_session';
    }

    /**
     * Build body
     *
     * @param $sub
     * @return SimpleXMLElement|string
     */
    public function __buildBody($sub = null)
    {

        $xml = '<body xmlns="http://jabber.org/protocol/httpbind" xmlns:xmpp="urn:xmpp:xbosh" />';
        $xml = new SimpleXMLElement($xml);
        $xml->addAttribute('content', 'text/xml; charset=utf-8');
        $xml->addAttribute('rid', $this->rid);
        $this->rid++;
        if ($this->sid) {
            $xml->addAttribute('sid', $this->sid);
        }

        $xml->addAttribute('xml:lang', 'en');

        if ($sub !== null) {

            // Ok, so simplexml is lame
            $parent = dom_import_simplexml($xml);
            $content = dom_import_simplexml($sub);
            $child = $parent->ownerDocument->importNode($content, true);
            $parent->appendChild($child);
            $xml = simplexml_import_dom($parent);
        }

        return $xml;
    }

    /**
     * Send body
     *
     * @param $body
     * @param $recv
     * @return bool|string
     * @throws Exception
     * @throws Exception
     */
    public function __sendBody($body = null, $recv = true)
    {

        if (!$body) {
            $body = $this->__buildBody();
        }

        $output = '';
        $header = array('Accept-Encoding: gzip, deflate', 'Content-Type: text/xml; charset=utf-8');
        $ch = curl_init();

        curl_setopt($ch, CURLOPT_URL, $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);
        curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
        curl_setopt($ch, CURLOPT_VERBOSE, 0);

        if ($recv) {
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
            $output = curl_exec($ch);
            if (curl_getinfo($ch, CURLINFO_HTTP_CODE) != '200') {
                throw new Exception('Wrong response from server!');
            }

            $this->http_buffer[] = $output;
        }
        curl_close($ch);

        return $output;
    }

    /**
     * Process
     *
     * @param $null1
     * @param $null2
     *
     * null params are not used and just to statify Strict Function Declaration
     * @return bool
     * @throws Exception
     * @throws Exception
     */
    public function __process($null1 = null, $null2 = null)
    {

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

        $this->saveSession();

        return true;
    }

    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);
                }
            }
        }
    }

    /**
     * Save session
     *
     */
    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']['basejid'] = (string)$this->basejid;
        $_SESSION['XMPPHP_BOSH']['fulljid'] = (string)$this->fulljid;
        $_SESSION['XMPPHP_BOSH']['inactivity'] = (string)$this->inactivity;
        $_SESSION['XMPPHP_BOSH']['lat'] = (string)time();

        if ($this->session == 'ON_FILE') {

            $session_file = $this->getSessionFile();
            $session_file_fp = fopen($session_file, 'r');
            flock($session_file_fp, LOCK_EX);
            // <?php prefix used to mask the content of the session file
            $session_serialized = '<?php ' . serialize($_SESSION);
            file_put_contents($session_file, $session_serialized);
            flock($session_file_fp, LOCK_UN);
            fclose($session_file_fp);
        }
    }

    /**
     * Process
     *
     * @param $msg
     * @param $null
     *
     * null param are not used and just to statify Strict Function Declaration
     * @throws Exception
     * @throws Exception
     */
    public function send($msg, $null = null)
    {
        $this->log->log('SEND: ' . $msg, Log::LEVEL_VERBOSE);
        $msg = new SimpleXMLElement($msg);
        $this->__sendBody($this->__buildBody($msg), true);
    }

    /**
     * Reset
     *
     * @throws Exception
     */
    public function reset()
    {

        $this->xml_depth = 0;
        unset($this->xmlobj);
        $this->xmlobj = array();
        $this->setupParser();
        $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);
    }

    /**
     * Disconnect
     *
     * @throws Exception
     */
    public function disconnect()
    {

        parent::disconnect();

        if ($this->session == 'ON_FILE') {
            unlink($this->getSessionFile());
        } else {
            $keys = array('RID', 'SID', 'authed', 'basejid', 'fulljid', 'inactivity', 'lat');
            foreach ($keys as $key) {
                unset($_SESSION['XMPPHP_BOSH'][$key]);
            }
        }
    }
}


code:
<?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>
 * @author     Alexander Birkner (https://github.com/BirknerAlex)
 * @author     zorn-v (https://github.com/zorn-v/xmpphp/)
 * @author     GNU social
 * @copyright  2008 Nathanael C. Fritz
 */

namespace XMPPHP;

use Exception as ObjectException;

/**
 * XMPPHP Exception
 *
 * @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 Exception extends ObjectException
{
}


code:
<?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>
 * @author     Alexander Birkner (https://github.com/BirknerAlex)
 * @author     zorn-v (https://github.com/zorn-v/xmpphp/)
 * @author     GNU social
 * @copyright  2008 Nathanael C. Fritz
 */

namespace XMPPHP;

/**
 * XMPPHP Log
 *
 * @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 Log
{
    const LEVEL_ERROR = 0;
    const LEVEL_WARNING = 1;
    const LEVEL_INFO = 2;
    const LEVEL_DEBUG = 3;
    const LEVEL_VERBOSE = 4;

    /**
     * @var array
     */
    protected $data = array();

    /**
     * @var array
     */
    protected $names = array('ERROR', 'WARNING', 'INFO', 'DEBUG', 'VERBOSE');

    /**
     * @var integer
     */
    protected $runlevel;

    /**
     * @var boolean
     */
    protected $printout;

    /**
     * Constructor
     *
     * @param boolean $printout
     * @param int $runlevel
     */
    public function __construct($printout = false, $runlevel = self::LEVEL_INFO)
    {
        $this->printout = (boolean)$printout;
        $this->runlevel = (int)$runlevel;
    }

    /**
     * Add a message to the log data array
     * If printout in this instance is set to true, directly output the message
     *
     * @param string $msg
     * @param integer $runlevel
     */
    public function log($msg, $runlevel = self::LEVEL_INFO)
    {
        $time = time();
        #$this->data[] = array($this->runlevel, $msg, $time);
        if ($this->printout and $runlevel <= $this->runlevel) {
            $this->writeLine($msg, $runlevel, $time);
        }
    }

    protected function writeLine($msg, $runlevel, $time)
    {
        //echo date('Y-m-d H:i:s', $time)." [".$this->names[$runlevel]."]: ".$msg."\n";
        echo $time . " [" . $this->names[$runlevel] . "]: " . $msg . "\n";
        flush();
    }

    /**
     * Output the complete log.
     * Log will be cleared if $clear = true
     *
     * @param boolean $clear
     * @param integer $runlevel
     */
    public function printout($clear = true, $runlevel = null)
    {
        if ($runlevel === null) {
            $runlevel = $this->runlevel;
        }
        foreach ($this->data as $data) {
            if ($runlevel <= $data[0]) {
                $this->writeLine($data[1], $runlevel, $data[2]);
            }
        }
        if ($clear) {
            $this->data = array();
        }
    }
}


code:
<?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>
 * @author     Alexander Birkner (https://github.com/BirknerAlex)
 * @author     zorn-v (https://github.com/zorn-v/xmpphp/)
 * @author     GNU social
 * @copyright  2008 Nathanael C. Fritz
 */

namespace XMPPHP;

/**
 * XMPPHP Roster
 *
 * @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 Roster
{
    /**
     * Roster array, handles contacts and presence.  Indexed by jid.
     * Contains array with potentially two indexes 'contact' and 'presence'
     * @var array
     */
    protected $roster_array = array();

    /**
     * Constructor
     * @param array $roster_array
     */
    public function __construct($roster_array = array())
    {
        if ($this->verifyRoster($roster_array)) {
            $this->roster_array = $roster_array; //Allow for pre-population with existing roster
        } else {
            $this->roster_array = array();
        }
    }

    /**
     *
     * Check that a given roster array is of a valid structure (empty is still valid)
     *
     * @param array $roster_array
     * @return bool
     */
    protected function verifyRoster($roster_array)
    {
        #TODO once we know *what* a valid roster array looks like
        return true;
    }

    /**
     *
     * Retrieve contact via jid
     *
     * @param string $jid
     * @return mixed
     */
    public function getContact($jid)
    {
        if ($this->isContact($jid)) {
            return $this->roster_array[$jid]['contact'];
        }
    }

    /**
     *
     * Discover if a contact exists in the roster via jid
     *
     * @param string $jid
     * @return bool
     */
    public function isContact($jid)
    {
        return (array_key_exists($jid, $this->roster_array));
    }

    /**
     *
     * Set presence
     *
     * @param string $presence
     * @param integer $priority
     * @param string $show
     * @param string $status
     */
    public function setPresence($presence, $priority, $show, $status)
    {
        $presence = explode('/', $presence, 2);
        $jid = $presence[0];
        $resource = isset($presence[1]) ? $presence[1] : '';
        if ($show != 'unavailable') {
            if (!$this->isContact($jid)) {
                $this->addContact($jid, 'not-in-roster');
            }
            $this->roster_array[$jid]['presence'][$resource] = array('priority' => $priority, 'show' => $show, 'status' => $status);
        } else { //Nuke unavailable resources to save memory
            unset($this->roster_array[$jid]['resource'][$resource]);
            unset($this->roster_array[$jid]['presence'][$resource]);
        }
    }

    /**
     *
     * Add given contact to roster
     *
     * @param string $jid
     * @param string $subscription
     * @param string $name
     * @param array $groups
     */
    public function addContact($jid, $subscription, $name = '', $groups = array())
    {
        $contact = array('jid' => $jid, 'subscription' => $subscription, 'name' => $name, 'groups' => $groups);
        if ($this->isContact($jid)) {
            $this->roster_array[$jid]['contact'] = $contact;
        } else {
            $this->roster_array[$jid] = array('contact' => $contact);
        }
    }

    /*
     *
     * Return best presence for jid
     *
     * @param string $jid
     */

    public function getPresence($jid)
    {
        $split = explode('/', $jid, 2);
        $jid = $split[0];
        if ($this->isContact($jid)) {
            $current = array('resource' => '', 'active' => '', 'priority' => -129, 'show' => '', 'status' => ''); //Priorities can only be -128 = 127
            foreach ($this->roster_array[$jid]['presence'] as $resource => $presence) {
                //Highest available priority or just highest priority
                if ($presence['priority'] > $current['priority'] and (($presence['show'] == "chat" or $presence['show'] == "available") or ($current['show'] != "chat" or $current['show'] != "available"))) {
                    $current = $presence;
                    $current['resource'] = $resource;
                }
            }
            return $current;
        }
    }

    /**
     *
     * Get roster
     *
     */
    public function getRoster()
    {
        return $this->roster_array;
    }
}


code:
<?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>
 * @author     Alexander Birkner (https://github.com/BirknerAlex)
 * @author     zorn-v (https://github.com/zorn-v/xmpphp/)
 * @author     GNU social
 * @copyright  2008 Nathanael C. Fritz
 */

namespace XMPPHP;

/**
 * XMPPHP XMLObject
 *
 * @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 XMLObj
{
    /**
     * Tag name
     *
     * @var string
     */
    public $name;

    /**
     * Namespace
     *
     * @var string
     */
    public $ns;

    /**
     * Attributes
     *
     * @var array
     */
    public $attrs = array();

    /**
     * Subs?
     *
     * @var array
     */
    public $subs = array();

    /**
     * Node data
     *
     * @var string
     */
    public $data = '';

    /**
     * Constructor
     *
     * @param string $name
     * @param string $ns
     * @param array $attrs
     * @param string $data
     */
    public function __construct($name, $ns = '', $attrs = array(), $data = '')
    {
        $this->name = strtolower($name);
        $this->ns = $ns;
        if (is_array($attrs) && count($attrs)) {
            foreach ($attrs as $key => $value) {
                $this->attrs[strtolower($key)] = $value;
            }
        }
        $this->data = $data;
    }

    /**
     * Dump this XML Object to output.
     *
     * @param integer $depth
     */
    public function printObj($depth = 0)
    {
        print str_repeat("\t", $depth) . $this->name . " " . $this->ns . ' ' . $this->data;
        print "\n";
        foreach ($this->subs as $sub) {
            $sub->printObj($depth + 1);
        }
    }

    /**
     * Return this XML Object in xml notation
     *
     * @param string $str
     * @return string
     */
    public function toString($str = '')
    {
        $str .= "<{$this->name} xmlns='{$this->ns}' ";
        foreach ($this->attrs as $key => $value) {
            if ($key != 'xmlns') {
                $value = htmlspecialchars($value);
                $str .= "$key='$value' ";
            }
        }
        $str .= ">";
        foreach ($this->subs as $sub) {
            $str .= $sub->toString();
        }
        $body = htmlspecialchars($this->data);
        $str .= "$body</{$this->name}>";
        return $str;
    }

    /**
     * Has this XML Object the given sub?
     *
     * @param string $name
     * @param null $ns
     * @return boolean
     */
    public function hasSub($name, $ns = null)
    {
        foreach ($this->subs as $sub) {
            if (($name == "*" or $sub->name == $name) and ($ns == null or $sub->ns == $ns)) {
                return true;
            }
        }
        return false;
    }

    /**
     * Return a sub
     *
     * @param string $name
     * @param string $attrs
     * @param string $ns
     * @return mixed
     */
    public function sub($name, $attrs = null, $ns = null)
    {
        #TODO attrs is ignored
        foreach ($this->subs as $sub) {
            if ($sub->name == $name and ($ns == null or $sub->ns == $ns)) {
                return $sub;
            }
        }
    }
}


code:
<?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>
 * @author     Alexander Birkner (https://github.com/BirknerAlex)
 * @author     zorn-v (https://github.com/zorn-v/xmpphp/)
 * @author     GNU social
 * @copyright  2008 Nathanael C. Fritz
 */

namespace XMPPHP;

/** Exception */
require_once __DIR__ . DIRECTORY_SEPARATOR . 'Exception.php';

/** XMLObj */
require_once __DIR__ . DIRECTORY_SEPARATOR . 'XMLObj.php';

/** Log */
require_once __DIR__ . DIRECTORY_SEPARATOR . 'Log.php';

/**
 * XMPPHP XMLStream
 *
 * @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 XMLStream
{
    /**
     * @var resource
     */
    protected $socket;
    /**
     * @var resource
     */
    protected $parser;
    /**
     * @var string
     */
    protected $buffer;
    /**
     * @var integer
     */
    protected $xml_depth = 0;
    /**
     * @var string
     */
    protected $host;
    /**
     * @var integer
     */
    protected $port;
    /**
     * @var string
     */
    protected $stream_start = '<stream>';
    /**
     * @var string
     */
    protected $stream_end = '</stream>';
    /**
     * @var boolean
     */
    protected $disconnected = false;
    /**
     * @var boolean
     */
    protected $sent_disconnect = false;
    /**
     * @var array
     */
    protected $ns_map = array();
    /**
     * @var array
     */
    protected $current_ns = array();
    /**
     * @var array
     */
    protected $xmlobj = null;
    /**
     * @var array
     */
    protected $nshandlers = array();
    /**
     * @var array
     */
    protected $xpathhandlers = array();
    /**
     * @var array
     */
    protected $idhandlers = array();
    /**
     * @var array
     */
    protected $eventhandlers = array();
    /**
     * @var integer
     */
    protected $lastid = 0;
    /**
     * @var string
     */
    protected $default_ns;
    /**
     * @var string[]
     */
    protected $until = [];
    /**
     * @var int[]
     */
    protected $until_count = [];
    /**
     * @var array
     */
    protected $until_happened = false;
    /**
     * @var array
     */
    protected $until_payload = array();
    /**
     * @var Log
     */
    protected $log;
    /**
     * @var boolean
     */
    protected $reconnect = true;
    /**
     * @var boolean
     */
    protected $been_reset = false;
    /**
     * @var boolean
     */
    protected $is_server;
    /**
     * @var float
     */
    protected $last_send = 0;
    /**
     * @var boolean
     */
    protected $use_ssl = false;
    /**
     * @var integer
     */
    protected $reconnectTimeout = 30;

    /**
     * Constructor
     *
     * @param string $host
     * @param string $port
     * @param boolean $printlog
     * @param string $loglevel
     * @param boolean $is_server
     */
    public function __construct($host = null, $port = null, $printlog = false, $loglevel = null, $is_server = false)
    {
        $this->reconnect = !$is_server;
        $this->is_server = $is_server;
        $this->host = $host;
        $this->port = $port;
        $this->setupParser();
        $this->log = new Log($printlog, $loglevel);
    }

    /**
     * Setup the XML parser
     */
    public function setupParser()
    {
        $this->parser = xml_parser_create('UTF-8');
        xml_parser_set_option($this->parser, XML_OPTION_SKIP_WHITE, 1);
        xml_parser_set_option($this->parser, XML_OPTION_TARGET_ENCODING, 'UTF-8');
        xml_set_object($this->parser, $this);
        xml_set_element_handler($this->parser, 'startXML', 'endXML');
        xml_set_character_data_handler($this->parser, 'charXML');
    }

    /**
     * Destructor
     * Cleanup connection
     */
    public function __destruct()
    {
        if (!$this->disconnected && $this->socket) {
            $this->disconnect();
        }
    }

    /**
     * Disconnect from XMPP Host
     */
    public function disconnect()
    {
        $this->log->log("Disconnecting...", Log::LEVEL_VERBOSE);
        if (false == (bool)$this->socket) {
            return;
        }
        $this->reconnect = false;
        $this->send($this->stream_end);
        $this->sent_disconnect = true;
        $this->processUntil('end_stream', 5);
        $this->disconnected = true;
    }

    /**
     * Send to socket
     *
     * @param string $msg
     * @param null $timeout
     * @return bool|int
     * @throws Exception
     */
    public function send($msg, $timeout = NULL)
    {

        if (is_null($timeout)) {
            $secs = NULL;
            $usecs = NULL;
        } else if ($timeout == 0) {
            $secs = 0;
            $usecs = 0;
        } else {
            $maximum = $timeout * 1000000;
            $usecs = $maximum % 1000000;
            $secs = floor(($maximum - $usecs) / 1000000);
        }

        $read = array();
        $write = array($this->socket);
        $except = array();

        $select = @stream_select($read, $write, $except, $secs, $usecs);

        if ($select === False) {
            $this->log->log("ERROR sending message; reconnecting.");
            $this->doReconnect();
            # TODO: retry send here
            return false;
        } elseif ($select > 0) {
            $this->log->log("Socket is ready; send it.", Log::LEVEL_VERBOSE);
        } else {
            $this->log->log("Socket is not ready; break.", Log::LEVEL_ERROR);
            return false;
        }

        $sentbytes = @fwrite($this->socket, $msg);
        $this->log->log("SENT: " . mb_substr($msg, 0, $sentbytes, '8bit'), Log::LEVEL_VERBOSE);
        if ($sentbytes === FALSE) {
            $this->log->log("ERROR sending message; reconnecting.", Log::LEVEL_ERROR);
            $this->doReconnect();
            return false;
        }
        $this->log->log("Successfully sent $sentbytes bytes.", Log::LEVEL_VERBOSE);
        return $sentbytes;
    }

    /**
     * Reconnect XMPP Host
     * @throws Exception
     */
    public function doReconnect()
    {
        if (!$this->is_server) {
            $this->log->log("Reconnecting ($this->reconnectTimeout)...", Log::LEVEL_WARNING);
            $this->connect($this->reconnectTimeout, false, false);
            $this->reset();
            $this->event('reconnect');
        }
    }

    /**
     * Connect to XMPP Host
     *
     * @param integer $timeout
     * @param boolean $persistent
     * @param boolean $sendinit
     * @throws Exception
     * @throws Exception
     */
    public function connect($timeout = 30, $persistent = false, $sendinit = true)
    {
        $this->sent_disconnect = false;
        $starttime = time();

        do {
            $this->disconnected = false;
            $this->sent_disconnect = false;
            if ($persistent) {
                $conflag = STREAM_CLIENT_CONNECT | STREAM_CLIENT_PERSISTENT;
            } else {
                $conflag = STREAM_CLIENT_CONNECT;
            }
            $conntype = 'tcp';
            if ($this->use_ssl) $conntype = 'ssl';
            $this->log->log("Connecting to $conntype://{$this->host}:{$this->port}");
            $this->socket = @stream_socket_client("$conntype://{$this->host}:{$this->port}", $errno, $errstr, $timeout, $conflag);
            if (!$this->socket) {
                $this->log->log("Could not connect.", Log::LEVEL_ERROR);
                $this->disconnected = true;
                # Take it easy for a few seconds
                sleep(min($timeout, 5));
            }
        } while (!$this->socket && (time() - $starttime) < $timeout);

        if ($this->socket) {
            stream_set_blocking($this->socket, 1);
            if ($sendinit) $this->send($this->stream_start);
        } else {
            throw new Exception("Could not connect before timeout.");
        }
    }

    /**
     * Reset connection
     */
    public function reset()
    {
        $this->xml_depth = 0;
        unset($this->xmlobj);
        $this->xmlobj = array();
        $this->setupParser();
        if (!$this->is_server) {
            $this->send($this->stream_start);
        }
        $this->been_reset = true;
    }

    /**
     * Event?
     *
     * @param string $name
     * @param string $payload
     */
    public function event($name, $payload = null)
    {
        $this->log->log("EVENT: $name", Log::LEVEL_DEBUG);
        foreach ($this->eventhandlers as $handler) {
            if ($name == $handler[0]) {
                if ($handler[2] === null) {
                    $handler[2] = $this;
                }
                $handler[2]->{$handler[1]}($payload);
            }
        }
        foreach ($this->until as $key => $until) {
            if (is_array($until)) {
                if (in_array($name, $until)) {
                    $this->until_payload[$key][] = array($name, $payload);
                    if (!isset($this->until_count[$key])) {
                        $this->until_count[$key] = 0;
                    }
                    $this->until_count[$key] += 1;
                    #$this->until[$key] = false;
                }
            }
        }
    }

    /**
     * Process until a specified event or a timeout occurs
     *
     * @param string|array $event
     * @param integer $timeout
     * @return string
     * @throws Exception
     */
    public function processUntil($event, $timeout = -1)
    {
        $start = time();
        if (!is_array($event)) $event = array($event);
        $this->until[] = $event;
        end($this->until);
        $event_key = key($this->until);
        reset($this->until);
        $this->until_count[$event_key] = 0;
        while (!$this->disconnected and $this->until_count[$event_key] < 1 and (time() - $start < $timeout or $timeout == -1)) {
            $this->__process();
        }
        if (array_key_exists($event_key, $this->until_payload)) {
            $payload = $this->until_payload[$event_key];
            unset($this->until_payload[$event_key]);
            unset($this->until_count[$event_key]);
            unset($this->until[$event_key]);
        } else {
            $payload = array();
        }
        return $payload;
    }

    /**
     * Core reading tool
     * 0 -> only read if data is immediately ready
     * NULL -> wait forever and ever
     * integer -> process for this amount of time
     * @param int $maximum
     * @return bool
     * @throws Exception
     */

    private function __process($maximum = 5)
    {

        $remaining = $maximum;

        do {
            $starttime = (microtime(true) * 1000000);
            $read = array($this->socket);
            $write = array();
            $except = array();
            if (is_null($maximum)) {
                $secs = NULL;
                $usecs = NULL;
            } else if ($maximum == 0) {
                $secs = 0;
                $usecs = 0;
            } else {
                $usecs = $remaining % 1000000;
                $secs = floor(($remaining - $usecs) / 1000000);
            }
            $updated = @stream_select($read, $write, $except, $secs, $usecs);
            if ($updated === false) {
                $this->log->log("Error on stream_select()", Log::LEVEL_VERBOSE);
                if ($this->reconnect) {
                    $this->doReconnect();
                } else {
                    fclose($this->socket);
                    $this->socket = NULL;
                    return false;
                }
            } else if ($updated > 0) {
                # XXX: Is this big enough?
                $buff = @fread($this->socket, 4096);
                if (!$buff) {
                    if ($this->reconnect) {
                        $this->doReconnect();
                    } else {
                        fclose($this->socket);
                        $this->socket = NULL;
                        return false;
                    }
                }
                $this->log->log("RECV: $buff", Log::LEVEL_VERBOSE);
                xml_parse($this->parser, $buff, false);
            } // Otherwise,
              // $updated == 0 means no changes during timeout.

            $endtime = (microtime(true) * 1000000);
            $time_past = $endtime - $starttime;
            $remaining = $remaining - $time_past;
        } while (is_null($maximum) || $remaining > 0);
        return true;
    }

    /**
     * Return the log instance
     *
     * @return Log
     */
    public function getLog()
    {
        return $this->log;
    }

    /**
     * Get next ID
     *
     * @return integer
     */
    public function getId()
    {
        $this->lastid++;
        return $this->lastid;
    }

    /**
     * Set SSL
     * @param bool $use
     */
    public function useSSL($use = true)
    {
        $this->use_ssl = $use;
    }

    /**
     * Add ID Handler
     *
     * @param integer $id
     * @param string $pointer
     * @param string $obj
     */
    public function addIdHandler($id, $pointer, $obj = null)
    {
        $this->idhandlers[$id] = array($pointer, $obj);
    }

    /**
     * Add Handler
     *
     * @param string $name
     * @param string $ns
     * @param string $pointer
     * @param string $obj
     * @param integer $depth
     */
    public function addHandler($name, $ns, $pointer, $obj = null, $depth = 1)
    {
        #TODO deprication warning
        $this->nshandlers[] = array($name, $ns, $pointer, $obj, $depth);
    }

    /**
     * Add XPath Handler
     *
     * @param string $xpath
     * @param string $pointer
     * @param
     */
    public function addXPathHandler($xpath, $pointer, $obj = null)
    {
        if (preg_match_all("/\(?{[^\}]+}\)?(\/?)[^\/]+/", $xpath, $regs)) {
            $ns_tags = $regs[0];
        } else {
            $ns_tags = array($xpath);
        }
        foreach ($ns_tags as $ns_tag) {
            list($l, $r) = explode("}", $ns_tag);
            if ($r != null) {
                $xpart = array(substr($l, 1), $r);
            } else {
                $xpart = array(null, $l);
            }
            $xpath_array[] = $xpart;
        }
        $this->xpathhandlers[] = array($xpath_array, $pointer, $obj);
    }

    /**
     * Add Event Handler
     *
     * @param $name
     * @param string $pointer
     * @param string $obj
     */
    public function addEventHandler($name, $pointer, $obj)
    {
        $this->eventhandlers[] = array($name, $pointer, $obj);
    }

    public function setReconnectTimeout($timeout)
    {
        $this->reconnectTimeout = $timeout;
    }

    /**
     * Are we are disconnected?
     *
     * @return boolean
     */
    public function isDisconnected()
    {
        return $this->disconnected;
    }

    /**
     * Process
     *
     */
    public function process()
    {
        $this->__process(NULL);
    }

    /**
     * Process until a timeout occurs
     *
     * @param integer $timeout
     * @return string
     * @throws Exception
     */
    public function processTime($timeout = NULL)
    {
        if (is_null($timeout)) {
            return $this->__process(NULL);
        } else {
            return $this->__process($timeout * 1000000);
        }
    }

    /**
     * Obsolete?
     * @param $socket
     */
    public function Xapply_socket($socket)
    {
        $this->socket = $socket;
    }

    /**
     * XML start callback
     *
     * @param resource $parser
     * @param string $name
     * @param $attr
     * @see xml_set_element_handler
     */
    public function startXML($parser, $name, $attr)
    {
        if ($this->been_reset) {
            $this->been_reset = false;
            $this->xml_depth = 0;
        }
        $this->xml_depth++;
        if (array_key_exists('XMLNS', $attr)) {
            $this->current_ns[$this->xml_depth] = $attr['XMLNS'];
        } else {
            $this->current_ns[$this->xml_depth] = $this->current_ns[$this->xml_depth - 1];
            if (!$this->current_ns[$this->xml_depth]) $this->current_ns[$this->xml_depth] = $this->default_ns;
        }
        $ns = $this->current_ns[$this->xml_depth];
        foreach ($attr as $key => $value) {
            if (strstr($key, ":")) {
                $key = explode(':', $key);
                $key = $key[1];
                $this->ns_map[$key] = $value;
            }
        }
        if (!strstr($name, ":") === false) {
            $name = explode(':', $name);
            $ns = $this->ns_map[$name[0]];
            $name = $name[1];
        }
        $obj = new XMLObj($name, $ns, $attr);
        if ($this->xml_depth > 1) {
            $this->xmlobj[$this->xml_depth - 1]->subs[] = $obj;
        }
        $this->xmlobj[$this->xml_depth] = $obj;
    }

    /**
     * XML end callback
     *
     * @param resource $parser
     * @param string $name
     * @throws Exception
     * @see xml_set_element_handler
     *
     */
    public function endXML($parser, $name)
    {
        #$this->log->log("Ending $name",  Log::LEVEL_DEBUG);
        #print "$name\n";
        if ($this->been_reset) {
            $this->been_reset = false;
            $this->xml_depth = 0;
        }
        $this->xml_depth--;
        if ($this->xml_depth == 1) {
            #clean-up old objects
            #$found = false; #FIXME This didn't appear to be in use --Gar
            foreach ($this->xpathhandlers as $handler) {
                if (is_array($this->xmlobj) && array_key_exists(2, $this->xmlobj)) {
                    $searchxml = $this->xmlobj[2];
                    $nstag = array_shift($handler[0]);
                    if (($nstag[0] == null or $searchxml->ns == $nstag[0]) and ($nstag[1] == "*" or $nstag[1] == $searchxml->name)) {
                        foreach ($handler[0] as $nstag) {
                            if ($searchxml !== null and $searchxml->hasSub($nstag[1], $ns = $nstag[0])) {
                                $searchxml = $searchxml->sub($nstag[1], $ns = $nstag[0]);
                            } else {
                                $searchxml = null;
                                break;
                            }
                        }
                        if ($searchxml !== null) {
                            if ($handler[2] === null) $handler[2] = $this;
                            $this->log->log("Calling {$handler[1]}", Log::LEVEL_DEBUG);
                            $handler[2]->{$handler[1]}($this->xmlobj[2]);
                        }
                    }
                }
            }
            foreach ($this->nshandlers as $handler) {
                if ($handler[4] != 1 and array_key_exists(2, $this->xmlobj) and $this->xmlobj[2]->hasSub($handler[0])) {
                    $searchxml = $this->xmlobj[2]->sub($handler[0]);
                } elseif (is_array($this->xmlobj) and array_key_exists(2, $this->xmlobj)) {
                    $searchxml = $this->xmlobj[2];
                }
                if ($searchxml !== null and $searchxml->name == $handler[0] and ($searchxml->ns == $handler[1] or (!$handler[1] and $searchxml->ns == $this->default_ns))) {
                    if ($handler[3] === null) $handler[3] = $this;
                    $this->log->log("Calling {$handler[2]}", Log::LEVEL_DEBUG);
                    $handler[3]->{$handler[2]}($this->xmlobj[2]);
                }
            }
            foreach ($this->idhandlers as $id => $handler) {
                if (array_key_exists('id', $this->xmlobj[2]->attrs) and $this->xmlobj[2]->attrs['id'] == $id) {
                    if ($handler[1] === null) $handler[1] = $this;
                    $handler[1]->{$handler[0]}($this->xmlobj[2]);
                    #id handlers are only used once
                    unset($this->idhandlers[$id]);
                    break;
                }
            }
            if (is_array($this->xmlobj)) {
                $this->xmlobj = array_slice($this->xmlobj, 0, 1);
                if (isset($this->xmlobj[0]) && $this->xmlobj[0] instanceof XMLObj) {
                    $this->xmlobj[0]->subs = null;
                }
            }
            unset($this->xmlobj[2]);
        }
        if ($this->xml_depth == 0 and !$this->been_reset) {
            if (!$this->disconnected) {
                if (!$this->sent_disconnect) {
                    $this->send($this->stream_end);
                }
                $this->disconnected = true;
                $this->sent_disconnect = true;
                fclose($this->socket);
                if ($this->reconnect) {
                    $this->doReconnect();
                }
            }
            $this->event('end_stream');
        }
    }

    /**
     * XML character callback
     * @param resource $parser
     * @param string $data
     * @see xml_set_character_data_handler
     *
     */
    public function charXML($parser, $data)
    {
        if (array_key_exists($this->xml_depth, $this->xmlobj)) {
            $this->xmlobj[$this->xml_depth]->data .= $data;
        }
    }

    /**
     * Read from socket
     */
    public function read()
    {
        $buff = @fread($this->socket, 1024);
        if (!$buff) {
            if ($this->reconnect) {
                $this->doReconnect();
            } else {
                fclose($this->socket);
                return false;
            }
        }
        $this->log->log("RECV: $buff", Log::LEVEL_VERBOSE);
        xml_parse($this->parser, $buff, false);
    }

    public function time()
    {
        list($usec, $sec) = explode(" ", microtime());
        return (float)$sec + (float)$usec;
    }

    public function readyToProcess()
    {
        $read = array($this->socket);
        $write = array();
        $except = array();
        $updated = @stream_select($read, $write, $except, 0);
        return (($updated !== false) && ($updated > 0));
    }
}


code:
<?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>
 * @author     Alexander Birkner (https://github.com/BirknerAlex)
 * @author     zorn-v (https://github.com/zorn-v/xmpphp/)
 * @author     GNU social
 * @copyright  2008 Nathanael C. Fritz
 */

namespace XMPPHP;

/** XMPPHP_XMLStream */
require_once __DIR__ . DIRECTORY_SEPARATOR . 'XMLStream.php';
require_once __DIR__ . DIRECTORY_SEPARATOR . 'Roster.php';

/**
 * XMPPHP XMPP
 *
 * @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 XMPP extends XMLStream
{
    /**
     * @var string
     */
    public $server;

    /**
     * @var string
     */
    public $user;
    /**
     * @var boolean
     */
    public $track_presence = true;
    /**
     * @var object
     */
    public $roster;
    /**
     * @var string
     */
    protected $password;
    /**
     * @var string
     */
    protected $resource;
    /**
     * @var string
     */
    protected $fulljid;
    /**
     * @var string
     */
    protected $basejid;
    /**
     * @var boolean
     */
    protected $authed = false;
    protected $session_started = false;
    /**
     * @var boolean
     */
    protected $auto_subscribe = false;
    /**
     * @var boolean
     */
    protected $use_encryption = true;

    /**
     * Constructor
     *
     * @param string $host
     * @param integer $port
     * @param string $user
     * @param string $password
     * @param string $resource
     * @param string $server
     * @param boolean $printlog
     * @param string $loglevel
     */
    public function __construct($host, $port, $user, $password, $resource, $server = null, $printlog = false, $loglevel = null)
    {
        parent::__construct($host, $port, $printlog, $loglevel);

        $this->user = $user;
        $this->password = $password;
        $this->resource = $resource;
        if (!$server) {
            $server = $host;
        }
        $this->server = $server;
        $this->basejid = $this->user . '@' . $this->host;

        $this->roster = new Roster();
        $this->track_presence = true;

        $this->stream_start = '<stream:stream to="' . $server . '" xmlns:stream="http://etherx.jabber.org/streams" xmlns="jabber:client" version="1.0">';
        $this->stream_end = '</stream:stream>';
        $this->default_ns = 'jabber:client';

        $this->addXPathHandler('{http://etherx.jabber.org/streams}features', 'features_handler');
        $this->addXPathHandler('{urn:ietf:params:xml:ns:xmpp-sasl}success', 'sasl_success_handler');
        $this->addXPathHandler('{urn:ietf:params:xml:ns:xmpp-sasl}failure', 'sasl_failure_handler');
        $this->addXPathHandler('{urn:ietf:params:xml:ns:xmpp-tls}proceed', 'tls_proceed_handler');
        $this->addXPathHandler('{jabber:client}message', 'message_handler');
        $this->addXPathHandler('{jabber:client}presence', 'presence_handler');
        $this->addXPathHandler('iq/{jabber:iq:roster}query', 'roster_iq_handler');
    }

    /**
     * Turn encryption on/ff
     *
     * @param boolean $useEncryption
     */
    public function useEncryption($useEncryption = true)
    {
        $this->use_encryption = $useEncryption;
    }

    /**
     * Turn on auto-authorization of subscription requests.
     *
     * @param boolean $autoSubscribe
     */
    public function autoSubscribe($autoSubscribe = true)
    {
        $this->auto_subscribe = $autoSubscribe;
    }

    /**
     * Send XMPP Message
     *
     * @param string $to
     * @param string $body
     * @param string $type
     * @param string $subject
     * @param null $payload
     * @throws Exception
     */
    public function message($to, $body, $type = 'chat', $subject = null, $payload = null)
    {
        if ($this->disconnected) {
            throw new Exception('You need to connect first');
        }

        if (empty($type)) {
            $type = 'chat';
        }

        $to      = htmlspecialchars($to);
        $body    = htmlspecialchars($body);
        $subject = htmlspecialchars($subject);
        $subject = ($subject) ? '<subject>' . $subject . '</subject>' : '';
        $payload = ($payload) ? $payload : '';
        $sprintf = '<message from="%s" to="%s" type="%s">%s<body>%s</body>%s</message>';
        $output  = sprintf($sprintf, $this->fulljid, $to, $type, $subject, $body, $payload);
        $this->send($output);
    }

    /**
     * Set Presence
     *
     * @param string $status
     * @param string $show
     * @param string $to
     * @param string $type
     * @param null $priority
     * @throws Exception
     */
    public function presence($status = null, $show = 'available', $to = null, $type = 'available', $priority = null)
    {
        if ($this->disconnected) {
            throw new Exception('You need to connect first');
        }

        if ($type == 'available') {
            $type = '';
        }
        $to = htmlspecialchars($to);
        $status = htmlspecialchars($status);
        if ($show == 'unavailable') {
            $type = 'unavailable';
        }

        $out = "<presence";
        if ($to) {
            $out .= " to=\"$to\"";
        }
        if ($type) {
            $out .= " type='$type'";
        }
        if ($show == 'available' and !$status and $priority !== null) {
            $out .= "/>";
        } else {
            $out .= ">";
            if ($show != 'available') {
                $out .= "<show>$show</show>";
            }
            if ($status) {
                $out .= "<status>$status</status>";
            }
            if ($priority !== null) {
                $out .= "<priority>$priority</priority>";
            }
            $out .= "</presence>";
        }

        $this->send($out);
    }

    /**
     * Send Auth request
     *
     * @param string $jid
     */
    public function subscribe($jid)
    {
        $this->send("<presence type='subscribe' to='{$jid}' from='{$this->fulljid}' />");
        #$this->send("<presence type='subscribed' to='{$jid}' from='{$this->fulljid}' />");
    }

    /**
     * Message handler
     *
     * @param string $xml
     */
    public function message_handler($xml)
    {
        if (isset($xml->attrs['type'])) {
            $payload['type'] = $xml->attrs['type'];
        } else {
            $payload['type'] = 'chat';
        }
        $body = $xml->sub('body');
        $payload['from'] = $xml->attrs['from'];
        $payload['body'] = is_object($body) ? $body->data : false; // $xml->sub('body')->data;
        $payload['xml'] = $xml;
        $this->log->log("Message: {$payload['body']}", Log::LEVEL_DEBUG);
        $this->event('message', $payload);
    }

    /**
     * Presence handler
     *
     * @param string $xml
     */
    public function presence_handler($xml)
    {
        $payload['type'] = (isset($xml->attrs['type'])) ? $xml->attrs['type'] : 'available';
        $payload['show'] = (isset($xml->sub('show')->data)) ? $xml->sub('show')->data : $payload['type'];
        $payload['from'] = $xml->attrs['from'];
        $payload['status'] = (isset($xml->sub('status')->data)) ? $xml->sub('status')->data : '';
        $payload['priority'] = (isset($xml->sub('priority')->data)) ? intval($xml->sub('priority')->data) : 0;
        $payload['xml'] = $xml;
        if ($this->track_presence) {
            $this->roster->setPresence($payload['from'], $payload['priority'], $payload['show'], $payload['status']);
        }
        $this->log->log("Presence: {$payload['from']} [{$payload['show']}] {$payload['status']}", Log::LEVEL_DEBUG);
        if (array_key_exists('type', $xml->attrs) and $xml->attrs['type'] == 'subscribe') {
            if ($this->auto_subscribe) {
                $this->send("<presence type='subscribed' to='{$xml->attrs['from']}' from='{$this->fulljid}' />");
                $this->send("<presence type='subscribe' to='{$xml->attrs['from']}' from='{$this->fulljid}' />");
            }
            $this->event('subscription_requested', $payload);
        } elseif (array_key_exists('type', $xml->attrs) and $xml->attrs['type'] == 'subscribed') {
            $this->event('subscription_accepted', $payload);
        } else {
            $this->event('presence', $payload);
        }
    }

    /**
     * Retrieves the roster
     *
     */
    public function getRoster()
    {
        $id = $this->getID();
        $this->send("<iq xmlns='jabber:client' type='get' id='$id'><query xmlns='jabber:iq:roster' /></iq>");
    }

    /**
     * Retrieves the vcard
     * @param null $jid
     */
    public function getVCard($jid = null)
    {
        $id = $this->getID();
        $this->addIdHandler($id, 'vcard_get_handler');
        if ($jid) {
            $this->send("<iq type='get' id='$id' to='$jid'><vCard xmlns='vcard-temp' /></iq>");
        } else {
            $this->send("<iq type='get' id='$id'><vCard xmlns='vcard-temp' /></iq>");
        }
    }

    /**
     * Features handler
     *
     * @param string $xml
     */
    protected function features_handler($xml)
    {
        if ($xml->hasSub('starttls') and $this->use_encryption) {
            $this->send("<starttls xmlns='urn:ietf:params:xml:ns:xmpp-tls'><required /></starttls>");
        } elseif ($xml->hasSub('bind') and $this->authed) {
            $id = $this->getId();
            $this->addIdHandler($id, 'resource_bind_handler');
            $this->send("<iq xmlns=\"jabber:client\" type=\"set\" id=\"$id\"><bind xmlns=\"urn:ietf:params:xml:ns:xmpp-bind\"><resource>{$this->resource}</resource></bind></iq>");
        } else {
            $this->log->log("Attempting Auth...");
            if ($this->password) {
                $this->send("<auth xmlns='urn:ietf:params:xml:ns:xmpp-sasl' mechanism='PLAIN'>" . base64_encode("\x00" . $this->user . "\x00" . $this->password) . "</auth>");
            } else {
                $this->send("<auth xmlns='urn:ietf:params:xml:ns:xmpp-sasl' mechanism='ANONYMOUS'/>");
            }
        }
    }

    /**
     * SASL success handler
     *
     * @param string $xml
     */
    protected function sasl_success_handler($xml)
    {
        $this->log->log("Auth success!");
        $this->authed = true;
        $this->reset();
    }

    /**
     * SASL feature handler
     *
     * @param string $xml
     * @throws Exception
     */
    protected function sasl_failure_handler($xml)
    {
        $this->log->log("Auth failed!", Log::LEVEL_ERROR);
        $this->disconnect();

        throw new Exception('Auth failed!');
    }

    /**
     * Resource bind handler
     *
     * @param string $xml
     */
    protected function resource_bind_handler($xml)
    {
        if ($xml->attrs['type'] == 'result') {
            $this->log->log("Bound to " . $xml->sub('bind')->sub('jid')->data);
            $this->fulljid = $xml->sub('bind')->sub('jid')->data;
            $jidarray = explode('/', $this->fulljid);
            $this->jid = $jidarray[0];
        }
        $id = $this->getId();
        $this->addIdHandler($id, 'session_start_handler');
        $this->send("<iq xmlns='jabber:client' type='set' id='$id'><session xmlns='urn:ietf:params:xml:ns:xmpp-session' /></iq>");
    }

    /**
     * Roster iq handler
     * Gets all packets matching XPath "iq/{jabber:iq:roster}query'
     *
     * @param string $xml
     */
    protected function roster_iq_handler($xml)
    {
        $status = "result";
        $xmlroster = $xml->sub('query');
        foreach ($xmlroster->subs as $item) {
            $groups = array();
            if ($item->name == 'item') {
                $jid = $item->attrs['jid']; //REQUIRED
                $name = $item->attrs['name']; //MAY
                $subscription = $item->attrs['subscription'];
                foreach ($item->subs as $subitem) {
                    if ($subitem->name == 'group') {
                        $groups[] = $subitem->data;
                    }
                }
                $contacts[] = array($jid, $subscription, $name, $groups); //Store for action if no errors happen
            } else {
                $status = "error";
            }
        }
        if ($status == "result") { //No errors, add contacts
            foreach ($contacts as $contact) {
                $this->roster->addContact($contact[0], $contact[1], $contact[2], $contact[3]);
            }
        }
        if ($xml->attrs['type'] == 'set') {
            $this->send("<iq type=\"reply\" id=\"{$xml->attrs['id']}\" to=\"{$xml->attrs['from']}\" />");
        }
    }

    /**
     * Session start handler
     *
     * @param string $xml
     */
    protected function session_start_handler($xml)
    {
        $this->log->log("Session started");
        $this->session_started = true;
        $this->event('session_start');
    }

    /**
     * TLS proceed handler
     *
     * @param string $xml
     */
    protected function tls_proceed_handler($xml)
    {
        $this->log->log("Starting TLS encryption");
        stream_socket_enable_crypto($this->socket, true, STREAM_CRYPTO_METHOD_SSLv23_CLIENT);
        $this->reset();
    }

    /**
     * VCard retrieval handler
     *
     * @param XMLObj $xml
     */
    protected function vcard_get_handler($xml)
    {
        $vcard_array = array();
        $vcard = $xml->sub('vcard');
        // go through all of the sub elements and add them to the vcard array
        foreach ($vcard->subs as $sub) {
            if ($sub->subs) {
                $vcard_array[$sub->name] = array();
                foreach ($sub->subs as $sub_child) {
                    $vcard_array[$sub->name][$sub_child->name] = $sub_child->data;
                }
            } else {
                $vcard_array[$sub->name] = $sub->data;
            }
        }
        $vcard_array['from'] = $xml->attrs['from'];
        $this->event('vcard', $vcard_array);
    }
}


diogocomposer/xmpphp

description: XMPP PHP Library

keywords: jabber xmpphp xmpp


code:
<?php

/**
 * @file: XMPPHP Cli example
 *
 * @info: If this script doesn't work, are you running 64-bit PHP with < 5.2.6?
 */

/**
 * Activate full error reporting
 * error_reporting(E_ALL & E_STRICT);
 *
 * XMPPHP Log levels:
 *
 * LEVEL_ERROR   = 0;
 * LEVEL_WARNING = 1;
 * LEVEL_INFO    = 2;
 * LEVEL_DEBUG   = 3;
 * LEVEL_VERBOSE = 4;
 */

require '../vendor/autoload.php';

$conf = array(
  'server'   => 'talk.google.com',
  'port'     => 5222,
  'username' => 'username',
  'password' => 'password',
  'proto'    => 'xmpphp',
  'domain'   => 'gmail.com',
  'printlog' => true,
  'loglevel' => XMPPHP\Log::LEVEL_VERBOSE,
);

// Easy and simple for access to variables with their names
extract($conf);

$conn = new XMPPHP\XMPP($server, $port, $username, $password, $proto, $domain, $printlog, $loglevel);
$conn->autoSubscribe();

$vcard_request = array();

try {
    $conn->connect();

    while (!$conn->isDisconnected()) {
        $events   = array('message', 'presence', 'end_stream', 'session_start', 'vcard');
        $payloads = $conn->processUntil($events);

        foreach ($payloads as $result) {
            list($event, $data) = $result;

            if (isset($data)) {
                extract($data);
            }

            switch ($event) {

        case 'message':

          if (!$body) {
              break;
          }

          echo str_repeat('-', 80);
          echo "Message from: $from";

          if (isset($subject)) {
              echo "Subject: $subject";
          }

          echo $body;
          echo str_repeat('-', 80);

          $cmd  = explode(' ', $body);
          $body = "Mi no entender! '$body'";
          $conn->message($from, $body, $type);

          if (isset($cmd[0])) {
              if ($cmd[0] == 'quit') {
                  $conn->disconnect();
              }

              if ($cmd[0] == 'break') {
                  $conn->send('</end>');
              }

              if ($cmd[0] == 'vcard') {
                  if (!isset($cmd[1])) {
                      $cmd[1] = $conn->user;
                  }

                  // Take a note which user requested which vcard
                  $vcard_request[$from] = $cmd[1];
                  // Request the vcard
                  $conn->getVCard($cmd[1]);
              }
          }
          break;

        case 'presence':

          echo "Presence: $from [$show] $status\n";
          break;

        case 'session_start':

          echo "Session start\n";
          $conn->getRoster();
          $conn->presence('Quasar!');
          break;

        case 'vcard':

          $deliver = array_keys($vcard_request, $from);
          $msg     = '';

          foreach ($data as $key => $item) {
              $msg .= $key . ': ';

              if (is_array($item)) {
                  $msg .= "\n";
                  foreach ($item as $subkey => $subitem) {
                      $msg .= ' ' . $subkey . ':' . $subitem . "\n";
                  }
              } else {
                  $msg .= $item . "\n";
              }
          }

          foreach ($deliver as $sendjid) {
              unset($vcard_request[$sendjid]);
              $conn->message($sendjid, $msg, 'chat');
          }
          break;
      }
        }
    }
} catch (XMPPHP\Exception $e) {
    die($e->getMessage());
}


code:
<?php

/**
 * @file: XMPPHP Cli example BOSH
 *
 * @info: If this script doesn't work, are you running 64-bit PHP with < 5.2.6?
 */

/**
 * Activate full error reporting
 * error_reporting(E_ALL & E_STRICT);
 *
 * XMPPHP Log levels:
 *
 * LEVEL_ERROR   = 0;
 * LEVEL_WARNING = 1;
 * LEVEL_INFO    = 2;
 * LEVEL_DEBUG   = 3;
 * LEVEL_VERBOSE = 4;
 */

require '../vendor/autoload.php';

$conf = array(
  'server'   => 'server.tld',
  'port'     => 5280,
  'username' => 'username',
  'password' => 'password',
  'proto'    => 'xmpphp',
  'domain'   => 'server.tld',
  'printlog' => true,
  'loglevel' => XMPPHP\Log::LEVEL_VERBOSE,
);

// Easy and simple for access to variables with their names
extract($conf);

$conn = new XMPPHP\BOSH($server, $port, $username, $password, $proto, $domain, $printlog, $loglevel);
$conn->autoSubscribe();

try {
    $conn->connect('http://server.tld:5280/xmpp-httpbind');

    while (!$conn->isDisconnected()) {
        $events   = array('message', 'presence', 'end_stream', 'session_start');
        $payloads = $conn->processUntil($events);

        foreach ($payloads as $result) {
            list($event, $data) = $result;

            if (isset($data)) {
                extract($data);
            }

            switch ($event) {

        case 'message':

          if (!$body) {
              break;
          }

          echo str_repeat('-', 80);
          echo "Message from: $from";

          if (isset($subject)) {
              echo "Subject: $subject";
          }

          echo $body;
          echo str_repeat('-', 80);

          $cmd  = explode(' ', $body);
          $body = "Mi no entender! '$body'";
          $conn->message($from, $body, $type);

          if (isset($cmd[0])) {
              if ($cmd[0] == 'quit') {
                  $conn->disconnect();
              }

              if ($cmd[0] == 'break') {
                  $conn->send('</end>');
              }
          }
          break;

        case 'presence':

          echo "Presence: $from [$show] $status\n";
          break;

        case 'session_start':

          echo "Session start\n";
          $conn->getRoster();
          $conn->presence('Quasar!');
          break;
      }
        }
    }
} catch (XMPPHP\Exception $e) {
    die($e->getMessage());
}


code:
<?php

/**
 * @file: XMPPHP Send message example
 *
 * @info: If this script doesn't work, are you running 64-bit PHP with < 5.2.6?
 */
/**
 * Activate full error reporting
 * error_reporting(E_ALL & E_STRICT);
 *
 * XMPPHP Log levels:
 *
 * LEVEL_ERROR   = 0;
 * LEVEL_WARNING = 1;
 * LEVEL_INFO    = 2;
 * LEVEL_DEBUG   = 3;
 * LEVEL_VERBOSE = 4;
 */

require_once __DIR__.'/../vendor/autoload.php';

$conf = array(
  'server'   => 'talk.google.com',
  'port'     => 5222,
  'username' => 'username',
  'password' => 'password',
  'proto'    => 'xmpphp',
  'domain'   => 'gmail.com',
  'printlog' => true,
  'loglevel' => XMPPHP\Log::LEVEL_VERBOSE,
);

// Easy and simple for access to variables with their names
extract($conf);

$XMPP = new XMPPHP\XMPP($server, $port, $username, $password, $proto, $domain, $printlog, $loglevel);

try {
    $XMPP->connect();
    $XMPP->processUntil('session_start', 10);
    $XMPP->presence();
    $XMPP->message('target.user@jabber.domain.com', 'Hello, how are you?', 'chat');
    $XMPP->disconnect();
} catch (XMPPHP\Exception $e) {
    die($e->getMessage());
}


code:
<?php

/**
 * @file: XMPPHP Cli example
 *
 * @info: If this script doesn't work, are you running 64-bit PHP with < 5.2.6?
 */

/**
 * Activate full error reporting
 * error_reporting(E_ALL & E_STRICT);
 *
 * XMPPHP Log levels:
 *
 * LEVEL_ERROR   = 0;
 * LEVEL_WARNING = 1;
 * LEVEL_INFO    = 2;
 * LEVEL_DEBUG   = 3;
 * LEVEL_VERBOSE = 4;
 */

session_start();
header('content-type', 'plain/text');

require '../vendor/autoload.php';

$conf = array(
  'server'   => 'talk.google.com',
  'port'     => 5222,
  'username' => 'username',
  'password' => 'password',
  'proto'    => 'xmpphp',
  'domain'   => 'gmail.com',
  'printlog' => true,
  'loglevel' => XMPPHP\Log::LEVEL_VERBOSE,
);

// Easy and simple for access to variables with their names
extract($conf);

$conn = new XMPPHP\XMPP($server, $port, $username, $password, $proto, $domain, $printlog, $loglevel);
$conn->autoSubscribe();

try {
    if (isset($_SESSION['messages'])) {
        foreach ($_SESSION['messages'] as $message) {
            echo $message;
            flush();
        }
    } else {
        $_SESSION['messages'] = array();
    }

    $conn->connect('http://server.tld:5280/xmpp-httpbind', 1, true);
    $events   = array('message', 'presence', 'end_stream', 'session_start', 'vcard');
    $payloads = $conn->processUntil($events);

    foreach ($payloads as $result) {
        list($event, $data) = $result;

        if (isset($data)) {
            extract($data);
        }

        switch ($event) {

      case 'message':

        if (!$body) {
            break;
        }

        $cmd  = explode(' ', $body);
        $msg  = str_repeat('-', 80);
        $msg .= "\nMessage from: $from\n";

        if (isset($subject)) {
            $msg .= "Subject: $subject\n";
        }

        $msg .= $body . "\n";
        $msg .= str_repeat('-', 80);
        echo "
$msg
";

        if (isset($cmd[0])) {
            if ($cmd[0] == 'quit') {
                $conn->disconnect();
            }

            if ($cmd[0] == 'break') {
                $conn->send('</end>');
            }
        }
        $_SESSION['messages'][] = $msg;
        flush();
        break;

      case 'presence':

        echo "Presence: $from [$show] $status\n";
        break;

      case 'session_start':

        echo "Session start\n";
        $conn->getRoster();
        $conn->presence('Quasar!');
        break;
    }
    }
} catch (XMPPHP\Exception $e) {
    die($e->getMessage());
}

$conn->saveSession();

echo '';


code:
<?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
 */

// Get current working directory with trailing slash
define('TESTS_DIR', dirname(__FILE__) . DIRECTORY_SEPARATOR);

// Get class directory with trailing slash
define('CLASS_DIR', dirname(TESTS_DIR) . DIRECTORY_SEPARATOR);

/** XMPPHP_LogTest */
require_once TESTS_DIR . 'XMPPHP' . DIRECTORY_SEPARATOR . 'LogTest.php';

/** XMPPHP_XMLObjTest */
require_once TESTS_DIR . 'XMPPHP' . DIRECTORY_SEPARATOR . 'XMLObjTest.php';

/** XMPPHP_XMPPTest */
require_once TESTS_DIR . 'XMPPHP' . DIRECTORY_SEPARATOR . 'XMPPTest.php';

if (!defined('PHPUnit_MAIN_METHOD')) {
    define('PHPUnit_MAIN_METHOD', 'AllTests::main');
}

/**
 * XMPPHP AllTests
 *
 * @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 AllTests
{
    public static function main()
    {
        PHPUnit_TextUI_TestRunner::run(self::suite());
    }

    public static function suite()
    {
        $suite = new PHPUnit_Framework_TestSuite();
        $suite->addTestSuite('XMPPHP_LogTest');
        $suite->addTestSuite('XMPPHP_XMLObjTest');
        $suite->addTestSuite('XMPPHP_XMPPTest');

        return $suite;
    }
}

if (PHPUnit_MAIN_METHOD == 'AllTests::main') {
    AllTests::main();
}


code:
<?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_Log */
require_once CLASS_DIR . 'XMPPHP' . DIRECTORY_SEPARATOR . 'Log.php';

/**
 * XMPPHP LogTest
 *
 * @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_LogTest extends PHPUnit_Framework_TestCase
{
    public function testPrintoutNoOutput()
    {
        $log = new XMPPHP_Log();
        $msg = 'I am a test log message';

        ob_start();
        $log->log('test');
        $result = ob_get_clean();

        $this->assertEquals('', $result);
    }

    public function testPrintoutOutput()
    {
        $log = new XMPPHP_Log(true);
        $msg = 'I am a test log message';

        ob_start();
        $log->log($msg);
        $result = ob_get_clean();

        $this->assertContains($msg, $result);
    }

    public function testPrintoutNoOutputWithDefaultLevel()
    {
        $log = new XMPPHP_Log(true, XMPPHP_Log::LEVEL_ERROR);
        $msg = 'I am a test log message';

        ob_start();
        $log->log($msg);
        $result = ob_get_clean();

        $this->assertSame('', $result);
    }

    public function testPrintoutOutputWithDefaultLevel()
    {
        $log = new XMPPHP_Log(true, XMPPHP_Log::LEVEL_INFO);
        $msg = 'I am a test log message';

        ob_start();
        $log->log($msg);
        $result = ob_get_clean();

        $this->assertContains($msg, $result);
    }

    public function testPrintoutNoOutputWithCustomLevel()
    {
        $log = new XMPPHP_Log(true, XMPPHP_Log::LEVEL_INFO);
        $msg = 'I am a test log message';

        ob_start();
        $log->log($msg, XMPPHP_Log::LEVEL_DEBUG);
        $result = ob_get_clean();

        $this->assertSame('', $result);
    }

    public function testPrintoutOutputWithCustomLevel()
    {
        $log = new XMPPHP_Log(true, XMPPHP_Log::LEVEL_INFO);
        $msg = 'I am a test log message';

        ob_start();
        $log->log($msg, XMPPHP_Log::LEVEL_INFO);
        $result = ob_get_clean();

        $this->assertContains($msg, $result);
    }

    public function testExplicitPrintout()
    {
        $log = new XMPPHP_Log(false);
        $msg = 'I am a test log message';

        ob_start();
        $log->log($msg);
        $result = ob_get_clean();

        $this->assertSame('', $result);
    }

    public function testExplicitPrintoutResult()
    {
        $log = new XMPPHP_Log(false);
        $msg = 'I am a test log message';

        ob_start();
        $log->log($msg);
        $result = ob_get_clean();

        $this->assertSame('', $result);

        ob_start();
        $log->printout();
        $result = ob_get_clean();

        $this->assertContains($msg, $result);
    }

    public function testExplicitPrintoutClear()
    {
        $log = new XMPPHP_Log(false);
        $msg = 'I am a test log message';

        ob_start();
        $log->log($msg);
        $result = ob_get_clean();

        $this->assertSame('', $result);

        ob_start();
        $log->printout();
        $result = ob_get_clean();

        $this->assertContains($msg, $result);

        ob_start();
        $log->printout();
        $result = ob_get_clean();

        $this->assertSame('', $result);
    }

    public function testExplicitPrintoutLevel()
    {
        $log = new XMPPHP_Log(false, XMPPHP_Log::LEVEL_ERROR);
        $msg = 'I am a test log message';

        ob_start();
        $log->log($msg);
        $result = ob_get_clean();

        $this->assertSame('', $result);

        ob_start();
        $log->printout(true, XMPPHP_Log::LEVEL_INFO);
        $result = ob_get_clean();

        $this->assertSame('', $result);
    }
}


code:
<?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_XMLObj */
require_once CLASS_DIR . 'XMPPHP' . DIRECTORY_SEPARATOR . 'XMLObj.php';

/**
 * XMPPHP XMLObjectTest
 *
 * @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_XMLObjTest extends PHPUnit_Framework_TestCase
{
    public function testToStringNameNamespace()
    {
        $xmlobj   = new XMPPHP_XMLObj('testname', 'testNameSpace');
        $expected = '<testname xmlns="testNameSpace"></testname>';
        $result   = $xmlobj->toString();
        $this->assertSame($expected, $result);
    }

    public function testToStringNameNamespaceAttr()
    {
        $xmlobj   = new XMPPHP_XMLObj('testName', 'testNameSpace', array('attr1' => 'valA', 'attr2' => 'valB'));
        $expected = '<testname xmlns="testNameSpace" attr1="valA" attr2="valB"></testname>';
        $result   = $xmlobj->toString();
        $this->assertSame($expected, $result);
    }

    public function testToStringNameNamespaceData()
    {
        $xmlobj   = new XMPPHP_XMLObj('testName', 'testNameSpace', array(), 'I am test data');
        $expected = '<testname xmlns="testNameSpace">I am test data</testname>';
        $result   = $xmlobj->toString();
        $this->assertSame($expected, $result);
    }

    public function testToStringNameNamespaceSub()
    {
        $xmlobj       = new XMPPHP_XMLObj('testName', 'testNameSpace');
        $sub1         = new XMPPHP_XMLObj('subName', 'subNameSpace');
        $xmlobj->subs = array($sub1);
        $expected     = '<testname xmlns="testNameSpace"><subname xmlns="subNameSpace"></subname></testname>';
        $result       = $xmlobj->toString();
        $this->assertSame($expected, $result);
    }
}


code:
<?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_XMPP */
require_once CLASS_DIR . 'XMPPHP' . DIRECTORY_SEPARATOR . 'XMPP.php';

/**
 * XMPPHP XMPPTest
 *
 * @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_XMPPTest extends PHPUnit_Framework_TestCase
{
    public function testConnectException()
    {
        try {
            $xmpp = new XMPPHP_XMPP('talk.google.com', 1234, 'invalidusername', 'invalidpassword', 'xmpphp', 'talk.google.com', false, XMPPHP_Log::LEVEL_VERBOSE);
            $xmpp->useEncryption(false);
            $xmpp->connect(10);
            $xmpp->processUntil('session_start');
            $xmpp->presence();
            $xmpp->message('stephan@jabber.wentz.it', 'This is a test message!');
            $xmpp->disconnect();
        } catch (XMPPHP_Exception $e) {
            return;
        } catch (Exception $e) {
            $this->fail('Unexpected Exception thrown: '.$e->getMessage());
        }

        $this->fail('Expected XMPPHP_Exception not thrown!');
    }

    public function testAuthException()
    {
        try {
            $xmpp = new XMPPHP_XMPP('jabber.wentz.it', 5222, 'invalidusername', 'invalidpassword', 'xmpphp', 'jabber.wentz.it', true, XMPPHP_Log::LEVEL_VERBOSE);
            $xmpp->useEncryption(false);
            $xmpp->connect(10);
            $xmpp->processUntil('session_start');
            $xmpp->presence();
            $xmpp->message('stephan@jabber.wentz.it', 'This is a test message!');
            $xmpp->disconnect();
        } catch (XMPPHP_Exception $e) {
            return;
        } catch (Exception $e) {
            $this->fail('Unexpected Exception thrown: '.$e->getMessage());
        }

        $this->fail('Expected XMPPHP_Exception not thrown!');
    }
}