- <dt><label for="jab_resource">{L_JAB_RESOURCE}:</label><br /><span>{L_JAB_RESOURCE_EXPLAIN}</span></dt>

- <dd><input type="text" id="jab_resource" name="jab_resource" value="{JAB_RESOURCE}" /></dd>

- <td><a href="{attach.U_DOWNLOAD}">{attach.REAL_FILENAME}</a><br /><span class="small"><!-- IF attach.S_IN_MESSAGE --><strong>{L_PM}: </strong><!-- ELSE --><strong>{L_TOPIC}: </strong><!-- ENDIF --><a href="{attach.U_VIEW_TOPIC}">{attach.TOPIC_TITLE}</a></span></td>

- color: #aaa;

-Jabber Class (c) 2004 Nathan Fritz, http://cjphp.netflint.net

- $jab_resource = request_var('jab_resource', $config['jab_resource']);

- $jabber = new jabber($jab_host, $jab_port, $jab_username, $jab_password, $jab_resource);

- $error = array();

-

- $message = $user->lang['JAB_SETTINGS_CHANGED'];

- $log = 'JAB_SETTINGS_CHANGED';

-

- // Are changing (or initialising) a new host or username? If so run some checks and

- // try to create account if it doesn't exist

- if ($jab_enable)

- if (($jab_host != $config['jab_host'] || $jab_username != $config['jab_username']) && $jab_username)

- {

- if (!$jabber->connect())

- {

- trigger_error($user->lang['ERR_JAB_CONNECT'] . $jabber->get_log() . adm_back_link($this->u_action), E_USER_WARNING);

- }

- // First we'll try to authorise using this account, if that fails we'll try to create it.

- if (!($result = $jabber->send_auth()))

- {

- if (($result = $jabber->account_registration($config['board_email'], $config['sitename'])) <> 2)

- {

- $error[] = ($result == 1) ? $user->lang['ERR_JAB_USERNAME'] : sprintf($user->lang['ERR_JAB_REGISTER'], $result);

- }

- else

- {

- $message = $user->lang['JAB_REGISTERED'];

- $log = 'JAB_REGISTER';

- }

- }

- else

- {

- $message = $user->lang['JAB_CHANGED'];

- $log = 'JAB_CHANGED';

- }

- sleep(1);

- $jabber->disconnect();

- }

- else if ($jab_password != $config['jab_password'])

- if (!$jabber->send_auth())

- $jabber->send_presence(NULL, NULL, 'online');

- if (($result = $jabber->change_password($jab_password)) <> 2)

- {

- $error[] = ($result == 1) ? $user->lang['ERR_JAB_PASSCHG'] : sprintf($user->lang['ERR_JAB_PASSFAIL'], $result);

- }

- else

- {

- $message = $user->lang['JAB_PASS_CHANGED'];

- $log = 'JAB_PASSCHG';

- }

-

- sleep(1);

- }

- // Pull relevant config data

- $sql = 'SELECT *

- FROM ' . CONFIG_TABLE . "

- WHERE config_name LIKE 'jab_%'";

- $result = $db->sql_query($sql);

- while ($row = $db->sql_fetchrow($result))

- {

- $config_name = $row['config_name'];

- $config_value = $row['config_value'];

-

- $default_config[$config_name] = $config_value;

- $new[$config_name] = (isset($_POST[$config_name])) ? request_var($config_name, '') : $default_config[$config_name];

-

- if ($submit && !sizeof($error))

- {

- set_config($config_name, $new[$config_name]);

- }

- }

-

- if ($submit && !sizeof($error))

- {

- if (sizeof($error))

- {

- $template->assign_vars(array(

- 'S_WARNING' => true,

- 'WARNING_MSG' => implode('<br />', $error))

- );

- }

-

- 'JAB_ENABLE' => $new['jab_enable'],

- 'JAB_HOST' => $new['jab_host'],

- 'JAB_PORT' => $new['jab_port'],

- 'JAB_USERNAME' => $new['jab_username'],

- 'JAB_PASSWORD' => $new['jab_password'],

- 'JAB_RESOURCE' => $new['jab_resource'],

- 'JAB_PACKAGE_SIZE' => $new['jab_package_size'])

- );

- $cp_data[$right_delim . $key . $left_delim] = $value;

- $view_topic = append_sid("{$phpbb_root_path}viewtopic.$phpEx", "t={$row['topic_id']}&amp;p={$row['post_msg_id']}#{$row['post_msg_id']}");

-* Class.Jabber.PHP v0.4.2

-* (c) 2004 Nathan "Fritzy" Fritz

-* http://cjphp.netflint.net *** fritzy@netflint.net

-* This is a bugfix version, specifically for those who can't get

-* 0.4 to work on Jabberd2 servers.

-*

-* last modified: 24.03.2004 13:01:53

-*

-* Modified by phpBB Development Team

-* version: v0.4.3

- var $resource;

- var $jid;

-

- var $connection;

- var $delay_disconnect;

-

- var $stream_id;

- var $iq_sleep_timer;

- var $last_ping_time;

-

- var $packet_queue;

-

- var $iq_version_name;

- var $iq_version_os;

- var $iq_version_version;

-

- var $error_codes;

-

- var $connected;

- var $keep_alive_id;

- var $returned_keep_alive;

- var $txnid;

-

- var $connector;

- var $version;

- var $show_version;

-

- /**

- * Constructor

- */

- function jabber($server, $port, $username, $password, $resource)

- $this->port = ($port) ? $port : '5222';

- $this->resource = ($resource) ? $resource : NULL;

-

- $this->enable_logging = true;

- $this->log_array = array();

- $this->version = '1.0';

- $this->show_version = false;

-

- $this->packet_queue = array();

- $this->iq_sleep_timer = $this->delay_disconnect = 1;

-

- $this->returned_keep_alive = true;

- $this->txnid = 0;

-

- $this->iq_version_name = "Class.Jabber.PHP -- http://cjphp.netflint.net -- by Nathan 'Fritzy' Fritz, fritz@netflint.net";

