". t("Jabber") ."";
}
return $links ? $links : array();
}
function startElement($parser, $name, $attributes) {
global $jabber;
if ($attributes["ID"]) {
$jabber["jid"] = $attributes["ID"];
}
if (stristr($name, "error") || ($attributes["ERROR"])){
$jabber["error"] = true;
}
}
function endElement($parser, $name) {
}
function characterData($parser, $data) {
global $jabber;
$jabber["data"] = $data;
}
function jabber_send($session, $message) {
// print "SEND: ". htmlentities($message) ."
";
fwrite($session, $message, strlen($message));
}
function jabber_recv($session, $timout = 50) {
/*
** Returns a chunk of data, read from the socket descriptor '$session'.
** If the call fails, or if no data is read after the specified timout,
** false will be returned.
*/
while ($count < $timout) {
$data = fread($session, 1);
if ($data) {
$message .= $data;
}
else {
usleep(100);
$count = $count + 1;
}
}
if ($message) {
// print "RECV: ". htmlentities($message) ."
";
return $message;
}
else {
return false;
}
}
function jabber_auth($username, $password, $server, $port = 5222) {
global $jabber;
watchdog("user", "starting jabber auth");
$session = fsockopen($server, $port, &$errno, &$errstr, 5);
if ($session) {
$xml_parser = xml_parser_create();
xml_set_element_handler($xml_parser, "startElement", "endElement");
xml_set_character_data_handler($xml_parser, "characterData");
/*
** Switch the given socket descriptor '$session' to non-blocking mode:
*/
watchdog("user", "about to socket block in jabber auth");
set_socket_blocking($session, false); //this line is crashing.
watchdog("user", "done socket block in jabber auth");
/*
** A jabber session consists of two parallel XML streams, one from
** the client to the server and one from the server to the client.
** On connecting to a Jabber server, a Jabber client initiates the
** client-to-server XML stream and the server responds by initiating
** the server-to-client XML stream:
*/
jabber_send($session, "");
jabber_send($session, "");
$data = jabber_recv($session);
if (!xml_parse($xml_parser, $data, 0)) {
watchdog("error", "XML error: '". xml_error_string(xml_get_error_code($xml_parser)) ."' at line ". xml_get_current_line_number($xml_parser));
return 0;
}
if ($jabber["error"]) {
watchdog("error", "protocol error: ". $jabber["data"]);
return 0;
}
/*
** Hash the password:
*/
jabber_send($session, "$username$passworddrupal");
$data = jabber_recv($session);
if (!xml_parse($xml_parser, $data, 0)) {
watchdog("error", "XML error: '". xml_error_string(xml_get_error_code($xml_parser)) ."' at line ". xml_get_current_line_number($xml_parser));
}
if ($jabber["error"]) {
watchdog("error", "protocol error: ". $jabber["data"]);
return 0;
}
xml_parser_free($xml_parser);
return 1;
}
else {
watchdog("error", "failed to open socket to jabber server:\n $errno, $errstr");
return 0;
}
}
function jabber_page() {
global $theme;
$theme->header();
$theme->box(t("Jabber"), jabber_auth_help());
$theme->footer();
}
function jabber_auth_help() {
$html_output = <<
vanilla
chocolate
strawberry
EOF;
return $html_output;
}
?>