/*
Plugin of Miranda IM for communicating with users of the AIM protocol.
Copyright (c) 2008-2012 Boris Krasnovskiy
Copyright (C) 2005-2006 Aaron Myles Landwehr
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, see .
*/
#include "aim.h"
void CAimProto::snac_md5_authkey(SNAC &snac,HANDLE hServerConn,unsigned short &seqno, const char* username, const char* password)//family 0x0017
{
if (snac.subcmp(0x0007))//md5 authkey string
{
unsigned short length=snac.ushort();
char* authkey = snac.part(2, length);
aim_auth_request(hServerConn, seqno, authkey, AIM_LANGUAGE, AIM_COUNTRY, username, password);
mir_free(authkey);
}
}
int CAimProto::snac_authorization_reply(SNAC &snac)//family 0x0017
{
int res = 0;
if (snac.subcmp(0x0003))
{
char* server = NULL;
int address = 0;
unsigned short port;
unsigned char use_ssl = 0;
while (address < snac.len())
{
TLV tlv(snac.val(address));
if (tlv.cmp(0x0005))
server = tlv.dup();
else if (tlv.cmp(0x0006))
{
Netlib_CloseHandle(hServerConn);
if (server == NULL) return 3;
char* delim = strchr(server, ':');
port = delim ? (unsigned short)atoi(delim + 1) : get_default_port();
if (delim) *delim = 0;
hServerConn = aim_connect(server, port, use_ssl != 0, "bos.oscar.aol.com");
if (hServerConn)
{
mir_free(COOKIE);
COOKIE_LENGTH = tlv.len();
COOKIE = tlv.dup();
ForkThread(&CAimProto::aim_protocol_negotiation, 0);
res = 1;
}
else
res = 3;
break;
}
else if (tlv.cmp(0x0008))
{
login_error(tlv.ushort());
res = 2;
break;
}
else if (tlv.cmp(0x0011))
{
char* email = tlv.dup();
setString(AIM_KEY_EM, email);
mir_free(email);
}
else if (tlv.cmp(0x008e))
{
use_ssl = tlv.ubyte();
}
address += tlv.len() + 4;
}
mir_free(server);
}
return res;
}
void CAimProto::snac_supported_families(SNAC &snac,HANDLE hServerConn,unsigned short &seqno)//family 0x0001
{
if (snac.subcmp(0x0003))//server supported service list
{
aim_send_service_request(hServerConn,seqno);
}
}
void CAimProto::snac_supported_family_versions(SNAC &snac,HANDLE hServerConn,unsigned short &seqno)//family 0x0001
{
if (snac.subcmp(0x0018))//service list okayed
{
aim_request_rates(hServerConn,seqno);//request some rate crap
}
}
void CAimProto::snac_rate_limitations(SNAC &snac,HANDLE hServerConn,unsigned short &seqno)// family 0x0001
{
if (snac.subcmp(0x0007))
{
aim_accept_rates(hServerConn,seqno);
aim_request_icbm(hServerConn,seqno);
}
}
void CAimProto::snac_mail_rate_limitations(SNAC &snac,HANDLE hServerConn,unsigned short &seqno)// family 0x0001
{
if (snac.subcmp(0x0007))
{
aim_accept_rates(hServerConn,seqno);
aim_request_mail(hServerConn,seqno);
aim_activate_mail(hServerConn,seqno);
aim_mail_ready(hServerConn,seqno);
}
}
void CAimProto::snac_avatar_rate_limitations(SNAC &snac,HANDLE hServerConn,unsigned short &seqno)// family 0x0001
{
if (snac.subcmp(0x0007))
{
aim_accept_rates(hServerConn,seqno);
aim_avatar_ready(hServerConn,seqno);
SetEvent(hAvatarEvent);
}
}
void CAimProto::snac_chatnav_rate_limitations(SNAC &snac,HANDLE hServerConn,unsigned short &seqno)// family 0x0001
{
if (snac.subcmp(0x0007))
{
aim_accept_rates(hServerConn,seqno);
aim_chatnav_request_limits(hChatNavConn,chatnav_seqno); // Get the max number of rooms we're allowed in.
}
}
void CAimProto::snac_chat_rate_limitations(SNAC &snac,HANDLE hServerConn,unsigned short &seqno)// family 0x0001
{
if (snac.subcmp(0x0007))
{
aim_accept_rates(hServerConn,seqno);
aim_chat_ready(hServerConn,seqno);
}
}
void CAimProto::snac_icbm_limitations(SNAC &snac,HANDLE hServerConn,unsigned short &seqno)//family 0x0004
{
if (snac.subcmp(0x0005))
{
switch (m_iDesiredStatus)
{
case ID_STATUS_ONLINE:
broadcast_status(ID_STATUS_ONLINE);
aim_set_status(hServerConn,seqno,AIM_STATUS_ONLINE);
break;
case ID_STATUS_INVISIBLE:
broadcast_status(ID_STATUS_INVISIBLE);
aim_set_status(hServerConn,seqno,AIM_STATUS_INVISIBLE);
break;
case ID_STATUS_OCCUPIED:
broadcast_status(ID_STATUS_OCCUPIED);
aim_set_status(hServerConn,seqno,AIM_STATUS_BUSY|AIM_STATUS_AWAY);
break;
case ID_STATUS_AWAY:
broadcast_status(ID_STATUS_AWAY);
aim_set_status(hServerConn,seqno,AIM_STATUS_AWAY);
break;
}
char** msgptr = get_status_msg_loc(m_iDesiredStatus);
mir_free(last_status_msg);
last_status_msg = msgptr ? mir_strdup(*msgptr) : NULL;
aim_set_statusmsg(hServerConn, seqno, last_status_msg);
if (m_iDesiredStatus == ID_STATUS_AWAY)
aim_set_away(hServerConn, seqno, last_status_msg, true);
if (getByte(AIM_KEY_II,0))
{
unsigned long time = getDword(AIM_KEY_IIT, 0);
aim_set_idle(hServerConn,seqno,time*60);
instantidle=1;
}
aim_request_list(hServerConn,seqno);
}
}
void CAimProto::snac_self_info(SNAC &snac)//family 0x0001
{
if (snac.subcmp(0x000f))
{
int offset = snac.flags() & 0x8000 ? snac.ushort(0) + 2 : 0;
unsigned char sn_len = snac.ubyte(offset++);
char* sn = snac.part(offset, sn_len);
offset += sn_len + 2;
int tlv_count = snac.ushort(offset);
offset += 2;
for (int i = 0; i < tlv_count; i++)
{
TLV tlv(snac.val(offset));
offset += TLV_HEADER_SIZE + tlv.len();
if (tlv.cmp(0x000a))
{
detected_ip = tlv.ulong();
}
}
mir_free(sn);
}
}
void CAimProto::snac_user_online(SNAC &snac)//family 0x0003
{
if (snac.subcmp(0x000b))
{
char client[100] = "";
bool hiptop_user = false;
bool bot_user = false;
bool wireless_user = false;
bool away_user = false;
bool caps_included = false;
unsigned long status_type = 0; // 0 = online
char *hash_sm = NULL, *hash_lg = NULL;
unsigned char sn_len = snac.ubyte();
char* sn = snac.part(1, sn_len);
MCONTACT hContact = contact_from_sn(sn, true);
int offset = sn_len + 3;
int tlv_count = snac.ushort(offset);
offset += 2;
for (int i = 0; i < tlv_count; i++)
{
TLV tlv(snac.val(offset));
offset += TLV_HEADER_SIZE;
if (tlv.cmp(0x0001))//user m_iStatus
{
unsigned short status = tlv.ushort();
int unconfirmed = status & 0x0001;
int admin_aol = status & 0x0002;
int aol = status & 0x0004;
//int nonfree = status & 0x0008;
//int aim = status & 0x0010;
int away = status & 0x0020;
int icq = status & 0x0040;
int wireless = status & 0x0080;
int bot = status & 0x0400;
setString(hContact, AIM_KEY_NK, sn);
if (icq)
setString(hContact, "Transport", "ICQ");
else
delSetting(hContact, "Transport" );
if (admin_aol)
setByte(hContact, AIM_KEY_AC, ACCOUNT_TYPE_ADMIN);
else if (aol)
setByte(hContact, AIM_KEY_AC, ACCOUNT_TYPE_AOL);
else if (icq)
setByte(hContact, AIM_KEY_AC, ACCOUNT_TYPE_ICQ);
else if (unconfirmed)
setByte(hContact, AIM_KEY_AC, ACCOUNT_TYPE_UNCONFIRMED);
else
setByte(hContact, AIM_KEY_AC, ACCOUNT_TYPE_CONFIRMED);
if (bot)
{
strcpy(client,CLIENT_BOT);
bot_user=1;
}
if (wireless)
{
strcpy(client,CLIENT_SMS);
wireless_user=1;
}
else if (away)
{
away_user=1;
}
setDword(hContact, AIM_KEY_IT, 0);//erase idle time
setDword(hContact, AIM_KEY_OT, 0);//erase online time
}
else if (tlv.cmp(0x0006)) // Status
{
status_type = tlv.ulong() & 0x00000FFF;
}
else if (tlv.cmp(0x000d))
{
caps_included = true;
for(int i = 0; i 2)
{
unsigned short len = tlv.ushort(i + 4);
if (len)
{
msg_exist = true;
char* msg = tlv.part(i + 6, len);
char* msg_s = process_status_msg(msg, sn);
db_set_utf(hContact, MOD_KEY_CL, OTH_KEY_SM, msg_s);
TCHAR* tszMsg = mir_utf8decodeT(msg_s);
ProtoBroadcastAck(hContact, ACKTYPE_AWAYMSG, ACKRESULT_SUCCESS, NULL, (LPARAM)tszMsg);
mir_free(tszMsg);
mir_free(msg);
mir_free(msg_s);
}
}
break;
}
i += 4 + datalen;
}
if (!msg_exist)
db_unset(hContact, MOD_KEY_CL, OTH_KEY_SM);
}
}
else if (tlv.cmp(0x0004))//idle tlv
{
if (hContact)
{
time_t current_time;
time(¤t_time);
setDword(hContact, AIM_KEY_IT, ((DWORD)current_time) - tlv.ushort() * 60);
}
}
else if (tlv.cmp(0x0003))//online time tlv
{
if (hContact)
setDword(hContact, AIM_KEY_OT, tlv.ulong());
}
else if (tlv.cmp(0x0005))//member since
{
if (hContact)
setDword(hContact, AIM_KEY_MS, tlv.ulong());
}
offset += tlv.len();
}
if (status_type & AIM_STATUS_INVISIBLE)
setWord(hContact, AIM_KEY_ST, ID_STATUS_INVISIBLE);
else if (status_type & AIM_STATUS_BUSY)
setWord(hContact, AIM_KEY_ST, ID_STATUS_OCCUPIED);
else if (status_type & AIM_STATUS_AWAY || away_user)
setWord(hContact, AIM_KEY_ST, ID_STATUS_AWAY);
else if (wireless_user)
setWord(hContact, AIM_KEY_ST, ID_STATUS_ONTHEPHONE);
else
setWord(hContact, AIM_KEY_ST, ID_STATUS_ONLINE);
if (hash_lg)
avatar_request_handler(hContact, hash_lg, 12);
else
avatar_request_handler(hContact, hash_sm, 1);
if (bot_user)
setByte(hContact, AIM_KEY_ET, EXTENDED_STATUS_BOT);
else if (hiptop_user)
setByte(hContact, AIM_KEY_ET, EXTENDED_STATUS_HIPTOP);
if (caps_included)
set_contact_icon(this, hContact);
if (caps_included || client[0])
setString(hContact, AIM_KEY_MV, client[0] ? client : "?");
else if (atoi(sn))
setString(hContact, AIM_KEY_MV, CLIENT_ICQ);
else if (getBool(hContact, AIM_KEY_BLS, false))
setString(hContact, AIM_KEY_MV, CLIENT_BLAST);
else
setString(hContact, AIM_KEY_MV, CLIENT_AIMEXPRESS7);
mir_free(hash_lg);
mir_free(hash_sm);
mir_free(sn);
}
}
void CAimProto::snac_user_offline(SNAC &snac)//family 0x0003
{
if (snac.subcmp(0x000c)) {
unsigned char buddy_length = snac.ubyte();
char* buddy=snac.part(1,buddy_length);
MCONTACT hContact=contact_from_sn(buddy, true);
if (hContact)
offline_contact(hContact,0);
mir_free(buddy);
}
}
void CAimProto::snac_error(SNAC &snac)//family 0x0003 or 0x0004
{
if (snac.subcmp(0x0001))
get_error(snac.ushort());
}
void CAimProto::process_ssi_list(SNAC &snac, int &offset)
{
unsigned short name_length = snac.ushort(offset);
char* name = snac.part(offset+2, name_length);
unsigned short group_id = snac.ushort(offset+ 2 +name_length);
unsigned short item_id = snac.ushort(offset+4+name_length);
unsigned short type = snac.ushort(offset+6+name_length);
unsigned short tlv_size = snac.ushort(offset+8+name_length);
const int tlv_base = offset + name_length + 10;
switch (type) {
case 0x0000: //buddy record
{
MCONTACT hContact = contact_from_sn(name, true);
if (hContact) {
int i;
for (i = 1;; i++) {
if (!getBuddyId(hContact, i)) {
setBuddyId(hContact, i, item_id);
setGroupId(hContact, i, group_id);
break;
}
}
if (i == 1 && getByte(AIM_KEY_MG, 1)) {
const char* group = group_list.find_name(group_id);
if (group) {
bool ok = false;
DBVARIANT dbv;
if (!db_get_utf(hContact, MOD_KEY_CL, OTH_KEY_GP, &dbv) && dbv.pszVal[0]) {
ok = strcmp(group, dbv.pszVal) == 0;
db_free(&dbv);
}
else ok = strcmp(group, AIM_DEFAULT_GROUP) == 0;
if (!ok) {
if (strcmp(group, AIM_DEFAULT_GROUP))
db_set_utf(hContact, MOD_KEY_CL, OTH_KEY_GP, group);
else
db_unset(hContact, MOD_KEY_CL, OTH_KEY_GP);
}
}
}
setWord(hContact, AIM_KEY_ST, ID_STATUS_OFFLINE);
bool nickfound = false;
for (int tlv_offset = 0; tlv_offset < tlv_size;) {
TLV tlv(snac.val(tlv_base + tlv_offset));
if (tlv.cmp(0x0131) && tlv.len()) {
char* nick = tlv.dup();
db_set_utf(hContact, MOD_KEY_CL, "MyHandle", nick);
mir_free(nick);
nickfound = true;
}
else if (tlv.cmp(0x7b))
setByte(hContact, AIM_KEY_BLS, 1);
else if (tlv.cmp(0x6a))
setByte(hContact, AIM_KEY_NIL, 1);
tlv_offset += TLV_HEADER_SIZE + tlv.len();
}
if (!nickfound && getDword(AIM_KEY_LV, 0) >= 0x80500)
db_unset(hContact, MOD_KEY_CL, "MyHandle");
}
}
break;
case 0x0001: //group record
if (group_id) {
group_list.add(name, group_id);
if (getByte(AIM_KEY_MG, 1))
create_group(name);
}
break;
case 0x0002: //permit record
allow_list.add(name, item_id);
break;
case 0x0003: //deny record
block_list.add(name, item_id);
break;
case 0x0004: //privacy record
if (group_id == 0) {
pd_info_id = item_id;
for (int tlv_offset = 0; tlv_offset < tlv_size;) {
TLV tlv(snac.val(tlv_base + tlv_offset));
if (tlv.cmp(0x00ca))
pd_mode = tlv.ubyte();
else if (tlv.cmp(0x00cc))
pd_flags = tlv.ulong();
tlv_offset += TLV_HEADER_SIZE + tlv.len();
}
}
break;
case 0x0005: //prefernces record
if (group_id == 0) {
pref1_id = item_id;
for (int tlv_offset = 0; tlv_offset < tlv_size;) {
TLV tlv(snac.val(tlv_base + tlv_offset));
if (tlv.cmp(0x00c9))
pref1_flags = tlv.ulong();
else if (tlv.cmp(0x00d6))
pref1_set_flags = tlv.ulong();
else if (tlv.cmp(0x00d7)) {
mir_free(pref2_flags);
pref2_flags = tlv.dup();
pref2_len = tlv.len();
}
else if (tlv.cmp(0x00d8)) {
mir_free(pref2_set_flags);
pref2_set_flags = tlv.dup();
pref2_set_len = tlv.len();
}
tlv_offset += TLV_HEADER_SIZE + tlv.len();
}
}
break;
case 0x0014: //avatar record
if (!_strcmps(name, "1") || !_strcmps(name, "12")) {
if (name_length == 1)
avatar_id_sm = item_id;
else
avatar_id_lg = item_id;
for (int tlv_offset = 0; tlv_offset < tlv_size;) {
TLV tlv(snac.val(tlv_base + tlv_offset));
if (tlv.cmp(0x00d5) && tlv.len() > 2) {
unsigned char type = tlv.ubyte(0);
if (name_length == 1) {
mir_free(hash_sm);
hash_sm = bytes_to_string(tlv.val() + 2, tlv.ubyte(1));
}
else {
mir_free(hash_lg);
hash_lg = bytes_to_string(tlv.val() + 2, tlv.ubyte(1));
}
}
tlv_offset += TLV_HEADER_SIZE + tlv.len();
}
if (list_received)
avatar_request_handler(NULL, NULL, 0);
}
break;
case 0x001D: // Vanity information
if (group_id == 0) {
for (int tlv_offset = 0; tlv_offset < tlv_size;) {
TLV tlv(snac.val(tlv_base + tlv_offset));
if (tlv.cmp(0x0150)) // Number of IMs sent
setDword(AIM_KEY_TIS, tlv.ulong());
else if (tlv.cmp(0x0151)) // Number of seconds a user is online
setDword(AIM_KEY_TTO, tlv.ulong());
else if (tlv.cmp(0x0152)) // Number of times a user has the away message set
setDword(AIM_KEY_TAM, tlv.ulong());
else if (tlv.cmp(0x0153)) // Number of IMs received
setDword(AIM_KEY_TIR, tlv.ulong());
tlv_offset += TLV_HEADER_SIZE + tlv.len();
}
}
break;
}
mir_free(name);
offset = tlv_base + tlv_size;
}
void CAimProto::modify_ssi_list(SNAC &snac, int &offset)
{
unsigned short name_length = snac.ushort(offset);
char* name = snac.part(offset+2, name_length);
unsigned short group_id = snac.ushort(offset+ 2 +name_length);
unsigned short item_id = snac.ushort(offset+4+name_length);
unsigned short type = snac.ushort(offset+6+name_length);
unsigned short tlv_size = snac.ushort(offset+8+name_length);
const int tlv_base = offset + name_length + 10;
switch (type)
{
case 0x0000: //buddy record
{
MCONTACT hContact = contact_from_sn(name, true);
if (hContact)
{
for (int tlv_offset = 0; tlv_offset < tlv_size; )
{
TLV tlv(snac.val(tlv_base + tlv_offset));
if (tlv.cmp(0x0131) && tlv.len())
{
char* nick = tlv.dup();
if (nick)
db_set_utf(hContact, MOD_KEY_CL, "MyHandle", nick);
else
db_unset(hContact, MOD_KEY_CL, "MyHandle");
mir_free(nick);
}
tlv_offset += TLV_HEADER_SIZE + tlv.len();
}
}
break;
}
case 0x0004: //privacy record
if (group_id == 0)
{
pd_info_id = item_id;
for (int tlv_offset = 0; tlv_offset < tlv_size; )
{
TLV tlv(snac.val(tlv_base + tlv_offset));
if (tlv.cmp(0x00ca))
pd_mode = tlv.ubyte();
else if (tlv.cmp(0x00cc))
pd_flags = tlv.ulong();
tlv_offset += TLV_HEADER_SIZE + tlv.len();
}
}
break;
case 0x0005: //prefernces record
if (group_id == 0)
{
pref1_id = item_id;
for (int tlv_offset = 0; tlv_offset < tlv_size; )
{
TLV tlv(snac.val(tlv_base + tlv_offset));
if (tlv.cmp(0x00c9))
pref1_flags = tlv.ulong();
else if (tlv.cmp(0x00d6))
pref1_set_flags = tlv.ulong();
else if (tlv.cmp(0x00d7))
{
mir_free(pref2_flags);
pref2_flags = tlv.dup();
pref2_len = tlv.len();
}
else if (tlv.cmp(0x00d8))
{
mir_free(pref2_set_flags);
pref2_set_flags = tlv.dup();
pref2_set_len = tlv.len();
}
tlv_offset += TLV_HEADER_SIZE + tlv.len();
}
}
break;
case 0x0014: //avatar record
if (!_strcmps(name, "1") || !_strcmps(name, "12"))
{
if (name_length == 1)
avatar_id_sm = item_id;
else
avatar_id_lg = item_id;
for (int tlv_offset = 0; tlv_offset < tlv_size; )
{
TLV tlv(snac.val( tlv_base + tlv_offset));
if (tlv.cmp(0x00d5) && tlv.len() > 2)
{
unsigned char type = tlv.ubyte(0);
if (name_length == 1)
{
mir_free(hash_sm);
hash_sm = bytes_to_string(tlv.val() + 2, tlv.ubyte(1));
}
else
{
mir_free(hash_lg);
hash_lg = bytes_to_string(tlv.val() + 2, tlv.ubyte(1));
}
}
tlv_offset += TLV_HEADER_SIZE + tlv.len();
}
avatar_request_handler(NULL, NULL, 0);
}
break;
}
mir_free(name);
}
void CAimProto::delete_ssi_list(SNAC &snac, int &offset)
{
int i;
unsigned short name_length=snac.ushort(offset);
char* name=snac.part(offset+2,name_length);
unsigned short group_id=snac.ushort(offset+2+name_length);
unsigned short item_id=snac.ushort(offset+4+name_length);
unsigned short type=snac.ushort(offset+6+name_length);
MCONTACT hContact = contact_from_sn(name);
switch (type) {
case 0x0000: //buddy record
for(i=1;;++i)
{
unsigned short item_id_st = getBuddyId(hContact, i);
if (item_id_st == 0) break;
if (item_id == item_id_st)
{
deleteBuddyId(hContact, i);
deleteGroupId(hContact, i);
--i;
}
}
if (i == 1)
CallService(MS_DB_CONTACT_DELETE, hContact, 0);
break;
case 0x0001: //group record
group_list.remove_by_id(group_id);
break;
case 0x0014: //avatar record
if (_strcmps(name, "1"))
{
avatar_id_sm = 0;
mir_free(hash_sm);
hash_sm = NULL;
}
else if (!_strcmps(name, "12"))
{
avatar_id_lg = 0;
mir_free(hash_lg);
hash_lg = NULL;
}
avatar_request_handler(NULL, NULL, 0);
break;
}
mir_free(name) ;
}
void CAimProto::snac_contact_list(SNAC &snac,HANDLE hServerConn,unsigned short &seqno)//family 0x0013
{
if (snac.subcmp(0x0006)) //contact list
{
debugLogA("Contact List Received");
// unsigned char ver = snac.ubyte();
int num_obj = snac.ushort(1);
int offset=3;
for (int i=0; ihContact = hContact;
msg_ack->id = *(int*)icbm_cookie & 0x7fffffff;
msg_ack->msg = NULL;
msg_ack->success = true;
ForkThread(&CAimProto::msg_ack_success, msg_ack);
}
mir_free(sn);
mir_free(icbm_cookie);
}
}
void CAimProto::snac_received_message(SNAC &snac,HANDLE hServerConn,unsigned short &seqno)//family 0x0004
{
if (snac.subcmp(0x0007))
{
unsigned short channel = snac.ushort(8);
unsigned char sn_length = snac.ubyte(10);
char* sn = snac.part(11,sn_length);
MCONTACT hContact = contact_from_sn(sn, true, true), hMsgContact = NULL;
int offset=15+sn_length;
char* msg_buf=NULL;
unsigned long offline_timestamp = 0;
bool is_offline = false;
//file transfer stuff
char* icbm_cookie = NULL;
char* filename = NULL;
unsigned __int64 file_size=0;
bool auto_response=false;
bool force_proxy=false;
bool descr_included=false;
bool utf_fname=false;
bool unicode_descr=false;
short rdz_msg_type=-1;
unsigned short request_num=0;
unsigned long local_ip=0, verified_ip=0, proxy_ip=0;
unsigned short port = 0;
unsigned short max_ver = 0;
unsigned short num_files = 0;
//end file transfer stuff
unsigned short tlv_head_num=snac.ushort(offset-2);
for (int i=0;i=snac.len()) break;
}
while (offset < snac.len())
{
TLV tlv(snac.val(offset));
offset += TLV_HEADER_SIZE;
if (tlv.cmp(0x0004)&&!tlv.len())//auto response flag
auto_response = 1;
if (tlv.cmp(0x0002)) //msg
{
unsigned short caps_length=tlv.ushort(2);
unsigned short msg_length=tlv.ushort(6+caps_length)-4;
unsigned short encoding=tlv.ushort(8+caps_length);
char* buf = tlv.part(12+caps_length,msg_length);
if (hContact) {
wchar_t* wbuf;
hMsgContact = hContact;
switch (encoding) {
case 2:
wbuf = (wchar_t*)buf;
wcs_htons(wbuf);
msg_buf = mir_utf8encodeW(wbuf);
mir_free(wbuf);
break;
case 3:
wbuf = mir_a2u_cp(buf, 28591);
msg_buf = mir_utf8encodeW(wbuf);
mir_free(wbuf);
mir_free(buf);
break;
default:
msg_buf = buf;
break;
}
}
}
if (tlv.cmp(0x0004) && !tlv.len())//auto response flag
auto_response = 1;
if (channel == 2 && tlv.cmp(0x0005)) { //recv rendervous packet
rdz_msg_type = snac.ushort(offset);
icbm_cookie = snac.part(offset+2,8);
if (cap_cmp(snac.val(offset+10), AIM_CAP_FILE_TRANSFER) == 0) {
for (int i = 26; i < tlv.len(); ) {
TLV tlv(snac.val(offset+i));
if (tlv.cmp(0x000A))
request_num=tlv.ushort();//for file transfer
else if (tlv.cmp(0x0002))//proxy ip
proxy_ip = tlv.ulong();
else if (tlv.cmp(0x0003))//client ip
local_ip = tlv.ulong();
else if (tlv.cmp(0x0004))//verified ip
verified_ip = tlv.ulong();
else if (tlv.cmp(0x0005))
port=tlv.ushort();
else if (tlv.cmp(0x0010))
force_proxy=1;
else if (tlv.cmp(0x0012))
max_ver = tlv.ushort();
else if (tlv.cmp(0x2711)) {
num_files = tlv.ushort(2);
file_size = tlv.ulong(4);
filename = tlv.part(8, tlv.len()-8);
}
else if (tlv.cmp(0x2712)) {
char* enc = tlv.dup();
utf_fname = strcmp(enc, "utf-8") == 0;
mir_free(enc);
}
else if (tlv.cmp(0x2713)) {
file_size = tlv.u64();
}
else if (tlv.cmp(0x000c)) {
msg_buf = unicode_descr ? tlv.dupw() : tlv.dup();
html_decode(msg_buf);
descr_included = true;
if (strstr(msg_buf, "")) {
char* beg = strstr(msg_buf, "");
char* end = strstr(msg_buf, "");
if (beg && end && beg < end) {
beg += 6;
end[0] = 0;
memmove(msg_buf, beg, end - beg + 1);
}
else descr_included = false;
}
}
else if (tlv.cmp(0x000d)) {
char* enc = tlv.dup();
unicode_descr = strcmp(enc, "unicode-2-0") == 0;
mir_free(enc);
}
i += TLV_HEADER_SIZE + tlv.len();
}
}
else if (cap_cmp(snac.val(offset+10), AIM_CAP_RTCAUDIO) == 0 || cap_cmp(snac.val(offset+10), AIM_CAP_RTCVIDEO) == 0) {
for (int i = 26; i < tlv.len(); ) {
TLV tlv(snac.val(offset+i));
if (tlv.cmp(0x000A))
request_num=tlv.ushort();//for file transfer
else if (tlv.cmp(0x0002))//proxy ip
proxy_ip = tlv.ulong();
else if (tlv.cmp(0x0003))//client ip
local_ip = tlv.ulong();
else if (tlv.cmp(0x0004))//verified ip
verified_ip = tlv.ulong();
else if (tlv.cmp(0x0005))
port=tlv.ushort();
}
channel = 0;
break;
}
else if (cap_cmp(snac.val(offset+10), AIM_CAP_CHAT) == 0) { //it's a chat invite request
for(int i=26; i < tlv.len();) {
TLV tlv(snac.val(offset+i));
if (tlv.cmp(0x000c)) //optional message
msg_buf = tlv.dup();
else if (tlv.cmp(0x2711)) { //room information
int cookie_len=tlv.ubyte(2);
chatnav_param* par =
new chatnav_param(tlv.part(3,cookie_len), tlv.ushort(), tlv.ushort(3+cookie_len),
msg_buf, sn, icbm_cookie);
invite_chat_req_param* chat_rq = new invite_chat_req_param(par, this, msg_buf, sn, icbm_cookie);
CallFunctionAsync(chat_request_cb, chat_rq);
}
i+=TLV_HEADER_SIZE+tlv.len();
}
}
else {
channel = 0;
break;
}
}
if (channel == 6 && tlv.cmp(0x0005))//audio/video tunnel
msg_buf = tlv.dup();
if (tlv.cmp(0x0006))//Offline message flag
is_offline = true;
if (tlv.cmp(0x0016))//Offline message timestamp
offline_timestamp = tlv.ulong(0);
offset += (tlv.len());
}
if (channel == 1) { //Message not file
if (auto_response) { //this message must be an autoresponse
char* away = mir_utf8encodeT(TranslateT("[Auto-Response]:"));
size_t len = strlen(msg_buf) + strlen(away) + 2;
char* buf = (char*)mir_alloc(len);
mir_snprintf(buf, len, "%s %s", away, msg_buf);
mir_free(away);
mir_free(msg_buf);
msg_buf = buf;
}
// Okay we are setting up the structure to give the message back to miranda's core
CallService(MS_PROTO_CONTACTISTYPING, (WPARAM)hMsgContact, 0);
{
PROTORECVEVENT pre = { 0 };
pre.flags = PREF_UTF;
pre.timestamp = (is_offline) ? offline_timestamp : (DWORD)time(0);
pre.szMessage = msg_buf;
ProtoChainRecvMsg(hMsgContact, &pre);
}
if (m_iStatus==ID_STATUS_AWAY && !auto_response && !getByte(AIM_KEY_DM,0))
{
unsigned long msg_time = getDword(hContact, AIM_KEY_LM, 0);
unsigned long away_time = getDword(AIM_KEY_LA, 0);
char** msgptr = get_status_msg_loc(m_iStatus);
if (away_time > msg_time && *msgptr)
{
char* s_msg = process_status_msg(*msgptr, sn);
char* away = mir_utf8encodeT(TranslateT("[Auto-Response]:"));
size_t len = strlen(s_msg) + strlen(away) + 2;
char* buf = (char*)alloca(len);
mir_snprintf(buf, len, "%s %s", away, s_msg);
mir_free(away);
DBEVENTINFO dbei = { sizeof(dbei) };
dbei.szModule = m_szModuleName;
dbei.timestamp = (DWORD)time(NULL);
dbei.flags = DBEF_SENT | DBEF_UTF;
dbei.eventType = EVENTTYPE_MESSAGE;
dbei.cbBlob = (int)len;
dbei.pBlob = (PBYTE)buf;
db_event_add(hContact, &dbei);
aim_send_message(hServerConn, seqno, sn, s_msg, true, getBool(hContact, AIM_KEY_BLS, false));
mir_free(s_msg);
}
setDword(hContact, AIM_KEY_LM, (DWORD)time(NULL));
}
}
else if (channel == 2) // File Transfer
{
if (rdz_msg_type == 0 && request_num == 1) //buddy wants to send us a file
{
debugLogA("Buddy Wants to Send us a file. Request 1");
debugLogA(force_proxy ? "Forcing a Proxy File transfer." : "Not forcing Proxy File transfer.");
file_transfer* ft = new file_transfer(hContact, sn, icbm_cookie);
ft->me_force_proxy = getByte(AIM_KEY_FP, 0) != 0;
ft->peer_force_proxy = force_proxy;
ft->local_ip = local_ip;
ft->verified_ip = verified_ip;
ft->proxy_ip = proxy_ip;
ft->port = port;
ft->max_ver = max_ver;
ft->req_num = request_num;
ft->file = mir_strdup(filename);
ft->pfts.totalBytes = file_size;
ft->pfts.totalFiles = num_files;
ft_list.insert(ft);
if (!descr_included) msg_buf = NULL;
TCHAR* filenameT = mir_utf8decodeT(filename);
PROTORECVFILET pre = {0};
pre.flags = PREF_TCHAR;
pre.fileCount = 1;
pre.timestamp = time(NULL);
pre.tszDescription = mir_utf8decodeT(msg_buf);
pre.ptszFiles = &filenameT;
pre.lParam = (LPARAM)ft;
ProtoChainRecvFile(hContact, &pre);
mir_free(pre.tszDescription);
mir_free(filenameT);
char cip[20];
debugLogA("Local IP: %s:%u", long_ip_to_char_ip(local_ip, cip), port);
debugLogA("Verified IP: %s:%u", long_ip_to_char_ip(verified_ip, cip), port);
debugLogA("Proxy IP: %s:%u", long_ip_to_char_ip(proxy_ip, cip), port);
}
else if (rdz_msg_type == 0)
{
debugLogA("We are sending a file. Buddy wants us to connect to them. Request %d", request_num);
debugLogA(force_proxy ? "Forcing a Proxy File transfer." : "Not forcing Proxy File transfer.");
file_transfer* ft = ft_list.find_by_cookie(icbm_cookie, hContact);
if (ft)
{
ft->hContact = hContact;
ft->me_force_proxy |= (request_num > 2);
ft->peer_force_proxy = force_proxy;
ft->local_ip = local_ip;
ft->verified_ip = verified_ip;
ft->proxy_ip = proxy_ip;
ft->port = port;
ft->requester = false;
ft->req_num = request_num;
ft->max_ver = max_ver;
char cip[20];
debugLogA("Local IP: %s:%u", long_ip_to_char_ip(local_ip, cip), port);
debugLogA("Verified IP: %s:%u", long_ip_to_char_ip(verified_ip, cip), port);
debugLogA("Proxy IP: %s:%u", long_ip_to_char_ip(proxy_ip, cip), port);
ForkThread(&CAimProto::accept_file_thread, ft);
}
else
{
debugLogA("Unknown File transfer, thus denied.");
aim_file_ad(hServerConn, seqno, sn, icbm_cookie, true, 0);
}
}
else if (rdz_msg_type == 1)//buddy cancelled or denied file transfer
{
debugLogA("File transfer cancelled or denied.");
file_transfer* ft = ft_list.find_by_cookie(icbm_cookie, hContact);
ProtoBroadcastAck(hContact, ACKTYPE_FILE, ACKRESULT_DENIED, ft, 0);
ft_list.remove_by_ft(ft);
}
else if (rdz_msg_type == 2)//buddy accepts our file transfer request
{
debugLogA("File transfer accepted");
file_transfer* ft = ft_list.find_by_cookie(icbm_cookie, hContact);
if (ft)
{
ft->accepted = true;
ft->max_ver = max_ver;
}
else
aim_file_ad(hServerConn, seqno, sn, icbm_cookie, true, 0);
}
}
else if (channel == 6) // Audio/Video call
{
aim_file_ad(hServerConn, seqno, sn, icbm_cookie, true, 0);
ShowPopup(LPGEN("Contact tried to open an audio/video conference (not currently supported)"), ERROR_POPUP);
}
mir_free(sn);
mir_free(msg_buf);
mir_free(filename);
mir_free(icbm_cookie);
}
}
void CAimProto::snac_file_decline(SNAC &snac)//family 0x0004
{
if (snac.subcmp(0x000b))
{
char *icbm_cookie = snac.part(0, 8);
int channel = snac.ushort(8);
if (channel == 0x01)
{
int sn_len = snac.ubyte(10);
char* sn = snac.part(11, sn_len);
int reason = snac.ushort(11 + sn_len);
MCONTACT hContact = contact_from_sn(sn);
msg_ack_param *msg_ack = (msg_ack_param*)mir_alloc(sizeof(msg_ack_param));
msg_ack->hContact = hContact;
msg_ack->msg = NULL;
msg_ack->id = *(int*)icbm_cookie & 0x7fffffff;
msg_ack->success = false;
ForkThread(&CAimProto::msg_ack_success, msg_ack);
}
if (channel == 0x02)
{
int sn_len = snac.ubyte(10);
char* sn = snac.part(11, sn_len);
int reason = snac.ushort(11 + sn_len);
if (reason == 0x03)
{
int error = snac.ushort(13 + sn_len);
if (error == 0x02)
{
debugLogA("File Transfer declied");
MCONTACT hContact = contact_from_sn(sn);
file_transfer *ft = ft_list.find_by_cookie(icbm_cookie, hContact);
if (ft)
{
ProtoBroadcastAck(hContact, ACKTYPE_FILE, ACKRESULT_DENIED, ft, 0);
if (ft->hConn) Netlib_Shutdown(ft->hConn);
else ft_list.remove_by_ft(ft);
}
}
}
mir_free(sn);
}
mir_free(icbm_cookie);
}
}
void CAimProto::snac_received_info(SNAC &snac)//family 0x0002
{
if (snac.subcmp(0x0006))
{
unsigned short offset = 0;
int i = 0;
bool away_message_received = false;
bool away_message_unicode = false;
bool away_message_utf = false;
bool profile_received = false;
bool profile_unicode = false;
bool profile_utf = false;
unsigned char sn_length = snac.ubyte();
char* sn = snac.part(1, sn_length);
unsigned short tlv_count = snac.ushort(3 + sn_length);
offset = 5 + sn_length;
MCONTACT hContact = contact_from_sn(sn, true, true);
while (offset < snac.len())
{
TLV tlv(snac.val(offset));
if (++i > tlv_count)
{
if (tlv.cmp(0x0001))//profile encoding
{
char* enc = tlv.dup();
profile_unicode = strstr(enc, "unicode-2-0") != NULL;
profile_utf = strstr(enc, "utf-8") != NULL;
mir_free(enc);
}
else if (tlv.cmp(0x0002))//profile message string
{
char* msg = profile_unicode ? tlv.dupw() : tlv.dup();
profile_received = true;
write_profile(sn, msg, profile_unicode | profile_utf);
mir_free(msg);
}
else if (tlv.cmp(0x0003))//away message encoding
{
char* enc = tlv.dup();
away_message_unicode = strstr(enc, "unicode-2-0") != NULL;
away_message_utf = strstr(enc, "utf-8") != NULL;
mir_free(enc);
}
else if (tlv.cmp(0x0004))//away message string
{
char* msg = away_message_unicode ? tlv.dupw() : tlv.dup();
away_message_received = true;
write_away_message(sn, msg, away_message_unicode | away_message_utf);
mir_free(msg);
}
}
offset += TLV_HEADER_SIZE + tlv.len();
}
if (hContact)
{
if (getWord(hContact,AIM_KEY_ST,ID_STATUS_OFFLINE) == ID_STATUS_AWAY)
{
if (!away_message_received && request_away_message)
write_away_message(sn,Translate("No information has been provided by the server."),false);
request_away_message = 0;
}
if (!profile_received&&request_HTML_profile)
write_profile(sn,"No Profile",false);
request_HTML_profile=0;
}
mir_free(sn);
}
}
void CAimProto::snac_typing_notification(SNAC &snac)//family 0x004
{
if (snac.subcmp(0x0014))
{
unsigned char sn_length=snac.ubyte(10);
char* sn=snac.part(11,sn_length);
MCONTACT hContact=contact_from_sn(sn);
if (hContact)
{
unsigned short type=snac.ushort(11+sn_length);
if (type==0x0000)//typing finished
CallService(MS_PROTO_CONTACTISTYPING,hContact,(WPARAM)PROTOTYPE_CONTACTTYPING_OFF);
else if (type==0x0001)//typed
CallService(MS_PROTO_CONTACTISTYPING,hContact,PROTOTYPE_CONTACTTYPING_INFINITE);
else if (type==0x0002)//typing
CallService(MS_PROTO_CONTACTISTYPING,hContact,(LPARAM)60);
}
mir_free(sn);
}
}
void CAimProto::snac_list_modification_ack(SNAC &snac)//family 0x0013
{
if (snac.subcmp(0x000e))
{
unsigned short id = snac.id();
TLV tlv(snac.val(2));
unsigned short code = snac.ushort(6 + tlv.len());
// ssi_queue.execute(this, code == 0);
switch (id)
{
case 0x000a:
switch (code)
{
case 0x0000:
// ShowPopup(LPGEN("Successfully removed buddy from list."), ERROR_POPUP);
break;
case 0x0002:
ShowPopup(LPGEN("Item you want to delete not found in list."), ERROR_POPUP);
break;
default:
char msg[64];
mir_snprintf(msg, SIZEOF(msg), "Error removing buddy from list. Error code %#x", code);
ShowPopup(msg, ERROR_POPUP);
break;
}
break;
case 0x0008:
switch (code)
{
case 0x0000:
// ShowPopup("Successfully added buddy to list.", ERROR_POPUP);
break;
case 0x0003:
ShowPopup(LPGEN("Failed to add buddy to list: Item already exist."), ERROR_POPUP);
break;
case 0x000a:
ShowPopup(LPGEN("Error adding buddy (invalid ID or already in list?)"), ERROR_POPUP);
break;
case 0x000c:
ShowPopup(LPGEN("Cannot add buddy. Limit for this type of item exceeded."), ERROR_POPUP);
break;
case 0x000d:
ShowPopup(LPGEN("Error? Attempting to add ICQ contact to an AIM list."), ERROR_POPUP);
break;
case 0x000e:
ShowPopup(LPGEN("Cannot add this buddy because it requires authorization."), ERROR_POPUP);
break;
default:
char msg[64];
mir_snprintf(msg, SIZEOF(msg), Translate("Unknown error when adding buddy to list. Error code %#x"), code);
ShowPopup(msg, ERROR_POPUP);
break;
}
break;
case 0x0009:
switch (code)
{
case 0x0000:
case 0x000e:
// ShowPopup(LPGEN("Successfully modified group."), ERROR_POPUP);
break;
case 0x0002:
ShowPopup(LPGEN("Item you want to modify not found in list."), ERROR_POPUP);
break;
default:
char msg[64];
mir_snprintf(msg, SIZEOF(msg), Translate("Unknown error when attempting to modify a group. Error code %#x"), code);
ShowPopup(msg, ERROR_POPUP);
break;
}
break;
}
}
}
void CAimProto::snac_service_redirect(SNAC &snac)//family 0x0001
{
if (snac.subcmp(0x0005))
{
char* server=NULL;
char* local_cookie=NULL;
char* host=NULL;
int local_cookie_length=0;
unsigned short family=0;
unsigned char use_ssl=0;
int offset=2; // skip number of bytes in family version tlv
while (offset < snac.len())
{
TLV tlv(snac.val(offset));
if (tlv.cmp(0x000d))
{
family=tlv.ushort();
}
else if (tlv.cmp(0x0005))
{
server=tlv.dup();
}
else if (tlv.cmp(0x0006))
{
local_cookie=tlv.dup();
local_cookie_length=tlv.len();
}
else if (tlv.cmp(0x008d))
{
host=tlv.dup();
}
else if (tlv.cmp(0x008e))
{
use_ssl=tlv.ubyte();
}
offset+=TLV_HEADER_SIZE+tlv.len();
}
if (family == 0x0018)
{
hMailConn = aim_connect(server, get_default_port(), false/*use_ssl != 0*/, host);
if (hMailConn)
{
debugLogA("Successfully Connected to the Mail Server.");
MAIL_COOKIE=local_cookie;
MAIL_COOKIE_LENGTH=local_cookie_length;
ForkThread( &CAimProto::aim_mail_negotiation, 0 );
}
else
debugLogA("Failed to connect to the Mail Server.");
}
else if (family == 0x0010)
{
hAvatarConn = aim_connect(server, get_default_port(), false/*use_ssl != 0*/);
if (hAvatarConn)
{
debugLogA("Successfully Connected to the Avatar Server.");
AVATAR_COOKIE = local_cookie;
AVATAR_COOKIE_LENGTH = local_cookie_length;
ForkThread( &CAimProto::aim_avatar_negotiation, 0 );
}
else
debugLogA("Failed to connect to the Avatar Server.");
}
else if (family == 0x000D)
{
hChatNavConn = aim_connect(server, get_default_port(), use_ssl != 0, host);
if (hChatNavConn)
{
debugLogA("Successfully Connected to the Chat Navigation Server.");
CHATNAV_COOKIE = local_cookie;
CHATNAV_COOKIE_LENGTH = local_cookie_length;
ForkThread( &CAimProto::aim_chatnav_negotiation, 0 );
}
else
debugLogA("Failed to connect to the Chat Navigation Server.");
}
else if (family == 0x000E)
{
chat_list_item* item = find_chat_by_cid(snac.idh());
if (item)
{
item->hconn = aim_connect(server, get_default_port(), use_ssl != 0, host);
if (item->hconn)
{
debugLogA("Successfully Connected to the Chat Server.");
chat_start(item->id, item->exchange);
item->CHAT_COOKIE = local_cookie;
item->CHAT_COOKIE_LENGTH = local_cookie_length;
ForkThread( &CAimProto::aim_chat_negotiation, item );
}
else
debugLogA("Failed to connect to the Chat Server.");
}
}
else if (family == 0x0007)
{
hAdminConn = aim_connect(server, get_default_port(), false /*use_ssl != 0*/);
if (hAdminConn)
{
debugLogA("Successfully Connected to the Admin Server.");
ADMIN_COOKIE = local_cookie;
ADMIN_COOKIE_LENGTH = local_cookie_length;
ForkThread( &CAimProto::aim_admin_negotiation, 0 );
}
else
debugLogA("Failed to connect to the Admin Server.");
}
mir_free(server);
mir_free(host);
}
}
void CAimProto::snac_mail_response(SNAC &snac)//family 0x0018
{
if (snac.subcmp(0x0007))
{
char* sn = NULL;
time_t time = 0;
unsigned short num_msgs = 0;
unsigned short flags = 0;
char new_mail = 0;
char* url = NULL;
char* address = NULL;
int position = 26;
int num_tlvs = snac.ushort(24);
for (int i = 0; i < num_tlvs; i++)
{
TLV tlv(snac.val(position));
if (tlv.cmp(0x0009))
{
sn = tlv.dup();
}
else if (tlv.cmp(0x001d))
{
time = tlv.ulong();
}
else if (tlv.cmp(0x0080))
{
num_msgs = tlv.ushort();
}
else if (tlv.cmp(0x0081))
{
new_mail = tlv.ubyte();
}
else if (tlv.cmp(0x0084))
{
flags = tlv.ushort();
}
else if (tlv.cmp(0x0007))
{
url = tlv.dup();
}
else if (tlv.cmp(0x0082))
{
address = tlv.dup();
}
position += TLV_HEADER_SIZE + tlv.len();
}
if (new_mail && num_msgs)
{
TCHAR msg[1024];
int len = mir_sntprintf(msg, SIZEOF(msg), _T("%S@%S (%d)\r\n%s "), sn, address, num_msgs,
TranslateT("You've got mail! Checked at")) ;
SYSTEMTIME stLocal;
GetLocalTime(&stLocal);
GetTimeFormat(LOCALE_USER_DEFAULT, 0, &stLocal, NULL, msg + len, SIZEOF(msg) - len);
ShowPopup((char*)msg, MAIL_POPUP | TCHAR_POPUP, url);
}
mir_free(sn);
mir_free(address);
mir_free(url);
}
}
void CAimProto::snac_retrieve_avatar(SNAC &snac)//family 0x0010
{
if (snac.subcmp(0x0007))
{
int sn_len = snac.ubyte(0);
char* sn = snac.part(1, sn_len);
int parse_off = sn_len + 4;
parse_off += snac.ubyte(parse_off);
int hash_size=snac.ubyte(5+parse_off);
char* hash_string=bytes_to_string(snac.val(6+parse_off), hash_size);
parse_off += hash_size + 6;
int icon_length=snac.ushort(parse_off);
char* icon_data=snac.val(parse_off+2);
avatar_retrieval_handler(sn, hash_string, icon_data, icon_length);
mir_free(hash_string);
mir_free(sn);
}
}
void CAimProto::snac_upload_reply_avatar(SNAC &snac)//family 0x0010
{
if (snac.subcmp(0x0003))
{
int code = snac.ubyte(0);
switch (code)
{
case 0:
break;
case 3:
ShowPopup(LPGEN("Error uploading avatar. (Too small)"), ERROR_POPUP);
break;
case 4:
ShowPopup(LPGEN("Error uploading avatar. (Too big)"), ERROR_POPUP);
break;
case 5:
ShowPopup(LPGEN("Error uploading avatar. (Wrong type)"), ERROR_POPUP);
break;
case 6:
ShowPopup(LPGEN("Error uploading avatar. (Is banned)"), ERROR_POPUP);
break;
default:
ShowPopup(LPGEN("Error uploading avatar. (Unknown error)"), ERROR_POPUP);
break;
}
}
}
void CAimProto::snac_email_search_results(SNAC &snac)//family 0x000A
{
if (snac.subcmp(0x0003)) // Found some buddies
{
PROTOSEARCHRESULT psr = {0};
psr.cbSize = sizeof(psr);
unsigned short offset=0;
while(offsetcid);
}
mir_free(name);
mir_free(cookie);
}
offset_info += TLV_HEADER_SIZE + info_tlv.len();
}
}
}
void CAimProto::snac_chat_joined_left_users(SNAC &snac,chat_list_item* item)//family 0x000E
{ // Handles both joining and leaving users.
if (snac.subcmp(0x0003) || snac.subcmp(0x0004))
{
int offset = 0;
while (offset < snac.len())
{
int sn_len = snac.ubyte(offset);
char* sn = snac.part(offset+1, sn_len); // Most important part (screenname)
chat_event(item->id, sn, snac.subcmp(0x0003) ? GC_EVENT_JOIN : GC_EVENT_PART);
mir_free(sn);
// int warning = snac.ushort(offset+1+sn_len);
int num_tlv = snac.ushort(offset+3+sn_len);
offset += 5+sn_len; // We're looking at any remaining TLVs
/*
unsigned short user_class = 0;
unsigned long idle_time = 0;
unsigned long signon_time = 0;
unsigned long creation_time = 0; // Server uptime?
*/
for (int i = 0; i < num_tlv; i++) // Loop through all the TLVs
{
TLV tlv(snac.val(offset));
/*
if (tlv.cmp(0x0001))
user_class = tlv.ushort();
else if (tlv.cmp(0x0003))
signon_time = tlv.ulong();
else if (tlv.cmp(0x0005))
creation_time = tlv.ulong();
else if (tlv.cmp(0x000F))
idle_time = tlv.ulong();
*/
offset += TLV_HEADER_SIZE + tlv.len();
}
}
}
}
void CAimProto::snac_chat_received_message(SNAC &snac,chat_list_item* item)//family 0x000E
{
if (snac.subcmp(0x0006))
{
TCHAR* message = NULL;
char* sn = NULL;
// unsigned long cookie = snac.ulong(0);
// unsigned short channel = snac.ushort(8);
int tlv_offset = 10;
while (tlv_offset < snac.len())
{
TLV tlv(snac.val(tlv_offset));
if (tlv.cmp(0x0003)) // Sender information
{
int sn_len = tlv.ubyte(0);
sn = tlv.part(1, sn_len);
/*
unsigned short warning = tlv.ushort(1+sn_len);
int num_tlv = tlv.ushort(3+sn_len);
int offset = 19 + sn_len;
unsigned short user_class = 0;
unsigned long idle_time = 0;
unsigned long signon_time = 0;
unsigned long creation_time = 0; //Server uptime?
for (int i = 0; i < num_tlv; i++) // Loop through all the TLVs
{
TLV info_tlv(tlv.val() + offset);
// TLV List
if (info_tlv.cmp(0x0001))
user_class = info_tlv.ushort();
else if (info_tlv.cmp(0x0003))
signon_time = info_tlv.ulong();
else if (info_tlv.cmp(0x0005))
creation_time = info_tlv.ulong();
else if (info_tlv.cmp(0x000F))
idle_time = info_tlv.ulong();
offset += TLV_HEADER_SIZE + info_tlv.len();
}
*/
}
else if (tlv.cmp(0x0001)) // Public/Whisper flag
{
}
else if (tlv.cmp(0x0005)) // Message information
{
bool uni = false;
bool utf = false;
// char* language = NULL;
int offset = 0;
while (offset < tlv.len())
{
TLV msg_tlv(tlv.val() + offset);
// TLV List
if (msg_tlv.cmp(0x0001))
{
if (uni)
{
char* msg = msg_tlv.dupw();
html_decode(msg);
message = mir_utf8decodeT(msg);
mir_free(msg);
}
else if (utf)
{
char* msg = msg_tlv.dup();
html_decode(msg);
message = mir_utf8decodeT(msg);
mir_free(msg);
}
else
{
char* msg = msg_tlv.dup();
html_decode(msg);
message = mir_a2t(msg);
mir_free(msg);
}
}
else if (msg_tlv.cmp(0x0002))
{
char* enc = msg_tlv.dup();
uni = strstr(enc, "unicode-2-0") != NULL;
utf = strstr(enc, "utf-8") != NULL;
mir_free(enc);
}
// else if (msg_tlv.cmp(0x0003))
// language = msg_tlv.dup();
offset += TLV_HEADER_SIZE + msg_tlv.len();
}
}
tlv_offset += TLV_HEADER_SIZE + tlv.len();
}
chat_event(item->id, sn, GC_EVENT_MESSAGE, message);
mir_free(message);
mir_free(sn);
}
}
void CAimProto::snac_admin_rate_limitations(SNAC &snac,HANDLE hServerConn,unsigned short &seqno)// family 0x0001
{
if (snac.subcmp(0x0007))
{
aim_accept_rates(hServerConn,seqno);
aim_admin_ready(hServerConn,seqno);
SetEvent(hAdminEvent);
}
}
void CAimProto::snac_admin_account_infomod(SNAC &snac)//family 0x0007
{
if (snac.subcmp(0x0003) || snac.subcmp(0x0005)) // Handles info response and modification response
{
bool err = false;
bool req_email = false;
unsigned short perms = 0;
unsigned short num_tlv = 0;
perms = snac.ushort(); // Permissions
num_tlv = snac.ushort(2); // Number of TLVs
char* sn = NULL; // Screen Name
char* email = NULL; // Email address
//unsigned short status = 0; // Account status
unsigned short offset = 0;
for (int i = 0; i < num_tlv; i++) // Loop through all the TLVs
{
TLV tlv(snac.val(4+offset));
// TLV List
if (tlv.cmp(0x0001))
sn = tlv.dup();
if (tlv.cmp(0x0011))
{
req_email = true;
email = tlv.dup();
}
//if (tlv.cmp(0x0013))
// status = tlv.ushort();
if (tlv.cmp(0x0008)) // Handles any problems when requesting/changing information
{
err = true;
admin_error(tlv.ushort());
}
//if (tlv.cmp(0x0004))
//error description
offset += TLV_HEADER_SIZE + tlv.len();
}
if (snac.subcmp(0x0003) && !err) // Requested info
{
// Display messages
if (email)
setString(AIM_KEY_EM,email); // Save our email for future reference.
if (sn)
setString(AIM_KEY_SN,sn); // Update the database to reflect the formatted name.
ProtoBroadcastAck( NULL, ACKTYPE_GETINFO, ACKRESULT_SUCCESS, (HANDLE)1, 0 );
}
else if (snac.subcmp(0x0005) && !err) // Changed info
{
// Display messages
if (email && req_email) // We requested to change the email
ShowPopup(LPGEN("A confirmation message has been sent to the new email address. Please follow its instructions."), 0);
else if (sn)
{
setString(AIM_KEY_SN,sn); // Update the database to reflect the formatted name.
//ShowPopup("Your Screen Name has been successfully formatted.", 0);
}
}
mir_free(sn);
mir_free(email);
}
}
void CAimProto::snac_admin_account_confirm(SNAC &snac)//family 0x0007
{
if (snac.subcmp(0x0007))
{
unsigned short status = 0;
status = snac.ushort();
switch (status)
{
case 0:
ShowPopup(LPGEN("A confirmation message has been sent to your email address. Please follow its instructions."), 0);
break;
case 0x13:
ShowPopup(LPGEN("Unable to confirm at this time. Please try again later."), 0);
break;
case 0x1e:
ShowPopup(LPGEN("Your account has already been confirmed."), 0);
break;
case 0x23:
ShowPopup(LPGEN("Can't start the confirmation procedure."), 0);
break;
}
//TLV tlv(snac.val(2));
//if (tlv.cmp(0x0004))
//error description
}
}
/*void CAimProto::snac_delete_contact(SNAC &snac, char* buf)//family 0x0013
{
if (snac.subcmp(0x000a))
{
char sn[33];
int sn_length=buf[SNAC_SIZE*2];
MCONTACT hContact;
memset(sn, 0, sizeof(sn));
memcpy(sn,&buf[SNAC_SIZE*2+1],sn_length);
hContact=find_contact(sn);
if (hContact)
{
unsigned short* type=(unsigned short*)&buf[SNAC_SIZE*2+1+sn_length];
*type=htons(*type);
if (*type==0x0000)//typing finished
CallService(MS_PROTO_CONTACTISTYPING,hContact,(WPARAM)PROTOTYPE_CONTACTTYPING_OFF);
else if (*type==0x0001)//typed
CallService(MS_PROTO_CONTACTISTYPING,hContact,PROTOTYPE_CONTACTTYPING_INFINITE);
else if (*type==0x0002)//typing
CallService(MS_PROTO_CONTACTISTYPING,hContact,(LPARAM)60);
}
}
}*/