root/trunk/licqweb/rms.php

<?
/*
 * licqweb. Copyright 2005, Philip Nelson
 *
 * This file is part of licqweb.
 *
 * licqweb 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.
 *
 * licqweb 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 licqweb; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
 */
function readSocket() {
    global $sock;
    return socket_read($sock, 512, PHP_NORMAL_READ);
}

function sendData($cmd) {
    global $sock;
    socket_write($sock, $cmd, strlen($cmd));
}

function rmsLogin($uin, $passwd) {
    global $errmsg, $sock, $server, $port, $loggedIn, $h, $a;

    if ($loggedIn == true) {
        return;
    }
    $loggedIn = true;

    // Connect to the RMS server
    socket_connect($sock, $server, $port);
    
    // Get the version prompt
    $packet = socket_read($sock, 512, PHP_NORMAL_READ);

    // Get the UIN prompt
    $packet = socket_read($sock, 512, PHP_NORMAL_READ);

    if (!preg_match("/^300\s{1}.*/", $packet)) {
        socket_close($sock);
        $sock = 0;
        $loggedIn = false;
        return false;
    }

    //sendData($uin);
    socket_write($sock, $uin, strlen($uin));

    $packet = socket_read($sock, 512, PHP_NORMAL_READ);

    if (!preg_match("/^301\s{1}.*/", $packet)) {
        socket_close($sock);
        $sock = 0;
        $loggedIn = false;
        return false;
    }

    sendData($passwd);

    $packet = socket_read($sock, 512, PHP_NORMAL_READ);

    if (!preg_match("/^200\s{1}.*/", $packet)) {
        $errmsg = $packet;
        socket_close($sock);
        $sock = 0;
        $loggedIn = false;
        return false;
    }
    list($nick, $tmp) = sscanf($packet, "200 Hello %s %s");

    return $nick;
}

function rmsGetlist($type = 'online') {
    global $sock;
    $packet = " ";
    $cmd = "LIST $type\r\n";

    if ($sock == 0) return;

    socket_write($sock, $cmd, strlen($cmd));
    $packet = socket_read($sock, 512, PHP_NORMAL_READ);

    $users = array();
    while (!preg_match("/^206$/", $packet)) {
        if (preg_match("/^204\s{1}.*/", $packet)) {
            $user = getUserStuff($packet);
            array_push($users, $user);
            $packet = socket_read($sock, 512, PHP_NORMAL_READ);
        }
    }
    return $users;
}

function rmsViewEvent($id, $pp) {
    global $sock;
    $cmd = "VIEW " . $id . "." . $pp . "\r\n";
    sendData($cmd);

    $packet = socket_read($sock, 1024, PHP_NORMAL_READ);
    if (substr($packet, 0, 3) == 502) {
        return false;
    }

    $packet = socket_read($sock, 1024, PHP_NORMAL_READ);
    $snttime = substr($packet, 12);

    $packet = socket_read($sock, 1024, PHP_NORMAL_READ);
    $packet = socket_read($sock, 1024, PHP_BINARY_READ);
    $msg = str_replace("\r\n", "<br/>", $packet);
    $msg = str_replace("\n", '<br/>', $msg);
    preg_match("/^(.*)<br\/>223 Message Complete<br\/>$/", $msg, $matches);
    $msg = $matches[1]; 
    // kses input filtering
    $allowed = array('b' => array(),
                     'i' => array(),
                     'a' => array('href' => 1, 'title' => 1),
                     'p' => array('align' => 1),
                     'br' => array(),
                     'font' => array('size' => 1, 'color' => 1, 'face' => 1)
                    );
    
    if (get_magic_quotes_gpc()) {
        $msg = stripslashes($msg);
    }
    return array('msg' => kses($msg, $allowed), 'time' => trim($snttime));
}