- $this->iq_version_version = '0.4';

- $this->iq_version_os = $_SERVER['SERVER_SOFTWARE'];

-

- $this->error_codes = array(

- 400 => 'Bad Request',

- 401 => 'Unauthorised',

- 402 => 'Payment Required',

- 403 => 'Forbidden',

- 404 => 'Not Found',

- 405 => 'Not Allowed',

- 406 => 'Not Acceptable',

- 407 => 'Registration Required',

- 408 => 'Request Timeout',

- 409 => 'Conflict',

- 500 => 'Internal Server Error',

- 501 => 'Not Implemented',

- 502 => 'Remove Server Error',

- 503 => 'Service Unavailable',

- 504 => 'Remove Server Timeout',

- 510 => 'Disconnected'

- );

- }

-

- /**

- * Connect

- */

- function connect()

- {

- $this->connector = new cjp_standard_connector;

-

- if ($this->connector->open_socket($this->server, $this->port))

- $this->send_packet("<?xml version='1.0' encoding='UTF-8' ?" . ">\n");

- $this->send_packet("<stream:stream to='{$this->server}' xmlns='jabber:client' xmlns:stream='http://etherx.jabber.org/streams'" . (($this->show_version) ? " version='{$this->version}'" : '') . ">\n");

-

- sleep(2);

-

- if ($this->_check_connected())

- {

- $this->connected = true; // Nathan Fritz

- return true;

- }

- else

- {

- $this->add_to_log('ERROR: connect() #1');

- return false;

- }

- else

- {

- $this->add_to_log('ERROR: connect() #2');

- return false;

- }

- }

-

- /**

- * Disconnect

- */

- function disconnect()

- {

- if (is_int($this->delay_disconnect))

- {

- sleep($this->delay_disconnect);

- }

-

- $this->send_packet('</stream:stream>');

- $this->connector->close_socket();

- }

-

- /**

- * Send authentication request

- */

- function send_auth()

- {

- $this->auth_id = 'auth_' . md5(time() . $_SERVER['REMOTE_ADDR']);

- $this->resource = ($this->resource != NULL) ? $this->resource : ('Class.Jabber.PHP ' . md5($this->auth_id));

- $this->jid = "{$this->username}@{$this->server}/{$this->resource}";

-

- // request available authentication methods

- $payload = "<username>{$this->username}</username>";

- $packet = $this->send_iq(NULL, 'get', $this->auth_id, 'jabber:iq:auth', $payload);

-

- // was a result returned?

- if ($this->get_info_from_iq_type($packet) == 'result' && $this->get_info_from_iq_id($packet) == $this->auth_id)

- {

- // yes, now check for auth method availability in descending order (best to worst)

- if (isset($packet['iq']['#']['query'][0]['#']['sequence'][0]['#']) && isset($packet['iq']['#']['query'][0]['#']['token'][0]['#']))

- {

- // auth_0k

- return $this->_sendauth_ok($packet['iq']['#']['query'][0]['#']['token'][0]['#'], $packet['iq']['#']['query'][0]['#']['sequence'][0]['#']);

- }

- else if (isset($packet['iq']['#']['query'][0]['#']['digest']))

- {

- // digest

- return $this->_sendauth_digest();

- }

- else if ($packet['iq']['#']['query'][0]['#']['password'])

- {

- // plain text

- return $this->_sendauth_plaintext();

- }

- else

- {

- $this->add_to_log('ERROR: send_auth() #2 - No auth method available!');

- return false;

- }

- }

- else

- {

- // no result returned

- $this->add_to_log('ERROR: send_auth() #1');

- return false;

- }

- }

-

- /**

- * Register account

- */

- function account_registration($reg_email = NULL, $reg_name = NULL)

- {

- $packet = $this->send_iq($this->server, 'get', 'reg_01', 'jabber:iq:register');

-

- if ($packet)

- {

- // just in case a key was passed back from the server

- $key = $this->get_info_from_iq_key($packet);

- unset($packet);

-

- $payload = "<username>{$this->username}</username>

- <password>{$this->password}</password>

- <email>$reg_email</email>

- <name>$reg_name</name>\n";

-

- $payload .= ($key) ? "<key>$key</key>\n" : '';

- $packet = $this->send_iq($this->server, 'set', 'reg_01', 'jabber:iq:register', $payload);

-

- if ($this->get_info_from_iq_type($packet) == 'result')

- {

- $return_code = (isset($packet['iq']['#']['query'][0]['#']['registered'][0]['#'])) ? 1 : 2;

- $this->jid = ($this->resource) ? "{$this->username}@{$this->server}/{$this->resource}" : "{$this->username}@{$this->server}";

- }

- else if ($this->get_info_from_iq_type($packet) == 'error' && isset($packet['iq']['#']['error'][0]['#']))

- {

- // "conflict" error, i.e. already registered

- if ($packet['iq']['#']['error'][0]['@']['code'] == '409')

- {

- $return_code = 1;

- }

- else

- {

- $return_code = 'Error ' . $packet['iq']['#']['error'][0]['@']['code'] . ': ' . $packet['iq']['#']['error'][0]['#'];

- }

- }

-

- return $return_code;

- }

- else

- {

- return 3;

- }

- * Change password

- function change_password($new_password)

- $packet = $this->send_iq($this->server, 'get', 'A0', 'jabber:iq:register');

-

- if ($packet)

- {

- // just in case a key was passed back from the server

- $key = $this->get_info_from_iq_key($packet);

- unset($packet);

-

- $payload = "<username>{$this->username}</username>

- <password>{$new_password}</password>\n";

- $payload .= ($key) ? "<key>$key</key>\n" : '';

-

- $packet = $this->send_iq($this->server, 'set', 'A0', 'jabber:iq:register', $payload);

-

- if ($this->get_info_from_iq_type($packet) == 'result')

- {

- $return_code = (isset($packet['iq']['#']['query'][0]['#']['registered'][0]['#'])) ? 1 : 2;

- }

- else if ($this->get_info_from_iq_type($packet) == 'error' && isset($packet['iq']['#']['error'][0]['#']))

- {

- // "conflict" error, i.e. already registered

- if ($packet['iq']['#']['error'][0]['@']['code'] == '409')

- {

- $return_code = 1;

- }

- else

- {

- $return_code = 'Error ' . $packet['iq']['#']['error'][0]['@']['code'] . ': ' . $packet['iq']['#']['error'][0]['#'];

- }

- }

-

- return $return_code;

- }

- else

- {

- return 3;

- }

- * Send packet

- function send_packet($xml)

- $xml = trim($xml);

-

- if ($this->connector->write_to_socket($xml))

- $this->add_to_log('SEND: ' . $xml);

- return true;

- }

