keep_alive.c

浏览该文件的文档。

// START OF FILE
/*****************************************************************************/
#include "debug.h"              // gaim_debug
#include "server.h"             // serv_got_update

#include "utils.h"              // uid_to_gaim_name
#include "packet_parse.h"       // create_packet
#include "buddy_list.h"         // qq_send_packet_get_buddies_online
#include "buddy_status.h"       // QQ_BUDDY_ONLINE_NORMAL
#include "crypt.h"              // qq_crypt
#include "header_info.h"        // cmd alias
#include "keep_alive.h"
#include "send_core.h"          // qq_send_cmd

#define QQ_UPDATE_ONLINE_INTERVAL   300 // in sec

/*****************************************************************************/
// send keep-alive packet to QQ server (it is a heart-beat)
void qq_send_packet_keep_alive(GaimConnection * gc)
{
        qq_data *qd;
        guint8 *raw_data, *cursor;

        g_return_if_fail(gc != NULL && gc->proto_data != NULL);

        qd = (qq_data *) gc->proto_data;
        raw_data = g_newa(guint8, 4);
        cursor = raw_data;

        // In fact, we can send whatever we like to server
        // with this command, server return the same result including
        // the amount of online QQ users, my ip and port
        create_packet_dw(raw_data, &cursor, qd->uid);

        qq_send_cmd(gc, QQ_CMD_KEEP_ALIVE, TRUE, 0, TRUE, raw_data, 4);

}                               // qq_send_packet_keep_alive

/*****************************************************************************/
// parse the return of keep-alive packet, it includes some system information
void qq_process_keep_alive_reply(guint8 * buf, gint buf_len, GaimConnection * gc) {
        qq_data *qd;
        gint len;
        gchar *data, **segments;        // the returns are gchar, no need guint8

        g_return_if_fail(gc != NULL && gc->proto_data != NULL);
        g_return_if_fail(buf != NULL && buf_len != 0);

        qd = (qq_data *) gc->proto_data;
        len = buf_len;
        data = g_newa(guint8, len);

        if (qq_crypt(DECRYPT, buf, buf_len, qd->session_key, data, &len)) {
                if (NULL == (segments = split_data(data, len, "\x1f", 6)))
                        return;
                // segments[0] and segment[1] are all 0x30 ("0")
                qd->all_online = strtol(segments[2], NULL, 10);
                g_free(qd->my_ip);
                qd->my_ip = g_strdup(segments[3]);
                qd->my_port = strtol(segments[4], NULL, 10);
                g_strfreev(segments);
        } else
                gaim_debug(GAIM_DEBUG_ERROR, "QQ", "Error decrypt keep alive reply\n");

        // we refresh buddies's online status periodically 
        // qd->lasat_get_online is updated when setting get_buddies_online packet
        if ((time(NULL) - qd->last_get_online) >= QQ_UPDATE_ONLINE_INTERVAL)
                qq_send_packet_get_buddies_online(gc, QQ_FRIENDS_ONLINE_POSITION_START);

}                               // qq_process_keep_alive_reply

/*****************************************************************************/
// refresh all buddies online/offline,
// after receiving reply for get_buddies_online packet 
void qq_refresh_all_buddy_status(GaimConnection * gc)
{
        time_t now;
        GList *list;
        qq_data *qd;
        qq_buddy *q_bud;

        g_return_if_fail(gc != NULL && gc->proto_data != NULL);

        qd = (qq_data *) (gc->proto_data);
        now = time(NULL);
        list = qd->buddies;
        g_return_if_fail(qd != NULL);

        while (list != NULL) {
                q_bud = (qq_buddy *) list->data;
                if (q_bud != NULL && now > q_bud->last_refresh + QQ_UPDATE_ONLINE_INTERVAL) {
                        q_bud->status = QQ_BUDDY_ONLINE_OFFLINE;
                        qq_update_buddy_contact(gc, q_bud);
                }
                list = list->next;
        }                       // while
}                               // qq_refresh_all_buddy_status

/*****************************************************************************/
void qq_update_buddy_contact(GaimConnection * gc, qq_buddy * q_bud)
{
        gchar *name;
        gboolean online;
        GaimBuddy *bud;
        g_return_if_fail(gc != NULL && q_bud != NULL);

        online = is_online(q_bud->status);
        name = uid_to_gaim_name(q_bud->uid);
        bud = gaim_find_buddy(gc->account, name);
        if (bud == NULL) return;

        if (bud != NULL) {
                gaim_blist_alias_buddy(bud, q_bud->nickname);
                q_bud->last_refresh = time(NULL);

                // gaim support signon and idle time
                // but it is not much useful for QQ, I do not use them it
                serv_got_update(gc, name, online, 0, q_bud->signon, q_bud->idle, bud->uc);
        }                       // if bud

        g_free(name);
}                               // qq_update_buddy_contact

/*****************************************************************************/
// END OF FILE

---