diff options
Diffstat (limited to 'protocols/IcqOscarJ/src/icq_server.cpp')
| -rw-r--r-- | protocols/IcqOscarJ/src/icq_server.cpp | 444 |
1 files changed, 444 insertions, 0 deletions
diff --git a/protocols/IcqOscarJ/src/icq_server.cpp b/protocols/IcqOscarJ/src/icq_server.cpp new file mode 100644 index 0000000000..63a5d63d84 --- /dev/null +++ b/protocols/IcqOscarJ/src/icq_server.cpp @@ -0,0 +1,444 @@ +// ---------------------------------------------------------------------------80
+// ICQ plugin for Miranda Instant Messenger
+// ________________________________________
+//
+// Copyright © 2000-2001 Richard Hughes, Roland Rabien, Tristan Van de Vreede
+// Copyright © 2001-2002 Jon Keating, Richard Hughes
+// Copyright © 2002-2004 Martin Öberg, Sam Kothari, Robert Rainwater
+// Copyright © 2004-2010 Joe Kucera
+//
+// 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 02110-1301 USA.
+//
+// -----------------------------------------------------------------------------
+// DESCRIPTION:
+//
+// Manages main server connection, low-level communication
+//
+// -----------------------------------------------------------------------------
+#include "icqoscar.h"
+
+
+void icq_newConnectionReceived(HANDLE hNewConnection, DWORD dwRemoteIP, void *pExtra);
+
+/////////////////////////////////////////////////////////////////////////////////////////
+// ICQ Server thread
+
+void __cdecl CIcqProto::ServerThread(serverthread_start_info *infoParam)
+{
+ serverthread_info info = {0};
+
+ info.isLoginServer = 1;
+ info.wAuthKeyLen = infoParam->wPassLen;
+ null_strcpy((char*)info.szAuthKey, infoParam->szPass, info.wAuthKeyLen);
+ // store server port
+ info.wServerPort = infoParam->nloc.wPort;
+
+ srand(time(NULL));
+
+ ResetSettingsOnConnect();
+
+ // Connect to the login server
+ NetLog_Server("Authenticating to server");
+ {
+ NETLIBOPENCONNECTION nloc = infoParam->nloc;
+ nloc.timeout = 6;
+ if (m_bGatewayMode)
+ nloc.flags |= NLOCF_HTTPGATEWAY;
+
+ hServerConn = NetLib_OpenConnection(m_hServerNetlibUser, NULL, &nloc);
+
+ SAFE_FREE((void**)&nloc.szHost);
+ SAFE_FREE((void**)&infoParam);
+
+ if (hServerConn && m_bSecureConnection)
+ {
+ if (!CallService(MS_NETLIB_STARTSSL, (WPARAM)hServerConn, 0))
+ {
+ icq_LogMessage(LOG_ERROR, LPGEN("Unable to connect to ICQ login server, SSL could not be negotiated"));
+ SetCurrentStatus(ID_STATUS_OFFLINE);
+ NetLib_CloseConnection(&hServerConn, TRUE);
+ return;
+ }
+ }
+ }
+
+ // Login error
+ if (hServerConn == NULL)
+ {
+ DWORD dwError = GetLastError();
+
+ SetCurrentStatus(ID_STATUS_OFFLINE);
+
+ icq_LogUsingErrorCode(LOG_ERROR, dwError, LPGEN("Unable to connect to ICQ login server"));
+ return;
+ }
+
+ // Initialize direct connection ports
+ {
+ DWORD dwInternalIP;
+ BYTE bConstInternalIP = getSettingByte(NULL, "ConstRealIP", 0);
+
+ info.hDirectBoundPort = NetLib_BindPort(icq_newConnectionReceived, this, &wListenPort, &dwInternalIP);
+ if (!info.hDirectBoundPort)
+ {
+ icq_LogUsingErrorCode(LOG_WARNING, GetLastError(), LPGEN("Miranda was unable to allocate a port to listen for direct peer-to-peer connections between clients. You will be able to use most of the ICQ network without problems but you may be unable to send or receive files.\n\nIf you have a firewall this may be blocking Miranda, in which case you should configure your firewall to leave some ports open and tell Miranda which ports to use in M->Options->ICQ->Network."));
+ wListenPort = 0;
+ if (!bConstInternalIP) deleteSetting(NULL, "RealIP");
+ }
+ else if (!bConstInternalIP)
+ setSettingDword(NULL, "RealIP", dwInternalIP);
+ }
+
+ // Initialize rate limiting queues
+ {
+ icq_lock l(m_ratesMutex);
+
+ m_ratesQueue_Request = new rates_queue(this, "request", RML_IDLE_30, RML_IDLE_50, 1);
+ m_ratesQueue_Response = new rates_queue(this, "response", RML_IDLE_10, RML_IDLE_30, -1);
+ }
+
+ // This is the "infinite" loop that receives the packets from the ICQ server
+ {
+ int recvResult;
+ NETLIBPACKETRECVER packetRecv = {0};
+
+ info.hPacketRecver = (HANDLE)CallService(MS_NETLIB_CREATEPACKETRECVER, (WPARAM)hServerConn, 0x2400);
+ packetRecv.cbSize = sizeof(packetRecv);
+ packetRecv.dwTimeout = INFINITE;
+ while (serverThreadHandle)
+ {
+ if (info.bReinitRecver)
+ { // we reconnected, reinit struct
+ info.bReinitRecver = 0;
+ ZeroMemory(&packetRecv, sizeof(packetRecv));
+ packetRecv.cbSize = sizeof(packetRecv);
+ packetRecv.dwTimeout = INFINITE;
+ }
+
+ recvResult = CallService(MS_NETLIB_GETMOREPACKETS, (WPARAM)info.hPacketRecver, (LPARAM)&packetRecv);
+
+ if (recvResult == 0)
+ {
+ NetLog_Server("Clean closure of server socket");
+ break;
+ }
+
+ if (recvResult == SOCKET_ERROR)
+ {
+ NetLog_Server("Abortive closure of server socket, error: %d", GetLastError());
+ break;
+ }
+
+ if (m_iDesiredStatus == ID_STATUS_OFFLINE)
+ { // Disconnect requested, send disconnect packet
+ icq_sendCloseConnection();
+
+ // disconnected upon request
+ m_bConnectionLost = FALSE;
+ SetCurrentStatus(ID_STATUS_OFFLINE);
+
+ NetLog_Server("Logged off.");
+ break;
+ }
+
+ // Deal with the packet
+ packetRecv.bytesUsed = handleServerPackets(packetRecv.buffer, packetRecv.bytesAvailable, &info);
+ }
+ serverThreadHandle = NULL;
+
+ // Time to shutdown
+ NetLib_CloseConnection(&hServerConn, TRUE);
+
+ // Close the packet receiver (connection may still be open)
+ NetLib_SafeCloseHandle(&info.hPacketRecver);
+
+ // Close DC port
+ NetLib_SafeCloseHandle(&info.hDirectBoundPort);
+ }
+
+ // disable auto info-update thread
+ icq_EnableUserLookup(FALSE);
+
+ if (m_iStatus != ID_STATUS_OFFLINE && m_iDesiredStatus != ID_STATUS_OFFLINE)
+ {
+ if (!info.bLoggedIn)
+ icq_LogMessage(LOG_FATAL, LPGEN("Connection failed.\nLogin sequence failed for unknown reason.\nTry again later."));
+
+ // set flag indicating we were kicked out
+ m_bConnectionLost = TRUE;
+
+ SetCurrentStatus(ID_STATUS_OFFLINE);
+ }
+
+ // signal keep-alive thread to stop
+ StopKeepAlive(&info);
+
+ // Close all open DC connections
+ CloseContactDirectConns(NULL);
+
+ // Close avatar connection if any
+ StopAvatarThread();
+
+ // Offline all contacts
+ HANDLE hContact = FindFirstContact();
+ while (hContact)
+ {
+ DWORD dwUIN;
+ uid_str szUID;
+
+ if (!getContactUid(hContact, &dwUIN, &szUID))
+ {
+ if (getContactStatus(hContact) != ID_STATUS_OFFLINE)
+ {
+ char tmp = 0;
+
+ setSettingWord(hContact, "Status", ID_STATUS_OFFLINE);
+
+ handleXStatusCaps(dwUIN, szUID, hContact, (BYTE*)&tmp, 0, &tmp, 0);
+ }
+ }
+
+ hContact = FindNextContact(hContact);
+ }
+
+ setSettingDword(NULL, "LogonTS", 0); // clear logon time
+
+ servlistPendingFlushOperations(); // clear pending operations list
+
+ // release rates queues
+ {
+ icq_lock l(m_ratesMutex);
+
+ SAFE_DELETE((MZeroedObject**)&m_ratesQueue_Request);
+ SAFE_DELETE((MZeroedObject**)&m_ratesQueue_Response);
+ SAFE_DELETE((MZeroedObject**)&m_rates);
+ }
+
+ FlushServerIDs(); // clear server IDs list
+
+ NetLog_Server("%s thread ended.", "Server");
+}
+
+
+void CIcqProto::icq_serverDisconnect(BOOL bBlock)
+{
+ if ( !hServerConn)
+ return;
+
+ NetLog_Server("Server shutdown requested");
+ Netlib_Shutdown(hServerConn);
+
+ if (serverThreadHandle) {
+ // Not called from network thread?
+ if (bBlock && GetCurrentThreadId() != serverThreadId)
+ while (ICQWaitForSingleObject(serverThreadHandle, INFINITE) != WAIT_OBJECT_0);
+
+ CloseHandle(serverThreadHandle);
+ serverThreadHandle = NULL;
+ }
+}
+
+
+int CIcqProto::handleServerPackets(BYTE *buf, int len, serverthread_info *info)
+{
+ BYTE channel;
+ WORD sequence;
+ WORD datalen;
+ int bytesUsed = 0;
+
+ while (len > 0)
+ {
+ if (info->bReinitRecver)
+ break;
+
+ // All FLAPS begin with 0x2a
+ if (*buf++ != FLAP_MARKER)
+ break;
+
+ if (len < 6)
+ break;
+
+ unpackByte(&buf, &channel);
+ unpackWord(&buf, &sequence);
+ unpackWord(&buf, &datalen);
+
+ if (len < 6 + datalen)
+ break;
+
+
+#ifdef _DEBUG
+ NetLog_Server("Server FLAP: Channel %u, Seq %u, Length %u bytes", channel, sequence, datalen);
+#endif
+
+ switch (channel) {
+ case ICQ_LOGIN_CHAN:
+ handleLoginChannel(buf, datalen, info);
+ break;
+
+ case ICQ_DATA_CHAN:
+ handleDataChannel(buf, datalen, info);
+ break;
+
+ case ICQ_ERROR_CHAN:
+ handleErrorChannel(buf, datalen);
+ break;
+
+ case ICQ_CLOSE_CHAN:
+ handleCloseChannel(buf, datalen, info);
+ break; // we need this for walking thru proxy
+
+ case ICQ_PING_CHAN:
+ handlePingChannel(buf, datalen);
+ break;
+
+ default:
+ NetLog_Server("Warning: Unhandled Server FLAP Channel: Channel %u, Seq %u, Length %u bytes", channel, sequence, datalen);
+ break;
+ }
+
+ /* Increase pointers so we can check for more FLAPs */
+ buf += datalen;
+ len -= (datalen + 6);
+ bytesUsed += (datalen + 6);
+ }
+
+ return bytesUsed;
+}
+
+
+void CIcqProto::sendServPacket(icq_packet *pPacket)
+{
+ // make sure to have the connection handle
+ connectionHandleMutex->Enter();
+
+ if (hServerConn)
+ {
+ int nSendResult;
+
+ // This critsec makes sure that the sequence order doesn't get screwed up
+ localSeqMutex->Enter();
+
+ // :IMPORTANT:
+ // The FLAP sequence must be a WORD. When it reaches 0xFFFF it should wrap to
+ // 0x0000, otherwise we'll get kicked by server.
+ wLocalSequence++;
+
+ // Pack sequence number
+ pPacket->pData[2] = ((wLocalSequence & 0xff00) >> 8);
+ pPacket->pData[3] = (wLocalSequence & 0x00ff);
+
+ nSendResult = Netlib_Send(hServerConn, (const char *)pPacket->pData, pPacket->wLen, 0);
+
+ localSeqMutex->Leave();
+ connectionHandleMutex->Leave();
+
+ // Send error
+ if (nSendResult == SOCKET_ERROR)
+ {
+ icq_LogUsingErrorCode(LOG_ERROR, GetLastError(), LPGEN("Your connection with the ICQ server was abortively closed"));
+ icq_serverDisconnect(FALSE);
+
+ if (m_iStatus != ID_STATUS_OFFLINE)
+ {
+ SetCurrentStatus(ID_STATUS_OFFLINE);
+ }
+ }
+ else
+ { // Rates management
+ icq_lock l(m_ratesMutex);
+ m_rates->packetSent(pPacket);
+ }
+
+ }
+ else
+ {
+ connectionHandleMutex->Leave();
+ NetLog_Server("Error: Failed to send packet (no connection)");
+ }
+
+ SAFE_FREE((void**)&pPacket->pData);
+}
+
+
+void __cdecl CIcqProto::SendPacketAsyncThread(icq_packet* pkt)
+{
+ sendServPacket( pkt );
+ SAFE_FREE((void**)&pkt);
+}
+
+
+void CIcqProto::sendServPacketAsync(icq_packet *packet)
+{
+ icq_packet *pPacket;
+
+ pPacket = (icq_packet*)SAFE_MALLOC(sizeof(icq_packet)); // This will be freed in the new thread
+ memcpy(pPacket, packet, sizeof(icq_packet));
+
+ ForkThread(( IcqThreadFunc )&CIcqProto::SendPacketAsyncThread, pPacket);
+}
+
+
+int CIcqProto::IsServerOverRate(WORD wFamily, WORD wCommand, int nLevel)
+{
+ icq_lock l(m_ratesMutex);
+
+ if (m_rates)
+ {
+ WORD wGroup = m_rates->getGroupFromSNAC(wFamily, wCommand);
+
+ // check if the rate is not over specified level
+ if (m_rates->getNextRateLevel(wGroup) < m_rates->getLimitLevel(wGroup, nLevel))
+ return TRUE;
+ }
+
+ return FALSE;
+}
+
+
+/////////////////////////////////////////////////////////////////////////////////////////
+// ICQ Server thread
+
+void CIcqProto::icq_login(const char* szPassword)
+{
+ DWORD dwUin = getContactUin(NULL);
+ serverthread_start_info* stsi = (serverthread_start_info*)SAFE_MALLOC(sizeof(serverthread_start_info));
+
+ // Server host name
+ char szServer[MAX_PATH];
+ if (getSettingStringStatic(NULL, "OscarServer", szServer, MAX_PATH))
+ stsi->nloc.szHost = null_strdup(m_bSecureConnection ? DEFAULT_SERVER_HOST_SSL : DEFAULT_SERVER_HOST);
+ else
+ stsi->nloc.szHost = null_strdup(szServer);
+
+ // Server port
+ stsi->nloc.wPort = getSettingWord(NULL, "OscarPort", m_bSecureConnection ? DEFAULT_SERVER_PORT_SSL : DEFAULT_SERVER_PORT);
+ if (stsi->nloc.wPort == 0)
+ stsi->nloc.wPort = RandRange(1024, 65535);
+
+ // User password
+ stsi->wPassLen = strlennull(szPassword);
+ if (stsi->wPassLen > 8) stsi->wPassLen = 8;
+ null_strcpy(stsi->szPass, szPassword, stsi->wPassLen);
+
+ // Randomize sequence
+ wLocalSequence = generate_flap_sequence();
+
+ m_dwLocalUIN = dwUin;
+
+ // Initialize members
+ m_avatarsConnectionPending = TRUE;
+
+ serverThreadHandle = ForkThreadEx(( IcqThreadFunc )&CIcqProto::ServerThread, stsi, &serverThreadId);
+}
|