- else

- {

- $this->add_to_log('ERROR: send_packet() #1');

- }

-

- /**

- * Listen to socket

- */

- function listen()

- {

- $incoming = '';

-

- while ($line = $this->connector->read_from_socket(4096))

- {

- $incoming .= $line;

- }

- $incoming = trim($incoming);

- if ($incoming != '')

- $this->add_to_log('RECV: ' . $incoming);

- $temp = $this->_split_incoming($incoming);

-

- for ($i = 0, $size = sizeof($temp); $i < $size; $i++)

- {

- $this->packet_queue[] = $this->xmlize($temp[$i]);

- }

- * Strip jid

- */

- function strip_jid($jid = NULL)

- {

- preg_match('#(.*)\/(.*)#Ui', $jid, $temp);

- return ($temp[1] != '') ? $temp[1] : $jid;

- }

-

- /**

- * Send a message

- function send_message($to, $type = 'normal', $id = NULL, $content = NULL, $payload = NULL)

- if ($to && is_array($content))

- {

- if (!$id)

- {

- $id = $type . '_' . time();

- }

-

- $this->_array_xmlspecialchars($content);

-

- $xml = "<message to='$to' type='$type' id='$id'>\n";

-

- if (!empty($content['subject']))

- {

- $xml .= '<subject>' . $content['subject'] . "</subject>\n";

- }

-

- if (!empty($content['thread']))

- {

- $xml .= '<thread>' . $content['thread'] . "</thread>\n";

- }

-

- $xml .= '<body>' . $content['body'] . "</body>\n";

- $xml .= $payload;

- $xml .= "</message>\n";

-

- if ($this->send_packet($xml))

- {

- return true;

- }

- else

- {

- $this->add_to_log('ERROR: send_message() #1');

- }

- }

- else

- $this->add_to_log('ERROR: send_message() #2');

- }

- }

-

- /**

- * Send presence

- */

- function send_presence($type = NULL, $to = NULL, $status = NULL, $show = NULL, $priority = NULL)

- {

- $xml = '<presence';

- $xml .= ($to) ? " to='$to'" : '';

- $xml .= ($type) ? " type='$type'" : '';

- $xml .= ($status || $show || $priority) ? ">\n" : " />\n";

-

- $xml .= ($status) ? " <status>$status</status>\n" : '';

- $xml .= ($show) ? " <show>$show</show>\n" : '';

- $xml .= ($priority) ? " <priority>$priority</priority>\n" : '';

- $xml .= ($status || $show || $priority) ? "</presence>\n" : '';

- if ($this->send_packet($xml))

- return true;

- $this->add_to_log('ERROR: send_presence() #1');

- }

-

- /**

- * Send error

- */

- function send_error($to, $id = NULL, $error_number, $error_message = NULL)

- {

- $xml = "<iq type='error' to='$to'";

- $xml .= ($id) ? " id='$id'" : '';

- $xml .= ">\n";

- $xml .= " <error code='$error_number'>";

- $xml .= ($error_message) ? $error_message : $this->error_codes[$error_number];

- $xml .= "</error>\n";

- $xml .= '</iq>';

-

- $this->send_packet($xml);

- }

- /**

- * Get first from queue

- */

- function get_first_from_queue()

- {

- return array_shift($this->packet_queue);

- * Get from queue by id

- function get_from_queue_by_id($packet_type, $id)

- $found_message = false;

-

- foreach ($this->packet_queue as $key => $value)

- if ($value[$packet_type]['@']['id'] == $id)

- $found_message = $value;

- unset($this->packet_queue[$key]);

-

- break;

- return (is_array($found_message)) ? $found_message : false;

- * Call handler

- function call_handler($packet = NULL)

- $packet_type = $this->_get_packet_type($packet);

-

- if ($packet_type == 'message')

- {

- $type = $packet['message']['@']['type'];

- $type = ($type != '') ? $type : 'normal';

- $funcmeth = "handler_message_$type";

- }

- else if ($packet_type == 'iq')

- {

- $namespace = $packet['iq']['#']['query'][0]['@']['xmlns'];

- $namespace = str_replace(':', '_', $namespace);

- $funcmeth = "handler_iq_$namespace";

- }

- else if ($packet_type == 'presence')

- {

- $type = $packet['presence']['@']['type'];

- $type = ($type != '') ? $type : 'available';

- $funcmeth = "handler_presence_$type";

- }

-

- if ($funcmeth != '')

- {

- if (function_exists($funcmeth))

- {

- call_user_func($funcmeth, $packet);

- }

- else if (method_exists($this, $funcmeth))

- {

- call_user_func(array(&$this, $funcmeth), $packet);

- }

- else

- {

- $this->handler_not_implemented($packet);

- $this->add_to_log("ERROR: call_handler() #1 - neither method nor function $funcmeth() available");

- }

- }

- * Cruise Control

- function cruise_control($seconds = -1)

- $count = 0;

-

- while ($count != $seconds)

- $this->listen();

-

- do

- {

- $packet = $this->get_first_from_queue();

-

- if ($packet)

- {

- $this->call_handler($packet);

- }

- }

- while (sizeof($this->packet_queue) > 1);

-

- $count += 0.25;

- usleep(250000);

-

- if (($this->last_ping_time + 180) < time())

- {

- // Modified by Nathan Fritz

- if ($this->returned_keep_alive == false)

- {

- $this->connected = false;

- $this->add_to_log('EVENT: Disconnected');

- }

-

- if ($this->returned_keep_alive == true)

- {

- $this->connected = true;

- }

-

- $this->returned_keep_alive = false;

-

- $this->keep_alive_id = 'keep_alive_' . time();

- // $this->send_packet("<iq id='{$this->keep_alive_id}'/>", 'cruise_control');

- $this->send_packet("<iq type='get' from='{$this->username}@{$this->server}/{$this->resource}' to='{$this->server}' id='{$this->keep_alive_id}'><query xmlns='jabber:iq:time' /></iq>");

- $this->last_ping_time = time();

- }

- return true;

- * Send iq

- function send_iq($to = NULL, $type = 'get', $id = NULL, $xmlns = NULL, $payload = NULL, $from = NULL)

- if (!preg_match('#^(get|set|result|error)$#', $type))

- unset($type);

-

- $this->add_to_log("ERROR: send_iq() #2 - type must be 'get', 'set', 'result' or 'error'");

- return false;

- }

- else if ($id && $xmlns)

- {

- $xml = "<iq type='$type' id='$id'";

- $xml .= ($to) ? " to='" . htmlspecialchars($to) . "'" : '';

- $xml .= ($from) ? " from='$from'" : '';

- $xml .= ">

- <query xmlns='$xmlns'>

- $payload

- </query>

- </iq>";

-

- $this->send_packet($xml);

- sleep($this->iq_sleep_timer);

- $this->listen();

-

- return (preg_match('#^(get|set)$#', $type)) ? $this->get_from_queue_by_id('iq', $id) : true;

- $this->add_to_log('ERROR: send_iq() #1 - to, id and xmlns are mandatory');

- * get the transport registration fields

- * method written by Steve Blinch, http://www.blitzaffe.com

- function transport_registration_details($transport)

- $this->txnid++;

- $packet = $this->send_iq($transport, 'get', "reg_{$this->txnid}", 'jabber:iq:register', NULL, $this->jid);

-

- if ($packet)

- $res = array();

-

- foreach ($packet['iq']['#']['query'][0]['#'] as $element => $data)

- if ($element != 'instructions' && $element != 'key')

- {

- $res[] = $element;

- }

-

- return $res;

- return 3;

- }

- /**

- * register with the transport

- * method written by Steve Blinch, http://www.blitzaffe.com

- */

- function transport_registration($transport, $details)

- {

- $this->txnid++;

- $packet = $this->send_iq($transport, 'get', "reg_{$this->txnid}", 'jabber:iq:register', NULL, $this->jid);

- if ($packet)

- // just in case a key was passed back from the server

- $key = $this->get_info_from_iq_key($packet);

- unset($packet);

-

- $payload = ($key) ? "<key>$key</key>\n" : '';

- foreach ($details as $element => $value)

- {

- $payload .= "<$element>$value</$element>\n";

- }

-

- $packet = $this->send_iq($transport, 'set', "reg_{$this->txnid}", 'jabber:iq:register', $payload);

-

- if ($this->get_info_from_iq_type($packet) == 'result')

- {

- $return_code = (isset($packet['iq']['#']['query'][0]['#']['registered'][0]['#'])) ? 1 : 2;

- }

- else if ($this->get_info_from_iq_type($packet) == 'error')

- {

- if (isset($packet['iq']['#']['error'][0]['#']))

- {

- $return_code = 'Error ' . $packet['iq']['#']['error'][0]['@']['code'] . ': ' . $packet['iq']['#']['error'][0]['#'];

- $this->add_to_log('ERROR: transport_registration()');

- }

- }

- return $return_code;

- }

- else

- {

- return 3;

- return implode("<br /><br />", $this->log_array);

- $this->log_array[] = htmlspecialchars($string);

-

- // ======================================================================

- // private methods

- // ======================================================================

-

- * Send auth

- * @access private

- function _sendauth_ok($zerok_token, $zerok_sequence)

- // initial hash of password

- $zerok_hash = sha1($this->password);

-

- // sequence 0: hash of hashed-password and token

- $zerok_hash = sha1($zerok_hash . $zerok_token);

-

- // repeat as often as needed

- for ($i = 0; $i < $zerok_sequence; $i++)

- $zerok_hash = sha1($zerok_hash);

- $payload = "<username>{$this->username}</username>

- <hash>$zerok_hash</hash>

- <resource>{$this->resource}</resource>";

-

- $packet = $this->send_iq(NULL, 'set', $this->auth_id, 'jabber:iq:auth', $payload);

- // was a result returned?

- if ($this->get_info_from_iq_type($packet) == 'result' && $this->get_info_from_iq_id($packet) == $this->auth_id)

- return true;

- else

- {

- $this->add_to_log('ERROR: _sendauth_ok() #1');

- return false;

- }

- }

- /**

- * Send auth digest

- * @access private

- */

- function _sendauth_digest()

- {

- $payload = "<username>{$this->username}</username>

- <resource>{$this->resource}</resource>

- <digest>" . sha1($this->stream_id . $this->password) . "</digest>";

-

- $packet = $this->send_iq(NULL, 'set', $this->auth_id, 'jabber:iq:auth', $payload);

-

- // was a result returned?

- if ($this->get_info_from_iq_type($packet) == 'result' && $this->get_info_from_iq_id($packet) == $this->auth_id)

- return true;

- $this->add_to_log('ERROR: _sendauth_digest() #1');

- * Send auth plain

- * @access private

- function _sendauth_plaintext()

- $payload = "<username>{$this->username}</username>

- <password>{$this->password}</password>

- <resource>{$this->resource}</resource>";

-

- $packet = $this->send_iq(NULL, 'set', $this->auth_id, 'jabber:iq:auth', $payload);

-

- // was a result returned?

- if ($this->get_info_from_iq_type($packet) == 'result' && $this->get_info_from_iq_id($packet) == $this->auth_id)

- {

- return true;

- }

- else

- $this->add_to_log('ERROR: _sendauth_plaintext() #1');

- * Listen on socket

- * @access private

- function _listen_incoming()

- $incoming = '';

-

- while ($line = $this->connector->read_from_socket(4096))

- $incoming .= $line;

- }

-

- $incoming = trim($incoming);

-

- if ($incoming != '')

- {

- $this->add_to_log('RECV: ' . $incoming);

- return $this->xmlize($incoming);

- }

- /**

- * Check if connected

- * @access private

- */

- function _check_connected($in_tls = false)

- {

- $incoming_array = $this->_listen_incoming();

-

- if (is_array($incoming_array))

- {

- if ($incoming_array['stream:stream']['@']['from'] == $this->server && $incoming_array['stream:stream']['@']['xmlns'] == 'jabber:client' && $incoming_array['stream:stream']['@']['xmlns:stream'] == 'http://etherx.jabber.org/streams')

- {

- $this->stream_id = $incoming_array['stream:stream']['@']['id'];

- // We only start TLS authentication if not called within TLS authentication itself, which may produce a never ending loop...

- if (!$in_tls)

- {

- if (!empty($incoming_array['stream:stream']['#']['stream:features'][0]['#']['starttls'][0]['@']['xmlns']) && $incoming_array['stream:stream']['#']['stream:features'][0]['#']['starttls'][0]['@']['xmlns'] == 'urn:ietf:params:xml:ns:xmpp-tls')

- {

- return $this->_starttls();

- }

- }

- return true;

- }

- else

- {

- $this->add_to_log('ERROR: _check_connected() #1');

- return false;

- }

- }

- else

- {

- $this->add_to_log('ERROR: _check_connected() #2');

- return false;

- }

- * Start TLS/SSL session if supported (PHP5.1)

- * @access private

- function _starttls()

- if (!function_exists('stream_socket_enable_crypto') || !function_exists('stream_get_meta_data') || !function_exists('socket_set_blocking') || !function_exists('stream_get_wrappers'))

- $this->add_to_log('WARNING: TLS is not available');

- return true;

- }

-

- // Make sure the encryption stream is supported

- $streams = stream_get_wrappers();

-

- if (!in_array('streams.crypto', $streams))

- {

- $this->add_to_log('WARNING: SSL/crypto stream not supported');

- return true;

- }

-

- $this->send_packet("<starttls xmlns='urn:ietf:params:xml:ns:xmpp-tls'/>\n");

- sleep(2);

- $incoming_array = $this->_listen_incoming();

-

- if (!is_array($incoming_array))

- {

- $this->add_to_log('ERROR: _starttls() #1');

- return false;

- }

-

- if ($incoming_array['proceed']['@']['xmlns'] != 'urn:ietf:params:xml:ns:xmpp-tls')

- {

- $this->add_to_log('ERROR: _starttls() #2');

- $meta = stream_get_meta_data($this->connector->active_socket);

- socket_set_blocking($this->connector->active_socket, 1);

-

- $result = @stream_socket_enable_crypto($this->connector->active_socket, true, STREAM_CRYPTO_METHOD_TLS_CLIENT);

- if (!$result)

- socket_set_blocking($this->connector->active_socket, $meta['blocked']);

- $this->add_to_log('ERROR: _starttls() #3');

- return false;

-

- socket_set_blocking($this->connector->active_socket, $meta['blocked']);

-

- $this->send_packet("<?xml version='1.0' encoding='UTF-8' ?" . ">\n");

- $this->send_packet("<stream:stream to='{$this->server}' xmlns='jabber:client' xmlns:stream='http://etherx.jabber.org/streams'" . (($this->show_version) ? " version='{$this->version}'" : '') . ">\n");

- sleep(2);

-

- if (!$this->_check_connected(true))

- $this->add_to_log('ERROR: _starttls() #4');

- return false;

- return true;

- }

-

- /**

- * Get packet type

- * @access private

- */

- function _get_packet_type($packet = NULL)

- {

- if (is_array($packet))

- reset($packet);

- $packet_type = key($packet);

- }

-

- return ($packet_type) ? $packet_type : false;

- }

