pidgin: 2747d5e0: 2008.08.03 - csyfek <csyfek(at)gmail.com...
csyfek at gmail.com
csyfek at gmail.com
Sun Aug 3 01:20:43 EDT 2008
-----------------------------------------------------------------
Revision: 2747d5e0324ca6b81e83bbb8b75e1efebcbbad6e
Ancestor: f92b1358e9dd1e3a6e2f7104325f5ba6d44beeb2
Author: csyfek at gmail.com
Date: 2008-08-03T05:13:29
Branch: im.pidgin.pidgin
URL: http://d.pidgin.im/viewmtn/revision/info/2747d5e0324ca6b81e83bbb8b75e1efebcbbad6e
Added files:
libpurple/protocols/qq/qq_base.c
libpurple/protocols/qq/qq_base.h
libpurple/protocols/qq/qq_process.c
libpurple/protocols/qq/qq_process.h
Modified files:
libpurple/protocols/qq/ChangeLog
ChangeLog:
2008.08.03 - csyfek <csyfek(at)gmail.com>
* Commit lost files to Pidgin
-------------- next part --------------
============================================================
--- libpurple/protocols/qq/qq_base.c 4e74703569de34e00044f6a36aed04c6cb784a26
+++ libpurple/protocols/qq/qq_base.c 4e74703569de34e00044f6a36aed04c6cb784a26
@@ -0,0 +1,523 @@
+/**
+ * @file qq_base.c
+ *
+ * purple
+ *
+ * Purple is the legal property of its developers, whose names are too numerous
+ * to list here. Please refer to the COPYRIGHT file distributed with this
+ * source distribution.
+ *
+ * This program 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.
+ *
+ * This program 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 this program; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02111-1301 USA
+ */
+
+#include "debug.h"
+#include "internal.h"
+#include "server.h"
+#include "cipher.h"
+
+#include "buddy_info.h"
+#include "buddy_list.h"
+#include "char_conv.h"
+#include "crypt.h"
+#include "group.h"
+#include "header_info.h"
+#include "qq_base.h"
+#include "packet_parse.h"
+#include "qq.h"
+#include "qq_network.h"
+#include "utils.h"
+
+#define QQ_LOGIN_DATA_LENGTH 416
+#define QQ_LOGIN_REPLY_OK_PACKET_LEN 139
+#define QQ_LOGIN_REPLY_REDIRECT_PACKET_LEN 11
+
+/* for QQ 2003iii 0117, fixed value */
+/* static const guint8 login_23_51[29] = {
+ 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
+ 0x00, 0x00, 0x00, 0x00, 0xbf, 0x14, 0x11, 0x20,
+ 0x03, 0x9d, 0xb2, 0xe6, 0xb3, 0x11, 0xb7, 0x13,
+ 0x95, 0x67, 0xda, 0x2c, 0x01
+}; */
+
+/* for QQ 2003iii 0304, fixed value */
+/*
+static const guint8 login_23_51[29] = {
+ 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
+ 0x00, 0x00, 0x00, 0x00, 0x9a, 0x93, 0xfe, 0x85,
+ 0xd3, 0xd9, 0x2a, 0x41, 0xc8, 0x0d, 0xff, 0xb6,
+ 0x40, 0xb8, 0xac, 0x32, 0x01
+};
+*/
+
+/* for QQ 2005? copy from lumaqq */
+/* FIXME: change to guint8 */
+static const guint8 login_23_51[29] = {
+ 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
+ 0x00, 0x00, 0x00, 0x00, 0x86, 0xcc, 0x4c, 0x35,
+ 0x2c, 0xd3, 0x73, 0x6c, 0x14, 0xf6, 0xf6, 0xaf,
+ 0xc3, 0xfa, 0x33, 0xa4, 0x01
+};
+
+static const guint8 login_53_68[16] = {
+ 0x8D, 0x8B, 0xFA, 0xEC, 0xD5, 0x52, 0x17, 0x4A,
+ 0x86, 0xF9, 0xA7, 0x75, 0xE6, 0x32, 0xD1, 0x6D
+};
+
+static const guint8 login_100_bytes[100] = {
+ 0x40, 0x0B, 0x04, 0x02, 0x00, 0x01, 0x00, 0x00,
+ 0x00, 0x00, 0x00, 0x03, 0x09, 0x00, 0x00, 0x00,
+ 0x00, 0x00, 0x00, 0x00, 0x01, 0xE9, 0x03, 0x01,
+ 0x00, 0x00, 0x00, 0x00, 0x00, 0x01, 0xF3, 0x03,
+ 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x01, 0xED,
+ 0x03, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x01,
+ 0xEC, 0x03, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
+ 0x03, 0x05, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
+ 0x00, 0x03, 0x07, 0x00, 0x00, 0x00, 0x00, 0x00,
+ 0x00, 0x00, 0x01, 0xEE, 0x03, 0x00, 0x00, 0x00,
+ 0x00, 0x00, 0x00, 0x01, 0xEF, 0x03, 0x00, 0x00,
+ 0x00, 0x00, 0x00, 0x00, 0x01, 0xEB, 0x03, 0x00,
+ 0x00, 0x00, 0x00, 0x00
+};
+
+
+/* fixed value, not affected by version, or mac address */
+/*
+static const guint8 login_53_68[16] = {
+ 0x82, 0x2a, 0x91, 0xfd, 0xa5, 0xca, 0x67, 0x4c,
+ 0xac, 0x81, 0x1f, 0x6f, 0x52, 0x05, 0xa7, 0xbf
+};
+*/
+
+
+typedef struct _qq_login_reply_ok qq_login_reply_ok_packet;
+typedef struct _qq_login_reply_redirect qq_login_reply_redirect_packet;
+
+struct _qq_login_reply_ok {
+ guint8 result;
+ guint8 session_key[QQ_KEY_LENGTH];
+ guint32 uid;
+ struct in_addr client_ip; /* those detected by server */
+ guint16 client_port;
+ struct in_addr server_ip;
+ guint16 server_port;
+ time_t login_time;
+ guint8 unknown1[26];
+ struct in_addr unknown_server1_ip;
+ guint16 unknown_server1_port;
+ struct in_addr unknown_server2_ip;
+ guint16 unknown_server2_port;
+ guint16 unknown2; /* 0x0001 */
+ guint16 unknown3; /* 0x0000 */
+ guint8 unknown4[32];
+ guint8 unknown5[12];
+ struct in_addr last_client_ip;
+ time_t last_login_time;
+ guint8 unknown6[8];
+};
+
+struct _qq_login_reply_redirect {
+ guint8 result;
+ guint32 uid;
+ struct in_addr new_server_ip;
+ guint16 new_server_port;
+};
+
+/* generate a md5 key using uid and session_key */
+static void get_session_md5(guint8 *session_md5, guint32 uid, guint8 *session_key)
+{
+ guint8 src[QQ_KEY_LENGTH + QQ_KEY_LENGTH];
+ gint bytes = 0;
+
+ bytes += qq_put32(src + bytes, uid);
+ bytes += qq_putdata(src + bytes, session_key, QQ_KEY_LENGTH);
+
+ qq_get_md5(session_md5, QQ_KEY_LENGTH, src, bytes);
+}
+
+/* process login reply which says OK */
+static gint8 process_login_ok(PurpleConnection *gc, guint8 *data, gint len)
+{
+ gint bytes;
+ qq_data *qd;
+ qq_login_reply_ok_packet lrop;
+
+ qd = (qq_data *) gc->proto_data;
+ /* FIXME, check QQ_LOGIN_REPLY_OK_PACKET_LEN here */
+ bytes = 0;
+
+ /* 000-000: reply code */
+ bytes += qq_get8(&lrop.result, data + bytes);
+ /* 001-016: session key */
+ bytes += qq_getdata(lrop.session_key, sizeof(lrop.session_key), data + bytes);
+ purple_debug(PURPLE_DEBUG_INFO, "QQ", "Get session_key done\n");
+ /* 017-020: login uid */
+ bytes += qq_get32(&lrop.uid, data + bytes);
+ /* 021-024: server detected user public IP */
+ bytes += qq_getIP(&lrop.client_ip, data + bytes);
+ /* 025-026: server detected user port */
+ bytes += qq_get16(&lrop.client_port, data + bytes);
+ /* 027-030: server detected itself ip 127.0.0.1 ? */
+ bytes += qq_getIP(&lrop.server_ip, data + bytes);
+ /* 031-032: server listening port */
+ bytes += qq_get16(&lrop.server_port, data + bytes);
+ /* 033-036: login time for current session */
+ bytes += qq_getime(&lrop.login_time, data + bytes);
+ /* 037-062: 26 bytes, unknown */
+ bytes += qq_getdata((guint8 *) &lrop.unknown1, 26, data + bytes);
+ /* 063-066: unknown server1 ip address */
+ bytes += qq_getIP(&lrop.unknown_server1_ip, data + bytes);
+ /* 067-068: unknown server1 port */
+ bytes += qq_get16(&lrop.unknown_server1_port, data + bytes);
+ /* 069-072: unknown server2 ip address */
+ bytes += qq_getIP(&lrop.unknown_server2_ip, data + bytes);
+ /* 073-074: unknown server2 port */
+ bytes += qq_get16(&lrop.unknown_server2_port, data + bytes);
+ /* 075-076: 2 bytes unknown */
+ bytes += qq_get16(&lrop.unknown2, data + bytes);
+ /* 077-078: 2 bytes unknown */
+ bytes += qq_get16(&lrop.unknown3, data + bytes);
+ /* 079-110: 32 bytes unknown */
+ bytes += qq_getdata((guint8 *) &lrop.unknown4, 32, data + bytes);
+ /* 111-122: 12 bytes unknown */
+ bytes += qq_getdata((guint8 *) &lrop.unknown5, 12, data + bytes);
+ /* 123-126: login IP of last session */
+ bytes += qq_getIP(&lrop.last_client_ip, data + bytes);
+ /* 127-130: login time of last session */
+ bytes += qq_getime(&lrop.last_login_time, data + bytes);
+ /* 131-138: 8 bytes unknown */
+ bytes += qq_getdata((guint8 *) &lrop.unknown6, 8, data + bytes);
+
+ if (bytes != QQ_LOGIN_REPLY_OK_PACKET_LEN) { /* fail parsing login info */
+ purple_debug(PURPLE_DEBUG_WARNING, "QQ",
+ "Fail parsing login info, expect %d bytes, read %d bytes\n",
+ QQ_LOGIN_REPLY_OK_PACKET_LEN, bytes);
+ } /* but we still go on as login OK */
+
+ memcpy(qd->session_key, lrop.session_key, sizeof(qd->session_key));
+ get_session_md5(qd->session_md5, qd->uid, qd->session_key);
+
+ qd->my_ip.s_addr = lrop.client_ip.s_addr;
+
+ qd->my_port = lrop.client_port;
+ qd->login_time = lrop.login_time;
+ qd->last_login_time = lrop.last_login_time;
+ qd->last_login_ip = g_strdup( inet_ntoa(lrop.last_client_ip) );
+
+ return QQ_LOGIN_REPLY_OK;
+}
+
+/* process login reply packet which includes redirected new server address */
+static gint8 process_login_redirect(PurpleConnection *gc, guint8 *data, gint len)
+{
+ qq_data *qd;
+ gint bytes;
+ qq_login_reply_redirect_packet lrrp;
+
+ qd = (qq_data *) gc->proto_data;
+ bytes = 0;
+ /* 000-000: reply code */
+ bytes += qq_get8(&lrrp.result, data + bytes);
+ /* 001-004: login uid */
+ bytes += qq_get32(&lrrp.uid, data + bytes);
+ /* 005-008: redirected new server IP */
+ bytes += qq_getIP(&lrrp.new_server_ip, data + bytes);
+ /* 009-010: redirected new server port */
+ bytes += qq_get16(&lrrp.new_server_port, data + bytes);
+
+ if (bytes != QQ_LOGIN_REPLY_REDIRECT_PACKET_LEN) {
+ purple_debug(PURPLE_DEBUG_ERROR, "QQ",
+ "Fail parsing login redirect packet, expect %d bytes, read %d bytes\n",
+ QQ_LOGIN_REPLY_REDIRECT_PACKET_LEN, bytes);
+ return QQ_LOGIN_REPLY_ERR_MISC;
+ }
+
+ /* redirect to new server, do not disconnect or connect here
+ * those connect should be called at packet_process */
+ if (qd->real_hostname) {
+ purple_debug(PURPLE_DEBUG_INFO, "QQ", "free real_hostname\n");
+ g_free(qd->real_hostname);
+ qd->real_hostname = NULL;
+ }
+ qd->real_hostname = g_strdup( inet_ntoa(lrrp.new_server_ip) );
+ qd->real_port = lrrp.new_server_port;
+
+ return QQ_LOGIN_REPLY_REDIRECT;
+}
+
+/* process login reply which says wrong password */
+static gint8 process_login_wrong_pwd(PurpleConnection *gc, guint8 *data, gint len)
+{
+ gchar *server_reply, *server_reply_utf8;
+ server_reply = g_new0(gchar, len);
+ g_memmove(server_reply, data + 1, len - 1);
+ server_reply_utf8 = qq_to_utf8(server_reply, QQ_CHARSET_DEFAULT);
+ purple_debug(PURPLE_DEBUG_ERROR, "QQ", "Wrong password, server msg in UTF8: %s\n", server_reply_utf8);
+ g_free(server_reply);
+ g_free(server_reply_utf8);
+
+ return QQ_LOGIN_REPLY_ERR_PWD;
+}
+
+/* request before login */
+void qq_send_packet_token(PurpleConnection *gc)
+{
+ qq_data *qd;
+ guint8 buf[16] = {0};
+ gint bytes = 0;
+
+ g_return_if_fail(gc != NULL && gc->proto_data != NULL);
+ qd = (qq_data *) gc->proto_data;
+
+ bytes += qq_put8(buf + bytes, 0);
+
+ qd->send_seq++;
+ qq_send_data(qd, QQ_CMD_TOKEN, qd->send_seq, TRUE, buf, bytes);
+}
+
+/* send login packet to QQ server */
+void qq_send_packet_login(PurpleConnection *gc)
+{
+ qq_data *qd;
+ guint8 *buf, *raw_data;
+ gint bytes;
+ guint8 *encrypted_data;
+ gint encrypted_len;
+
+ g_return_if_fail(gc != NULL && gc->proto_data != NULL);
+ qd = (qq_data *) gc->proto_data;
+
+ g_return_if_fail(qd->token != NULL && qd->token_len > 0);
+
+ raw_data = g_newa(guint8, QQ_LOGIN_DATA_LENGTH);
+ memset(raw_data, 0, QQ_LOGIN_DATA_LENGTH);
+
+ encrypted_data = g_newa(guint8, QQ_LOGIN_DATA_LENGTH + 16); /* 16 bytes more */
+#ifdef DEBUG
+ memset(qd->inikey, 0x01, sizeof(qd->inikey));
+#else
+ for (bytes = 0; bytes < sizeof(qd->inikey); bytes++) {
+ qd->inikey[bytes] = (guint8) (g_random_int_range(0, 255) % 256);
+ }
+#endif
+
+ bytes = 0;
+ /* now generate the encrypted data
+ * 000-015 use password_twice_md5 as key to encrypt empty string */
+ qq_encrypt((guint8 *) "", 0, qd->password_twice_md5, raw_data + bytes, &encrypted_len);
+ bytes += 16;
+ /* 016-016 */
+ bytes += qq_put8(raw_data + bytes, 0x00);
+ /* 017-020, used to be IP, now zero */
+ bytes += qq_put32(raw_data + bytes, 0x00000000);
+ /* 021-022, used to be port, now zero */
+ bytes += qq_put16(raw_data + bytes, 0x0000);
+ /* 023-051, fixed value, unknown */
+ bytes += qq_putdata(raw_data + bytes, login_23_51, 29);
+ /* 052-052, login mode */
+ bytes += qq_put8(raw_data + bytes, qd->login_mode);
+ /* 053-068, fixed value, maybe related to per machine */
+ bytes += qq_putdata(raw_data + bytes, login_53_68, 16);
+ /* 069, login token length */
+ bytes += qq_put8(raw_data + bytes, qd->token_len);
+ /* 070-093, login token, normally 24 bytes */
+ bytes += qq_putdata(raw_data + bytes, qd->token, qd->token_len);
+ /* 100 bytes unknown */
+ bytes += qq_putdata(raw_data + bytes, login_100_bytes, 100);
+ /* all zero left */
+
+ qq_encrypt(raw_data, QQ_LOGIN_DATA_LENGTH, qd->inikey, encrypted_data, &encrypted_len);
+
+ buf = g_newa(guint8, MAX_PACKET_SIZE);
+ memset(buf, 0, MAX_PACKET_SIZE);
+ bytes = 0;
+ bytes += qq_putdata(buf + bytes, qd->inikey, QQ_KEY_LENGTH);
+ bytes += qq_putdata(buf + bytes, encrypted_data, encrypted_len);
+
+ qd->send_seq++;
+ qq_send_data(qd, QQ_CMD_LOGIN, qd->send_seq, TRUE, buf, bytes);
+}
+
+guint8 qq_process_token_reply(PurpleConnection *gc, gchar *error_msg, guint8 *buf, gint buf_len)
+{
+ qq_data *qd;
+ guint8 ret;
+ int token_len;
+
+ g_return_val_if_fail(buf != NULL && buf_len != 0, -1);
+
+ g_return_val_if_fail(gc != NULL && gc->proto_data != NULL, -1);
+ qd = (qq_data *) gc->proto_data;
+
+ ret = buf[0];
+
+ if (ret != QQ_TOKEN_REPLY_OK) {
+ purple_debug(PURPLE_DEBUG_ERROR, "QQ", "Unknown request login token reply code : %d\n", buf[0]);
+ qq_hex_dump(PURPLE_DEBUG_WARNING, "QQ",
+ buf, buf_len,
+ ">>> [default] decrypt and dump");
+ error_msg = try_dump_as_gbk(buf, buf_len);
+ return ret;
+ }
+
+ token_len = buf_len-2;
+ if (token_len <= 0) {
+ error_msg = g_strdup_printf( _("Invalid token len, %d"), token_len);
+ return -1;
+ }
+
+ if (buf[1] != token_len) {
+ purple_debug(PURPLE_DEBUG_INFO, "QQ",
+ "Invalid token len. Packet specifies length of %d, actual length is %d\n", buf[1], buf_len-2);
+ }
+ qq_hex_dump(PURPLE_DEBUG_INFO, "QQ",
+ buf+2, token_len,
+ "<<< got a token -> [default] decrypt and dump");
+
+ qd->token = g_new0(guint8, token_len);
+ qd->token_len = token_len;
+ g_memmove(qd->token, buf + 2, qd->token_len);
+ return ret;
+}
+
+/* send logout packets to QQ server */
+void qq_send_packet_logout(PurpleConnection *gc)
+{
+ gint i;
+ qq_data *qd;
+
+ qd = (qq_data *) gc->proto_data;
+ for (i = 0; i < 4; i++)
+ qq_send_cmd_detail(qd, QQ_CMD_LOGOUT, 0xffff, FALSE, qd->password_twice_md5, QQ_KEY_LENGTH);
+
+ qd->logged_in = FALSE; /* update login status AFTER sending logout packets */
+}
+
+/* process the login reply packet */
+guint8 qq_process_login_reply(guint8 *buf, gint buf_len, PurpleConnection *gc)
+{
+ qq_data *qd;
+ guint8 *data;
+ gint data_len;
+ gchar* error_msg;
+
+ g_return_val_if_fail(buf != NULL && buf_len != 0, QQ_LOGIN_REPLY_ERR_MISC);
+
+ qd = (qq_data *) gc->proto_data;
+
+ data_len = buf_len;
+ data = g_newa(guint8, data_len);
+
+ if (qq_decrypt(buf, buf_len, qd->inikey, data, &data_len)) {
+ purple_debug(PURPLE_DEBUG_WARNING, "QQ",
+ "Decrypt login reply packet with inikey, %d bytes\n", data_len);
+ } else {
+ /* reset data_len since it may changed */
+ data_len = buf_len;
+ if (qq_decrypt(buf, buf_len, qd->password_twice_md5, data, &data_len)) {
+ purple_debug(PURPLE_DEBUG_INFO, "QQ",
+ "Decrypt login reply packet with password_twice_md5, %d bytes\n", data_len);
+ } else {
+ purple_debug(PURPLE_DEBUG_ERROR, "QQ",
+ "No idea how to decrypt login reply\n");
+ return QQ_LOGIN_REPLY_ERR_MISC;
+ }
+ }
+
+ switch (data[0]) {
+ case QQ_LOGIN_REPLY_OK:
+ purple_debug(PURPLE_DEBUG_INFO, "QQ", "Login reply is OK\n");
+ return process_login_ok(gc, data, data_len);
+ case QQ_LOGIN_REPLY_REDIRECT:
+ purple_debug(PURPLE_DEBUG_INFO, "QQ", "Login reply is redirect\n");
+ return process_login_redirect(gc, data, data_len);
+ case QQ_LOGIN_REPLY_ERR_PWD:
+ purple_debug(PURPLE_DEBUG_INFO, "QQ", "Login reply is error password\n");
+ return process_login_wrong_pwd(gc, data, data_len);
+ case QQ_LOGIN_REPLY_NEED_REACTIVE:
+ case QQ_LOGIN_REPLY_REDIRECT_EX:
+ purple_debug(PURPLE_DEBUG_INFO, "QQ", "Login reply is not actived or redirect extend\n");
+ default:
+ break;
+ }
+
+ purple_debug(PURPLE_DEBUG_ERROR, "QQ", "Unknown reply code: %d\n", data[0]);
+ qq_hex_dump(PURPLE_DEBUG_WARNING, "QQ",
+ data, data_len,
+ ">>> [default] decrypt and dump");
+ error_msg = try_dump_as_gbk(data, data_len);
+ if (error_msg) {
+ purple_connection_error_reason(gc, PURPLE_CONNECTION_ERROR_NETWORK_ERROR, error_msg);
+ g_free(error_msg);
+ }
+ return QQ_LOGIN_REPLY_ERR_MISC;
+}
+
+/* send keep-alive packet to QQ server (it is a heart-beat) */
+void qq_send_packet_keep_alive(PurpleConnection *gc)
+{
+ qq_data *qd;
+ guint8 raw_data[16] = {0};
+ gint bytes= 0;
+
+ qd = (qq_data *) gc->proto_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 */
+ bytes += qq_put32(raw_data + bytes, qd->uid);
+
+ qq_send_cmd(qd, QQ_CMD_KEEP_ALIVE, raw_data, 4);
+}
+
+/* parse the return of keep-alive packet, it includes some system information */
+gboolean qq_process_keep_alive(guint8 *buf, gint buf_len, PurpleConnection *gc)
+{
+ qq_data *qd;
+ gint len;
+ gchar **segments;
+ guint8 *data;
+
+ g_return_val_if_fail(buf != NULL && buf_len != 0, FALSE);
+
+ qd = (qq_data *) gc->proto_data;
+ len = buf_len;
+ data = g_newa(guint8, len);
+
+ if ( !qq_decrypt(buf, buf_len, qd->session_key, data, &len) ) {
+ purple_debug(PURPLE_DEBUG_ERROR, "QQ", "Error decrypt keep alive reply\n");
+ return FALSE;
+ }
+
+ /* qq_show_packet("Keep alive reply packet", data, len); */
+
+ /* the last one is 60, don't know what it is */
+ if (NULL == (segments = split_data(data, len, "\x1f", 6)))
+ return TRUE;
+
+ /* segments[0] and segment[1] are all 0x30 ("0") */
+ qd->total_online = strtol(segments[2], NULL, 10);
+ if(0 == qd->total_online) {
+ purple_connection_error_reason(gc, PURPLE_CONNECTION_ERROR_NETWORK_ERROR,
+ _("Keep alive error"));
+ }
+ qd->my_ip.s_addr = inet_addr(segments[3]);
+ qd->my_port = strtol(segments[4], NULL, 10);
+
+ purple_debug(PURPLE_DEBUG_INFO, "QQ", "keep alive, %s:%d\n",
+ inet_ntoa(qd->my_ip), qd->my_port);
+
+ g_strfreev(segments);
+ return TRUE;
+}
============================================================
--- libpurple/protocols/qq/qq_base.h 1432e2c23df0251a58eeec56798e3281bf94cd17
+++ libpurple/protocols/qq/qq_base.h 1432e2c23df0251a58eeec56798e3281bf94cd17
@@ -0,0 +1,56 @@
+/**
+ * file qq_base.h
+ *
+ * purple
+ *
+ * Purple is the legal property of its developers, whose names are too numerous
+ * to list here. Please refer to the COPYRIGHT file distributed with this
+ * source distribution.
+ *
+ * This program 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.
+ *
+ * This program 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 this program; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02111-1301 USA
+ */
+
+#ifndef _QQ_BASE_H_
+#define _QQ_BASE_H_
+
+#include <glib.h>
+#include "connection.h"
+
+#define QQ_TOKEN_REPLY_OK 0x00
+
+#define QQ_LOGIN_REPLY_OK 0x00
+#define QQ_LOGIN_REPLY_REDIRECT 0x01
+#define QQ_LOGIN_REPLY_ERR_PWD 0x05
+#define QQ_LOGIN_REPLY_NEED_REACTIVE 0x06
+#define QQ_LOGIN_REPLY_REDIRECT_EX 0x0A
+#define QQ_LOGIN_REPLY_ERR_MISC 0xff /* defined by myself */
+
+#define QQ_LOGIN_MODE_NORMAL 0x0a
+#define QQ_LOGIN_MODE_AWAY 0x1e
+#define QQ_LOGIN_MODE_HIDDEN 0x28
+
+#define QQ_UPDATE_ONLINE_INTERVAL 300 /* in sec */
+
+void qq_send_packet_token(PurpleConnection *gc);
+guint8 qq_process_token_reply(PurpleConnection *gc, gchar *error_msg, guint8 *buf, gint buf_len);
+
+void qq_send_packet_login(PurpleConnection *gc);
+guint8 qq_process_login_reply(guint8 *buf, gint buf_len, PurpleConnection *gc);
+
+void qq_send_packet_logout(PurpleConnection *gc);
+
+void qq_send_packet_keep_alive(PurpleConnection *gc);
+gboolean qq_process_keep_alive(guint8 *buf, gint buf_len, PurpleConnection *gc);
+#endif
============================================================
--- libpurple/protocols/qq/qq_process.c 69944268ca7cb43ba17e523a46bd6deae2bcb4f2
+++ libpurple/protocols/qq/qq_process.c 69944268ca7cb43ba17e523a46bd6deae2bcb4f2
@@ -0,0 +1,267 @@
+/**
+ * @file qq_network.c
+ *
+ * purple
+ *
+ * Purple is the legal property of its developers, whose names are too numerous
+ * to list here. Please refer to the COPYRIGHT file distributed with this
+ * source distribution.
+ *
+ * This program 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.
+ *
+ * This program 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 this program; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02111-1301 USA
+ */
+
+#include "cipher.h"
+#include "debug.h"
+#include "internal.h"
+
+#ifdef _WIN32
+#define random rand
+#define srandom srand
+#endif
+
+#include "buddy_info.h"
+#include "buddy_list.h"
+#include "buddy_opt.h"
+#include "group_info.h"
+#include "group_free.h"
+#include "char_conv.h"
+#include "crypt.h"
+#include "group_network.h"
+#include "header_info.h"
+#include "qq_base.h"
+#include "im.h"
+#include "qq_process.h"
+#include "packet_parse.h"
+#include "qq_network.h"
+#include "qq_trans.h"
+#include "sys_msg.h"
+#include "utils.h"
+
+/* default process, decrypt and dump */
+static void process_cmd_unknow(PurpleConnection *gc,gchar *title, guint8 *buf, gint buf_len, guint16 cmd, guint16 seq)
+{
+ qq_data *qd;
+ guint8 *data;
+ gint data_len;
+ gchar *msg_utf8 = NULL;
+
+ g_return_if_fail(buf != NULL && buf_len != 0);
+
+ qq_show_packet(title, buf, buf_len);
+
+ qd = (qq_data *) gc->proto_data;
+
+ data_len = buf_len;
+ data = g_newa(guint8, data_len);
+ memset(data, 0, data_len);
+ if ( !qq_decrypt(buf, buf_len, qd->session_key, data, &data_len )) {
+ purple_debug(PURPLE_DEBUG_ERROR, "QQ", "Fail decrypt packet with default process\n");
+ return;
+ }
+
+ qq_hex_dump(PURPLE_DEBUG_WARNING, "QQ",
+ data, data_len,
+ ">>> [%d] %s -> [default] decrypt and dump",
+ seq, qq_get_cmd_desc(cmd));
+
+ msg_utf8 = try_dump_as_gbk(data, data_len);
+ if (msg_utf8) {
+ g_free(msg_utf8);
+ }
+}
+
+void qq_proc_cmd_server(PurpleConnection *gc,
+ guint16 cmd, guint16 seq, guint8 *data, gint data_len)
+{
+ /* now process the packet */
+ switch (cmd) {
+ case QQ_CMD_RECV_IM:
+ qq_process_recv_im(data, data_len, seq, gc);
+ break;
+ case QQ_CMD_RECV_MSG_SYS:
+ qq_process_msg_sys(data, data_len, seq, gc);
+ break;
+ case QQ_CMD_RECV_MSG_BUDDY_CHANGE_STATUS:
+ qq_process_buddy_change_status(data, data_len, gc);
+ break;
+ default:
+ process_cmd_unknow(gc, "Unknow SERVER CMD", data, data_len, cmd, seq);
+ break;
+ }
+}
+
+static void process_cmd_login(PurpleConnection *gc, guint8 *data, gint data_len)
+{
+ qq_data *qd;
+ guint ret_8;
+
+ g_return_if_fail (gc != NULL && gc->proto_data != NULL);
+
+ qd = (qq_data *) gc->proto_data;
+
+ ret_8 = qq_process_login_reply(data, data_len, gc);
+ if (ret_8 == QQ_LOGIN_REPLY_OK) {
+ purple_debug(PURPLE_DEBUG_INFO, "QQ", "Login repliess OK; everything is fine\n");
+
+ purple_connection_set_state(gc, PURPLE_CONNECTED);
+ qd->logged_in = TRUE; /* must be defined after sev_finish_login */
+
+ /* now initiate QQ Qun, do it first as it may take longer to finish */
+ qq_group_init(gc);
+
+ /* Now goes on updating my icon/nickname, not showing info_window */
+ qd->modifying_face = FALSE;
+
+ qq_send_packet_get_info(gc, qd->uid, FALSE);
+ /* grab my level */
+ qq_send_packet_get_level(gc, qd->uid);
+
+ qq_send_packet_change_status(gc);
+
+ /* refresh buddies */
+ qq_send_packet_get_buddies_list(gc, 0);
+
+ /* refresh groups */
+ qq_send_packet_get_all_list_with_group(gc, 0);
+
+ return;
+ }
+
+ if (ret_8 == QQ_LOGIN_REPLY_REDIRECT) {
+ qd->is_redirect = TRUE;
+ /*
+ purple_debug(PURPLE_DEBUG_WARNING, "QQ",
+ "Redirected to new server: %s:%d\n", qd->real_hostname, qd->real_port);
+ */
+ return;
+ }
+
+ if (ret_8 == QQ_LOGIN_REPLY_ERR_PWD) {
+ if (!purple_account_get_remember_password(gc->account)) {
+ purple_account_set_password(gc->account, NULL);
+ }
+ purple_connection_error_reason(gc,
+ PURPLE_CONNECTION_ERROR_AUTHENTICATION_FAILED, _("Incorrect password."));
+ return;
+ }
+
+ if (ret_8 == QQ_LOGIN_REPLY_ERR_MISC) {
+ if (purple_debug_is_enabled())
+ purple_connection_error_reason(gc,
+ PURPLE_CONNECTION_ERROR_NETWORK_ERROR, _("Unable to login. Check debug log."));
+ else
+ purple_connection_error_reason(gc,
+ PURPLE_CONNECTION_ERROR_NETWORK_ERROR, _("Unable to login"));
+ return;
+ }
+}
+
+void qq_proc_cmd_reply(PurpleConnection *gc,
+ guint16 cmd, guint16 seq, guint8 *data, gint data_len)
+{
+ gboolean ret_bool = FALSE;
+ guint8 ret_8 = 0;
+ guint16 ret_16 = 0;
+ guint32 ret_32 = 0;
+ gchar *error_msg = NULL;
+
+ switch (cmd) {
+ case QQ_CMD_TOKEN:
+ ret_8 = qq_process_token_reply(gc, error_msg, data, data_len);
+ if (ret_8 != QQ_TOKEN_REPLY_OK) {
+ if (error_msg == NULL) {
+ error_msg = g_strdup_printf( _("Invalid token reply code, 0x%02X"), ret_8);
+ }
+ purple_connection_error_reason(gc, PURPLE_CONNECTION_ERROR_NETWORK_ERROR, error_msg);
+ g_free(error_msg);
+ return;
+ }
+
+ qq_send_packet_login(gc);
+ break;
+ case QQ_CMD_LOGIN:
+ process_cmd_login(gc, data, data_len);
+ break;
+ case QQ_CMD_UPDATE_INFO:
+ qq_process_modify_info_reply(data, data_len, gc);
+ break;
+ case QQ_CMD_ADD_BUDDY_WO_AUTH:
+ qq_process_add_buddy_reply(data, data_len, seq, gc);
+ break;
+ case QQ_CMD_DEL_BUDDY:
+ qq_process_remove_buddy_reply(data, data_len, gc);
+ break;
+ case QQ_CMD_REMOVE_SELF:
+ qq_process_remove_self_reply(data, data_len, gc);
+ break;
+ case QQ_CMD_BUDDY_AUTH:
+ qq_process_add_buddy_auth_reply(data, data_len, gc);
+ break;
+ case QQ_CMD_GET_USER_INFO:
+ qq_process_get_info_reply(data, data_len, gc);
+ break;
+ case QQ_CMD_CHANGE_ONLINE_STATUS:
+ qq_process_change_status_reply(data, data_len, gc);
+ break;
+ case QQ_CMD_SEND_IM:
+ qq_process_send_im_reply(data, data_len, gc);
+ break;
+ case QQ_CMD_KEEP_ALIVE:
+ qq_process_keep_alive(data, data_len, gc);
+ break;
+ case QQ_CMD_GET_BUDDIES_ONLINE:
+ ret_8 = qq_process_get_buddies_online_reply(data, data_len, gc);
+ if (ret_8 > 0 && ret_8 < 0xff) {
+ purple_debug(PURPLE_DEBUG_INFO, "QQ", "Requesting for more online buddies\n");
+ qq_send_packet_get_buddies_online(gc, ret_8);
+ } else {
+ purple_debug(PURPLE_DEBUG_INFO, "QQ", "All online buddies received\n");
+ /* Fixme: this should not be called once*/
+ qq_send_packet_get_buddies_levels(gc);
+
+ qq_refresh_all_buddy_status(gc);
+ }
+ break;
+ case QQ_CMD_GET_LEVEL:
+ qq_process_get_level_reply(data, data_len, gc);
+ break;
+ case QQ_CMD_GET_BUDDIES_LIST:
+ ret_16 = qq_process_get_buddies_list_reply(data, data_len, gc);
+ if (ret_16 > 0 && ret_16 < 0xffff) {
+ purple_debug(PURPLE_DEBUG_INFO, "QQ", "Requesting for more buddies\n");
+ qq_send_packet_get_buddies_list(gc, ret_16);
+ } else {
+ purple_debug(PURPLE_DEBUG_INFO, "QQ", "All buddies received. Requesting buddies' levels\n");
+ qq_send_packet_get_buddies_online(gc, 0);
+ }
+ break;
+ case QQ_CMD_GROUP_CMD:
+ qq_process_group_cmd_reply(data, data_len, seq, gc);
+ break;
+ case QQ_CMD_GET_ALL_LIST_WITH_GROUP:
+ ret_32 = qq_process_get_all_list_with_group_reply(data, data_len, gc);
+ if (ret_32 > 0 && ret_32 < 0xffffffff) {
+ purple_debug(PURPLE_DEBUG_INFO, "QQ", "Requesting for more buddies and groups\n");
+ qq_send_packet_get_all_list_with_group(gc, ret_32);
+ } else {
+ purple_debug(PURPLE_DEBUG_INFO, "QQ", "All buddies and groups received\n");
+ }
+ break;
+ default:
+ process_cmd_unknow(gc, "Unknow reply CMD", data, data_len, cmd, seq);
+ break;
+ }
+}
+
============================================================
--- libpurple/protocols/qq/qq_process.h 3c6cc46da9190a223a0e1397d4f01cc3876a6cef
+++ libpurple/protocols/qq/qq_process.h 3c6cc46da9190a223a0e1397d4f01cc3876a6cef
@@ -0,0 +1,38 @@
+/**
+ * @file qq_process.h
+ *
+ * purple
+ *
+ * Purple is the legal property of its developers, whose names are too numerous
+ * to list here. Please refer to the COPYRIGHT file distributed with this
+ * source distribution.
+ *
+ * This program 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.
+ *
+ * This program 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 this program; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02111-1301 USA
+ */
+
+#ifndef _QQ_PROCESS_H
+#define _QQ_PROCESS_H
+
+#include <glib.h>
+#include "connection.h"
+
+#include "qq.h"
+
+void qq_proc_cmd_reply(PurpleConnection *gc,
+ guint16 cmd, guint16 seq, guint8 *data, gint data_len);
+void qq_proc_cmd_server(PurpleConnection *gc,
+ guint16 cmd, guint16 seq, guint8 *data, gint data_len);
+#endif
+
============================================================
--- libpurple/protocols/qq/ChangeLog 7e7c75bdf3dc9c5f02470a641ce2dba6711be52e
+++ libpurple/protocols/qq/ChangeLog e8dd5eb3ab6025809bdca23140286e3b1c465b96
@@ -1,3 +1,6 @@
+2008.08.03 - csyfek <csyfek(at)gmail.com>
+ * Commit lost files to Pidgin
+
2008.08.02 - csyfek <csyfek(at)gmail.com>
* Commit to Pidgin
* Tickets:
More information about the Commits
mailing list