+ include($this->cache_dir . 'data_global.' . $phpEx);

+ $cache->save();

+ if ($row['left_id'] < $right)

+ {

+ $padding++;

+ $padding_store[$row['parent_id']] = $padding;

+ }

+ else if ($row['left_id'] > $right + 1)

+ {

+ $padding = $padding_store[$row['parent_id']];

+ }

+

+ $right = $row['right_id'];

+

+ // Remove expired sessions

+ 'S_TIMEZONE' => ($user->data['user_dst'] || ($user->data['user_id'] == ANONYMOUS && $config['board_dst'])) ? sprintf($user->lang['ALL_TIMES'], (($tz >= 0) ? '+' . $tz : $tz), $user->lang['tz']['dst']) : sprintf($user->lang['ALL_TIMES'], (($tz >= 0) ? '+' . $tz : $tz), ''),

+class jabber

+ var $connector;

+ function jabber()

+ $this->port = '5222';

+ $this->packet_queue = $this->subscription_queue = array();

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

+ $this->returned_keep_alive = true;

+ $this->error_codes = array(

+ 400 => 'Bad Request',

+ 401 => 'Unauthorized',

+ 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'

+ );

+ 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'>\n");

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

+ return true;

+ return false;

+ return false;

+ function disconnect()

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

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

+ function cruise_control($seconds = -1)

+ $this->listen();

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

+ $this->call_handler($packet);

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

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

+ $this->connected = false;

+ //EVENT: Disconnected

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

+ $this->last_ping_time = date('H:i');

+ return true;

+ function send_auth()

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

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

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

+ return false;

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

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

+ $key = $this->get_info_from_iq_key($packet); // just in case a key was passed back from the server

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

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

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

+ function change_password($new_password)

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

+ $key = $this->get_info_from_iq_key($packet); // just in case a key was passed back from the server

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

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

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

+ function send_packet($xml)

+ return ($this->connector->write_to_socket($xml)) ? true : false;

+ function transport_registration_details($transport)

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

+ function transport_registration($transport, $details)

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

+ $key = $this->get_info_from_iq_key($packet); // just in case a key was passed back from the server

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

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

+ elseif ($this->get_info_from_iq_type($packet) == 'error')

+ // ERROR: TransportRegistration()

+ function listen()

+ $incoming = '';

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

+ return true;

+ function strip_jid($jid = NULL)

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

+ if (isset($content['subject']) && $content['subject'])

+ if (isset($content['thread']) && $content['thread'])

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

+ return true;

+ return false;

+ return false;

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

+ return ($this->send_packet($xml)) ? true : false;

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

+ $this->send_packet($xml);

+ function get_first_from_queue()

+ function get_from_queue_by_id($packet_type, $id)

+ $found_message = false;

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

+ function call_handler($packet = NULL)

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

+ $funcmeth = "handler_message_$type";

+ $funcmeth = "handler_iq_$namespace";

+ $funcmeth = "handler_presence_$type";

+ $this->handler_not_implemented($packet);

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

+ return false;

+ else if ($id && $xmlns)

+ $this->send_packet($xml);

+ $this->listen();

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

+ return false;

+ function _sendauth_ok($zerok_token, $zerok_sequence)

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

+ return ($this->get_info_from_iq_type($packet) == 'result' && $this->get_info_from_iq_id($packet) == $this->auth_id) ? true : false;

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

+ return ($this->get_info_from_iq_type($packet) == 'result' && $this->get_info_from_iq_id($packet) == $this->auth_id) ? true : false;

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

+ return ($this->get_info_from_iq_type($packet) == 'result' && $this->get_info_from_iq_id($packet) == $this->auth_id) ? true : false;

+ $incoming = '';

+

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

+ return true;

+ return false;

+ return false;

+ for ($a = 1; $a < sizeof($temp); $a = $a + 2)

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

+ function get_info_from_message_from($packet = NULL)

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

+ function get_info_from_message_type($packet = NULL)

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

+ function get_info_from_message_id($packet = NULL)

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

+ function get_info_from_message_thread($packet = NULL)

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

+ function get_info_from_message_subject($packet = NULL)

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

+ function get_info_from_message_body($packet = NULL)

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

+ function get_info_from_message_error($packet = NULL)

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

+ function get_info_from_iq_from($packet = NULL)

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

+ function get_info_from_iq_type($packet = NULL)

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

+ function get_info_from_iq_id($packet = NULL)

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

+ function get_info_from_iq_key($packet = NULL)

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

+ function get_info_from_iq_error($packet = NULL)

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

+ function handler_message_normal($packet)

+ function handler_message_error($packet)

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

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

+ function handler_iq_($packet)

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

+ $this->returned_keep_alive = true;

+ function handler_not_implemented($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);

+ if (isset($vals[$i]['value']) && $vals[$i]['value'])

+ while (++$i < sizeof($vals))

+ $size = (isset($children[$tagname])) ? sizeof($children[$tagname]) : 0;

+ $children[$tagname][$size]['#'] = (isset($vals[$i]['value'])) ? trim($vals[$i]['value']) : '';

+ if (isset($vals[$i]['attributes']) && $vals[$i]['attributes'])

+ $size = (isset($children[$tagname])) ? sizeof($children[$tagname]) : 0;

+ // traverse_xmlize()

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

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

+ echo '$' . $arr_name . '[' . $key . '] = "' . $val . "\"\n";

+* make_xml

+* Currently not in use

+class make_xml extends jabber

+ function make_xml()

+ function add_packet_details($string, $value = NULL)

+ function build_packet($array = NULL)

+ $text .= $this->build_packet($value[$a]);

+ return (is_array($newarray)) ? $newarray : false;

+* connector

+class cjp_standard_connector

+ function open_socket($server, $port)

+ return true;

+ return false;

+ function close_socket()

+ function write_to_socket($data)

+ function read_from_socket($chunksize)

+ //@set_magic_quotes_runtime(get_magic_quotes_gpc());

+ $this->jabber = new jabber;

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

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

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

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

+ $this->jabber->disconnect();

+ 'subject' => htmlentities($this->subject),

+ set_config('last_queue_run', time(), true);

+ $this->jabber = new jabber;

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

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

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

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

+ $this->jabber->disconnect();

+ // function generate_profile_fields($mode, $lang_id, $cp_error)

+ // TODO: Maybe we should try to make this a bit more generic (not limited to bbcode)?

+ if ($ident_ary['data']['bbcode_bitfield'])

+ $value = (isset($_REQUEST[$profile_row['field_ident']])) ? request_var($profile_row['field_ident'], $default_value) : ((!isset($user->profile_fields[str_replace('pf_', '', $profile_row['field_ident'])]) || $preview) ? $default_value : $user->profile_fields[str_replace('pf_', '', $profile_row['field_ident'])]);

+ $value = $this->get_var('', $profile_row, $profile_row['lang_default_value'], $preview);

+

+ if ($preview == false)

+ // TODO: It might be nice to make this a per field setting.

+ $var = array(

+ $profile_row['field_ident'] => $message_parser->message,

+ 'submitted' => request_var($var_name, '')

+ );

+ // TODO: Login Attempt++