- /**

- * Split incoming packet

- * @access private

- */

- function _split_incoming($incoming)

- {

- $temp = preg_split('#<(message|iq|presence|stream)#', $incoming, -1, PREG_SPLIT_DELIM_CAPTURE);

- $array = array();

-

- for ($i = 1, $size = sizeof($temp); $i < $size; $i += 2)

- {

- $array[] = '<' . $temp[$i] . $temp[($i + 1)];

- }

-

- return $array;

- }

-

- /**

- * Recursively prepares the strings in an array to be used in XML data.

- * @access private

- */

- function _array_xmlspecialchars(&$array)

- {

- if (is_array($array))

- {

- foreach ($array as $k => $v)

- {

- if (is_array($v))

- $this->_array_xmlspecialchars($array[$k]);

- $this->_xmlspecialchars($array[$k]);

- }

- }

- }

-

- /**

- * Prepares a string for usage in XML data.

- * @access private

- */

- function _xmlspecialchars(&$string)

- {

- // we only have a few entities in xml

- $string = str_replace(array('&', '>', '<', '"', '\''), array('&amp;', '&gt;', '&lt;', '&quot;', '&apos;'), $string);

- }

-

- // ======================================================================

- // <message/> parsers

- // ======================================================================

-

- /**

- * Get info from message (from)

- */

