Code Coverage
 
Classes and Traits
Functions and Methods
Lines
Total
0.00% covered (danger)
0.00%
0 / 1
0.00% covered (danger)
0.00%
0 / 22
CRAP
0.00% covered (danger)
0.00%
0 / 534
jabber
0.00% covered (danger)
0.00%
0 / 1
0.00% covered (danger)
0.00%
0 / 22
19740.00
0.00% covered (danger)
0.00%
0 / 530
 __construct
0.00% covered (danger)
0.00%
0 / 1
72.00
0.00% covered (danger)
0.00%
0 / 26
 can_use_ssl
0.00% covered (danger)
0.00%
0 / 1
2.00
0.00% covered (danger)
0.00%
0 / 3
 can_use_tls
0.00% covered (danger)
0.00%
0 / 1
42.00
0.00% covered (danger)
0.00%
0 / 7
 set_resource
0.00% covered (danger)
0.00%
0 / 1
2.00
0.00% covered (danger)
0.00%
0 / 3
 connect
0.00% covered (danger)
0.00%
0 / 1
6.00
0.00% covered (danger)
0.00%
0 / 15
 disconnect
0.00% covered (danger)
0.00%
0 / 1
20.00
0.00% covered (danger)
0.00%
0 / 18
 connected
0.00% covered (danger)
0.00%
0 / 1
12.00
0.00% covered (danger)
0.00%
0 / 3
 login
0.00% covered (danger)
0.00%
0 / 1
6.00
0.00% covered (danger)
0.00%
0 / 8
 send
0.00% covered (danger)
0.00%
0 / 1
6.00
0.00% covered (danger)
0.00%
0 / 12
 open_socket
0.00% covered (danger)
0.00%
0 / 1
42.00
0.00% covered (danger)
0.00%
0 / 29
 get_log
0.00% covered (danger)
0.00%
0 / 1
12.00
0.00% covered (danger)
0.00%
0 / 7
 add_to_log
0.00% covered (danger)
0.00%
0 / 1
6.00
0.00% covered (danger)
0.00%
0 / 6
 listen
0.00% covered (danger)
0.00%
0 / 1
90.00
0.00% covered (danger)
0.00%
0 / 23
 register
0.00% covered (danger)
0.00%
0 / 1
12.00
0.00% covered (danger)
0.00%
0 / 9
 send_presence
0.00% covered (danger)
0.00%
0 / 1
30.00
0.00% covered (danger)
0.00%
0 / 13
 response
0.00% covered (danger)
0.00%
0 / 1
2756.00
0.00% covered (danger)
0.00%
0 / 225
 send_message
0.00% covered (danger)
0.00%
0 / 1
12.00
0.00% covered (danger)
0.00%
0 / 15
 encrypt_password
0.00% covered (danger)
0.00%
0 / 1
20.00
0.00% covered (danger)
0.00%
0 / 20
 parse_data
0.00% covered (danger)
0.00%
0 / 1
30.00
0.00% covered (danger)
0.00%
0 / 20
 implode_data
0.00% covered (danger)
0.00%
0 / 1
6.00
0.00% covered (danger)
0.00%
0 / 8
 xmlize
0.00% covered (danger)
0.00%
0 / 1
20.00
0.00% covered (danger)
0.00%
0 / 22
 _xml_depth
