initial commit

git-svn-id: http://svn.miranda-ng.org/main/trunk@2 1316c22d-e87f-b044-9b9b-93d7a3e3ba9c

1 files changed, 452 insertions, 0 deletions

diff --git a/protocols/IcqOscarJ/icq_server.cpp b/protocols/IcqOscarJ/icq_server.cpp
new file mode 100644
index 0000000000..a3621ec6aa
--- /dev/null
+++ b/protocols/IcqOscarJ/icq_server.cpp
@@ -0,0 +1,452 @@
+// ---------------------------------------------------------------------------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.

+//

+// -----------------------------------------------------------------------------

+//

+// File name      : $URL: http://miranda.googlecode.com/svn/trunk/miranda/protocols/IcqOscarJ/icq_server.cpp $

+// Revision       : $Revision: 13324 $

+// Last change on : $Date: 2011-01-23 17:58:59 +0200 (Вс, 23 янв 2011) $

+// Last change by : $Author: borkra $

+//

+// 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((void_struct**)&m_ratesQueue_Request);

+		SAFE_DELETE((void_struct**)&m_ratesQueue_Response);

+		SAFE_DELETE((void_struct**)&m_rates);

+	}

+

+	FlushServerIDs();         // clear server IDs list

+

+	NetLog_Server("%s thread ended.", "Server");

+}

+

+

+void CIcqProto::icq_serverDisconnect(BOOL bBlock)

+{

+	if (hServerConn)

+	{

+		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);

+}