- function get_info_from_message_from($packet = NULL)

- {

- return (is_array($packet)) ? $packet['message']['@']['from'] : false;

- }

-

- /**

- * Get info from message (type)

- */

- function get_info_from_message_type($packet = NULL)

- {

- return (is_array($packet)) ? $packet['message']['@']['type'] : false;

- }

-

- /**

- * Get info from message (id)

- */

- function get_info_from_message_id($packet = NULL)

- {

- return (is_array($packet)) ? $packet['message']['@']['id'] : false;

- }

-

- /**

- * Get info from message (thread)

- */

- function get_info_from_message_thread($packet = NULL)

- {

- return (is_array($packet)) ? $packet['message']['#']['thread'][0]['#'] : false;

- }

- /**

- * Get info from message (subject)

- */

- function get_info_from_message_subject($packet = NULL)

- {

- return (is_array($packet)) ? $packet['message']['#']['subject'][0]['#'] : false;

- }

-

- /**

- * Get info from message (body)

- */

- function get_info_from_message_body($packet = NULL)

- {

- return (is_array($packet)) ? $packet['message']['#']['body'][0]['#'] : false;

- }

-

- /**

- * Get info from message (xmlns)

- */

- function get_info_from_message_xmlns($packet = NULL)

- {

- return (is_array($packet)) ? $packet['message']['#']['x'] : false;

- }

