diff options
Diffstat (limited to 'protocols/AimOscar/src/connection.cpp')
| -rw-r--r-- | protocols/AimOscar/src/connection.cpp | 427 |
1 files changed, 185 insertions, 242 deletions
diff --git a/protocols/AimOscar/src/connection.cpp b/protocols/AimOscar/src/connection.cpp index 1961da1dbc..0a09c6d86c 100644 --- a/protocols/AimOscar/src/connection.cpp +++ b/protocols/AimOscar/src/connection.cpp @@ -16,6 +16,7 @@ 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 <http://www.gnu.org/licenses/>.
*/
+
#include "stdafx.h"
HANDLE CAimProto::aim_connect(const char* server, unsigned short port, bool use_ssl, const char* host)
@@ -27,9 +28,9 @@ HANDLE CAimProto::aim_connect(const char* server, unsigned short port, bool use_ ncon.timeout = 6;
ncon.flags = NLOCF_V2;
debugLogA("%s:%u", server, port);
- HANDLE con = (HANDLE) CallService(MS_NETLIB_OPENCONNECTION, (WPARAM)m_hNetlibUser, (LPARAM)&ncon);
+ HANDLE con = (HANDLE)CallService(MS_NETLIB_OPENCONNECTION, (WPARAM)m_hNetlibUser, (LPARAM)&ncon);
if (con && use_ssl) {
- NETLIBSSL ssl = {0};
+ NETLIBSSL ssl = { 0 };
ssl.cbSize = sizeof(ssl);
ssl.host = host;
if (!CallService(MS_NETLIB_STARTSSL, (WPARAM)con, (LPARAM)&ssl)) {
@@ -41,14 +42,14 @@ HANDLE CAimProto::aim_connect(const char* server, unsigned short port, bool use_ }
HANDLE CAimProto::aim_peer_connect(const char* ip, unsigned short port)
-{
+{
NETLIBOPENCONNECTION ncon = { 0 };
ncon.cbSize = sizeof(ncon);
ncon.flags = NLOCF_V2;
ncon.szHost = ip;
ncon.wPort = port;
ncon.timeout = 3;
- return (HANDLE)CallService(MS_NETLIB_OPENCONNECTION, (WPARAM)hNetlibPeer, (LPARAM)&ncon);
+ return (HANDLE)CallService(MS_NETLIB_OPENCONNECTION, (WPARAM)m_hNetlibPeer, (LPARAM)&ncon);
}
HANDLE CAimProto::aim_peer_connect(unsigned long ip, unsigned short port)
@@ -64,15 +65,15 @@ void CAimProto::aim_connection_authorization(void) if (m_iDesiredStatus != ID_STATUS_OFFLINE) {
char *password = getStringA(AIM_KEY_PW);
if (password != NULL) {
- mir_free(username);
- username = getStringA(AIM_KEY_SN);
- if (username != NULL) {
- HANDLE hServerPacketRecver = (HANDLE)CallService(MS_NETLIB_CREATEPACKETRECVER, (WPARAM)hServerConn, 2048 * 4);
- NETLIBPACKETRECVER packetRecv = {0};
+ mir_free(m_username);
+ m_username = getStringA(AIM_KEY_SN);
+ if (m_username != NULL) {
+ HANDLE hServerPacketRecver = (HANDLE)CallService(MS_NETLIB_CREATEPACKETRECVER, (WPARAM)m_hServerConn, 2048 * 4);
+ NETLIBPACKETRECVER packetRecv = { 0 };
packetRecv.cbSize = sizeof(packetRecv);
packetRecv.dwTimeout = 5000;
for (;;) {
- int recvResult = CallService(MS_NETLIB_GETMOREPACKETS, (WPARAM) hServerPacketRecver, (LPARAM) & packetRecv);
+ int recvResult = CallService(MS_NETLIB_GETMOREPACKETS, (WPARAM)hServerPacketRecver, (LPARAM)& packetRecv);
if (recvResult == 0) {
debugLogA("Connection Closed: No Error? during Connection Authorization");
break;
@@ -82,24 +83,24 @@ void CAimProto::aim_connection_authorization(void) break;
}
else {
- unsigned short flap_length=0;
- for (;packetRecv.bytesUsed<packetRecv.bytesAvailable;packetRecv.bytesUsed = flap_length) {
+ unsigned short flap_length = 0;
+ for (; packetRecv.bytesUsed < packetRecv.bytesAvailable; packetRecv.bytesUsed = flap_length) {
if (!packetRecv.buffer)
break;
- FLAP flap((char*)&packetRecv.buffer[packetRecv.bytesUsed],(unsigned short)(packetRecv.bytesAvailable-packetRecv.bytesUsed));
+ FLAP flap((char*)&packetRecv.buffer[packetRecv.bytesUsed], (unsigned short)(packetRecv.bytesAvailable - packetRecv.bytesUsed));
if (!flap.len())
break;
- flap_length+=FLAP_SIZE+flap.len();
+ flap_length += FLAP_SIZE + flap.len();
if (flap.cmp(0x01)) {
- if (aim_send_connection_packet(hServerConn, seqno,flap.val())==0)//cookie challenge
- aim_authkey_request(hServerConn, seqno);//md5 authkey request
+ if (aim_send_connection_packet(m_hServerConn, m_seqno, flap.val()) == 0) // cookie challenge
+ aim_authkey_request(m_hServerConn, m_seqno); // md5 authkey request
}
else if (flap.cmp(0x02)) {
- SNAC snac(flap.val(),flap.snaclen());
+ SNAC snac(flap.val(), flap.snaclen());
if (snac.cmp(0x0017)) {
- snac_md5_authkey(snac,hServerConn,seqno, username, password);
+ snac_md5_authkey(snac, m_hServerConn, m_seqno, m_username, password);
int authres = snac_authorization_reply(snac);
switch (authres) {
case 1:
@@ -125,102 +126,88 @@ void CAimProto::aim_connection_authorization(void) }
}
}
-exit:
+ exit:
if (hServerPacketRecver)
- Netlib_CloseHandle(hServerPacketRecver);
+ Netlib_CloseHandle(hServerPacketRecver);
}
}
mir_free(password);
}
- if (m_iStatus!=ID_STATUS_OFFLINE)
+ if (m_iStatus != ID_STATUS_OFFLINE)
broadcast_status(ID_STATUS_OFFLINE);
- Netlib_CloseHandle(hServerConn);
- hServerConn=NULL;
+ Netlib_CloseHandle(m_hServerConn);
+ m_hServerConn = NULL;
debugLogA("Connection Authorization Thread Ending: End of Thread");
}
-void __cdecl CAimProto::aim_protocol_negotiation( void* )
+void __cdecl CAimProto::aim_protocol_negotiation(void*)
{
- HANDLE hServerPacketRecver = (HANDLE)CallService(MS_NETLIB_CREATEPACKETRECVER, (WPARAM)hServerConn, 2048 * 8);
+ HANDLE hServerPacketRecver = (HANDLE)CallService(MS_NETLIB_CREATEPACKETRECVER, (WPARAM)m_hServerConn, 2048 * 8);
- NETLIBPACKETRECVER packetRecv = {0};
+ NETLIBPACKETRECVER packetRecv = { 0 };
packetRecv.cbSize = sizeof(packetRecv);
- packetRecv.dwTimeout = DEFAULT_KEEPALIVE_TIMER*1000;
- for (;;)
- {
+ packetRecv.dwTimeout = DEFAULT_KEEPALIVE_TIMER * 1000;
+ for (;;) {
int recvResult = CallService(MS_NETLIB_GETMOREPACKETS, (WPARAM)hServerPacketRecver, (LPARAM)&packetRecv);
- if (recvResult == 0)
- {
+ if (recvResult == 0) {
debugLogA("Connection Closed: No Error during Connection Negotiation?");
break;
}
- else if (recvResult == SOCKET_ERROR)
- {
- if (WSAGetLastError() == ERROR_TIMEOUT)
- {
- if (aim_keepalive(hServerConn,seqno) < 0)
+ else if (recvResult == SOCKET_ERROR) {
+ if (WSAGetLastError() == ERROR_TIMEOUT) {
+ if (aim_keepalive(m_hServerConn, m_seqno) < 0)
break;
}
- else
- {
+ else {
debugLogA("Connection Closed: Socket Error during Connection Negotiation %d", WSAGetLastError());
break;
}
}
- else if (recvResult>0)
- {
- unsigned short flap_length=0;
- for (;packetRecv.bytesUsed<packetRecv.bytesAvailable;packetRecv.bytesUsed=flap_length)
- {
+ else if (recvResult > 0) {
+ unsigned short flap_length = 0;
+ for (; packetRecv.bytesUsed < packetRecv.bytesAvailable; packetRecv.bytesUsed = flap_length) {
if (!packetRecv.buffer)
break;
- FLAP flap((char*)&packetRecv.buffer[packetRecv.bytesUsed],packetRecv.bytesAvailable-packetRecv.bytesUsed);
+ FLAP flap((char*)&packetRecv.buffer[packetRecv.bytesUsed], packetRecv.bytesAvailable - packetRecv.bytesUsed);
if (!flap.len())
break;
- flap_length+=FLAP_SIZE+flap.len();
- if (flap.cmp(0x01))
- {
- aim_send_cookie(hServerConn,seqno,COOKIE_LENGTH,COOKIE);//cookie challenge
+ flap_length += FLAP_SIZE + flap.len();
+ if (flap.cmp(0x01)) {
+ aim_send_cookie(m_hServerConn, m_seqno, COOKIE_LENGTH, COOKIE);//cookie challenge
mir_free(COOKIE);
- COOKIE=NULL;
- COOKIE_LENGTH=0;
+ COOKIE = NULL;
+ COOKIE_LENGTH = 0;
}
- else if (flap.cmp(0x02))
- {
- SNAC snac(flap.val(),flap.snaclen());
- if (snac.cmp(0x0001))
- {
- snac_supported_families(snac,hServerConn,seqno);
- snac_supported_family_versions(snac,hServerConn,seqno);
- snac_rate_limitations(snac,hServerConn,seqno);
+ else if (flap.cmp(0x02)) {
+ SNAC snac(flap.val(), flap.snaclen());
+ if (snac.cmp(0x0001)) {
+ snac_supported_families(snac, m_hServerConn, m_seqno);
+ snac_supported_family_versions(snac, m_hServerConn, m_seqno);
+ snac_rate_limitations(snac, m_hServerConn, m_seqno);
snac_service_redirect(snac);
snac_self_info(snac);
snac_error(snac);
}
- else if (snac.cmp(0x0002))
- {
+ else if (snac.cmp(0x0002)) {
snac_received_info(snac);
snac_error(snac);
}
- else if (snac.cmp(0x0003))
- {
+ else if (snac.cmp(0x0003)) {
snac_user_online(snac);
snac_user_offline(snac);
snac_error(snac);
}
- else if (snac.cmp(0x0004))
- {
- snac_icbm_limitations(snac,hServerConn,seqno);
+ else if (snac.cmp(0x0004)) {
+ snac_icbm_limitations(snac, m_hServerConn, m_seqno);
snac_message_accepted(snac);
- snac_received_message(snac,hServerConn,seqno);
+ snac_received_message(snac, m_hServerConn, m_seqno);
snac_typing_notification(snac);
snac_error(snac);
snac_file_decline(snac);
}
- else if (snac.cmp(0x000A))
- {
+ else if (snac.cmp(0x000A)) {
snac_email_search_results(snac);
- /*
+ /*
If there's no match (error 0x14), AIM will pop up a message.
Since it's annoying and there's no other errors that'll get
generated, I just assume leave this commented out. It's here
@@ -228,15 +215,13 @@ void __cdecl CAimProto::aim_protocol_negotiation( void* ) */
//snac_error(snac);
}
- else if (snac.cmp(0x0013))
- {
- snac_contact_list(snac,hServerConn,seqno);
+ else if (snac.cmp(0x0013)) {
+ snac_contact_list(snac, m_hServerConn, m_seqno);
snac_list_modification_ack(snac);
snac_error(snac);
}
}
- else if (flap.cmp(0x04))
- {
+ else if (flap.cmp(0x04)) {
ProtoBroadcastAck(NULL, ACKTYPE_LOGIN, ACKRESULT_FAILED, NULL, LOGINERR_OTHERLOCATION);
debugLogA("Connection Negotiation Thread Ending: Flap 0x04");
goto exit;
@@ -246,67 +231,57 @@ void __cdecl CAimProto::aim_protocol_negotiation( void* ) }
exit:
- if (m_iStatus!=ID_STATUS_OFFLINE) broadcast_status(ID_STATUS_OFFLINE);
- Netlib_CloseHandle(hServerPacketRecver); hServerPacketRecver=NULL;
- Netlib_CloseHandle(hServerConn); hServerConn=NULL;
+ if (m_iStatus != ID_STATUS_OFFLINE) broadcast_status(ID_STATUS_OFFLINE);
+ Netlib_CloseHandle(hServerPacketRecver); hServerPacketRecver = NULL;
+ Netlib_CloseHandle(m_hServerConn); m_hServerConn = NULL;
debugLogA("Connection Negotiation Thread Ending: End of Thread");
offline_contacts();
}
-void __cdecl CAimProto::aim_mail_negotiation( void* )
+void __cdecl CAimProto::aim_mail_negotiation(void*)
{
- HANDLE hServerPacketRecver = (HANDLE) CallService(MS_NETLIB_CREATEPACKETRECVER, (WPARAM)hMailConn, 2048 * 8);
+ HANDLE hServerPacketRecver = (HANDLE)CallService(MS_NETLIB_CREATEPACKETRECVER, (WPARAM)m_hMailConn, 2048 * 8);
- NETLIBPACKETRECVER packetRecv = {0};
+ NETLIBPACKETRECVER packetRecv = { 0 };
packetRecv.cbSize = sizeof(packetRecv);
- packetRecv.dwTimeout = DEFAULT_KEEPALIVE_TIMER*1000;
- while(m_iStatus!=ID_STATUS_OFFLINE)
- {
+ packetRecv.dwTimeout = DEFAULT_KEEPALIVE_TIMER * 1000;
+ while (m_iStatus != ID_STATUS_OFFLINE) {
int recvResult = CallService(MS_NETLIB_GETMOREPACKETS, (WPARAM)hServerPacketRecver, (LPARAM)&packetRecv);
- if (recvResult == 0)
- {
+ if (recvResult == 0) {
break;
}
- if (recvResult == SOCKET_ERROR)
- {
- if (WSAGetLastError() == ERROR_TIMEOUT)
- {
- if (aim_keepalive(hMailConn, mail_seqno) < 0)
+ if (recvResult == SOCKET_ERROR) {
+ if (WSAGetLastError() == ERROR_TIMEOUT) {
+ if (aim_keepalive(m_hMailConn, m_mail_seqno) < 0)
break;
}
else
break;
}
- if (recvResult>0)
- {
- unsigned short flap_length=0;
- for (;packetRecv.bytesUsed<packetRecv.bytesAvailable;packetRecv.bytesUsed=flap_length)
- {
+ if (recvResult > 0) {
+ unsigned short flap_length = 0;
+ for (; packetRecv.bytesUsed < packetRecv.bytesAvailable; packetRecv.bytesUsed = flap_length) {
if (!packetRecv.buffer)
break;
- FLAP flap((char*)&packetRecv.buffer[packetRecv.bytesUsed],packetRecv.bytesAvailable-packetRecv.bytesUsed);
+ FLAP flap((char*)&packetRecv.buffer[packetRecv.bytesUsed], packetRecv.bytesAvailable - packetRecv.bytesUsed);
if (!flap.len())
break;
- flap_length+=FLAP_SIZE+flap.len();
- if (flap.cmp(0x01))
- {
- aim_send_cookie(hMailConn,mail_seqno,MAIL_COOKIE_LENGTH,MAIL_COOKIE);//cookie challenge
+ flap_length += FLAP_SIZE + flap.len();
+ if (flap.cmp(0x01)) {
+ aim_send_cookie(m_hMailConn, m_mail_seqno, MAIL_COOKIE_LENGTH, MAIL_COOKIE);//cookie challenge
mir_free(MAIL_COOKIE);
- MAIL_COOKIE=NULL;
- MAIL_COOKIE_LENGTH=0;
+ MAIL_COOKIE = NULL;
+ MAIL_COOKIE_LENGTH = 0;
}
- else if (flap.cmp(0x02))
- {
- SNAC snac(flap.val(),flap.snaclen());
- if (snac.cmp(0x0001))
- {
- snac_supported_families(snac,hMailConn,mail_seqno);
- snac_supported_family_versions(snac,hMailConn,mail_seqno);
- snac_mail_rate_limitations(snac,hMailConn,mail_seqno);
+ else if (flap.cmp(0x02)) {
+ SNAC snac(flap.val(), flap.snaclen());
+ if (snac.cmp(0x0001)) {
+ snac_supported_families(snac, m_hMailConn, m_mail_seqno);
+ snac_supported_family_versions(snac, m_hMailConn, m_mail_seqno);
+ snac_mail_rate_limitations(snac, m_hMailConn, m_mail_seqno);
snac_error(snac);
}
- else if (snac.cmp(0x0018))
- {
+ else if (snac.cmp(0x0018)) {
snac_mail_response(snac);
}
}
@@ -319,56 +294,49 @@ void __cdecl CAimProto::aim_mail_negotiation( void* ) exit:
debugLogA("Mail Server Connection has ended");
Netlib_CloseHandle(hServerPacketRecver);
- Netlib_CloseHandle(hMailConn);
- hMailConn=NULL;
+ Netlib_CloseHandle(m_hMailConn);
+ m_hMailConn = NULL;
}
-void __cdecl CAimProto::aim_avatar_negotiation( void* )
+void __cdecl CAimProto::aim_avatar_negotiation(void*)
{
- HANDLE hServerPacketRecver = (HANDLE) CallService(MS_NETLIB_CREATEPACKETRECVER, (WPARAM)hAvatarConn, 2048 * 8);
+ HANDLE hServerPacketRecver = (HANDLE)CallService(MS_NETLIB_CREATEPACKETRECVER, (WPARAM)m_hAvatarConn, 2048 * 8);
- NETLIBPACKETRECVER packetRecv = {0};
+ NETLIBPACKETRECVER packetRecv = { 0 };
packetRecv.cbSize = sizeof(packetRecv);
packetRecv.dwTimeout = 300000;//5 minutes connected
- for (;;)
- {
- int recvResult = CallService(MS_NETLIB_GETMOREPACKETS, (WPARAM) hServerPacketRecver, (LPARAM) & packetRecv);
+ for (;;) {
+ int recvResult = CallService(MS_NETLIB_GETMOREPACKETS, (WPARAM)hServerPacketRecver, (LPARAM)& packetRecv);
if (recvResult == 0)
break;
if (recvResult == SOCKET_ERROR)
break;
- if (recvResult > 0)
- {
- unsigned short flap_length=0;
- for (; packetRecv.bytesUsed < packetRecv.bytesAvailable; packetRecv.bytesUsed = flap_length)
- {
+ if (recvResult > 0) {
+ unsigned short flap_length = 0;
+ for (; packetRecv.bytesUsed < packetRecv.bytesAvailable; packetRecv.bytesUsed = flap_length) {
if (!packetRecv.buffer)
break;
- FLAP flap((char*)&packetRecv.buffer[packetRecv.bytesUsed],packetRecv.bytesAvailable-packetRecv.bytesUsed);
+ FLAP flap((char*)&packetRecv.buffer[packetRecv.bytesUsed], packetRecv.bytesAvailable - packetRecv.bytesUsed);
if (!flap.len())
break;
flap_length += FLAP_SIZE + flap.len();
- if (flap.cmp(0x01))
- {
- aim_send_cookie(hAvatarConn, avatar_seqno, AVATAR_COOKIE_LENGTH, AVATAR_COOKIE);//cookie challenge
+ if (flap.cmp(0x01)) {
+ aim_send_cookie(m_hAvatarConn, m_avatar_seqno, AVATAR_COOKIE_LENGTH, AVATAR_COOKIE); // cookie challenge
mir_free(AVATAR_COOKIE);
AVATAR_COOKIE = NULL;
AVATAR_COOKIE_LENGTH = 0;
}
- else if (flap.cmp(0x02))
- {
+ else if (flap.cmp(0x02)) {
SNAC snac(flap.val(), flap.snaclen());
- if (snac.cmp(0x0001))
- {
- snac_supported_families(snac, hAvatarConn, avatar_seqno);
- snac_supported_family_versions(snac, hAvatarConn, avatar_seqno);
- snac_avatar_rate_limitations(snac, hAvatarConn, avatar_seqno);
+ if (snac.cmp(0x0001)) {
+ snac_supported_families(snac, m_hAvatarConn, m_avatar_seqno);
+ snac_supported_family_versions(snac, m_hAvatarConn, m_avatar_seqno);
+ snac_avatar_rate_limitations(snac, m_hAvatarConn, m_avatar_seqno);
snac_error(snac);
}
- if (snac.cmp(0x0010))
- {
+ if (snac.cmp(0x0010)) {
snac_retrieve_avatar(snac);
snac_upload_reply_avatar(snac);
}
@@ -381,73 +349,64 @@ void __cdecl CAimProto::aim_avatar_negotiation( void* ) exit:
Netlib_CloseHandle(hServerPacketRecver);
- Netlib_CloseHandle(hAvatarConn);
- hAvatarConn=NULL;
- ResetEvent(hAvatarEvent);
+ Netlib_CloseHandle(m_hAvatarConn);
+ m_hAvatarConn = NULL;
+ ResetEvent(m_hAvatarEvent);
debugLogA("Avatar Server Connection has ended");
}
-void __cdecl CAimProto::aim_chatnav_negotiation( void* )
+void __cdecl CAimProto::aim_chatnav_negotiation(void*)
{
unsigned idle_chat = 0;
- HANDLE hServerPacketRecver = (HANDLE) CallService(MS_NETLIB_CREATEPACKETRECVER, (WPARAM)hChatNavConn, 2048 * 8);
+ HANDLE hServerPacketRecver = (HANDLE)CallService(MS_NETLIB_CREATEPACKETRECVER, (WPARAM)m_hChatNavConn, 2048 * 8);
- NETLIBPACKETRECVER packetRecv = {0};
+ NETLIBPACKETRECVER packetRecv = { 0 };
packetRecv.cbSize = sizeof(packetRecv);
- packetRecv.dwTimeout = DEFAULT_KEEPALIVE_TIMER*1000;
- for (;;)
- {
- int recvResult = CallService(MS_NETLIB_GETMOREPACKETS, (WPARAM) hServerPacketRecver, (LPARAM)&packetRecv);
+ packetRecv.dwTimeout = DEFAULT_KEEPALIVE_TIMER * 1000;
+ for (;;) {
+ int recvResult = CallService(MS_NETLIB_GETMOREPACKETS, (WPARAM)hServerPacketRecver, (LPARAM)&packetRecv);
if (recvResult == 0)
break;
- if (recvResult == SOCKET_ERROR)
- {
- if (WSAGetLastError() == ERROR_TIMEOUT)
- {
- if (chat_rooms.getCount())
+ if (recvResult == SOCKET_ERROR) {
+ if (WSAGetLastError() == ERROR_TIMEOUT) {
+ if (m_chat_rooms.getCount())
idle_chat = 0;
else if (++idle_chat >= 6)
break;
- if (aim_keepalive(hChatNavConn, chatnav_seqno) < 0)
+ if (aim_keepalive(m_hChatNavConn, m_chatnav_seqno) < 0)
break;
}
else
break;
}
- if (recvResult>0)
- {
- unsigned short flap_length=0;
- for (;packetRecv.bytesUsed<packetRecv.bytesAvailable;packetRecv.bytesUsed=flap_length)
- {
+ if (recvResult > 0) {
+ unsigned short flap_length = 0;
+ for (; packetRecv.bytesUsed < packetRecv.bytesAvailable; packetRecv.bytesUsed = flap_length) {
if (!packetRecv.buffer)
break;
- FLAP flap((char*)&packetRecv.buffer[packetRecv.bytesUsed],packetRecv.bytesAvailable-packetRecv.bytesUsed);
+ FLAP flap((char*)&packetRecv.buffer[packetRecv.bytesUsed], packetRecv.bytesAvailable - packetRecv.bytesUsed);
if (!flap.len())
break;
- flap_length+=FLAP_SIZE+flap.len();
- if (flap.cmp(0x01))
- {
- aim_send_cookie(hChatNavConn,chatnav_seqno,CHATNAV_COOKIE_LENGTH,CHATNAV_COOKIE);//cookie challenge
+ flap_length += FLAP_SIZE + flap.len();
+ if (flap.cmp(0x01)) {
+ aim_send_cookie(m_hChatNavConn, m_chatnav_seqno, CHATNAV_COOKIE_LENGTH, CHATNAV_COOKIE);//cookie challenge
mir_free(CHATNAV_COOKIE);
- CHATNAV_COOKIE=NULL;
- CHATNAV_COOKIE_LENGTH=0;
+ CHATNAV_COOKIE = NULL;
+ CHATNAV_COOKIE_LENGTH = 0;
}
- else if (flap.cmp(0x02))
- {
- SNAC snac(flap.val(),flap.snaclen());
- if (snac.cmp(0x0001))
- {
- snac_supported_families(snac,hChatNavConn,chatnav_seqno);
- snac_supported_family_versions(snac,hChatNavConn,chatnav_seqno);
- snac_chatnav_rate_limitations(snac,hChatNavConn,chatnav_seqno);
+ else if (flap.cmp(0x02)) {
+ SNAC snac(flap.val(), flap.snaclen());
+ if (snac.cmp(0x0001)) {
+ snac_supported_families(snac, m_hChatNavConn, m_chatnav_seqno);
+ snac_supported_family_versions(snac, m_hChatNavConn, m_chatnav_seqno);
+ snac_chatnav_rate_limitations(snac, m_hChatNavConn, m_chatnav_seqno);
snac_error(snac);
}
- if (snac.cmp(0x000D))
- {
- snac_chatnav_info_response(snac,hChatNavConn,chatnav_seqno);
+ if (snac.cmp(0x000D)) {
+ snac_chatnav_info_response(snac, m_hChatNavConn, m_chatnav_seqno);
snac_error(snac);
}
}
@@ -459,30 +418,27 @@ void __cdecl CAimProto::aim_chatnav_negotiation( void* ) exit:
Netlib_CloseHandle(hServerPacketRecver);
- Netlib_CloseHandle(hChatNavConn);
- hChatNavConn=NULL;
- ResetEvent(hChatNavEvent);
+ Netlib_CloseHandle(m_hChatNavConn);
+ m_hChatNavConn = NULL;
+ ResetEvent(m_hChatNavEvent);
debugLogA("Chat Navigation Server Connection has ended");
}
-void __cdecl CAimProto::aim_chat_negotiation( void* param )
+void __cdecl CAimProto::aim_chat_negotiation(void* param)
{
chat_list_item *item = (chat_list_item*)param;
HANDLE hServerPacketRecver = (HANDLE)CallService(MS_NETLIB_CREATEPACKETRECVER, (WPARAM)item->hconn, 2048 * 8);
- NETLIBPACKETRECVER packetRecv = {0};
+ NETLIBPACKETRECVER packetRecv = { 0 };
packetRecv.cbSize = sizeof(packetRecv);
- packetRecv.dwTimeout = DEFAULT_KEEPALIVE_TIMER*1000;
- for (;;)
- {
+ packetRecv.dwTimeout = DEFAULT_KEEPALIVE_TIMER * 1000;
+ for (;;) {
int recvResult = CallService(MS_NETLIB_GETMOREPACKETS, (WPARAM)hServerPacketRecver, (LPARAM)&packetRecv);
if (recvResult == 0)
break;
- if (recvResult == SOCKET_ERROR)
- {
- if (WSAGetLastError() == ERROR_TIMEOUT)
- {
+ if (recvResult == SOCKET_ERROR) {
+ if (WSAGetLastError() == ERROR_TIMEOUT) {
if (aim_keepalive(item->hconn, item->seqno) < 0)
break;
}
@@ -490,37 +446,31 @@ void __cdecl CAimProto::aim_chat_negotiation( void* param ) break;
}
- if (recvResult>0)
- {
- unsigned short flap_length=0;
- for (;packetRecv.bytesUsed<packetRecv.bytesAvailable;packetRecv.bytesUsed=flap_length)
- {
+ if (recvResult > 0) {
+ unsigned short flap_length = 0;
+ for (; packetRecv.bytesUsed < packetRecv.bytesAvailable; packetRecv.bytesUsed = flap_length) {
if (!packetRecv.buffer)
break;
- FLAP flap((char*)&packetRecv.buffer[packetRecv.bytesUsed],packetRecv.bytesAvailable-packetRecv.bytesUsed);
+ FLAP flap((char*)&packetRecv.buffer[packetRecv.bytesUsed], packetRecv.bytesAvailable - packetRecv.bytesUsed);
if (!flap.len())
break;
- flap_length+=FLAP_SIZE+flap.len();
- if (flap.cmp(0x01))
- {
- aim_send_cookie(item->hconn,item->seqno,item->CHAT_COOKIE_LENGTH,item->CHAT_COOKIE);//cookie challenge
+ flap_length += FLAP_SIZE + flap.len();
+ if (flap.cmp(0x01)) {
+ aim_send_cookie(item->hconn, item->seqno, item->CHAT_COOKIE_LENGTH, item->CHAT_COOKIE);//cookie challenge
mir_free(item->CHAT_COOKIE);
- item->CHAT_COOKIE=NULL;
- item->CHAT_COOKIE_LENGTH=0;
+ item->CHAT_COOKIE = NULL;
+ item->CHAT_COOKIE_LENGTH = 0;
}
- else if (flap.cmp(0x02))
- {
- SNAC snac(flap.val(),flap.snaclen());
- if (snac.cmp(0x0001))
- {
- snac_supported_families(snac,item->hconn,item->seqno);
- snac_supported_family_versions(snac,item->hconn,item->seqno);
- snac_chat_rate_limitations(snac,item->hconn,item->seqno);
+ else if (flap.cmp(0x02)) {
+ SNAC snac(flap.val(), flap.snaclen());
+ if (snac.cmp(0x0001)) {
+ snac_supported_families(snac, item->hconn, item->seqno);
+ snac_supported_family_versions(snac, item->hconn, item->seqno);
+ snac_chat_rate_limitations(snac, item->hconn, item->seqno);
snac_error(snac);
}
- if (snac.cmp(0x000E))
- {
+ if (snac.cmp(0x000E)) {
snac_chat_received_message(snac, item);
snac_chat_joined_left_users(snac, item);
snac_error(snac);
@@ -540,52 +490,45 @@ exit: debugLogA("Chat Server Connection has ended");
}
-void __cdecl CAimProto::aim_admin_negotiation( void* )
+void __cdecl CAimProto::aim_admin_negotiation(void*)
{
- HANDLE hServerPacketRecver = (HANDLE)CallService(MS_NETLIB_CREATEPACKETRECVER, (WPARAM)hAdminConn, 2048 * 8);
+ HANDLE hServerPacketRecver = (HANDLE)CallService(MS_NETLIB_CREATEPACKETRECVER, (WPARAM)m_hAdminConn, 2048 * 8);
- NETLIBPACKETRECVER packetRecv = {0};
+ NETLIBPACKETRECVER packetRecv = { 0 };
packetRecv.cbSize = sizeof(packetRecv);
packetRecv.dwTimeout = 300000;//5 minutes connected
- for (;;)
- {
- int recvResult = CallService(MS_NETLIB_GETMOREPACKETS, (WPARAM) hServerPacketRecver, (LPARAM) & packetRecv);
+ for (;;) {
+ int recvResult = CallService(MS_NETLIB_GETMOREPACKETS, (WPARAM)hServerPacketRecver, (LPARAM)& packetRecv);
if (recvResult == 0)
break;
if (recvResult == SOCKET_ERROR)
break;
- if (recvResult>0)
- {
- unsigned short flap_length=0;
- for (;packetRecv.bytesUsed<packetRecv.bytesAvailable;packetRecv.bytesUsed=flap_length)
- {
+ if (recvResult > 0) {
+ unsigned short flap_length = 0;
+ for (; packetRecv.bytesUsed < packetRecv.bytesAvailable; packetRecv.bytesUsed = flap_length) {
if (!packetRecv.buffer)
break;
- FLAP flap((char*)&packetRecv.buffer[packetRecv.bytesUsed],packetRecv.bytesAvailable-packetRecv.bytesUsed);
+ FLAP flap((char*)&packetRecv.buffer[packetRecv.bytesUsed], packetRecv.bytesAvailable - packetRecv.bytesUsed);
if (!flap.len())
break;
- flap_length+=FLAP_SIZE+flap.len();
- if (flap.cmp(0x01))
- {
- aim_send_cookie(hAdminConn,admin_seqno,ADMIN_COOKIE_LENGTH,ADMIN_COOKIE);//cookie challenge
+ flap_length += FLAP_SIZE + flap.len();
+ if (flap.cmp(0x01)) {
+ aim_send_cookie(m_hAdminConn, m_admin_seqno, ADMIN_COOKIE_LENGTH, ADMIN_COOKIE);//cookie challenge
mir_free(ADMIN_COOKIE);
- ADMIN_COOKIE=NULL;
- ADMIN_COOKIE_LENGTH=0;
+ ADMIN_COOKIE = NULL;
+ ADMIN_COOKIE_LENGTH = 0;
}
- else if (flap.cmp(0x02))
- {
- SNAC snac(flap.val(),flap.snaclen());
- if (snac.cmp(0x0001))
- {
- snac_supported_families(snac,hAdminConn,admin_seqno);
- snac_supported_family_versions(snac,hAdminConn,admin_seqno);
- snac_admin_rate_limitations(snac,hAdminConn,admin_seqno);
+ else if (flap.cmp(0x02)) {
+ SNAC snac(flap.val(), flap.snaclen());
+ if (snac.cmp(0x0001)) {
+ snac_supported_families(snac, m_hAdminConn, m_admin_seqno);
+ snac_supported_family_versions(snac, m_hAdminConn, m_admin_seqno);
+ snac_admin_rate_limitations(snac, m_hAdminConn, m_admin_seqno);
snac_error(snac);
}
- if (snac.cmp(0x0007))
- {
+ if (snac.cmp(0x0007)) {
snac_admin_account_infomod(snac);
snac_admin_account_confirm(snac);
snac_error(snac);
@@ -599,8 +542,8 @@ void __cdecl CAimProto::aim_admin_negotiation( void* ) exit:
Netlib_CloseHandle(hServerPacketRecver);
- Netlib_CloseHandle(hAdminConn);
- hAdminConn=NULL;
- ResetEvent(hAdminEvent);
+ Netlib_CloseHandle(m_hAdminConn);
+ m_hAdminConn = NULL;
+ ResetEvent(m_hAdminEvent);
debugLogA("Admin Server Connection has ended");
}
|