function rmsSendMessage($id, $pp, $msg) {
    global $sock, $h, $a;

    $cmd = "MESSAGE " . $id . "." . $pp . "\r\n";
    sendData($cmd);

    $packet = socket_read($sock, 1024, PHP_NORMAL_READ);
    if (!preg_match("/^302\s{1}.*/", $packet)) {
        return false;
    }

    $msgcontent = $msg . "\r\n.\r\n";
    sendData($msgcontent);
    $packet = socket_read($sock, 1024, PHP_NORMAL_READ); //e.g. 102 [1254] Sending message to foo@hotmail.com.
    preg_match("/\[(\d+)\]/", $packet, $matches);
    $packet = socket_read($sock, 1024, PHP_NORMAL_READ); //e.g. 203 [1254] Event done
    preg_match("/\[(\d+)\] Event (.*)/", $packet, $matches2);
    while ($matches[1] != $matches2[1]) {
        //Event tag doesn't match the Event Done tag, keep trying
        $packet = socket_read($sock, 1024, PHP_NORMAL_READ);
        preg_match("/\[(\d+)\]/", $packet, $matches2);
    }
    return $matches2[2];
}

function rmsGetStatus() {
    global $sock;
    $cmd = "STATUS\r\n";
    sendData($cmd);
    $packet = socket_read($sock, 512, PHP_NORMAL_READ);
    $ownerStatus = array();
    while (!preg_match("/^212/", $packet)) {
        list($tmp, $id, $pp, $status) = explode(' ', $packet, 4);
        $ownerStatus[$pp] = array('id' => $id, 'status' => $status);
        $packet = socket_read($sock, 512, PHP_NORMAL_READ);
    }
    return $ownerStatus;
}

function rmsChangeStatus($pp, $status) {
    global $sock;
    $cmd = "STATUS $status.$pp\r\n";
    sendData($cmd);
    $packet = socket_read($sock, 512, PHP_NORMAL_READ);
    while (!preg_match("/^212/", $packet)) {
        $packet = socket_read($sock, 512, PHP_NORMAL_READ);
    }
    return true;
}

function getUserStuff($packet) {
    $id = " ";
    $status = " ";
    $nick = " ";
    $newmsgs = " ";
    $pp = " ";

    // We have a user now, time to manipulate the string!
    $i = 3;
    while ($packet{$i} == ' ') {
        $i++;
    }

    // Grab the id
    while ($packet{$i} != ' ') {
        $id .= $packet{$i};
        $i++;
    }
    $id = trim($id);

    while ($packet{$i} == ' ') {
        $i++;
    }

    // Grab the Protocol
    while ($packet{$i} != ' ') {
        $pp .= $packet{$i};
        $i++;
    }
    $stop = $i;
    $pp = trim($pp);

    // Grab the status
    $i = strlen($packet) - 1;
    while ($packet{$i} == ' ') {
        $i--;
    }
    while (!($packet{$i} >= '0' && $packet{$i} <= '9')) {
        $status .= $packet{$i};
        $i--;
    }
    $status = strrev($status);
    $status = trim($status);

    // Grab the number of new messages
    while ($packet{$i} == ' ') {
        $i--;
    }
    while ($packet{$i} != ' ') {
        $newmsgs .= $packet{$i};
        $i--;
    }
    $newmsgs = strrev($newmsgs);
    $newmsgs = trim($newmsgs);

    // Grab the nick
    while ($packet{$i} == ' ') {
        $i--;
    }
    while ($i > $stop) {
        $nick .= $packet{$i};
        $i--;
    }
    $nick = strrev($nick);
    $nick = kses(trim($nick));

    // Now we have a user, lets build a list struct then display the list
    $user = array('id' => $id, 'nick' => $nick, 'newmsgs' => $newmsgs, 'status' => $status, 'pp' => $pp);
    return $user;
}

function xmlentities ($string) {
   return str_replace (array('&', '"', "'", '<', '>'), array ('&amp;' , '&quot;', '&apos;' , '&lt;' , '&gt;'), $string);
}
?>