-

- /**

- * Get info from message (error)

- */

- function get_info_from_message_error($packet = NULL)

- {

- $error = preg_replace('#^\/$#', '', ($packet['message']['#']['error'][0]['@']['code'] . '/' . $packet['message']['#']['error'][0]['#']));

- return (is_array($packet)) ? $error : false;

- }

- // ======================================================================

- // <iq/> parsers

- // ======================================================================

- /**

- * Get info from iq (from)

- */

- function get_info_from_iq_from($packet = NULL)

- {

- return (is_array($packet)) ? $packet['iq']['@']['from'] : false;

- }

- /**

- * Get info from iq (type)

- */

- function get_info_from_iq_type($packet = NULL)

- {

- return (is_array($packet)) ? $packet['iq']['@']['type'] : false;

- }

- /**

- * Get info from iq (id)

- */

- function get_info_from_iq_id($packet = NULL)

- {

- return (is_array($packet)) ? $packet['iq']['@']['id'] : false;

- }

- /**

- * Get info from iq (key)

- */

- function get_info_from_iq_key($packet = NULL)

- {

- return (is_array($packet) && isset($packet['iq']['#']['query'][0]['#']['key'][0]['#'])) ? $packet['iq']['#']['query'][0]['#']['key'][0]['#'] : false;

- }

- /**

- * Get info from iq (error)

- */

- function get_info_from_iq_error($packet = NULL)

- {

- $error = preg_replace('#^\/$#', '', ($packet['iq']['#']['error'][0]['@']['code'] . '/' . $packet['iq']['#']['error'][0]['#']));

- return (is_array($packet)) ? $error : false;

- }

- // ======================================================================

- // <message/> handlers

- // ======================================================================

- /**

- * Message type normal

- */

- function handler_message_normal($packet)

- {

- $from = $packet['message']['@']['from'];

- $this->add_to_log("EVENT: Message (type normal) from $from");

- }

- /**

- * Message type chat

- */

- function handler_message_chat($packet)

- {

- $from = $packet['message']['@']['from'];

- $this->add_to_log("EVENT: Message (type chat) from $from");

- }

- /**

- * Message type groupchat

- */

- function handler_message_groupchat($packet)

- {

- $from = $packet['message']['@']['from'];

- $this->add_to_log("EVENT: Message (type groupchat) from $from");

- }

- /**

- * Message type headline

- */

- function handler_message_headline($packet)

- {

- $from = $packet['message']['@']['from'];

- $this->add_to_log("EVENT: Message (type headline) from $from");

- }

- /**

- * Message type error

- */

- function handler_message_error($packet)

- {

- $from = $packet['message']['@']['from'];

- $this->add_to_log("EVENT: Message (type error) from $from");

- }

- // ======================================================================

- // <iq/> handlers

- // ======================================================================

- /**

- * application version updates

- */

- function handler_iq_jabber_iq_autoupdate($packet)

- {

- $from = $this->get_info_from_iq_from($packet);

- $id = $this->get_info_from_iq_id($packet);

- $this->send_error($from, $id, 501);

- $this->add_to_log("EVENT: jabber:iq:autoupdate from $from");

- }

- /**

- * interactive server component properties

- */

- function handler_iq_jabber_iq_agent($packet)

- {

- $from = $this->get_info_from_iq_from($packet);

- $id = $this->get_info_from_iq_id($packet);

- $this->send_error($from, $id, 501);

- $this->add_to_log("EVENT: jabber:iq:agent from $from");

- }

- /**

- * method to query interactive server components

- */

- function handler_iq_jabber_iq_agents($packet)

- {

- $from = $this->get_info_from_iq_from($packet);

- $id = $this->get_info_from_iq_id($packet);

- $this->send_error($from, $id, 501);

- $this->add_to_log("EVENT: jabber:iq:agents from $from");

- }

- /**

- * simple client authentication

- */

- function handler_iq_jabber_iq_auth($packet)

- {

- $from = $this->get_info_from_iq_from($packet);

- $id = $this->get_info_from_iq_id($packet);

- $this->send_error($from, $id, 501);

- $this->add_to_log("EVENT: jabber:iq:auth from $from");

- }

- /**

- * out of band data

- */

- function handler_iq_jabber_iq_oob($packet)

- {

- $from = $this->get_info_from_iq_from($packet);

- $id = $this->get_info_from_iq_id($packet);

- $this->send_error($from, $id, 501);

- $this->add_to_log("EVENT: jabber:iq:oob from $from");

- }

- /**

- * method to store private data on the server

- */

- function handler_iq_jabber_iq_private($packet)

- {

- $from = $this->get_info_from_iq_from($packet);

- $id = $this->get_info_from_iq_id($packet);

- $this->send_error($from, $id, 501);

- $this->add_to_log("EVENT: jabber:iq:private from $from");

- }

- /**

- * method for interactive registration

- */

- function handler_iq_jabber_iq_register($packet)

- {

- $from = $this->get_info_from_iq_from($packet);

- $id = $this->get_info_from_iq_id($packet);

- $this->send_error($from, $id, 501);

- $this->add_to_log("EVENT: jabber:iq:register from $from");

- /**

- * client roster management

- */

- function handler_iq_jabber_iq_roster($packet)

- $from = $this->get_info_from_iq_from($packet);

- $id = $this->get_info_from_iq_id($packet);

-

- $this->send_error($from, $id, 501);

- $this->add_to_log("EVENT: jabber:iq:roster from $from");

- }