0.00% covered (danger)
0.00%
0 / 1
182.00
0.00% covered (danger)
0.00%
0 / 38
<?php
/**
*
* This file is part of the phpBB Forum Software package.
*
* @copyright (c) phpBB Limited <https://www.phpbb.com>
* @license GNU General Public License, version 2 (GPL-2.0)
*
* For full copyright and license information, please see
* the docs/CREDITS.txt file.
*
*/
/**
* @ignore
*/
if (!defined('IN_PHPBB'))
{
    exit;
}
/**
*
* Jabber class from Flyspray project
*
* @version class.jabber2.php 1595 2008-09-19 (0.9.9)
* @copyright 2006 Flyspray.org
* @author Florian Schmitz (floele)
*
* Only slightly modified by Acyd Burn
*/
class jabber
{
    var $connection = null;
    var $session = array();
    var $timeout = 10;
    var $server;
    var $connect_server;
    var $port;
    var $username;
    var $password;
    var $use_ssl;
    var $verify_peer;
    var $verify_peer_name;
    var $allow_self_signed;
    var $resource = 'functions_jabber.phpbb.php';
    var $enable_logging;
    var $log_array;
    var $features = array();
    /** @var string Stream close handshake */
    private const STREAM_CLOSE_HANDSHAKE = '</stream:stream>';
    /**
    * Constructor
    *
    * @param string $server Jabber server
    * @param int $port Jabber server port
    * @param string $username Jabber username or JID
    * @param string $password Jabber password
    * @param bool $use_ssl Use ssl
    * @param bool $verify_peer Verify SSL certificate
    * @param bool $verify_peer_name Verify Jabber peer name
    * @param bool $allow_self_signed Allow self signed certificates
    */
    function __construct($server, $port, $username, $password, $use_ssl = false, $verify_peer = true, $verify_peer_name = true, $allow_self_signed = false)
    {
        $this->connect_server        = ($server) ? $server : 'localhost';
        $this->port                    = ($port) ? $port : 5222;
        // Get the server and the username
        if (strpos($username, '@') === false)
        {
            $this->server = $this->connect_server;
            $this->username = $username;
        }
        else
        {
            $jid = explode('@', $username, 2);
            $this->username = $jid[0];
            $this->server = $jid[1];
        }
        $this->password                = $password;
        $this->use_ssl                = ($use_ssl && self::can_use_ssl()) ? true : false;
        $this->verify_peer            = $verify_peer;
        $this->verify_peer_name        = $verify_peer_name;
        $this->allow_self_signed    = $allow_self_signed;
        // Change port if we use SSL
        if ($this->port == 5222 && $this->use_ssl)
        {
            $this->port = 5223;
        }
        $this->enable_logging        = true;
        $this->log_array            = array();
    }
    /**
    * Able to use the SSL functionality?
    */
    static public function can_use_ssl()
    {
        return @extension_loaded('openssl');
    }
    /**
    * Able to use TLS?
    */
    static public function can_use_tls()
    {
        if (!@extension_loaded('openssl') || !function_exists('stream_socket_enable_crypto') || !function_exists('stream_get_meta_data') || !function_exists('stream_set_blocking') || !function_exists('stream_get_wrappers'))
        {
            return false;
        }
        /**
        * Make sure the encryption stream is supported
        * Also seem to work without the crypto stream if correctly compiled
        $streams = stream_get_wrappers();
        if (!in_array('streams.crypto', $streams))
        {
            return false;
        }
        */
        return true;
    }
    /**
    * Sets the resource which is used. No validation is done here, only escaping.
    * @param string $name
    * @access public
    */
    function set_resource($name)
    {
        $this->resource = $name;
    }
    /**
    * Connect
    */
    function connect()
    {
/*        if (!$this->check_jid($this->username . '@' . $this->server))
        {
            $this->add_to_log('Error: Jabber ID is not valid: ' . $this->username . '@' . $this->server);
            return false;
        }*/
        $this->session['ssl'] = $this->use_ssl;
        if ($this->open_socket($this->connect_server, $this->port, $this->use_ssl, $this->verify_peer, $this->verify_peer_name, $this->allow_self_signed))
        {
            $this->send("<?xml version='1.0' encoding='UTF-8' ?" . ">\n");
            $this->send("<stream:stream to='{$this->server}' xmlns='jabber:client' xmlns:stream='http://etherx.jabber.org/streams' version='1.0'>\n");
        }
        else
        {
            $this->add_to_log('Error: connect() #2');
            return false;
        }
        // Now we listen what the server has to say...and give appropriate responses
        $this->response($this->listen());
        return true;
    }
    /**
    * Disconnect
    */
    function disconnect()
    {
        if ($this->connected())
        {
            // disconnect gracefully
            if (isset($this->session['sent_presence']))
            {
                $this->send_presence('offline', '', true);
            }
            $this->send(self::STREAM_CLOSE_HANDSHAKE);
            // Check stream close handshake reply
            $stream_close_reply = $this->listen();
            if ($stream_close_reply != self::STREAM_CLOSE_HANDSHAKE)
            {
                $this->add_to_log("Error: Unexpected stream close handshake reply ”{$stream_close_reply}");
            }
            $this->session = array();
            return fclose($this->connection);
        }
        return false;
    }
    /**
    * Connected?
    */
    function connected()
    {
        return (is_resource($this->connection) && !feof($this->connection)) ? true : false;
    }
    /**
    * Initiates login (using data from contructor, after calling connect())
    * @access public
    * @return bool
    */
    function login()
    {
        if (empty($this->features))
        {
            $this->add_to_log('Error: No feature information from server available.');
            return false;
        }
        return $this->response($this->features);
    }
    /**
    * Send data to the Jabber server
    * @param string $xml
    * @access public
    * @return bool
    */
    function send($xml)
    {
        if ($this->connected())
        {
            $xml = trim($xml);
            return fwrite($this->connection, $xml);
        }
        else
        {
            $this->add_to_log('Error: Could not send, connection lost (flood?).');
            return false;
        }
    }
    /**
    * OpenSocket
    * @param string $server host to connect to
    * @param int $port port number
    * @param bool $use_ssl use ssl or not
    * @param bool $verify_peer verify ssl certificate
    * @param bool $verify_peer_name verify peer name
    * @param bool $allow_self_signed allow self-signed ssl certificates
    * @access public
    * @return bool
    */
    function open_socket($server, $port, $use_ssl, $verify_peer, $verify_peer_name, $allow_self_signed)
    {
        if (@function_exists('dns_get_record'))
        {
            $record = @dns_get_record("_xmpp-client._tcp.$server", DNS_SRV);
            if (!empty($record) && !empty($record[0]['target']))
            {
                $server = $record[0]['target'];
            }
        }
        $options = array();
        if ($use_ssl)
        {
            $remote_socket = 'ssl://' . $server . ':' . $port;
            // Set ssl context options, see http://php.net/manual/en/context.ssl.php
            $options['ssl'] = array('verify_peer' => $verify_peer, 'verify_peer_name' => $verify_peer_name, 'allow_self_signed' => $allow_self_signed);
        }
        else
        {
            $remote_socket = $server . ':' . $port;
        }
        $socket_context = stream_context_create($options);
        if ($this->connection = @stream_socket_client($remote_socket, $errorno, $errorstr, $this->timeout, STREAM_CLIENT_CONNECT, $socket_context))
        {
            stream_set_blocking($this->connection, 0);
            stream_set_timeout($this->connection, 60);
            return true;
        }
        // Apparently an error occurred...
        $this->add_to_log('Error: open_socket() - ' . $errorstr);
        return false;
    }
    /**
    * Return log
    */
    function get_log()
    {
        if ($this->enable_logging && count($this->log_array))
        {
            return implode("<br /><br />", $this->log_array);
        }
        return '';
    }
    /**
    * Add information to log
    */
    function add_to_log($string)
    {
        if ($this->enable_logging)
        {
            $this->log_array[] = utf8_htmlspecialchars($string);
        }
    }
    /**
    * Listens to the connection until it gets data or the timeout is reached.
    * Thus, it should only be called if data is expected to be received.
    * @access public
    * @return mixed either false for timeout or an array with the received data
    */
    function listen($timeout = 10, $wait = false)
    {
        if (!$this->connected())
        {
            return false;
        }
        // Wait for a response until timeout is reached
        $start = time();
        $data = '';
        do
        {
            $read = trim(fread($this->connection, 4096));
            $data .= $read;
        }
        while (time() <= $start + $timeout && !feof($this->connection) && ($wait || $data == '' || $read != '' || (substr(rtrim($data), -1) != '>')));
        if ($data != '')
        {
            return $this->xmlize($data);
        }
        else
        {
            $this->add_to_log('Timeout, no response from server.');
            return false;
        }
    }
    /**
    * Initiates account registration (based on data used for contructor)
    * @access public
    * @return bool
    */
    function register()
    {
        if (!isset($this->session['id']) || isset($this->session['jid']))
        {
            $this->add_to_log('Error: Cannot initiate registration.');
            return false;
        }
        $this->send("<iq type='get' id='reg_1'><query xmlns='jabber:iq:register'/></iq>");
        return $this->response($this->listen());
    }
    /**
    * Sets account presence. No additional info required (default is "online" status)
    * @param $message online, offline...
    * @param $type dnd, away, chat, xa or nothing
    * @param $unavailable set this to true if you want to become unavailable
    * @access public
    * @return bool
    */
    function send_presence($message = '', $type = '', $unavailable = false)
    {
        if (!isset($this->session['jid']))
        {
            $this->add_to_log('ERROR: send_presence() - Cannot set presence at this point, no jid given.');
            return false;
        }
        $type = strtolower($type);
        $type = (in_array($type, array('dnd', 'away', 'chat', 'xa'))) ? '<show>'. $type .'</show>' : '';
        $unavailable = ($unavailable) ? " type='unavailable'" : '';
        $message = ($message) ? '<status>' . utf8_htmlspecialchars($message) .'</status>' : '';
        $this->session['sent_presence'] = !$unavailable;
        return $this->send("<presence$unavailable>" . $type . $message . '</presence>');
    }
    /**
    * This handles all the different XML elements
    * @param array $xml
    * @access public
    * @return bool
    */
    function response($xml)
    {
        if (!is_array($xml) || !count($xml))
        {
            return false;
        }
        // did we get multiple elements? do one after another
        // array('message' => ..., 'presence' => ...)
        if (count($xml) > 1)
        {
            foreach ($xml as $key => $value)
            {
                $this->response(array($key => $value));
            }
            return;
        }
        else
        {
            // or even multiple elements of the same type?
            // array('message' => array(0 => ..., 1 => ...))
            if (is_array(reset($xml)) && count(reset($xml)) > 1)
            {
                foreach (reset($xml) as $value)
                {
                    $this->response(array(key($xml) => array(0 => $value)));
                }
                return;
            }
        }
        switch (key($xml))
        {
            case 'stream:stream':
                // Connection initialised (or after authentication). Not much to do here...
                if (isset($xml['stream:stream'][0]['#']['stream:features']))
                {
                    // we already got all info we need
                    $this->features = $xml['stream:stream'][0]['#'];
                }
                else
                {
                    $this->features = $this->listen();
                }
                $second_time = isset($this->session['id']);
                $this->session['id'] = isset($xml['stream:stream'][0]['@']['id']) ? $xml['stream:stream'][0]['@']['id'] : '';
                if ($second_time)
                {
                    // If we are here for the second time after TLS, we need to continue logging in
                    return $this->login();
                }
                // go on with authentication?
                if (isset($this->features['stream:features'][0]['#']['bind']) || !empty($this->session['tls']))
                {
                    return $this->response($this->features);
                }
            break;
            case 'stream:features':
                // Resource binding after successful authentication
                if (isset($this->session['authenticated']))
                {
                    // session required?
                    $this->session['sess_required'] = isset($xml['stream:features'][0]['#']['session']);
                    $this->send("<iq type='set' id='bind_1'>
                        <bind xmlns='urn:ietf:params:xml:ns:xmpp-bind'>
                            <resource>" . utf8_htmlspecialchars($this->resource) . '</resource>
                        </bind>
                    </iq>');
                    return $this->response($this->listen());
                }
                // Let's use TLS if SSL is not enabled and we can actually use it
                if (!$this->session['ssl'] && self::can_use_tls() && self::can_use_ssl() && isset($xml['stream:features'][0]['#']['starttls']))
                {
                    $this->add_to_log('Switching to TLS.');
                    $this->send("<starttls xmlns='urn:ietf:params:xml:ns:xmpp-tls'/>\n");
                    return $this->response($this->listen());
                }
                // Does the server support SASL authentication?
                // I hope so, because we do (and no other method).
                if (isset($xml['stream:features'][0]['#']['mechanisms'][0]['@']['xmlns']) && $xml['stream:features'][0]['#']['mechanisms'][0]['@']['xmlns'] == 'urn:ietf:params:xml:ns:xmpp-sasl')
                {
                    // Now decide on method
                    $methods = array();
                    foreach ($xml['stream:features'][0]['#']['mechanisms'][0]['#']['mechanism'] as $value)
                    {
                        $methods[] = $value['#'];
                    }
                    // we prefer DIGEST-MD5
                    // we don't want to use plain authentication (neither does the server usually) if no encryption is in place
                    // http://www.xmpp.org/extensions/attic/jep-0078-1.7.html
                    // The plaintext mechanism SHOULD NOT be used unless the underlying stream is encrypted (using SSL or TLS)
                    // and the client has verified that the server certificate is signed by a trusted certificate authority.
                    if (in_array('DIGEST-MD5', $methods))
                    {
                        $this->send("<auth xmlns='urn:ietf:params:xml:ns:xmpp-sasl' mechanism='DIGEST-MD5'/>");
                    }
                    else if (in_array('PLAIN', $methods) && ($this->session['ssl'] || !empty($this->session['tls'])))
                    {
                        // http://www.ietf.org/rfc/rfc4616.txt (PLAIN SASL Mechanism)
                        $this->send("<auth xmlns='urn:ietf:params:xml:ns:xmpp-sasl' mechanism='PLAIN'>"
                            . base64_encode($this->username . '@' . $this->server . chr(0) . $this->username . chr(0) . $this->password) .
                            '</auth>');
                    }
                    else if (in_array('ANONYMOUS', $methods))
                    {
                        $this->send("<auth xmlns='urn:ietf:params:xml:ns:xmpp-sasl' mechanism='ANONYMOUS'/>");
                    }
                    else
                    {
                        // not good...
                        $this->add_to_log('Error: No authentication method supported.');
                        $this->disconnect();
                        return false;
                    }
                    return $this->response($this->listen());
                }
                else
                {
                    // ok, this is it. bye.
                    $this->add_to_log('Error: Server does not offer SASL authentication.');
                    $this->disconnect();
                    return false;
                }
            break;
            case 'challenge':
                // continue with authentication...a challenge literally -_-
                $decoded = base64_decode($xml['challenge'][0]['#']);
                $decoded = $this->parse_data($decoded);
                if (!isset($decoded['digest-uri']))
                {
                    $decoded['digest-uri'] = 'xmpp/'. $this->server;
                }
                // better generate a cnonce, maybe it's needed
                $decoded['cnonce'] = base64_encode(md5(uniqid(mt_rand(), true)));
                // second challenge?
                if (isset($decoded['rspauth']))
                {
                    $this->send("<response xmlns='urn:ietf:params:xml:ns:xmpp-sasl'/>");
                }
                else
                {
                    // Make sure we only use 'auth' for qop (relevant for $this->encrypt_password())
                    // If the <response> is choking up on the changed parameter we may need to adjust encrypt_password() directly
                    if (isset($decoded['qop']) && $decoded['qop'] != 'auth' && strpos($decoded['qop'], 'auth') !== false)
                    {
                        $decoded['qop'] = 'auth';
                    }
                    $response = array(
                        'username'    => $this->username,
                        'response'    => $this->encrypt_password(array_merge($decoded, array('nc' => '00000001'))),
                        'charset'    => 'utf-8',
                        'nc'        => '00000001',
                        'qop'        => 'auth',            // only auth being supported
                    );
                    foreach (array('nonce', 'digest-uri', 'realm', 'cnonce') as $key)
                    {
                        if (isset($decoded[$key]))
                        {
                            $response[$key] = $decoded[$key];
                        }
                    }
                    $this->send("<response xmlns='urn:ietf:params:xml:ns:xmpp-sasl'>" . base64_encode($this->implode_data($response)) . '</response>');
                }
                return $this->response($this->listen());
            break;
            case 'failure':
                $this->add_to_log('Error: Server sent "failure".');
                $this->disconnect();
                return false;
            break;
            case 'proceed':
                // continue switching to TLS
                $meta = stream_get_meta_data($this->connection);
                stream_set_blocking($this->connection, 1);
                if (!stream_socket_enable_crypto($this->connection, true, STREAM_CRYPTO_METHOD_TLS_CLIENT))
                {
                    $this->add_to_log('Error: TLS mode change failed.');
                    return false;
                }
                stream_set_blocking($this->connection, $meta['blocked']);
                $this->session['tls'] = true;
                // new stream
                $this->send("<?xml version='1.0' encoding='UTF-8' ?" . ">\n");
                $this->send("<stream:stream to='{$this->server}' xmlns='jabber:client' xmlns:stream='http://etherx.jabber.org/streams' version='1.0'>\n");
                return $this->response($this->listen());
            break;
            case 'success':
                // Yay, authentication successful.
                $this->send("<stream:stream to='{$this->server}' xmlns='jabber:client' xmlns:stream='http://etherx.jabber.org/streams' version='1.0'>\n");
                $this->session['authenticated'] = true;
                // we have to wait for another response
                return $this->response($this->listen());
            break;
            case 'iq':
                // we are not interested in IQs we did not expect
                if (!isset($xml['iq'][0]['@']['id']))
                {
                    return false;
                }
                // multiple possibilities here
                switch ($xml['iq'][0]['@']['id'])
                {
                    case 'bind_1':
                        $this->session['jid'] = $xml['iq'][0]['#']['bind'][0]['#']['jid'][0]['#'];
                        // and (maybe) yet another request to be able to send messages *finally*
                        if ($this->session['sess_required'])
                        {
                            $this->send("<iq to='{$this->server}' type='set' id='sess_1'>
                                <session xmlns='urn:ietf:params:xml:ns:xmpp-session'/>
                                </iq>");
                            return $this->response($this->listen());
                        }
                        return true;
                    break;
                    case 'sess_1':
                        return true;
                    break;
                    case 'reg_1':
                        $this->send("<iq type='set' id='reg_2'>
                                <query xmlns='jabber:iq:register'>
                                    <username>" . utf8_htmlspecialchars($this->username) . "</username>
                                    <password>" . utf8_htmlspecialchars($this->password) . "</password>
                                </query>
                            </iq>");
                        return $this->response($this->listen());
                    break;
                    case 'reg_2':
                        // registration end
                        if (isset($xml['iq'][0]['#']['error']))
                        {
                            $this->add_to_log('Warning: Registration failed.');
                            return false;
                        }
                        return true;
                    break;
                    case 'unreg_1':
                        return true;
                    break;
                    default:
                        $this->add_to_log('Notice: Received unexpected IQ.');
                        return false;
                    break;
                }
            break;
            case 'message':
                // we are only interested in content...
                if (!isset($xml['message'][0]['#']['body']))
                {
                    return false;
                }
                $message['body'] = $xml['message'][0]['#']['body'][0]['#'];
                $message['from'] = $xml['message'][0]['@']['from'];
                if (isset($xml['message'][0]['#']['subject']))
                {
                    $message['subject'] = $xml['message'][0]['#']['subject'][0]['#'];
                }
                $this->session['messages'][] = $message;
            break;
            default:
                // hm...don't know this response
                $this->add_to_log('Notice: Unknown server response');
                return false;
            break;
        }
    }
    function send_message($to, $text, $subject = '', $type = 'normal')
    {
        if (!isset($this->session['jid']))
        {
            return false;
        }
        if (!in_array($type, array('chat', 'normal', 'error', 'groupchat', 'headline')))
        {
            $type = 'normal';
        }
        return $this->send("<message from='" . utf8_htmlspecialchars($this->session['jid']) . "' to='" . utf8_htmlspecialchars($to) . "' type='$type' id='" . uniqid('msg') . "'>
            <subject>" . utf8_htmlspecialchars($subject) . "</subject>
            <body>" . utf8_htmlspecialchars($text) . "</body>
            </message>"
        );
    }
    /**
    * Encrypts a password as in RFC 2831
    * @param array $data Needs data from the client-server connection
    * @access public
    * @return string
    */
    function encrypt_password($data)
    {
        // let's me think about <challenge> again...
        foreach (array('realm', 'cnonce', 'digest-uri') as $key)
        {
            if (!isset($data[$key]))
            {
                $data[$key] = '';
            }
        }
        $pack = md5($this->username . ':' . $data['realm'] . ':' . $this->password);
        if (isset($data['authzid']))
        {
            $a1 = pack('H32', $pack)  . sprintf(':%s:%s:%s', $data['nonce'], $data['cnonce'], $data['authzid']);
        }
        else
        {
            $a1 = pack('H32', $pack)  . sprintf(':%s:%s', $data['nonce'], $data['cnonce']);
        }
        // should be: qop = auth
        $a2 = 'AUTHENTICATE:'. $data['digest-uri'];
        return md5(sprintf('%s:%s:%s:%s:%s:%s', md5($a1), $data['nonce'], $data['nc'], $data['cnonce'], $data['qop'], md5($a2)));
    }
    /**
    * parse_data like a="b",c="d",... or like a="a, b", c, d="e", f=g,...
    * @param string $data
    * @access public
    * @return array a => b ...
    */
    function parse_data($data)
    {
        $data = explode(',', $data);
        $pairs = array();
        $key = false;
        foreach ($data as $pair)
        {
            $dd = strpos($pair, '=');
            if ($dd)
            {
                $key = trim(substr($pair, 0, $dd));
                $pairs[$key] = trim(trim(substr($pair, $dd + 1)), '"');
            }
            else if (strpos(strrev(trim($pair)), '"') === 0 && $key)
            {
                // We are actually having something left from "a, b" values, add it to the last one we handled.
                $pairs[$key] .= ',' . trim(trim($pair), '"');
                continue;
            }
        }
        return $pairs;
    }
    /**
    * opposite of jabber::parse_data()
    * @param array $data
    * @access public
    * @return string
    */
    function implode_data($data)
    {
        $return = array();
        foreach ($data as $key => $value)
        {
            $return[] = $key . '="' . $value . '"';
        }
        return implode(',', $return);
    }
    /**
    * xmlize()
    * @author Hans Anderson
    * @copyright Hans Anderson / http://www.hansanderson.com/php/xml/
    */
    function xmlize($data, $skip_white = 1, $encoding = 'UTF-8')
    {
        $data = trim($data);
        if (substr($data, 0, 5) != '<?xml')
        {
            // mod
            $data = '<root>'. $data . '</root>';
        }
        $vals = $index = $array = array();
        $parser = xml_parser_create($encoding);
        xml_parser_set_option($parser, XML_OPTION_CASE_FOLDING, 0);
        xml_parser_set_option($parser, XML_OPTION_SKIP_WHITE, $skip_white);
        xml_parse_into_struct($parser, $data, $vals, $index);
        xml_parser_free($parser);
        $i = 0;
        $tagname = $vals[$i]['tag'];
        $array[$tagname][0]['@'] = (isset($vals[$i]['attributes'])) ? $vals[$i]['attributes'] : array();
        $array[$tagname][0]['#'] = $this->_xml_depth($vals, $i);
        if (substr($data, 0, 5) != '<?xml')
        {
            $array = $array['root'][0]['#'];
        }
        return $array;
    }
    /**
    * _xml_depth()
    * @author Hans Anderson
    * @copyright Hans Anderson / http://www.hansanderson.com/php/xml/
    */
    function _xml_depth($vals, &$i)
    {
        $children = array();
        if (isset($vals[$i]['value']))
        {
            array_push($children, $vals[$i]['value']);
        }
        while (++$i < count($vals))
        {
            switch ($vals[$i]['type'])
            {
                case 'open':
                    $tagname = (isset($vals[$i]['tag'])) ? $vals[$i]['tag'] : '';
                    $size = (isset($children[$tagname])) ? count($children[$tagname]) : 0;
                    if (isset($vals[$i]['attributes']))
                    {
                        $children[$tagname][$size]['@'] = $vals[$i]['attributes'];
                    }
                    $children[$tagname][$size]['#'] = $this->_xml_depth($vals, $i);
                break;
                case 'cdata':
                    array_push($children, $vals[$i]['value']);
                break;
                case 'complete':
                    $tagname = $vals[$i]['tag'];
                    $size = (isset($children[$tagname])) ? count($children[$tagname]) : 0;
                    $children[$tagname][$size]['#'] = (isset($vals[$i]['value'])) ? $vals[$i]['value'] : array();
                    if (isset($vals[$i]['attributes']))
                    {
                        $children[$tagname][$size]['@'] = $vals[$i]['attributes'];
                    }
                break;
                case 'close':
                    return $children;
                break;
            }
        }
        return $children;
    }
}