diff options
Diffstat (limited to 'libpurple/protocols/qq/group_network.c')
| -rw-r--r-- | libpurple/protocols/qq/group_network.c | 248 |
1 files changed, 248 insertions, 0 deletions
diff --git a/libpurple/protocols/qq/group_network.c b/libpurple/protocols/qq/group_network.c new file mode 100644 index 0000000000..af66e23b7a --- /dev/null +++ b/libpurple/protocols/qq/group_network.c @@ -0,0 +1,248 @@ +/** + * @file group_network.c + * + * gaim + * + * Gaim 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., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA + */ + +#include "debug.h" +#include "notify.h" + +#include "char_conv.h" +#include "crypt.h" +#include "group_conv.h" +#include "group_find.h" +#include "group_internal.h" +#include "group_im.h" +#include "group_info.h" +#include "group_join.h" +#include "group_network.h" +#include "group_opt.h" +#include "group_search.h" +#include "header_info.h" +#include "send_core.h" +#include "utils.h" + +enum { + QQ_GROUP_CMD_REPLY_OK = 0x00, + QQ_GROUP_CMD_REPLY_SEARCH_ERROR = 0x02, + QQ_GROUP_CMD_REPLY_NOT_MEMBER = 0x0a +}; + +const gchar *qq_group_cmd_get_desc(qq_group_cmd cmd) +{ + switch (cmd) { + case QQ_GROUP_CMD_CREATE_GROUP: + return "QQ_GROUP_CMD_CREATE_GROUP"; + case QQ_GROUP_CMD_MEMBER_OPT: + return "QQ_GROUP_CMD_MEMBER_OPT"; + case QQ_GROUP_CMD_MODIFY_GROUP_INFO: + return "QQ_GROUP_CMD_MODIFY_GROUP_INFO"; + case QQ_GROUP_CMD_GET_GROUP_INFO: + return "QQ_GROUP_CMD_GET_GROUP_INFO"; + case QQ_GROUP_CMD_ACTIVATE_GROUP: + return "QQ_GROUP_CMD_ACTIVATE_GROUP"; + case QQ_GROUP_CMD_SEARCH_GROUP: + return "QQ_GROUP_CMD_SEARCH_GROUP"; + case QQ_GROUP_CMD_JOIN_GROUP: + return "QQ_GROUP_CMD_JOIN_GROUP"; + case QQ_GROUP_CMD_JOIN_GROUP_AUTH: + return "QQ_GROUP_CMD_JOIN_GROUP_AUTH"; + case QQ_GROUP_CMD_EXIT_GROUP: + return "QQ_GROUP_CMD_EXIT_GROUP"; + case QQ_GROUP_CMD_SEND_MSG: + return "QQ_GROUP_CMD_SEND_MSG"; + case QQ_GROUP_CMD_GET_ONLINE_MEMBER: + return "QQ_GROUP_CMD_GET_ONLINE_MEMBER"; + case QQ_GROUP_CMD_GET_MEMBER_INFO: + return "QQ_GROUP_CMD_GET_MEMBER_INFO"; + default: + return "Unknown QQ Group Command"; + } +} + +/* default process of reply error */ +static void _qq_process_group_cmd_reply_error_default(guint8 reply, guint8 *cursor, gint len, GaimConnection *gc) +{ + gchar *msg, *msg_utf8; + g_return_if_fail(cursor != NULL && len > 0); + + msg = g_strndup((gchar *) cursor, len); /* it will append 0x00 */ + msg_utf8 = qq_to_utf8(msg, QQ_CHARSET_DEFAULT); + g_free(msg); + msg = g_strdup_printf(_("Code [0x%02X]: %s"), reply, msg_utf8); + gaim_notify_error(gc, NULL, _("Group Operation Error"), msg); + g_free(msg); + g_free(msg_utf8); +} + +/* default process, dump only */ +static void _qq_process_group_cmd_reply_default(guint8 *data, guint8 **cursor, gint len, GaimConnection *gc) +{ + gchar *hex_dump; + g_return_if_fail(data != NULL && len > 0); + + hex_dump = hex_dump_to_str(data, len); + gaim_debug(GAIM_DEBUG_INFO, "QQ", "Dump unprocessed group cmd reply:\n%s", hex_dump); + g_free(hex_dump); +} + +/* The lower layer command of send group cmd */ +void qq_send_group_cmd(GaimConnection *gc, qq_group *group, guint8 *raw_data, gint data_len) +{ + qq_data *qd; + group_packet *p; + + g_return_if_fail(raw_data != NULL && data_len > 0); + + qd = (qq_data *) gc->proto_data; + + qq_send_cmd(gc, QQ_CMD_GROUP_CMD, TRUE, 0, TRUE, raw_data, data_len); + + p = g_new0(group_packet, 1); + + p->send_seq = qd->send_seq; + if (group == NULL) + p->internal_group_id = 0; + else + p->internal_group_id = group->internal_group_id; + + qd->group_packets = g_list_append(qd->group_packets, p); +} + +/* the main entry of group cmd processing, called by qq_recv_core.c */ +void qq_process_group_cmd_reply(guint8 *buf, gint buf_len, guint16 seq, GaimConnection *gc) +{ + qq_group *group; + qq_data *qd; + gint len, bytes; + guint32 internal_group_id; + guint8 *data, *cursor, sub_cmd, reply; + + 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_group_find_internal_group_id_by_seq(gc, seq, &internal_group_id)) { + gaim_debug(GAIM_DEBUG_WARNING, "QQ", "We have no record of group cmd, seq [%d]\n", seq); + return; + } + + if (qq_crypt(DECRYPT, buf, buf_len, qd->session_key, data, &len)) { + if (len <= 2) { + gaim_debug(GAIM_DEBUG_ERROR, "QQ", "Group cmd reply is too short, only %d bytes\n", len); + return; + } + + bytes = 0; + cursor = data; + bytes += read_packet_b(data, &cursor, len, &sub_cmd); + bytes += read_packet_b(data, &cursor, len, &reply); + + group = qq_group_find_by_id(gc, internal_group_id, QQ_INTERNAL_ID); + + if (reply != QQ_GROUP_CMD_REPLY_OK) { + gaim_debug(GAIM_DEBUG_WARNING, "QQ", + "Group cmd reply says cmd %s fails\n", qq_group_cmd_get_desc(sub_cmd)); + + if (group != NULL) + qq_set_pending_id(&qd->joining_groups, group->external_group_id, FALSE); + + switch (reply) { /* this should be all errors */ + case QQ_GROUP_CMD_REPLY_NOT_MEMBER: + if (group != NULL) { + gaim_debug(GAIM_DEBUG_WARNING, + "QQ", + "You are not a member of group \"%s\"\n", group->group_name_utf8); + group->my_status = QQ_GROUP_MEMBER_STATUS_NOT_MEMBER; + qq_group_refresh(gc, group); + } + break; + case QQ_GROUP_CMD_REPLY_SEARCH_ERROR: + if (qd->roomlist != NULL) { + if (gaim_roomlist_get_in_progress(qd->roomlist)) + gaim_roomlist_set_in_progress(qd->roomlist, FALSE); + } + _qq_process_group_cmd_reply_error_default(reply, cursor, len - bytes, gc); + break; + default: + _qq_process_group_cmd_reply_error_default(reply, cursor, len - bytes, gc); + } + return; + } + + /* seems ok so far, so we process the reply according to sub_cmd */ + switch (sub_cmd) { + case QQ_GROUP_CMD_GET_GROUP_INFO: + qq_process_group_cmd_get_group_info(data, &cursor, len, gc); + if (group != NULL) { + qq_send_cmd_group_get_members_info(gc, group); + qq_send_cmd_group_get_online_members(gc, group); + } + break; + case QQ_GROUP_CMD_CREATE_GROUP: + qq_group_process_create_group_reply(data, &cursor, len, gc); + break; + case QQ_GROUP_CMD_MODIFY_GROUP_INFO: + qq_group_process_modify_info_reply(data, &cursor, len, gc); + break; + case QQ_GROUP_CMD_MEMBER_OPT: + qq_group_process_modify_members_reply(data, &cursor, len, gc); + break; + case QQ_GROUP_CMD_ACTIVATE_GROUP: + qq_group_process_activate_group_reply(data, &cursor, len, gc); + break; + case QQ_GROUP_CMD_SEARCH_GROUP: + qq_process_group_cmd_search_group(data, &cursor, len, gc); + break; + case QQ_GROUP_CMD_JOIN_GROUP: + qq_process_group_cmd_join_group(data, &cursor, len, gc); + break; + case QQ_GROUP_CMD_JOIN_GROUP_AUTH: + qq_process_group_cmd_join_group_auth(data, &cursor, len, gc); + break; + case QQ_GROUP_CMD_EXIT_GROUP: + qq_process_group_cmd_exit_group(data, &cursor, len, gc); + break; + case QQ_GROUP_CMD_SEND_MSG: + qq_process_group_cmd_im(data, &cursor, len, gc); + break; + case QQ_GROUP_CMD_GET_ONLINE_MEMBER: + qq_process_group_cmd_get_online_members(data, &cursor, len, gc); + if (group != NULL) + qq_group_conv_refresh_online_member(gc, group); + break; + case QQ_GROUP_CMD_GET_MEMBER_INFO: + qq_process_group_cmd_get_members_info(data, &cursor, len, gc); + if (group != NULL) + qq_group_conv_refresh_online_member(gc, group); + break; + default: + gaim_debug(GAIM_DEBUG_WARNING, "QQ", + "Group cmd %s is processed by default\n", qq_group_cmd_get_desc(sub_cmd)); + _qq_process_group_cmd_reply_default(data, &cursor, len, gc); + } + + } else { + gaim_debug(GAIM_DEBUG_ERROR, "QQ", "Error decrypt group cmd reply\n"); + } +} |