- /**

- * method for searching a user database

- */

- function handler_iq_jabber_iq_search($packet)

- {

- $from = $this->get_info_from_iq_from($packet);

- $id = $this->get_info_from_iq_id($packet);

- $this->send_error($from, $id, 501);

- $this->add_to_log("EVENT: jabber:iq:search from $from");

- * method for requesting the current time

- function handler_iq_jabber_iq_time($packet)

- if ($this->keep_alive_id == $this->get_info_from_iq_id($packet))

- $this->returned_keep_alive = true;

- $this->connected = true;

-

- $this->add_to_log('EVENT: Keep-Alive returned, connection alive.');

- $type = $this->get_info_from_iq_type($packet);

- $from = $this->get_info_from_iq_from($packet);

- $id = $this->get_info_from_iq_id($packet);

- $id = ($id != '') ? $id : 'time_' . time();

- if ($type == 'get')

- $payload = '<utc>' . gmdate("Ydm\TH:i:s") . '</utc><tz>' . date('T') . '</tz><display>' . date("Y/d/m h:i:s A") . '</display>';

- $this->send_iq($from, 'result', $id, 'jabber:iq:time', $payload);

- $this->add_to_log("EVENT: jabber:iq:time (type $type) from $from");

- }

- /**

- */

- function handler_iq_error($packet)

- {

- // We'll do something with these later. This is a placeholder so that errors don't bounce back and forth.

- * method for requesting version

- function handler_iq_jabber_iq_version($packet)

- $type = $this->get_info_from_iq_type($packet);

- $from = $this->get_info_from_iq_from($packet);

- $id = $this->get_info_from_iq_id($packet);

- $id = ($id != '') ? $id : 'version_' . time();

- if ($type == 'get')

- $payload = "<name>{$this->iq_version_name}</name>

- <os>{$this->iq_version_os}</os>

- <version>{$this->iq_version_version}</version>";

-

- //$this->SendIq($from, 'result', $id, "jabber:iq:version", $payload);

-

- $this->add_to_log("EVENT: jabber:iq:version (type $type) from $from -- DISABLED");

- // ======================================================================

- // Generic handlers

- // ======================================================================

-

- * Generic handler for unsupported requests

- function handler_not_implemented($packet)

- $packet_type = $this->_get_packet_type($packet);

- $from = call_user_func(array(&$this, 'get_info_from_' . strtolower($packet_type) . '_from'), $packet);

- $id = call_user_func(array(&$this, 'get_info_from_' . strtolower($packet_type) . '_id'), $packet);

-

- $this->send_error($from, $id, 501);

- $this->add_to_log("EVENT: Unrecognized <$packet_type/> from $from");

- // ======================================================================

- // Third party code

- // m@d pr0ps to the coders ;)

- // ======================================================================

-

- $array[$tagname]['@'] = (isset($vals[$i]['attributes'])) ? $vals[$i]['attributes'] : array();

- $array[$tagname]['#'] = $this->_xml_depth($vals, $i);

-

- /**

- * TraverseXMLize()

- * @author acebone@f2s.com

- * @copyright acebone@f2s.com, a HUGE help!

- */

- function traverse_xmlize($array, $arr_name = 'array', $level = 0)

- {

- if ($level == 0)

- {

- echo '<pre>';

- }

-

- foreach ($array as $key => $val)

- {

- if (is_array($val))

- {

- $this->traverse_xmlize($val, $arr_name . '[' . $key . ']', $level + 1);

- }

- else

- {

- $GLOBALS['traverse_array'][] = '$' . $arr_name . '[' . $key . '] = "' . $val . "\"\n";

- }

- }

-

- if ($level == 0)

- {

- echo '</pre>';

- }

-

- return 1;

- }

-}

-

-/**

-* Jabber Connector

-* @package phpBB3

-*/

-class cjp_standard_connector

-{

- var $active_socket;

-

- /**

- * Open socket

- */

- function open_socket($server, $port)

- {

- if (function_exists('dns_get_record'))

- {

- $record = dns_get_record("_xmpp-client._tcp.$server", DNS_SRV);

-

- if (!empty($record))

- {

- $server = $record[0]['target'];

- $port = $record[0]['port'];

- }

- }

-

- $errno = 0;

- $errstr = '';

-

- if ($this->active_socket = @fsockopen($server, $port, $errno, $errstr, 5))

- {

- @socket_set_blocking($this->active_socket, 0);

- @socket_set_timeout($this->active_socket, 31536000);

-

- return true;

- }

- else

- {

- return false;

- }

- }

-

- /**

- * Close socket

- */

- function close_socket()

- {

- return @fclose($this->active_socket);

- }

-

- /**

- * Write to socket

- */

- function write_to_socket($data)

- {

- return @fwrite($this->active_socket, $data);

- }

-

- /**

- * Read from socket

- */

- function read_from_socket($chunksize)

- {

- $buffer = @fread($this->active_socket, $chunksize);

- $buffer = (STRIP) ? stripslashes($buffer) : $buffer;

-

- return $buffer;

- }

- $this->jabber = new jabber($config['jab_host'], $config['jab_port'], $config['jab_username'], $config['jab_password'], $config['jab_resource']);

- if (!$this->jabber->send_auth())

- $this->jabber->send_presence(NULL, NULL, 'online');

- $this->jabber->send_message($address, 'normal', NULL, array('body' => $this->msg, 'subject' => $this->subject));

- sleep(1);

- $this->jabber = new jabber($config['jab_host'], $config['jab_port'], $config['jab_username'], $config['jab_password'], $config['jab_resource']);

- if (!$this->jabber->send_auth())

- $this->jabber->send_presence(NULL, NULL, 'online');

- if ($this->jabber->send_message($address, 'normal', NULL, array('body' => $msg, 'subject' => $subject)) === false)

- sleep(1);

- if (empty($img_data) || $width !== false)

- return $img_data['width'];

- return '<img src="' . $img_data['src'] . '"' . (($img_data['width']) ? ' width="' . $img_data['width'] . '"' : '') . (($img_data['height']) ? ' height="' . $img_data['height'] . '"' : '') . ' alt="' . $alt . '" title="' . $alt . '" />';

-

-INSERT INTO phpbb_config (config_name, config_value) VALUES ('jab_resource', '');

-INSERT INTO phpbb_config (config_name, config_value) VALUES ('max_post_chars', '0');

- 'ACP_JABBER_SETTINGS_EXPLAIN' => 'Here you can enable and control the use of Jabber for instant messaging and board notifications. Jabber is an open source protocol and therefore available for use by anyone. Some Jabber servers include gateways or transports which allow you to contact users on other networks. Not all servers offer all transports and changes in protocols can prevent transports from operating. Note that it may take several seconds to update Jabber account details, so do not stop the script until it is completed!',

- 'ERR_JAB_PASSCHG' => 'Could not change password.',

- 'ERR_JAB_PASSFAIL' => 'Password update failed, %s.',

- 'ERR_JAB_REGISTER' => 'An error occurred trying to register this account, %s.',

- 'ERR_JAB_USERNAME' => 'The username specified already exists, please choose an alternative.',

-

- 'JAB_CHANGED' => 'Jabber account changed successfully.',

- 'JAB_PACKAGE_SIZE_EXPLAIN' => 'This is the number of messages sent in one package. If set to 0 the message is sent immediately and is not queued for later sending.',

- 'JAB_PASS_CHANGED' => 'Jabber password changed successfully.',

- 'JAB_REGISTERED' => 'New account registered successfully.',

- 'JAB_RESOURCE' => 'Jabber resource',

- 'JAB_RESOURCE_EXPLAIN' => 'The resource locates this particular connection, e.g. board, home, etc.',

- 'JAB_USERNAME_EXPLAIN' => 'If this user is not registered it will be created if possible.',

- 'LOGIN_INFO' => 'In order to login you must be registered. Registering takes only a few seconds but gives you increased capabilities. The board administrator may also grant additional permissions to registered users. Before you login please ensure you are familiar with our terms of use and related policies. Please ensure you read any forum rules as you navigate around the board.',

- $result = $db->sql_query_limit($sql, 1);

- <dl class="icon" style="background-image: url({forumrow.FORUM_FOLDER_IMG_SRC});">

- <!-- IF forumrow.FORUM_IMAGE --><div style="float: left; padding-top: 5px; margin-right: 5px;">{forumrow.FORUM_IMAGE}</div><!-- ENDIF -->

- <dl class="icon" style="background-image: url({topicrow.TOPIC_FOLDER_IMG_SRC});">

- <dt <!-- IF topicrow.TOPIC_ICON_IMG and S_TOPIC_ICONS -->style="background-image: url({T_ICONS_PATH}{topicrow.TOPIC_ICON_IMG});"<!-- ENDIF -->>

- insert_user(users.value);

- <!-- ELSE -->

- <dd><label for="poll_delete"><input type="checkbox" name="poll_delete" id="poll_delete"<!-- IF S_POLL_DELETE_CHECKED --> checked="checked"<!-- ENDIF --> /> {L_DELETE_POST_WARN}</label></dd>

- <dl class="icon" style="background-image: url({searchresults.TOPIC_FOLDER_IMG_SRC});">

- <dt <!-- IF searchresults.TOPIC_ICON_IMG -->style="background-image: url({T_ICONS_PATH}{searchresults.TOPIC_ICON_IMG});"<!-- ENDIF -->>

- <dl class="icon" style="background-image: url({topicrow.TOPIC_FOLDER_IMG_SRC});">

- <dt style="<!-- IF topicrow.TOPIC_ICON_IMG -->background-image: url({T_ICONS_PATH}{topicrow.TOPIC_ICON_IMG});<!-- ENDIF -->" title="{topicrow.TOPIC_FOLDER_IMG_ALT}">

- <dl class="icon" style="background-image: url({topicrow.TOPIC_FOLDER_IMG_SRC});">

- <dt <!-- IF topicrow.TOPIC_ICON_IMG -->style="background-image: url({T_ICONS_PATH}{topicrow.TOPIC_ICON_IMG});"<!-- ENDIF -->>

- <dl class="icon" style="background-image: url({forumrow.FORUM_FOLDER_IMG_SRC});">

- <dl class="icon" style="background-image: url({topicrow.TOPIC_FOLDER_IMG_SRC});">

- <dt style="<!-- IF topicrow.TOPIC_ICON_IMG -->background-image: url({T_ICONS_PATH}{topicrow.TOPIC_ICON_IMG});<!-- ENDIF -->" title="{topicrow.TOPIC_FOLDER_IMG_ALT}">

- <dl class="icon" style="background-image: url({messagerow.FOLDER_IMG_SRC});">

- <dt<!-- IF messagerow.PM_ICON_URL and S_PM_ICONS --> style="background-image: url({messagerow.PM_ICON_URL});"<!-- ENDIF -->>

- <!-- IF profile_fields.ERROR --><br /><span style="color:red">{profile_fields.ERROR}</span><!-- ENDIF --></dt>

- <dl class="icon" style="background-image: url({topicrow.TOPIC_FOLDER_IMG_SRC});">

- <dt style="<!-- IF topicrow.TOPIC_ICON_IMG and S_TOPIC_ICONS -->background-image: url({T_ICONS_PATH}{topicrow.TOPIC_ICON_IMG});<!-- ENDIF -->" title="{topicrow.TOPIC_FOLDER_IMG_ALT}"><!-- IF topicrow.S_UNREAD_TOPIC --><a href="{topicrow.U_NEWEST_POST}">{NEWEST_POST_IMG}</a> <!-- ENDIF --><a href="{topicrow.U_VIEW_TOPIC}" class="topictitle">{topicrow.TOPIC_TITLE}</a>

-} \ No newline at end of file

- insert_user(users.value);