1 files changed, 1460 insertions, 1475 deletions
diff --git a/protocols/IRCG/src/irclib.cpp b/protocols/IRCG/src/irclib.cpp
index d824dbd080..cae41d4668 100644
--- a/protocols/IRCG/src/irclib.cpp
+++ b/protocols/IRCG/src/irclib.cpp
@@ -1,1475 +1,1460 @@
-/*
-IRC plugin for Miranda IM
-
-Copyright (C) 2003-05 Jurgen Persson
-Copyright (C) 2007-09 George Hazan
-
-This program is free software; you can redistribute it and/or
-modify it under the terms of the GNU General Public License
-as published by the Free Software Foundation; either version 2
-of the License, or (at your option) any later version.
-
-This program is distributed in the hope that it will be useful,
-but WITHOUT ANY WARRANTY; without even the implied warranty of
-MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-GNU General Public License for more details.
-
-You should have received a copy of the GNU General Public License
-along with this program; if not, write to the Free Software
-Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
-*/
-#include "irc.h"
-
-#define DCCCHATTIMEOUT 300
-#define DCCSENDTIMEOUT 120
-
-using namespace irc;
-
-int CDccSession::nDcc = 0;
-
-static int CompareHandlers( const CIrcHandler* p1, const CIrcHandler* p2 )
-{
-	return lstrcmp( p1->m_name, p2->m_name );
-}
-
-OBJLIST<CIrcHandler> CIrcProto::m_handlers( 30, CompareHandlers );
-
-////////////////////////////////////////////////////////////////////
-
-CIrcMessage::CIrcMessage( CIrcProto* _pro, const TCHAR* lpszCmdLine, int codepage, bool bIncoming, bool bNotify ) :
-	m_proto( _pro ),
-	m_bIncoming( bIncoming ),
-	m_bNotify( bNotify ),
-	m_codePage( codepage ),
-	parameters( 10 )
-{
-	ParseIrcCommand(lpszCmdLine);
-}
-
-CIrcMessage::CIrcMessage(const CIrcMessage& m) :
-	sCommand( m.sCommand ),
-	m_bIncoming( m.m_bIncoming ), 
-	m_bNotify( m.m_bNotify ),
-	m_codePage( m.m_codePage ),
-	m_proto( m.m_proto ),
-	parameters( m.parameters.getCount())
-{
-	prefix.sNick = m.prefix.sNick;
-	prefix.sUser = m.prefix.sUser;
-	prefix.sHost = m.prefix.sHost;
-
-	for (int i = 0; i < m.parameters.getCount(); i++)
-		parameters.insert(new CMString(m.parameters[i]));
-}
-
-CIrcMessage::~CIrcMessage()
-{
-}
-
-void CIrcMessage::Reset()
-{
-	prefix.sNick = prefix.sUser = prefix.sHost = sCommand = _T("");
-	m_bIncoming = false;
-	m_bNotify = true;
-
-	parameters.destroy();
-}
-
-CIrcMessage& CIrcMessage::operator = (const CIrcMessage& m)
-{
-	if (&m != this) {
-		sCommand = m.sCommand;
-		parameters = m.parameters;
-		prefix.sNick = m.prefix.sNick;
-		prefix.sUser = m.prefix.sUser;
-		prefix.sHost = m.prefix.sHost;
-		m_bIncoming = m.m_bIncoming;
-		m_bNotify = m.m_bNotify;
-	}
-	return *this;
-}
-
-CIrcMessage& CIrcMessage::operator = (const TCHAR* lpszCmdLine)
-{
-	Reset();
-	ParseIrcCommand(lpszCmdLine);
-	return *this;
-}
-
-void CIrcMessage::ParseIrcCommand(const TCHAR* lpszCmdLine)
-{
-	const TCHAR* p1 = lpszCmdLine;
-	const TCHAR* p2 = lpszCmdLine;
-
-	// prefix exists ?
-	if (*p1 == ':') {
-		// break prefix into its components (nick!user@host)
-		p2 = ++p1;
-		while (*p2 && !_tcschr(_T(" !"), *p2))
-			++p2;
-		prefix.sNick.SetString(p1, p2 - p1);
-		if (*p2 != '!')
-			goto end_of_prefix;
-		p1 = ++p2;
-		while (*p2 && !_tcschr(_T(" @"), *p2))
-			++p2;
-		prefix.sUser.SetString(p1, p2 - p1);
-		if (*p2 != '@')
-			goto end_of_prefix;
-		p1 = ++p2;
-		while (*p2 && *p2 != ' ')
-			++p2;
-		prefix.sHost.SetString(p1, p2 - p1);
-end_of_prefix:
-		while (*p2 && *p2 == ' ')
-			++p2;
-		p1 = p2;
-	}
-
-	// get command
-	p2 = p1;
-	while (*p2 && *p2 != ' ')
-		++p2;
-
-	sCommand.SetString(p1, p2 - p1);
-	sCommand.MakeUpper();
-	while (*p2 && *p2 == ' ')
-		++p2;
-	p1 = p2;
-
-	// get parameters
-	while (*p1) {
-		if (*p1 == ':') {
-			++p1;
-
-			// seek end-of-message
-			while (*p2)
-				++p2;
-			parameters.insert(new CMString(p1, p2 - p1));
-			break;
-		}
-		else {
-			// seek end of parameter
-			while (*p2 && *p2 != ' ')
-				++p2;
-			parameters.insert(new CMString(p1, p2 - p1));
-			// see next parameter
-			while (*p2 && *p2 == ' ')
-				++p2;
-			p1 = p2;
-		}
-	}
-}
-
-////////////////////////////////////////////////////////////////////
-
-int CIrcProto::getCodepage() const
-{
-	return (con != NULL) ? codepage : CP_ACP;
-}
-
-void CIrcProto::SendIrcMessage(const TCHAR* msg, bool bNotify, int codepage)
-{
-	if (codepage == -1)
-		codepage = getCodepage();
-
-	if (this) {
-		char* str = mir_t2a_cp(msg, codepage);
-		rtrim(str);
-		int cbLen = (int)strlen(str);
-		str = (char*)mir_realloc(str, cbLen + 3);
-		strcat(str, "\r\n");
-		NLSend((const BYTE*)str, cbLen + 2);
-		mir_free(str);
-
-		if (bNotify) {
-			CIrcMessage ircMsg(this, msg, codepage);
-			if (!ircMsg.sCommand.IsEmpty() && ircMsg.sCommand != _T("QUIT"))
-				Notify(&ircMsg);
-		}
-	}
-}
-
-bool CIrcProto::Connect(const CIrcSessionInfo& info)
-{
-	codepage = m_codepage;
-
-	NETLIBOPENCONNECTION ncon = { 0 };
-	ncon.cbSize = sizeof(ncon);
-	ncon.szHost = info.sServer.c_str();
-	ncon.wPort = info.iPort;
-	con = (HANDLE)CallService(MS_NETLIB_OPENCONNECTION, (WPARAM)m_hNetlibUser, (LPARAM)&ncon);
-	if (con == NULL) {
-		TCHAR szTemp[300];
-		mir_sntprintf(szTemp, SIZEOF(szTemp), _T("\0035%s \002%s\002 (%S: %u)."),
-			TranslateT("Failed to connect to"), si.sNetwork.c_str(), si.sServer.c_str(), si.iPort);
-		DoEvent(GC_EVENT_INFORMATION, SERVERWINDOW, NULL, szTemp, NULL, NULL, NULL, true, false);
-		return false;
-	}
-
-	FindLocalIP(con); // get the local ip used for filetransfers etc
-
-	if (info.m_iSSL > 0) {
-		if (!CallService(MS_NETLIB_STARTSSL, (WPARAM)con, 0) && info.m_iSSL == 2) {
-			Netlib_CloseHandle(con);
-			con = NULL;
-			m_info.Reset();
-			return false;
-		}
-	}
-
-	if (Miranda_Terminated()) {
-		Disconnect();
-		return false;
-	}
-
-	m_info = info;
-
-	// start receiving messages from host
-	ForkThread(&CIrcProto::ThreadProc, NULL);
-	Sleep(100);
-	if (info.sPassword.GetLength())
-		NLSend("PASS %s\r\n", info.sPassword.c_str());
-	NLSend(_T("NICK %s\r\n"), info.sNick.c_str());
-
-	CMString m_userID = GetWord(info.sUserID.c_str(), 0);
-	TCHAR szHostName[MAX_PATH];
-	DWORD cbHostName = SIZEOF(szHostName);
-	GetComputerName(szHostName, &cbHostName);
-	CMString HostName = GetWord(szHostName, 0);
-	if (m_userID.IsEmpty())
-		m_userID = _T("Miranda");
-	if (HostName.IsEmpty())
-		HostName = _T("host");
-	NLSend(_T("USER %s %s %s :%s\r\n"), m_userID.c_str(), HostName.c_str(), _T("server"), info.sFullName.c_str());
-
-	return con != NULL;
-}
-
-void CIrcProto::Disconnect(void)
-{
-	static const DWORD dwServerTimeout = 5 * 1000;
-
-	if (con == NULL)
-		return;
-
-	KillIdent();
-
-	if (m_quitMessage && m_quitMessage[0])
-		NLSend(_T("QUIT :%s\r\n"), m_quitMessage);
-	else
-		NLSend("QUIT \r\n");
-
-	Sleep(50);
-
-	if (con)
-		Netlib_Shutdown(con);
-
-	m_info.Reset();
-	return;
-}
-
-void CIrcProto::Notify(const CIrcMessage* pmsg)
-{
-	OnIrcMessage(pmsg);
-}
-
-int CIrcProto::NLSend(const unsigned char* buf, int cbBuf)
-{
-	if (m_scriptingEnabled) {
-		int iVal = NULL;
-		char * pszTemp = 0;
-		pszTemp = (char*)mir_alloc(lstrlenA((const char *)buf) + 1);
-		lstrcpynA(pszTemp, (const char *)buf, lstrlenA((const char *)buf) + 1);
-
-		if (pszTemp) {
-			if (con)
-				iVal = Netlib_Send(con, (const char*)pszTemp, lstrlenA(pszTemp), MSG_DUMPASTEXT);
-		}
-		if (pszTemp)
-			mir_free(pszTemp);
-
-		return iVal;
-	}
-
-	if (con)
-		return Netlib_Send(con, (const char*)buf, cbBuf, MSG_DUMPASTEXT);
-
-	return 0;
-}
-
-int CIrcProto::NLSend(const TCHAR* fmt, ...)
-{
-	va_list marker;
-	va_start(marker, fmt);
-
-	TCHAR szBuf[1024 * 4];
-	mir_vsntprintf(szBuf, SIZEOF(szBuf), fmt, marker);
-	va_end(marker);
-
-	char* buf = mir_t2a_cp(szBuf, getCodepage());
-	int result = NLSend((unsigned char*)buf, (int)strlen(buf));
-	mir_free(buf);
-	return result;
-}
-
-int CIrcProto::NLSend(const char* fmt, ...)
-{
-	va_list marker;
-	va_start(marker, fmt);
-
-	char szBuf[1024 * 4];
-	int cbLen = mir_vsnprintf(szBuf, SIZEOF(szBuf), fmt, marker);
-	va_end(marker);
-
-	return NLSend((unsigned char*)szBuf, cbLen);
-}
-
-int CIrcProto::NLSendNoScript(const unsigned char* buf, int cbBuf)
-{
-	if (con)
-		return Netlib_Send(con, (const char*)buf, cbBuf, MSG_DUMPASTEXT);
-
-	return 0;
-}
-
-int CIrcProto::NLReceive(unsigned char* buf, int cbBuf)
-{
-	return Netlib_Recv(con, (char*)buf, cbBuf, MSG_DUMPASTEXT);
-}
-
-void CIrcProto::KillIdent()
-{
-	if (hBindPort) {
-		HANDLE hPort = hBindPort;
-		hBindPort = NULL;
-		Netlib_CloseHandle(hPort);
-	}
-}
-
-void CIrcProto::InsertIncomingEvent(TCHAR* pszRaw)
-{
-	CIrcMessage msg(this, pszRaw, true);
-	Notify(&msg);
-	return;
-}
-
-void CIrcProto::createMessageFromPchar(const char* p)
-{
-	TCHAR* ptszMsg;
-	if (codepage != CP_UTF8 && m_utfAutodetect) {
-		if (mir_utf8decodecp(NEWSTR_ALLOCA(p), codepage, &ptszMsg) == NULL)
-			ptszMsg = mir_a2t_cp(p, codepage);
-	}
-	else ptszMsg = mir_a2t_cp(p, codepage);
-	CIrcMessage msg(this, ptszMsg, codepage, true);
-	Notify(&msg);
-	mir_free(ptszMsg);
-}
-
-void CIrcProto::DoReceive()
-{
-	char chBuf[1024 * 4 + 1];
-	int cbInBuf = 0;
-
-	if (m_info.bIdentServer && m_info.iIdentServerPort != NULL) {
-		NETLIBBIND nb = { 0 };
-		nb.cbSize = sizeof(NETLIBBIND);
-		nb.pfnNewConnectionV2 = DoIdent;
-		nb.pExtra = this;
-		nb.wPort = m_info.iIdentServerPort;
-		hBindPort = (HANDLE)CallService(MS_NETLIB_BINDPORT, (WPARAM)m_hNetlibUser, (LPARAM)&nb);
-		if (!hBindPort || nb.wPort != m_info.iIdentServerPort) {
-			debugLogA("Error: unable to bind local port %u", m_info.iIdentServerPort);
-			KillIdent();
-		}
-	}
-
-	while (con) {
-		int nLinesProcessed = 0;
-
-		int cbRead = NLReceive((unsigned char*)chBuf + cbInBuf, sizeof(chBuf)-cbInBuf - 1);
-		if (cbRead <= 0)
-			break;
-
-		cbInBuf += cbRead;
-		chBuf[cbInBuf] = '\0';
-
-		char* pStart = chBuf;
-		while (*pStart) {
-			char* pEnd;
-
-			// seek end-of-line
-			for (pEnd = pStart; *pEnd && *pEnd != '\r' && *pEnd != '\n'; ++pEnd)
-				;
-			if (*pEnd == '\0')
-				break; // uncomplete message. stop parsing.
-
-			++nLinesProcessed;
-
-			// replace end-of-line with NULLs and skip
-			while (*pEnd == '\r' || *pEnd == '\n')
-				*pEnd++ = '\0';
-
-			// process single message by monitor objects
-			if (*pStart) {
-				if (m_scriptingEnabled) {
-					char* pszTemp = mir_strdup(pStart);
-
-					if (pszTemp) {
-						char* p1 = pszTemp;
-						// replace end-of-line with NULLs
-						while (*p1 != '\0') {
-							if (*p1 == '\r' || *p1 == '\n')
-								*p1 = '\0';
-							p1++;
-						}
-
-						createMessageFromPchar(pszTemp);
-					}
-
-					mir_free(pszTemp);
-				}
-				else createMessageFromPchar(pStart);
-			}
-
-			cbInBuf -= pEnd - pStart;
-			pStart = pEnd;
-		}
-
-		// discard processed messages
-		if (nLinesProcessed != 0)
-			memmove(chBuf, pStart, cbInBuf + 1);
-	}
-
-	if (con) {
-		Netlib_CloseHandle(con);
-		con = NULL;
-	}
-
-	// notify monitor objects that the connection has been closed
-	Notify(NULL);
-}
-
-void __cdecl CIrcProto::ThreadProc(void*)
-{
-	DoReceive();
-	m_info.Reset();
-}
-
-void CIrcProto::AddDCCSession(MCONTACT, CDccSession* dcc)
-{
-	mir_cslock lck(m_dcc);
-
-	CDccSession* p = m_dcc_chats.find(dcc);
-	if (p)
-		m_dcc_chats.remove(p);
-
-	m_dcc_chats.insert(dcc);
-}
-
-void CIrcProto::AddDCCSession(DCCINFO*, CDccSession* dcc)
-{
-	mir_cslock lck(m_dcc);
-	m_dcc_xfers.insert(dcc);
-}
-
-void CIrcProto::RemoveDCCSession(MCONTACT hContact)
-{
-	mir_cslock lck(m_dcc);
-
-	for (int i = 0; i < m_dcc_chats.getCount(); i++)
-		if (m_dcc_chats[i]->di->hContact == hContact) {
-			m_dcc_chats.remove(i);
-			break;
-		}
-}
-
-void CIrcProto::RemoveDCCSession(DCCINFO* pdci)
-{
-	mir_cslock lck(m_dcc);
-
-	for (int i = 0; i < m_dcc_xfers.getCount(); i++) {
-		if (m_dcc_xfers[i]->di == pdci) {
-			m_dcc_xfers.remove(i);
-			break;
-		}
-	}
-}
-
-CDccSession* CIrcProto::FindDCCSession(MCONTACT hContact)
-{
-	mir_cslock lck(m_dcc);
-
-	for (int i = 0; i < m_dcc_chats.getCount(); i++)
-		if (m_dcc_chats[i]->di->hContact == hContact)
-			return m_dcc_chats[i];
-
-	return 0;
-}
-
-CDccSession* CIrcProto::FindDCCSession(DCCINFO* pdci)
-{
-	mir_cslock lck(m_dcc);
-
-	for (int i = 0; i < m_dcc_xfers.getCount(); i++)
-		if (m_dcc_xfers[i]->di == pdci)
-			return m_dcc_xfers[i];
-
-	return 0;
-}
-
-CDccSession* CIrcProto::FindDCCSendByPort(int iPort)
-{
-	mir_cslock lck(m_dcc);
-
-	for (int i = 0; i < m_dcc_xfers.getCount(); i++) {
-		CDccSession *p = m_dcc_xfers[i];
-		if (p->di->iType == DCC_SEND && p->di->bSender && iPort == p->di->iPort)
-			return p;
-	}
-
-	return 0;
-}
-
-CDccSession* CIrcProto::FindDCCRecvByPortAndName(int iPort, const TCHAR* szName)
-{
-	mir_cslock lck(m_dcc);
-
-	for (int i = 0; i < m_dcc_xfers.getCount(); i++) {
-		CDccSession* p = m_dcc_xfers[i];
-		DBVARIANT dbv;
-		if (!getTString(p->di->hContact, "Nick", &dbv)) {
-			if (p->di->iType == DCC_SEND && !p->di->bSender && !lstrcmpi(szName, dbv.ptszVal) && iPort == p->di->iPort) {
-				db_free(&dbv);
-				return p;
-			}
-			db_free(&dbv);
-		}
-	}
-
-	return 0;
-}
-
-CDccSession* CIrcProto::FindPassiveDCCSend(int iToken)
-{
-	mir_cslock lck(m_dcc);
-
-	for (int i = 0; i < m_dcc_xfers.getCount(); i++)
-		if (m_dcc_xfers[i]->iToken == iToken)
-			return m_dcc_xfers[i];
-
-	return 0;
-}
-
-CDccSession* CIrcProto::FindPassiveDCCRecv(CMString sName, CMString sToken)
-{
-	mir_cslock lck(m_dcc);
-
-	for (int i = 0; i < m_dcc_xfers.getCount(); i++) {
-		CDccSession *p = m_dcc_xfers[i];
-		if (sToken == p->di->sToken && sName == p->di->sContactName)
-			return p;
-	}
-
-	return 0;
-}
-
-void CIrcProto::DisconnectAllDCCSessions(bool Shutdown)
-{
-	mir_cslock lck(m_dcc);
-
-	for (int i = 0; i < m_dcc_chats.getCount(); i++)
-		if (m_disconnectDCCChats || Shutdown)
-			m_dcc_chats[i]->Disconnect();
-}
-
-void CIrcProto::CheckDCCTimeout(void)
-{
-	mir_cslock lck(m_dcc);
-
-	for (int i = 0; i < m_dcc_chats.getCount(); i++) {
-		CDccSession* p = m_dcc_chats[i];
-		if (time(0) > p->tLastActivity + DCCCHATTIMEOUT)
-			p->Disconnect();
-	}
-
-	for (int j = 0; j < m_dcc_xfers.getCount(); j++) {
-		CDccSession* p = m_dcc_xfers[j];
-		if (time(0) > p->tLastActivity + DCCSENDTIMEOUT)
-			p->Disconnect();
-	}
-}
-
-////////////////////////////////////////////////////////////////////
-
-CIrcIgnoreItem::CIrcIgnoreItem(const TCHAR* _mask, const TCHAR* _flags, const TCHAR* _network) :
-	mask(_mask),
-	flags(_flags),
-	network(_network)
-{
-}
-
-CIrcIgnoreItem::CIrcIgnoreItem(int codepage, const char* _mask, const char* _flags, const char* _network) :
-	mask((TCHAR*)_A2T(_mask, codepage)),
-	flags((TCHAR*)_A2T(_flags, codepage)),
-	network((TCHAR*)_A2T(_network, codepage))
-{
-}
-
-CIrcIgnoreItem::~CIrcIgnoreItem()
-{
-}
-
-////////////////////////////////////////////////////////////////////
-
-CIrcSessionInfo::CIrcSessionInfo() :
-	iPort(0),
-	bIdentServer(false),
-	iIdentServerPort(0)
-{
-}
-
-CIrcSessionInfo::CIrcSessionInfo(const CIrcSessionInfo& si) :
-	sServer(si.sServer),
-	sServerName(si.sServerName),
-	iPort(si.iPort),
-	sNick(si.sNick),
-	sUserID(si.sUserID),
-	sFullName(si.sFullName),
-	sPassword(si.sPassword),
-	bIdentServer(si.bIdentServer),
-	m_iSSL(si.m_iSSL),
-	sIdentServerType(si.sIdentServerType),
-	sNetwork(si.sNetwork),
-	iIdentServerPort(si.iIdentServerPort)
-{
-}
-
-void CIrcSessionInfo::Reset()
-{
-	sServer = "";
-	sServerName = _T("");
-	iPort = 0;
-	sNick = _T("");
-	sUserID = _T("");
-	sFullName = _T("");
-	sPassword = "";
-	bIdentServer = false;
-	bNickFlag = false;
-	m_iSSL = 0;
-	sIdentServerType = _T("");
-	iIdentServerPort = 0;
-	sNetwork = _T("");
-}
-
-////////////////////////////////////////////////////////////////////
-
-void CIrcProto::OnIrcMessage(const CIrcMessage* pmsg)
-{
-	if (pmsg != NULL) {
-		PfnIrcMessageHandler pfn = FindMethod(pmsg->sCommand.c_str());
-		if (pfn) {
-			// call member function. if it returns 'false',
-			// call the default handling
-			__try {
-				if (!(this->*pfn)(pmsg))
-					OnIrcDefault(pmsg);
-			}
-			__except (EXCEPTION_EXECUTE_HANDLER) // dedicated to Sava :)
-			{
-				debugLogA("IRC handler feels sick: %S", pmsg->sCommand.c_str());
-			}
-		}
-		else // handler not found. call default handler
-			OnIrcDefault(pmsg);
-	}
-	else OnIrcDisconnected();
-}
-
-PfnIrcMessageHandler CIrcProto::FindMethod(const TCHAR* lpszName)
-{
-	CIrcHandler temp(lpszName, NULL);
-	CIrcHandler* p = m_handlers.find(&temp);
-	return (p == NULL) ? NULL : p->m_handler;
-}
-
-////////////////////////////////////////////////////////////////////
-
-#define IPC_ADDR_SIZE				4		/* Size of IP address, change for IPv6. */
-
-char* ConvertIntegerToIP(unsigned long int_ip_addr)
-{
-	IN_ADDR intemp;
-	IN_ADDR in;
-	intemp.S_un.S_addr = int_ip_addr;
-
-	in.S_un.S_un_b.s_b1 = intemp.S_un.S_un_b.s_b4;
-	in.S_un.S_un_b.s_b2 = intemp.S_un.S_un_b.s_b3;
-	in.S_un.S_un_b.s_b3 = intemp.S_un.S_un_b.s_b2;
-	in.S_un.S_un_b.s_b4 = intemp.S_un.S_un_b.s_b1;
-
-	return inet_ntoa(in);
-}
-
-unsigned long ConvertIPToInteger(char* IP)
-{
-	IN_ADDR in;
-	IN_ADDR intemp;
-
-	if (IP == 0 || lstrlenA(IP) == 0)
-		return 0;
-
-	intemp.S_un.S_addr = inet_addr(IP);
-
-	in.S_un.S_un_b.s_b1 = intemp.S_un.S_un_b.s_b4;
-	in.S_un.S_un_b.s_b2 = intemp.S_un.S_un_b.s_b3;
-	in.S_un.S_un_b.s_b3 = intemp.S_un.S_un_b.s_b2;
-	in.S_un.S_un_b.s_b4 = intemp.S_un.S_un_b.s_b1;
-	return in.S_un.S_addr;
-}
-
-////////////////////////////////////////////////////////////////////
-
-// initialize basic stuff needed for the dcc objects, also start a timer for checking the status of connections (timeouts)
-CDccSession::CDccSession(CIrcProto* _pro, DCCINFO* pdci) :
-	m_proto(_pro),
-	NewFileName(0),
-	dwWhatNeedsDoing(0),
-	tLastPercentageUpdate(0),
-	dwTotal(0),
-	iGlobalToken(),
-	dwResumePos(0),
-	hEvent(0),
-	con(0),
-	hBindPort(0)
-{
-	tLastActivity = time(0);
-
-	di = pdci; // Setup values passed to the constructor
-
-	ZeroMemory(&pfts, sizeof(PROTOFILETRANSFERSTATUS));
-	pfts.cbSize = sizeof(PROTOFILETRANSFERSTATUS);
-
-	if (di->iType == DCC_SEND && di->bSender == false)
-		hEvent = CreateEvent(NULL, TRUE, FALSE, NULL);
-
-	if (nDcc == 0)
-		m_proto->SetChatTimer(m_proto->DCCTimer, 20 * 1000, DCCTimerProc);
-
-	nDcc++; // increase the count of existing objects
-
-	iGlobalToken++;
-	if (iGlobalToken == 1000)
-		iGlobalToken = 1;
-	iToken = iGlobalToken;
-
-	iPacketSize = m_proto->getWord("PacketSize", 4096);
-
-	if (di->dwAdr)
-		m_proto->setDword(di->hContact, "IP", di->dwAdr); // mtooltip stuff
-}
-
-CDccSession::~CDccSession() // destroy all that needs destroying
-{
-	if (di->iType == DCC_SEND) {
-		// ack SUCCESS or FAILURE
-		if (dwTotal == di->dwSize)
-			ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_SUCCESS, (void *)di, 0);
-		else
-			ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_FAILED, (void *)di, 0);
-	}
-
-	if (di->iType == DCC_CHAT) {
-		CDccSession* dcc = m_proto->FindDCCSession(di->hContact);
-		if (dcc && this == dcc) {
-			m_proto->RemoveDCCSession(di->hContact); // objects automatically remove themselves from the list of objects
-			m_proto->setWord(di->hContact, "Status", ID_STATUS_OFFLINE);
-		}
-	}
-
-	if (di->iType == DCC_SEND)
-		m_proto->RemoveDCCSession(di);
-
-	if (hEvent != NULL) {
-		SetEvent(hEvent);
-		CloseHandle(hEvent);
-		hEvent = NULL;
-	}
-
-	delete di;
-	nDcc--;
-
-	if (nDcc < 0)
-		nDcc = 0;
-
-	if (nDcc == 0)
-		m_proto->KillChatTimer(m_proto->DCCTimer); // destroy the timer when no dcc objects remain
-}
-
-int CDccSession::NLSend(const unsigned char* buf, int cbBuf)
-{
-	tLastActivity = time(0);
-
-	if (con)
-		return Netlib_Send(con, (const char*)buf, cbBuf, di->iType == DCC_CHAT ? MSG_DUMPASTEXT : MSG_NODUMP);
-
-	return 0;
-}
-
-int CDccSession::NLReceive(const unsigned char* buf, int cbBuf)
-{
-	int n = 0;
-
-	if (con)
-		n = Netlib_Recv(con, (char*)buf, cbBuf, di->iType == DCC_CHAT ? MSG_DUMPASTEXT : MSG_NODUMP);
-
-	tLastActivity = time(0);
-	return n;
-}
-
-int CDccSession::SendStuff(const TCHAR* fmt)
-{
-	String buf = _T2A(fmt, m_proto->getCodepage());
-	return NLSend((const unsigned char*)buf.c_str(), buf.GetLength());
-}
-
-// called when the user wants to connect/create a new connection given the parameters in the constructor.
-int CDccSession::Connect()
-{
-	if (!di->bSender || di->bReverse) {
-		if (!con)
-			mir_forkthread(ConnectProc, this); // spawn a new thread for time consuming activities, ie when connecting to a remote computer
-		return true;
-	}
-
-	if (!con)
-		return SetupConnection(); // no need to spawn thread for setting up a listening port locally
-
-	return false;
-}
-
-void __cdecl CDccSession::ConnectProc(void *pparam)
-{
-	CDccSession* pThis = (CDccSession*)pparam;
-	if (!pThis->con)
-		pThis->SetupConnection();
-}
-
-// small function to setup the address and port of the remote computer fror passive filetransfers
-void CDccSession::SetupPassive(DWORD adress, DWORD port)
-{
-	di->dwAdr = adress;
-	di->iPort = (int)port;
-
-	m_proto->setDword(di->hContact, "IP", di->dwAdr); // mtooltip stuff
-}
-
-int CDccSession::SetupConnection()
-{
-	// if it is a dcc chat connection make sure it is "offline" to begin with, since no connection exists still
-	if (di->iType == DCC_CHAT)
-		m_proto->setWord(di->hContact, "Status", ID_STATUS_OFFLINE);
-
-	// Set up stuff needed for the filetransfer dialog (if it is a filetransfer)
-	if (di->iType == DCC_SEND) {
-		file[0] = (TCHAR*)di->sFileAndPath.c_str();
-		file[1] = 0;
-
-		pfts.tszCurrentFile = (TCHAR*)di->sFileAndPath.c_str();
-		pfts.tszWorkingDir = (TCHAR*)di->sPath.c_str();
-		pfts.hContact = di->hContact;
-		pfts.flags = PFTS_TCHAR + ((di->bSender) ? PFTS_SENDING : PFTS_RECEIVING);
-		pfts.totalFiles = 1;
-		pfts.currentFileNumber = 0;
-		pfts.totalBytes = di->dwSize;
-		pfts.currentFileSize = pfts.totalBytes;
-		pfts.ptszFiles = file;
-		pfts.totalProgress = 0;
-		pfts.currentFileProgress = 0;
-		pfts.currentFileTime = (unsigned long)time(0);
-	}
-
-	// create a listening socket for outgoing chat/send requests. The remote computer connects to this computer. Used for both chat and filetransfer.
-	if (di->bSender && !di->bReverse) {
-		NETLIBBIND nb = { 0 };
-		nb.cbSize = sizeof(NETLIBBIND);
-		nb.pfnNewConnectionV2 = DoIncomingDcc; // this is the (helper) function to be called once an incoming connection is made. The 'real' function that is called is IncomingConnection()
-		nb.pExtra = (void *)this;
-		nb.wPort = 0;
-		hBindPort = (HANDLE)CallService(MS_NETLIB_BINDPORT, (WPARAM)m_proto->hNetlibDCC, (LPARAM)&nb);
-
-		if (hBindPort == NULL) {
-			delete this; // dcc objects destroy themselves when the connection has been closed or failed for some reasson.
-			return 0;
-		}
-
-		di->iPort = nb.wPort; // store the port internally so it is possible to search for it (for resuming of filetransfers purposes)
-		return nb.wPort; // return the created port so it can be sent to the remote computer in a ctcp/dcc command
-	}
-
-	// If a remote computer initiates a chat session this is used to connect to the remote computer (user already accepted at this point). 
-	// also used for connecting to a remote computer for remote file transfers
-	if (di->iType == DCC_CHAT && !di->bSender || di->iType == DCC_SEND && di->bSender && di->bReverse) {
-		NETLIBOPENCONNECTION ncon = { 0 };
-		ncon.cbSize = sizeof(ncon);
-		ncon.szHost = ConvertIntegerToIP(di->dwAdr);
-		ncon.wPort = (WORD)di->iPort;
-		con = (HANDLE)CallService(MS_NETLIB_OPENCONNECTION, (WPARAM)m_proto->hNetlibDCC, (LPARAM)&ncon);
-	}
-
-	// If a remote computer initiates a filetransfer this is used to connect to that computer (the user has chosen to accept but it is possible the file exists/needs to be resumed etc still)
-	if (di->iType == DCC_SEND && !di->bSender) {
-
-		// this following code is for miranda to be able to show the resume/overwrite etc dialog if the file that we are receiving already exists. 
-		// It must be done before we create the connection or else the other party will begin sending packets while the user is still deciding if 
-		// s/he wants to resume/cancel or whatever. Just the way dcc is...
-
-		// if the file exists (dialog is shown) WaitForSingleObject() till the dialog is closed and PS_FILERESUME has been processed. 
-		// dwWhatNeedsDoing will be set using InterlockedExchange() (from other parts of the code depending on action) before SetEvent() is called.
-		// If the user has chosen rename then InterlockedExchange() will be used for setting NewFileName to a string containing the new name.
-		// Furthermore dwResumePos will be set using InterlockedExchange() to indicate what the file position to start from is.
-		if (ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_FILERESUME, (void *)di, (LPARAM)&pfts)) {
-			WaitForSingleObject(hEvent, INFINITE);
-			switch (dwWhatNeedsDoing) {
-			case FILERESUME_RENAME:
-				// If the user has chosen to rename the file we need to change variables accordingly. NewFileName has been set using
-				// InterlockedExchange()
-				if (NewFileName) { // the user has chosen to rename the new incoming file.
-					di->sFileAndPath = NewFileName;
-
-					int i = di->sFileAndPath.ReverseFind('\\');
-					if (i != -1) {
-						di->sPath = di->sFileAndPath.Mid(0, i + 1);
-						di->sFile = di->sFileAndPath.Mid(i + 1, di->sFileAndPath.GetLength());
-					}
-
-					pfts.tszCurrentFile = (TCHAR*)di->sFileAndPath.c_str();
-					pfts.tszWorkingDir = (TCHAR*)di->sPath.c_str();
-					pfts.totalBytes = di->dwSize;
-					pfts.currentFileSize = pfts.totalBytes;
-
-					delete[] NewFileName;
-					NewFileName = NULL;
-				}
-				break;
-
-			case FILERESUME_OVERWRITE:
-			case FILERESUME_RESUME:
-				// no action needed at this point, just break out of the switch statement
-				break;
-
-			case FILERESUME_CANCEL:
-				return FALSE;
-
-			case FILERESUME_SKIP:
-			default:
-				delete this; // per usual dcc objects destroy themselves when they fail or when connection is closed
-				return FALSE;
-			}
-		}
-
-		// hack for passive filetransfers
-		if (di->iType == DCC_SEND && !di->bSender && di->bReverse) {
-			NETLIBBIND nb = { 0 };
-			nb.cbSize = sizeof(NETLIBBIND);
-			nb.pfnNewConnectionV2 = DoIncomingDcc; // this is the (helper) function to be called once an incoming connection is made. The 'real' function that is called is IncomingConnection()
-			nb.pExtra = (void *)this;
-			nb.wPort = 0;
-			hBindPort = (HANDLE)CallService(MS_NETLIB_BINDPORT, (WPARAM)m_proto->hNetlibDCC, (LPARAM)&nb);
-
-			if (hBindPort == NULL) {
-				m_proto->DoEvent(GC_EVENT_INFORMATION, 0, m_proto->m_info.sNick.c_str(), LPGENT("DCC ERROR: Unable to bind local port for passive file transfer"), NULL, NULL, NULL, true, false);
-				delete this; // dcc objects destroy themselves when the connection has been closed or failed for some reasson.
-				return 0;
-			}
-
-			di->iPort = nb.wPort; // store the port internally so it is possible to search for it (for resuming of filetransfers purposes)
-
-			CMString sFileWithQuotes = di->sFile;
-
-			// if spaces in the filename surround with quotes
-			if (sFileWithQuotes.Find(' ', 0) != -1) {
-				sFileWithQuotes.Insert(0, _T("\""));
-				sFileWithQuotes.Insert(sFileWithQuotes.GetLength(), _T("\""));
-			}
-
-			// send out DCC RECV command for passive filetransfers
-			unsigned long ulAdr = 0;
-			if (m_proto->m_manualHost)
-				ulAdr = ConvertIPToInteger(m_proto->m_mySpecifiedHostIP);
-			else
-				ulAdr = m_proto->m_IPFromServer ? ConvertIPToInteger(m_proto->m_myHost) : nb.dwExternalIP;
-
-			if (di->iPort && ulAdr)
-				m_proto->PostIrcMessage(_T("/CTCP %s DCC SEND %s %u %u %I64u %s"), di->sContactName.c_str(), sFileWithQuotes.c_str(), ulAdr, di->iPort, di->dwSize, di->sToken.c_str());
-
-			return TRUE;
-		}
-
-		// connect to the remote computer from which you are receiving the file (now all actions to take (resume/overwrite etc) have been decided
-		NETLIBOPENCONNECTION ncon = { 0 };
-		ncon.cbSize = sizeof(ncon);
-		ncon.szHost = ConvertIntegerToIP(di->dwAdr);
-		ncon.wPort = (WORD)di->iPort;
-
-		con = (HANDLE)CallService(MS_NETLIB_OPENCONNECTION, (WPARAM)m_proto->hNetlibDCC, (LPARAM)&ncon);
-	}
-
-	// if for some reason the plugin has failed to connect to the remote computer the object is destroyed.
-	if (con == NULL) {
-		delete this;
-		return FALSE; // failed to connect
-	}
-
-	// if it is a chat connection set the user to online now since we now know there is a connection
-	if (di->iType == DCC_CHAT)
-		m_proto->setWord(di->hContact, "Status", ID_STATUS_ONLINE);
-
-	// spawn a new thread to handle receiving/sending of data for the new chat/filetransfer connection to the remote computer
-	mir_forkthread(ThreadProc, this);
-
-	return con != NULL;
-}
-
-// called by netlib for incoming connections on a listening socket (chat/filetransfer)
-int CDccSession::IncomingConnection(HANDLE hConnection, DWORD dwIP)
-{
-	con = hConnection;
-	if (con == NULL) {
-		delete this;
-		return false; // failed to connect
-	}
-
-	m_proto->setDword(di->hContact, "IP", dwIP); // mToolTip stuff
-
-	if (di->iType == DCC_CHAT)
-		m_proto->setWord(di->hContact, "Status", ID_STATUS_ONLINE); // set chat to online
-
-	// same as above, spawn a new thread to handle receiving/sending of data for the new incoming chat/filetransfer connection  
-	mir_forkthread(ThreadProc, this);
-	return true;
-}
-
-// here we decide which function to use for communicating with the remote computer, depending on connection type
-void __cdecl CDccSession::ThreadProc(void *pparam)
-{
-	CDccSession* pThis = (CDccSession*)pparam;
-
-	// if it is an incoming connection on a listening port, then we should close the listenting port so only one can connect (the one you offered
-	// the connection to) can connect and not evil IRCopers with haxxored IRCDs
-	if (pThis->hBindPort) {
-		Netlib_CloseHandle(pThis->hBindPort);
-		pThis->hBindPort = NULL;
-	}
-
-	if (pThis->di->iType == DCC_CHAT)
-		pThis->DoChatReceive(); // dcc chat
-
-	else if (!pThis->di->bSender)
-		pThis->DoReceiveFile(); // receive a file
-
-	else if (pThis->di->bSender)
-		pThis->DoSendFile(); // send a file
-}
-
-// this is done when the user is initiating a filetransfer to a remote computer
-void CDccSession::DoSendFile()
-{
-	// initialize the filetransfer dialog
-	ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_INITIALISING, (void *)di, 0);
-	ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_NEXTFILE, (void *)di, 0);
-
-	WORD wPacketSize = m_proto->getWord("DCCPacketSize", 1024 * 4);
-
-	if (wPacketSize < 256)
-		wPacketSize = 256;
-
-	if (wPacketSize > 32 * 1024)
-		wPacketSize = 32 * 1024;
-
-	BYTE* chBuf = new BYTE[wPacketSize + 1];
-
-	// is there a connection?
-	if (con) {
-		// open the file for reading
-		int hFile = _topen(di->sFileAndPath.c_str(), _O_RDONLY | _O_BINARY, _S_IREAD);
-		if (hFile >= 0) {
-			unsigned __int64 dwLastAck = 0;
-
-			// if the user has chosen to resume a file, dwResumePos will contain a value (set using InterlockedExchange())
-			// and then the variables and the file pointer are changed accordingly.
-			if (dwResumePos && dwWhatNeedsDoing == FILERESUME_RESUME) {
-				_lseeki64(hFile, dwResumePos, SEEK_SET);
-				dwTotal = dwResumePos;
-				dwLastAck = dwResumePos;
-				pfts.totalProgress = dwResumePos;
-				pfts.currentFileProgress = dwResumePos;
-			}
-
-			// initial ack to set the 'percentage-ready meter' to the correct value
-			ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_DATA, (void *)di, (LPARAM)&pfts);
-
-			tLastActivity = time(0);
-
-			// create a packet receiver to handle receiving ack's from the remote computer.
-			HANDLE hPackrcver = (HANDLE)CallService(MS_NETLIB_CREATEPACKETRECVER, (WPARAM)con, sizeof(DWORD));
-			NETLIBPACKETRECVER npr;
-			npr.cbSize = sizeof(NETLIBPACKETRECVER);
-			npr.dwTimeout = 60 * 1000;
-			npr.bufferSize = sizeof(DWORD);
-			npr.bytesUsed = 0;
-
-			// until the connection is dropped it will spin around in this while() loop
-			while (con) {
-				// read a packet
-				int iRead = _read(hFile, chBuf, wPacketSize);
-				if (iRead <= 0)
-					break; // break out if everything has already been read
-
-				// send the package
-				int cbSent = NLSend((unsigned char*)chBuf, iRead);
-				if (cbSent <= 0)
-					break; // break out if connection is lost or a transmission error has occured
-
-				if (!con)
-					break;
-
-				dwTotal += cbSent;
-
-				// block connection and receive ack's from remote computer (if applicable)
-				if (m_proto->m_DCCMode == 0) {
-					DWORD dwRead = 0;
-					DWORD dwPacket = NULL;
-
-					do {
-						dwRead = CallService(MS_NETLIB_GETMOREPACKETS, (WPARAM)hPackrcver, (LPARAM)&npr);
-						npr.bytesUsed = sizeof(DWORD);
-
-						if (dwRead <= 0)
-							break; // connection closed, or a timeout occurred.
-
-						dwPacket = *(DWORD*)npr.buffer;
-						dwLastAck = ntohl(dwPacket);
-
-					}
-					while (con && dwTotal != dwLastAck);
-
-					if (!con || dwRead <= 0)
-						goto DCC_STOP;
-				}
-
-				if (m_proto->m_DCCMode == 1) {
-					DWORD dwRead = 0;
-					DWORD dwPacket = 0;
-
-					do {
-						dwRead = CallService(MS_NETLIB_GETMOREPACKETS, (WPARAM)hPackrcver, (LPARAM)&npr);
-						npr.bytesUsed = sizeof(DWORD);
-						if (dwRead <= 0)
-							break; // connection closed, or a timeout occurred.
-
-						dwPacket = *(DWORD*)npr.buffer;
-						dwLastAck = ntohl(dwPacket);
-					}
-					while (con && (di->dwSize != dwTotal
-					&& dwTotal - dwLastAck >= 100 * 1024
-					|| di->dwSize == dwTotal // get the last packets when the whole file has been sent
-					&& dwTotal != dwLastAck));
-
-					if (!con || dwRead <= 0)
-						goto DCC_STOP;
-				}
-
-				// update the filetransfer dialog's 'percentage-ready meter' once per second only to save cpu
-				if (tLastPercentageUpdate < time(0)) {
-					tLastPercentageUpdate = time(0);
-					pfts.totalProgress = dwTotal;
-					pfts.currentFileProgress = dwTotal;
-					ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_DATA, (void *)di, (LPARAM)&pfts);
-				}
-
-				// close the connection once the whole file has been sent an completely ack'ed
-				if (dwLastAck >= di->dwSize) {
-					Netlib_CloseHandle(con);
-					con = NULL;
-				}
-			}
-
-		DCC_STOP:
-			// need to close the connection if it isn't allready
-			if (con) {
-				Netlib_CloseHandle(con);
-				con = NULL;
-			}
-
-			// ack the progress one final time
-			tLastActivity = time(0);
-			pfts.totalProgress = dwTotal;
-			pfts.currentFileProgress = dwTotal;
-			ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_DATA, (void *)di, (LPARAM)&pfts);
-
-			_close(hFile);
-		}
-		else { // file was not possible to open for reading
-			ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_FAILED, (void *)di, 0);
-			if (con) {
-				Netlib_CloseHandle(con);
-				con = NULL;
-			}
-		}
-	}
-
-	delete[]chBuf;
-	delete this; // ... and hopefully all went right, cuz here the object is deleted in any case
-}
-
-// This is called when receiving a file from a remote computer.
-void CDccSession::DoReceiveFile()
-{
-	// initialize the filetransfer dialog
-	ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_INITIALISING, (void *)di, 0);
-
-	BYTE chBuf[1024 * 32 + 1];
-
-	// do some stupid thing so  the filetransfer dialog shows the right thing
-	ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_NEXTFILE, (void *)di, 0);
-
-	// open the file for writing (and reading in case it is a resume)
-	int hFile = _topen(di->sFileAndPath.c_str(),
-		(dwWhatNeedsDoing == FILERESUME_RESUME ? _O_APPEND : _O_TRUNC | _O_CREAT) | _O_RDWR | _O_BINARY,
-		_S_IREAD | _S_IWRITE);
-	if (hFile >= 0) {
-		unsigned __int64 dwLastAck = 0;
-
-		// dwResumePos and dwWhatNeedsDoing has possibly been set using InterlockedExchange()
-		// if set it is a resume and we adjust variables and the file pointer accordingly.
-		if (dwResumePos && dwWhatNeedsDoing == FILERESUME_RESUME) {
-			_lseeki64(hFile, dwResumePos, SEEK_SET);
-			dwTotal = dwResumePos;
-			dwLastAck = dwResumePos;
-			pfts.totalProgress = dwResumePos;
-			pfts.currentFileProgress = dwResumePos;
-		}
-
-		// send an initial ack for the percentage-ready meter
-		ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_DATA, (void *)di, (LPARAM)&pfts);
-
-		// the while loop will spin around till the connection is dropped, locally or by the remote computer.
-		while (con) {
-			// read
-			int cbRead = NLReceive((unsigned char*)chBuf, sizeof(chBuf));
-			if (cbRead <= 0)
-				break;
-
-			// write it to the file
-			_write(hFile, chBuf, cbRead);
-
-			dwTotal += cbRead;
-
-			// this snippet sends out an ack for every 4 kb received in send ahead
-			// or every packet for normal mode
-			if (!di->bTurbo) {
-				DWORD no = dwTotal;
-				no = htonl(no);
-				NLSend((unsigned char *)&no, sizeof(DWORD));
-				dwLastAck = dwTotal;
-			}
-			else dwLastAck = dwTotal;
-
-			// sets the 'last update time' to check for timed out connections, and also make sure we only
-			// ack the 'percentage-ready meter' only once a second to save CPU.
-			if (tLastPercentageUpdate < time(0)) {
-				tLastPercentageUpdate = time(0);
-				pfts.totalProgress = dwTotal;
-				pfts.currentFileProgress = dwTotal;
-				ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_DATA, (void *)di, (LPARAM)&pfts);
-			}
-
-			// if file size is known and everything is received then disconnect 
-			if (di->dwSize && di->dwSize == dwTotal) {
-				Netlib_CloseHandle(con);
-				con = NULL;
-			}
-		}
-		// receiving loop broken locally or by remote computer, just some cleaning up left....
-
-		pfts.totalProgress = dwTotal;
-		pfts.currentFileProgress = dwTotal;
-		ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_DATA, (void *)di, (LPARAM)&pfts);
-		_close(hFile);
-	}
-	else {
-		ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_FAILED, (void *)di, 0);
-		if (con) { // file not possible to open for writing so we ack FAILURE and close the handle
-			Netlib_CloseHandle(con);
-			con = NULL;
-		}
-	}
-
-	delete this; // and finally the object is deleted
-}
-
-// this function handles receiving text in dcc chats and then send it in the protochain. very uncomplicated...
-// For sending text the SendStuff() function is called (with the help of some function in CIrcProto to find the right
-// Dcc object). See CIrcProto for info on how the dcc objects are stored, retrieved and deleted.
-
-void CDccSession::DoChatReceive()
-{
-	char chBuf[1024 * 4 + 1];
-	int cbInBuf = 0;
-
-	// loop to spin around while there is a connection
-	while (con) {
-		int cbRead;
-		int nLinesProcessed = 0;
-
-		cbRead = NLReceive((unsigned char*)chBuf + cbInBuf, sizeof(chBuf)-cbInBuf - 1);
-		if (cbRead <= 0)
-			break;
-
-		cbInBuf += cbRead;
-		chBuf[cbInBuf] = '\0';
-
-		char* pStart = chBuf;
-		while (*pStart) {
-			char* pEnd;
-
-			// seek end-of-line
-			for (pEnd = pStart; *pEnd && *pEnd != '\r' && *pEnd != '\n'; ++pEnd)
-				;
-			if (*pEnd == '\0')
-				break; // uncomplete message. stop parsing.
-
-			++nLinesProcessed;
-
-			// replace end-of-line with NULLs and skip
-			while (*pEnd == '\r' || *pEnd == '\n')
-				*pEnd++ = '\0';
-
-			if (*pStart) {
-				// send it off to some messaging module
-				PROTORECVEVENT pre = { 0 };
-				pre.timestamp = (DWORD)time(NULL);
-				pre.szMessage = pStart;
-				ProtoChainRecvMsg(di->hContact, &pre);
-			}
-
-			cbInBuf -= pEnd - pStart;
-			pStart = pEnd;
-		}
-
-		// discard processed messages
-		if (nLinesProcessed != 0)
-			memmove(chBuf, pStart, cbInBuf + 1);
-	}
-
-	delete this; // delete the object when the connection is dropped
-}
-
-// disconnect the stuff
-int CDccSession::Disconnect()
-{
-	if (hBindPort) {
-		Netlib_CloseHandle(hBindPort);
-		hBindPort = NULL;
-	}
-
-	// if 'con' exists it is cuz a connection exists. 
-	// Terminating 'con' will cause any spawned threads to die and then the object will destroy itself.
-	if (con) {
-		Netlib_CloseHandle(con);
-		con = NULL;
-	}
-	else delete this; // if 'con' do not exist (no connection made so far from the object) the object is destroyed
-
-	return TRUE;
-}
-
-////////////////////////////////////////////////////////////////////
-// check if the dcc chats should disconnect ( default 5 minute timeout )
-
-VOID CALLBACK DCCTimerProc(HWND, UINT, UINT_PTR idEvent, DWORD)
-{
-	CIrcProto *ppro = GetTimerOwner(idEvent);
-	if (ppro)
-		ppro->CheckDCCTimeout();
-}
-
-// helper function for incoming dcc connections.
-void DoIncomingDcc(HANDLE hConnection, DWORD dwRemoteIP, void * p1)
-{
-	CDccSession* dcc = (CDccSession*)p1;
-	dcc->IncomingConnection(hConnection, dwRemoteIP);
-}
-
-// ident server
-
-void strdel(char* parBuffer, int len)
-{
-	char *p;
-	for (p = parBuffer + len; *p != 0; p++)
-		p[-len] = *p;
-
-	p[-len] = '\0';
-}
-
-void DoIdent(HANDLE hConnection, DWORD, void* extra)
-{
-	CIrcProto *ppro = (CIrcProto*)extra;
-
-	char szBuf[1024];
-	int cbTotal = 0;
-
-	while (true) {
-		int cbRead = Netlib_Recv(hConnection, szBuf + cbTotal, sizeof(szBuf)-1 - cbTotal, 0);
-		if (cbRead == SOCKET_ERROR || cbRead == 0)
-			break;
-
-		cbTotal += cbRead;
-		szBuf[cbTotal] = '\0';
-
-LBL_Parse:
-		char* EOLPos = strstr(szBuf, "\r\n");
-		if (EOLPos == NULL)
-			continue;
-
-		EOLPos[0] = EOLPos[1] = '\0';
-		rtrim(szBuf);
-		ppro->debugLogA("Got Ident request: %s", szBuf);
-
-		unsigned int PeerPortNrRcvd = 0, LocalPortNrRcvd = 0;
-		int iParamCnt = sscanf(szBuf, "%d , %d", &LocalPortNrRcvd, &PeerPortNrRcvd);
-
-		int cbLen = 0;
-		char buf[1024 * 4];
-
-		if (iParamCnt != 2)
-			cbLen = mir_snprintf(buf, SIZEOF(buf), "%s : ERROR : UNKNOWN-ERROR\r\n", szBuf);
-		else {
-			for (int i = 0; i < g_Instances.getCount(); i++) {
-				if (PeerPortNrRcvd == g_Instances[i]->m_info.iPort && LocalPortNrRcvd == g_Instances[i]->m_myLocalPort) {
-					cbLen = mir_snprintf(buf, SIZEOF(buf), "%s : USERID : %S : %S\r\n",
-						szBuf, g_Instances[i]->m_info.sIdentServerType.c_str(), g_Instances[i]->m_info.sUserID.c_str());
-					break;
-				}
-			}
-
-			if (cbLen == 0)
-				cbLen = mir_snprintf(buf, SIZEOF(buf), "%s : ERROR : INVALID-PORT\r\n", szBuf);
-		}
-
-		if (Netlib_Send(hConnection, (const char*)buf, cbLen, 0) > 0)
-			ppro->debugLogA("Sent Ident answer: %s", buf);
-		else
-			ppro->debugLogA("Sending Ident answer failed.");
-
-		if (ppro->m_identTimer)
-			break;
-
-		cbTotal -= EOLPos + 2 - szBuf;
-		strdel(szBuf, int(EOLPos + 2 - szBuf));
-		goto LBL_Parse;
-	}
-	Netlib_CloseHandle(hConnection);
-}
+/*
+IRC plugin for Miranda IM
+
+Copyright (C) 2003-05 Jurgen Persson
+Copyright (C) 2007-09 George Hazan
+
+This program is free software; you can redistribute it and/or
+modify it under the terms of the GNU General Public License
+as published by the Free Software Foundation; either version 2
+of the License, or (at your option) any later version.
+
+This program is distributed in the hope that it will be useful,
+but WITHOUT ANY WARRANTY; without even the implied warranty of
+MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+GNU General Public License for more details.
+
+You should have received a copy of the GNU General Public License
+along with this program; if not, write to the Free Software
+Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
+*/
+#include "irc.h"
+
+#define DCCCHATTIMEOUT 300
+#define DCCSENDTIMEOUT 120
+
+using namespace irc;
+
+int CDccSession::nDcc = 0;
+
+static int CompareHandlers( const CIrcHandler* p1, const CIrcHandler* p2 )
+{
+	return lstrcmp( p1->m_name, p2->m_name );
+}
+
+OBJLIST<CIrcHandler> CIrcProto::m_handlers( 30, CompareHandlers );
+
+////////////////////////////////////////////////////////////////////
+
+CIrcMessage::CIrcMessage( CIrcProto* _pro, const TCHAR* lpszCmdLine, int codepage, bool bIncoming, bool bNotify ) :
+	m_proto( _pro ),
+	m_bIncoming( bIncoming ),
+	m_bNotify( bNotify ),
+	m_codePage( codepage ),
+	parameters( 10 )
+{
+	ParseIrcCommand(lpszCmdLine);
+}
+
+CIrcMessage::CIrcMessage(const CIrcMessage& m) :
+	sCommand( m.sCommand ),
+	m_bIncoming( m.m_bIncoming ), 
+	m_bNotify( m.m_bNotify ),
+	m_codePage( m.m_codePage ),
+	m_proto( m.m_proto ),
+	parameters( m.parameters.getCount())
+{
+	prefix.sNick = m.prefix.sNick;
+	prefix.sUser = m.prefix.sUser;
+	prefix.sHost = m.prefix.sHost;
+
+	for (int i = 0; i < m.parameters.getCount(); i++)
+		parameters.insert(new CMString(m.parameters[i]));
+}
+
+CIrcMessage::~CIrcMessage()
+{
+}
+
+void CIrcMessage::Reset()
+{
+	prefix.sNick = prefix.sUser = prefix.sHost = sCommand = _T("");
+	m_bIncoming = false;
+	m_bNotify = true;
+
+	parameters.destroy();
+}
+
+CIrcMessage& CIrcMessage::operator = (const CIrcMessage& m)
+{
+	if (&m != this) {
+		sCommand = m.sCommand;
+		parameters = m.parameters;
+		prefix.sNick = m.prefix.sNick;
+		prefix.sUser = m.prefix.sUser;
+		prefix.sHost = m.prefix.sHost;
+		m_bIncoming = m.m_bIncoming;
+		m_bNotify = m.m_bNotify;
+	}
+	return *this;
+}
+
+CIrcMessage& CIrcMessage::operator = (const TCHAR* lpszCmdLine)
+{
+	Reset();
+	ParseIrcCommand(lpszCmdLine);
+	return *this;
+}
+
+void CIrcMessage::ParseIrcCommand(const TCHAR* lpszCmdLine)
+{
+	const TCHAR* p1 = lpszCmdLine;
+	const TCHAR* p2 = lpszCmdLine;
+
+	// prefix exists ?
+	if (*p1 == ':') {
+		// break prefix into its components (nick!user@host)
+		p2 = ++p1;
+		while (*p2 && !_tcschr(_T(" !"), *p2))
+			++p2;
+		prefix.sNick.SetString(p1, p2 - p1);
+		if (*p2 != '!')
+			goto end_of_prefix;
+		p1 = ++p2;
+		while (*p2 && !_tcschr(_T(" @"), *p2))
+			++p2;
+		prefix.sUser.SetString(p1, p2 - p1);
+		if (*p2 != '@')
+			goto end_of_prefix;
+		p1 = ++p2;
+		while (*p2 && *p2 != ' ')
+			++p2;
+		prefix.sHost.SetString(p1, p2 - p1);
+end_of_prefix:
+		while (*p2 && *p2 == ' ')
+			++p2;
+		p1 = p2;
+	}
+
+	// get command
+	p2 = p1;
+	while (*p2 && *p2 != ' ')
+		++p2;
+
+	sCommand.SetString(p1, p2 - p1);
+	sCommand.MakeUpper();
+	while (*p2 && *p2 == ' ')
+		++p2;
+	p1 = p2;
+
+	// get parameters
+	while (*p1) {
+		if (*p1 == ':') {
+			++p1;
+
+			// seek end-of-message
+			while (*p2)
+				++p2;
+			parameters.insert(new CMString(p1, p2 - p1));
+			break;
+		}
+		else {
+			// seek end of parameter
+			while (*p2 && *p2 != ' ')
+				++p2;
+			parameters.insert(new CMString(p1, p2 - p1));
+			// see next parameter
+			while (*p2 && *p2 == ' ')
+				++p2;
+			p1 = p2;
+		}
+	}
+}
+
+////////////////////////////////////////////////////////////////////
+
+int CIrcProto::getCodepage() const
+{
+	return (con != NULL) ? codepage : CP_ACP;
+}
+
+void CIrcProto::SendIrcMessage(const TCHAR* msg, bool bNotify, int codepage)
+{
+	if (codepage == -1)
+		codepage = getCodepage();
+
+	if (this) {
+		char* str = mir_t2a_cp(msg, codepage);
+		rtrim(str);
+		int cbLen = (int)strlen(str);
+		str = (char*)mir_realloc(str, cbLen + 3);
+		strcat(str, "\r\n");
+		NLSend((const BYTE*)str, cbLen + 2);
+		mir_free(str);
+
+		if (bNotify) {
+			CIrcMessage ircMsg(this, msg, codepage);
+			if (!ircMsg.sCommand.IsEmpty() && ircMsg.sCommand != _T("QUIT"))
+				Notify(&ircMsg);
+		}
+	}
+}
+
+bool CIrcProto::Connect(const CIrcSessionInfo& info)
+{
+	codepage = m_codepage;
+
+	NETLIBOPENCONNECTION ncon = { 0 };
+	ncon.cbSize = sizeof(ncon);
+	ncon.szHost = info.sServer.c_str();
+	ncon.wPort = info.iPort;
+	con = (HANDLE)CallService(MS_NETLIB_OPENCONNECTION, (WPARAM)m_hNetlibUser, (LPARAM)&ncon);
+	if (con == NULL) {
+		TCHAR szTemp[300];
+		mir_sntprintf(szTemp, SIZEOF(szTemp), _T("\0035%s \002%s\002 (%S: %u)."),
+			TranslateT("Failed to connect to"), si.sNetwork.c_str(), si.sServer.c_str(), si.iPort);
+		DoEvent(GC_EVENT_INFORMATION, SERVERWINDOW, NULL, szTemp, NULL, NULL, NULL, true, false);
+		return false;
+	}
+
+	FindLocalIP(con); // get the local ip used for filetransfers etc
+
+	if (info.m_iSSL > 0) {
+		if (!CallService(MS_NETLIB_STARTSSL, (WPARAM)con, 0) && info.m_iSSL == 2) {
+			Netlib_CloseHandle(con);
+			con = NULL;
+			m_info.Reset();
+			return false;
+		}
+	}
+
+	if (Miranda_Terminated()) {
+		Disconnect();
+		return false;
+	}
+
+	m_info = info;
+
+	// start receiving messages from host
+	ForkThread(&CIrcProto::ThreadProc, NULL);
+	Sleep(100);
+	if (info.sPassword.GetLength())
+		NLSend("PASS %s\r\n", info.sPassword.c_str());
+	NLSend(_T("NICK %s\r\n"), info.sNick.c_str());
+
+	CMString m_userID = GetWord(info.sUserID.c_str(), 0);
+	TCHAR szHostName[MAX_PATH];
+	DWORD cbHostName = SIZEOF(szHostName);
+	GetComputerName(szHostName, &cbHostName);
+	CMString HostName = GetWord(szHostName, 0);
+	if (m_userID.IsEmpty())
+		m_userID = _T("Miranda");
+	if (HostName.IsEmpty())
+		HostName = _T("host");
+	NLSend(_T("USER %s %s %s :%s\r\n"), m_userID.c_str(), HostName.c_str(), _T("server"), info.sFullName.c_str());
+
+	return con != NULL;
+}
+
+void CIrcProto::Disconnect(void)
+{
+	static const DWORD dwServerTimeout = 5 * 1000;
+
+	if (con == NULL)
+		return;
+
+	KillIdent();
+
+	if (m_quitMessage && m_quitMessage[0])
+		NLSend(_T("QUIT :%s\r\n"), m_quitMessage);
+	else
+		NLSend("QUIT \r\n");
+
+	Sleep(50);
+
+	if (con)
+		Netlib_Shutdown(con);
+
+	m_info.Reset();
+	return;
+}
+
+void CIrcProto::Notify(const CIrcMessage* pmsg)
+{
+	OnIrcMessage(pmsg);
+}
+
+int CIrcProto::NLSend(const unsigned char* buf, int cbBuf)
+{
+	if (!con || !buf)
+		return 0;
+	if (m_scriptingEnabled && cbBuf == 0)
+		cbBuf = lstrlenA((const char *)buf);
+	return Netlib_Send(con, (const char*)buf, cbBuf, MSG_DUMPASTEXT);
+}
+
+int CIrcProto::NLSend(const TCHAR* fmt, ...)
+{
+	va_list marker;
+	va_start(marker, fmt);
+
+	TCHAR szBuf[1024 * 4];
+	mir_vsntprintf(szBuf, SIZEOF(szBuf), fmt, marker);
+	va_end(marker);
+
+	char* buf = mir_t2a_cp(szBuf, getCodepage());
+	int result = NLSend((unsigned char*)buf, (int)strlen(buf));
+	mir_free(buf);
+	return result;
+}
+
+int CIrcProto::NLSend(const char* fmt, ...)
+{
+	va_list marker;
+	va_start(marker, fmt);
+
+	char szBuf[1024 * 4];
+	int cbLen = mir_vsnprintf(szBuf, SIZEOF(szBuf), fmt, marker);
+	va_end(marker);
+
+	return NLSend((unsigned char*)szBuf, cbLen);
+}
+
+int CIrcProto::NLSendNoScript(const unsigned char* buf, int cbBuf)
+{
+	if (con)
+		return Netlib_Send(con, (const char*)buf, cbBuf, MSG_DUMPASTEXT);
+
+	return 0;
+}
+
+int CIrcProto::NLReceive(unsigned char* buf, int cbBuf)
+{
+	return Netlib_Recv(con, (char*)buf, cbBuf, MSG_DUMPASTEXT);
+}
+
+void CIrcProto::KillIdent()
+{
+	if (hBindPort) {
+		HANDLE hPort = hBindPort;
+		hBindPort = NULL;
+		Netlib_CloseHandle(hPort);
+	}
+}
+
+void CIrcProto::InsertIncomingEvent(TCHAR* pszRaw)
+{
+	CIrcMessage msg(this, pszRaw, true);
+	Notify(&msg);
+	return;
+}
+
+void CIrcProto::createMessageFromPchar(const char* p)
+{
+	TCHAR* ptszMsg;
+	if (codepage != CP_UTF8 && m_utfAutodetect) {
+		if (mir_utf8decodecp(NEWSTR_ALLOCA(p), codepage, &ptszMsg) == NULL)
+			ptszMsg = mir_a2t_cp(p, codepage);
+	}
+	else ptszMsg = mir_a2t_cp(p, codepage);
+	CIrcMessage msg(this, ptszMsg, codepage, true);
+	Notify(&msg);
+	mir_free(ptszMsg);
+}
+
+void CIrcProto::DoReceive()
+{
+	char chBuf[1024 * 4 + 1];
+	int cbInBuf = 0;
+
+	if (m_info.bIdentServer && m_info.iIdentServerPort != NULL) {
+		NETLIBBIND nb = { 0 };
+		nb.cbSize = sizeof(NETLIBBIND);
+		nb.pfnNewConnectionV2 = DoIdent;
+		nb.pExtra = this;
+		nb.wPort = m_info.iIdentServerPort;
+		hBindPort = (HANDLE)CallService(MS_NETLIB_BINDPORT, (WPARAM)m_hNetlibUser, (LPARAM)&nb);
+		if (!hBindPort || nb.wPort != m_info.iIdentServerPort) {
+			debugLogA("Error: unable to bind local port %u", m_info.iIdentServerPort);
+			KillIdent();
+		}
+	}
+
+	while (con) {
+		int nLinesProcessed = 0;
+
+		int cbRead = NLReceive((unsigned char*)chBuf + cbInBuf, sizeof(chBuf)-cbInBuf - 1);
+		if (cbRead <= 0)
+			break;
+
+		cbInBuf += cbRead;
+		chBuf[cbInBuf] = '\0';
+
+		char* pStart = chBuf;
+		while (*pStart) {
+			char* pEnd;
+
+			// seek end-of-line
+			for (pEnd = pStart; *pEnd && *pEnd != '\r' && *pEnd != '\n'; ++pEnd)
+				;
+			if (*pEnd == '\0')
+				break; // uncomplete message. stop parsing.
+
+			++nLinesProcessed;
+
+			// replace end-of-line with NULLs and skip
+			while (*pEnd == '\r' || *pEnd == '\n')
+				*pEnd++ = '\0';
+
+			// process single message by monitor objects
+			if (*pStart) {
+				if (m_scriptingEnabled) {
+					char* pszTemp = mir_strdup(pStart);
+
+					if (pszTemp) {
+						char* p1 = pszTemp;
+						// replace end-of-line with NULLs
+						while (*p1 != '\0') {
+							if (*p1 == '\r' || *p1 == '\n')
+								*p1 = '\0';
+							p1++;
+						}
+
+						createMessageFromPchar(pszTemp);
+					}
+
+					mir_free(pszTemp);
+				}
+				else createMessageFromPchar(pStart);
+			}
+
+			cbInBuf -= pEnd - pStart;
+			pStart = pEnd;
+		}
+
+		// discard processed messages
+		if (nLinesProcessed != 0)
+			memmove(chBuf, pStart, cbInBuf + 1);
+	}
+
+	if (con) {
+		Netlib_CloseHandle(con);
+		con = NULL;
+	}
+
+	// notify monitor objects that the connection has been closed
+	Notify(NULL);
+}
+
+void __cdecl CIrcProto::ThreadProc(void*)
+{
+	DoReceive();
+	m_info.Reset();
+}
+
+void CIrcProto::AddDCCSession(MCONTACT, CDccSession* dcc)
+{
+	mir_cslock lck(m_dcc);
+
+	CDccSession* p = m_dcc_chats.find(dcc);
+	if (p)
+		m_dcc_chats.remove(p);
+
+	m_dcc_chats.insert(dcc);
+}
+
+void CIrcProto::AddDCCSession(DCCINFO*, CDccSession* dcc)
+{
+	mir_cslock lck(m_dcc);
+	m_dcc_xfers.insert(dcc);
+}
+
+void CIrcProto::RemoveDCCSession(MCONTACT hContact)
+{
+	mir_cslock lck(m_dcc);
+
+	for (int i = 0; i < m_dcc_chats.getCount(); i++)
+		if (m_dcc_chats[i]->di->hContact == hContact) {
+			m_dcc_chats.remove(i);
+			break;
+		}
+}
+
+void CIrcProto::RemoveDCCSession(DCCINFO* pdci)
+{
+	mir_cslock lck(m_dcc);
+
+	for (int i = 0; i < m_dcc_xfers.getCount(); i++) {
+		if (m_dcc_xfers[i]->di == pdci) {
+			m_dcc_xfers.remove(i);
+			break;
+		}
+	}
+}
+
+CDccSession* CIrcProto::FindDCCSession(MCONTACT hContact)
+{
+	mir_cslock lck(m_dcc);
+
+	for (int i = 0; i < m_dcc_chats.getCount(); i++)
+		if (m_dcc_chats[i]->di->hContact == hContact)
+			return m_dcc_chats[i];
+
+	return 0;
+}
+
+CDccSession* CIrcProto::FindDCCSession(DCCINFO* pdci)
+{
+	mir_cslock lck(m_dcc);
+
+	for (int i = 0; i < m_dcc_xfers.getCount(); i++)
+		if (m_dcc_xfers[i]->di == pdci)
+			return m_dcc_xfers[i];
+
+	return 0;
+}
+
+CDccSession* CIrcProto::FindDCCSendByPort(int iPort)
+{
+	mir_cslock lck(m_dcc);
+
+	for (int i = 0; i < m_dcc_xfers.getCount(); i++) {
+		CDccSession *p = m_dcc_xfers[i];
+		if (p->di->iType == DCC_SEND && p->di->bSender && iPort == p->di->iPort)
+			return p;
+	}
+
+	return 0;
+}
+
+CDccSession* CIrcProto::FindDCCRecvByPortAndName(int iPort, const TCHAR* szName)
+{
+	mir_cslock lck(m_dcc);
+
+	for (int i = 0; i < m_dcc_xfers.getCount(); i++) {
+		CDccSession* p = m_dcc_xfers[i];
+		DBVARIANT dbv;
+		if (!getTString(p->di->hContact, "Nick", &dbv)) {
+			if (p->di->iType == DCC_SEND && !p->di->bSender && !lstrcmpi(szName, dbv.ptszVal) && iPort == p->di->iPort) {
+				db_free(&dbv);
+				return p;
+			}
+			db_free(&dbv);
+		}
+	}
+
+	return 0;
+}
+
+CDccSession* CIrcProto::FindPassiveDCCSend(int iToken)
+{
+	mir_cslock lck(m_dcc);
+
+	for (int i = 0; i < m_dcc_xfers.getCount(); i++)
+		if (m_dcc_xfers[i]->iToken == iToken)
+			return m_dcc_xfers[i];
+
+	return 0;
+}
+
+CDccSession* CIrcProto::FindPassiveDCCRecv(CMString sName, CMString sToken)
+{
+	mir_cslock lck(m_dcc);
+
+	for (int i = 0; i < m_dcc_xfers.getCount(); i++) {
+		CDccSession *p = m_dcc_xfers[i];
+		if (sToken == p->di->sToken && sName == p->di->sContactName)
+			return p;
+	}
+
+	return 0;
+}
+
+void CIrcProto::DisconnectAllDCCSessions(bool Shutdown)
+{
+	mir_cslock lck(m_dcc);
+
+	for (int i = 0; i < m_dcc_chats.getCount(); i++)
+		if (m_disconnectDCCChats || Shutdown)
+			m_dcc_chats[i]->Disconnect();
+}
+
+void CIrcProto::CheckDCCTimeout(void)
+{
+	mir_cslock lck(m_dcc);
+
+	for (int i = 0; i < m_dcc_chats.getCount(); i++) {
+		CDccSession* p = m_dcc_chats[i];
+		if (time(0) > p->tLastActivity + DCCCHATTIMEOUT)
+			p->Disconnect();
+	}
+
+	for (int j = 0; j < m_dcc_xfers.getCount(); j++) {
+		CDccSession* p = m_dcc_xfers[j];
+		if (time(0) > p->tLastActivity + DCCSENDTIMEOUT)
+			p->Disconnect();
+	}
+}
+
+////////////////////////////////////////////////////////////////////
+
+CIrcIgnoreItem::CIrcIgnoreItem(const TCHAR* _mask, const TCHAR* _flags, const TCHAR* _network) :
+	mask(_mask),
+	flags(_flags),
+	network(_network)
+{
+}
+
+CIrcIgnoreItem::CIrcIgnoreItem(int codepage, const char* _mask, const char* _flags, const char* _network) :
+	mask((TCHAR*)_A2T(_mask, codepage)),
+	flags((TCHAR*)_A2T(_flags, codepage)),
+	network((TCHAR*)_A2T(_network, codepage))
+{
+}
+
+CIrcIgnoreItem::~CIrcIgnoreItem()
+{
+}
+
+////////////////////////////////////////////////////////////////////
+
+CIrcSessionInfo::CIrcSessionInfo() :
+	iPort(0),
+	bIdentServer(false),
+	iIdentServerPort(0)
+{
+}
+
+CIrcSessionInfo::CIrcSessionInfo(const CIrcSessionInfo& si) :
+	sServer(si.sServer),
+	sServerName(si.sServerName),
+	iPort(si.iPort),
+	sNick(si.sNick),
+	sUserID(si.sUserID),
+	sFullName(si.sFullName),
+	sPassword(si.sPassword),
+	bIdentServer(si.bIdentServer),
+	m_iSSL(si.m_iSSL),
+	sIdentServerType(si.sIdentServerType),
+	sNetwork(si.sNetwork),
+	iIdentServerPort(si.iIdentServerPort)
+{
+}
+
+void CIrcSessionInfo::Reset()
+{
+	sServer = "";
+	sServerName = _T("");
+	iPort = 0;
+	sNick = _T("");
+	sUserID = _T("");
+	sFullName = _T("");
+	sPassword = "";
+	bIdentServer = false;
+	bNickFlag = false;
+	m_iSSL = 0;
+	sIdentServerType = _T("");
+	iIdentServerPort = 0;
+	sNetwork = _T("");
+}
+
+////////////////////////////////////////////////////////////////////
+
+void CIrcProto::OnIrcMessage(const CIrcMessage* pmsg)
+{
+	if (pmsg != NULL) {
+		PfnIrcMessageHandler pfn = FindMethod(pmsg->sCommand.c_str());
+		if (pfn) {
+			// call member function. if it returns 'false',
+			// call the default handling
+			__try {
+				if (!(this->*pfn)(pmsg))
+					OnIrcDefault(pmsg);
+			}
+			__except (EXCEPTION_EXECUTE_HANDLER) // dedicated to Sava :)
+			{
+				debugLogA("IRC handler feels sick: %S", pmsg->sCommand.c_str());
+			}
+		}
+		else // handler not found. call default handler
+			OnIrcDefault(pmsg);
+	}
+	else OnIrcDisconnected();
+}
+
+PfnIrcMessageHandler CIrcProto::FindMethod(const TCHAR* lpszName)
+{
+	CIrcHandler temp(lpszName, NULL);
+	CIrcHandler* p = m_handlers.find(&temp);
+	return (p == NULL) ? NULL : p->m_handler;
+}
+
+////////////////////////////////////////////////////////////////////
+
+#define IPC_ADDR_SIZE				4		/* Size of IP address, change for IPv6. */
+
+char* ConvertIntegerToIP(unsigned long int_ip_addr)
+{
+	IN_ADDR intemp;
+	IN_ADDR in;
+	intemp.S_un.S_addr = int_ip_addr;
+
+	in.S_un.S_un_b.s_b1 = intemp.S_un.S_un_b.s_b4;
+	in.S_un.S_un_b.s_b2 = intemp.S_un.S_un_b.s_b3;
+	in.S_un.S_un_b.s_b3 = intemp.S_un.S_un_b.s_b2;
+	in.S_un.S_un_b.s_b4 = intemp.S_un.S_un_b.s_b1;
+
+	return inet_ntoa(in);
+}
+
+unsigned long ConvertIPToInteger(char* IP)
+{
+	IN_ADDR in;
+	IN_ADDR intemp;
+
+	if (IP == 0 || lstrlenA(IP) == 0)
+		return 0;
+
+	intemp.S_un.S_addr = inet_addr(IP);
+
+	in.S_un.S_un_b.s_b1 = intemp.S_un.S_un_b.s_b4;
+	in.S_un.S_un_b.s_b2 = intemp.S_un.S_un_b.s_b3;
+	in.S_un.S_un_b.s_b3 = intemp.S_un.S_un_b.s_b2;
+	in.S_un.S_un_b.s_b4 = intemp.S_un.S_un_b.s_b1;
+	return in.S_un.S_addr;
+}
+
+////////////////////////////////////////////////////////////////////
+
+// initialize basic stuff needed for the dcc objects, also start a timer for checking the status of connections (timeouts)
+CDccSession::CDccSession(CIrcProto* _pro, DCCINFO* pdci) :
+	m_proto(_pro),
+	NewFileName(0),
+	dwWhatNeedsDoing(0),
+	tLastPercentageUpdate(0),
+	dwTotal(0),
+	iGlobalToken(),
+	dwResumePos(0),
+	hEvent(0),
+	con(0),
+	hBindPort(0)
+{
+	tLastActivity = time(0);
+
+	di = pdci; // Setup values passed to the constructor
+
+	ZeroMemory(&pfts, sizeof(PROTOFILETRANSFERSTATUS));
+	pfts.cbSize = sizeof(PROTOFILETRANSFERSTATUS);
+
+	if (di->iType == DCC_SEND && di->bSender == false)
+		hEvent = CreateEvent(NULL, TRUE, FALSE, NULL);
+
+	if (nDcc == 0)
+		m_proto->SetChatTimer(m_proto->DCCTimer, 20 * 1000, DCCTimerProc);
+
+	nDcc++; // increase the count of existing objects
+
+	iGlobalToken++;
+	if (iGlobalToken == 1000)
+		iGlobalToken = 1;
+	iToken = iGlobalToken;
+
+	iPacketSize = m_proto->getWord("PacketSize", 4096);
+
+	if (di->dwAdr)
+		m_proto->setDword(di->hContact, "IP", di->dwAdr); // mtooltip stuff
+}
+
+CDccSession::~CDccSession() // destroy all that needs destroying
+{
+	if (di->iType == DCC_SEND) {
+		// ack SUCCESS or FAILURE
+		if (dwTotal == di->dwSize)
+			ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_SUCCESS, (void *)di, 0);
+		else
+			ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_FAILED, (void *)di, 0);
+	}
+
+	if (di->iType == DCC_CHAT) {
+		CDccSession* dcc = m_proto->FindDCCSession(di->hContact);
+		if (dcc && this == dcc) {
+			m_proto->RemoveDCCSession(di->hContact); // objects automatically remove themselves from the list of objects
+			m_proto->setWord(di->hContact, "Status", ID_STATUS_OFFLINE);
+		}
+	}
+
+	if (di->iType == DCC_SEND)
+		m_proto->RemoveDCCSession(di);
+
+	if (hEvent != NULL) {
+		SetEvent(hEvent);
+		CloseHandle(hEvent);
+		hEvent = NULL;
+	}
+
+	delete di;
+	nDcc--;
+
+	if (nDcc < 0)
+		nDcc = 0;
+
+	if (nDcc == 0)
+		m_proto->KillChatTimer(m_proto->DCCTimer); // destroy the timer when no dcc objects remain
+}
+
+int CDccSession::NLSend(const unsigned char* buf, int cbBuf)
+{
+	tLastActivity = time(0);
+
+	if (con)
+		return Netlib_Send(con, (const char*)buf, cbBuf, di->iType == DCC_CHAT ? MSG_DUMPASTEXT : MSG_NODUMP);
+
+	return 0;
+}
+
+int CDccSession::NLReceive(const unsigned char* buf, int cbBuf)
+{
+	int n = 0;
+
+	if (con)
+		n = Netlib_Recv(con, (char*)buf, cbBuf, di->iType == DCC_CHAT ? MSG_DUMPASTEXT : MSG_NODUMP);
+
+	tLastActivity = time(0);
+	return n;
+}
+
+int CDccSession::SendStuff(const TCHAR* fmt)
+{
+	String buf = _T2A(fmt, m_proto->getCodepage());
+	return NLSend((const unsigned char*)buf.c_str(), buf.GetLength());
+}
+
+// called when the user wants to connect/create a new connection given the parameters in the constructor.
+int CDccSession::Connect()
+{
+	if (!di->bSender || di->bReverse) {
+		if (!con)
+			mir_forkthread(ConnectProc, this); // spawn a new thread for time consuming activities, ie when connecting to a remote computer
+		return true;
+	}
+
+	if (!con)
+		return SetupConnection(); // no need to spawn thread for setting up a listening port locally
+
+	return false;
+}
+
+void __cdecl CDccSession::ConnectProc(void *pparam)
+{
+	CDccSession* pThis = (CDccSession*)pparam;
+	if (!pThis->con)
+		pThis->SetupConnection();
+}
+
+// small function to setup the address and port of the remote computer fror passive filetransfers
+void CDccSession::SetupPassive(DWORD adress, DWORD port)
+{
+	di->dwAdr = adress;
+	di->iPort = (int)port;
+
+	m_proto->setDword(di->hContact, "IP", di->dwAdr); // mtooltip stuff
+}
+
+int CDccSession::SetupConnection()
+{
+	// if it is a dcc chat connection make sure it is "offline" to begin with, since no connection exists still
+	if (di->iType == DCC_CHAT)
+		m_proto->setWord(di->hContact, "Status", ID_STATUS_OFFLINE);
+
+	// Set up stuff needed for the filetransfer dialog (if it is a filetransfer)
+	if (di->iType == DCC_SEND) {
+		file[0] = (TCHAR*)di->sFileAndPath.c_str();
+		file[1] = 0;
+
+		pfts.tszCurrentFile = (TCHAR*)di->sFileAndPath.c_str();
+		pfts.tszWorkingDir = (TCHAR*)di->sPath.c_str();
+		pfts.hContact = di->hContact;
+		pfts.flags = PFTS_TCHAR + ((di->bSender) ? PFTS_SENDING : PFTS_RECEIVING);
+		pfts.totalFiles = 1;
+		pfts.currentFileNumber = 0;
+		pfts.totalBytes = di->dwSize;
+		pfts.currentFileSize = pfts.totalBytes;
+		pfts.ptszFiles = file;
+		pfts.totalProgress = 0;
+		pfts.currentFileProgress = 0;
+		pfts.currentFileTime = (unsigned long)time(0);
+	}
+
+	// create a listening socket for outgoing chat/send requests. The remote computer connects to this computer. Used for both chat and filetransfer.
+	if (di->bSender && !di->bReverse) {
+		NETLIBBIND nb = { 0 };
+		nb.cbSize = sizeof(NETLIBBIND);
+		nb.pfnNewConnectionV2 = DoIncomingDcc; // this is the (helper) function to be called once an incoming connection is made. The 'real' function that is called is IncomingConnection()
+		nb.pExtra = (void *)this;
+		nb.wPort = 0;
+		hBindPort = (HANDLE)CallService(MS_NETLIB_BINDPORT, (WPARAM)m_proto->hNetlibDCC, (LPARAM)&nb);
+
+		if (hBindPort == NULL) {
+			delete this; // dcc objects destroy themselves when the connection has been closed or failed for some reasson.
+			return 0;
+		}
+
+		di->iPort = nb.wPort; // store the port internally so it is possible to search for it (for resuming of filetransfers purposes)
+		return nb.wPort; // return the created port so it can be sent to the remote computer in a ctcp/dcc command
+	}
+
+	// If a remote computer initiates a chat session this is used to connect to the remote computer (user already accepted at this point). 
+	// also used for connecting to a remote computer for remote file transfers
+	if (di->iType == DCC_CHAT && !di->bSender || di->iType == DCC_SEND && di->bSender && di->bReverse) {
+		NETLIBOPENCONNECTION ncon = { 0 };
+		ncon.cbSize = sizeof(ncon);
+		ncon.szHost = ConvertIntegerToIP(di->dwAdr);
+		ncon.wPort = (WORD)di->iPort;
+		con = (HANDLE)CallService(MS_NETLIB_OPENCONNECTION, (WPARAM)m_proto->hNetlibDCC, (LPARAM)&ncon);
+	}
+
+	// If a remote computer initiates a filetransfer this is used to connect to that computer (the user has chosen to accept but it is possible the file exists/needs to be resumed etc still)
+	if (di->iType == DCC_SEND && !di->bSender) {
+
+		// this following code is for miranda to be able to show the resume/overwrite etc dialog if the file that we are receiving already exists. 
+		// It must be done before we create the connection or else the other party will begin sending packets while the user is still deciding if 
+		// s/he wants to resume/cancel or whatever. Just the way dcc is...
+
+		// if the file exists (dialog is shown) WaitForSingleObject() till the dialog is closed and PS_FILERESUME has been processed. 
+		// dwWhatNeedsDoing will be set using InterlockedExchange() (from other parts of the code depending on action) before SetEvent() is called.
+		// If the user has chosen rename then InterlockedExchange() will be used for setting NewFileName to a string containing the new name.
+		// Furthermore dwResumePos will be set using InterlockedExchange() to indicate what the file position to start from is.
+		if (ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_FILERESUME, (void *)di, (LPARAM)&pfts)) {
+			WaitForSingleObject(hEvent, INFINITE);
+			switch (dwWhatNeedsDoing) {
+			case FILERESUME_RENAME:
+				// If the user has chosen to rename the file we need to change variables accordingly. NewFileName has been set using
+				// InterlockedExchange()
+				if (NewFileName) { // the user has chosen to rename the new incoming file.
+					di->sFileAndPath = NewFileName;
+
+					int i = di->sFileAndPath.ReverseFind('\\');
+					if (i != -1) {
+						di->sPath = di->sFileAndPath.Mid(0, i + 1);
+						di->sFile = di->sFileAndPath.Mid(i + 1, di->sFileAndPath.GetLength());
+					}
+
+					pfts.tszCurrentFile = (TCHAR*)di->sFileAndPath.c_str();
+					pfts.tszWorkingDir = (TCHAR*)di->sPath.c_str();
+					pfts.totalBytes = di->dwSize;
+					pfts.currentFileSize = pfts.totalBytes;
+
+					delete[] NewFileName;
+					NewFileName = NULL;
+				}
+				break;
+
+			case FILERESUME_OVERWRITE:
+			case FILERESUME_RESUME:
+				// no action needed at this point, just break out of the switch statement
+				break;
+
+			case FILERESUME_CANCEL:
+				return FALSE;
+
+			case FILERESUME_SKIP:
+			default:
+				delete this; // per usual dcc objects destroy themselves when they fail or when connection is closed
+				return FALSE;
+			}
+		}
+
+		// hack for passive filetransfers
+		if (di->iType == DCC_SEND && !di->bSender && di->bReverse) {
+			NETLIBBIND nb = { 0 };
+			nb.cbSize = sizeof(NETLIBBIND);
+			nb.pfnNewConnectionV2 = DoIncomingDcc; // this is the (helper) function to be called once an incoming connection is made. The 'real' function that is called is IncomingConnection()
+			nb.pExtra = (void *)this;
+			nb.wPort = 0;
+			hBindPort = (HANDLE)CallService(MS_NETLIB_BINDPORT, (WPARAM)m_proto->hNetlibDCC, (LPARAM)&nb);
+
+			if (hBindPort == NULL) {
+				m_proto->DoEvent(GC_EVENT_INFORMATION, 0, m_proto->m_info.sNick.c_str(), LPGENT("DCC ERROR: Unable to bind local port for passive file transfer"), NULL, NULL, NULL, true, false);
+				delete this; // dcc objects destroy themselves when the connection has been closed or failed for some reasson.
+				return 0;
+			}
+
+			di->iPort = nb.wPort; // store the port internally so it is possible to search for it (for resuming of filetransfers purposes)
+
+			CMString sFileWithQuotes = di->sFile;
+
+			// if spaces in the filename surround with quotes
+			if (sFileWithQuotes.Find(' ', 0) != -1) {
+				sFileWithQuotes.Insert(0, _T("\""));
+				sFileWithQuotes.Insert(sFileWithQuotes.GetLength(), _T("\""));
+			}
+
+			// send out DCC RECV command for passive filetransfers
+			unsigned long ulAdr = 0;
+			if (m_proto->m_manualHost)
+				ulAdr = ConvertIPToInteger(m_proto->m_mySpecifiedHostIP);
+			else
+				ulAdr = m_proto->m_IPFromServer ? ConvertIPToInteger(m_proto->m_myHost) : nb.dwExternalIP;
+
+			if (di->iPort && ulAdr)
+				m_proto->PostIrcMessage(_T("/CTCP %s DCC SEND %s %u %u %I64u %s"), di->sContactName.c_str(), sFileWithQuotes.c_str(), ulAdr, di->iPort, di->dwSize, di->sToken.c_str());
+
+			return TRUE;
+		}
+
+		// connect to the remote computer from which you are receiving the file (now all actions to take (resume/overwrite etc) have been decided
+		NETLIBOPENCONNECTION ncon = { 0 };
+		ncon.cbSize = sizeof(ncon);
+		ncon.szHost = ConvertIntegerToIP(di->dwAdr);
+		ncon.wPort = (WORD)di->iPort;
+
+		con = (HANDLE)CallService(MS_NETLIB_OPENCONNECTION, (WPARAM)m_proto->hNetlibDCC, (LPARAM)&ncon);
+	}
+
+	// if for some reason the plugin has failed to connect to the remote computer the object is destroyed.
+	if (con == NULL) {
+		delete this;
+		return FALSE; // failed to connect
+	}
+
+	// if it is a chat connection set the user to online now since we now know there is a connection
+	if (di->iType == DCC_CHAT)
+		m_proto->setWord(di->hContact, "Status", ID_STATUS_ONLINE);
+
+	// spawn a new thread to handle receiving/sending of data for the new chat/filetransfer connection to the remote computer
+	mir_forkthread(ThreadProc, this);
+
+	return con != NULL;
+}
+
+// called by netlib for incoming connections on a listening socket (chat/filetransfer)
+int CDccSession::IncomingConnection(HANDLE hConnection, DWORD dwIP)
+{
+	con = hConnection;
+	if (con == NULL) {
+		delete this;
+		return false; // failed to connect
+	}
+
+	m_proto->setDword(di->hContact, "IP", dwIP); // mToolTip stuff
+
+	if (di->iType == DCC_CHAT)
+		m_proto->setWord(di->hContact, "Status", ID_STATUS_ONLINE); // set chat to online
+
+	// same as above, spawn a new thread to handle receiving/sending of data for the new incoming chat/filetransfer connection  
+	mir_forkthread(ThreadProc, this);
+	return true;
+}
+
+// here we decide which function to use for communicating with the remote computer, depending on connection type
+void __cdecl CDccSession::ThreadProc(void *pparam)
+{
+	CDccSession* pThis = (CDccSession*)pparam;
+
+	// if it is an incoming connection on a listening port, then we should close the listenting port so only one can connect (the one you offered
+	// the connection to) can connect and not evil IRCopers with haxxored IRCDs
+	if (pThis->hBindPort) {
+		Netlib_CloseHandle(pThis->hBindPort);
+		pThis->hBindPort = NULL;
+	}
+
+	if (pThis->di->iType == DCC_CHAT)
+		pThis->DoChatReceive(); // dcc chat
+
+	else if (!pThis->di->bSender)
+		pThis->DoReceiveFile(); // receive a file
+
+	else if (pThis->di->bSender)
+		pThis->DoSendFile(); // send a file
+}
+
+// this is done when the user is initiating a filetransfer to a remote computer
+void CDccSession::DoSendFile()
+{
+	// initialize the filetransfer dialog
+	ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_INITIALISING, (void *)di, 0);
+	ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_NEXTFILE, (void *)di, 0);
+
+	WORD wPacketSize = m_proto->getWord("DCCPacketSize", 1024 * 4);
+
+	if (wPacketSize < 256)
+		wPacketSize = 256;
+
+	if (wPacketSize > 32 * 1024)
+		wPacketSize = 32 * 1024;
+
+	BYTE* chBuf = new BYTE[wPacketSize + 1];
+
+	// is there a connection?
+	if (con) {
+		// open the file for reading
+		int hFile = _topen(di->sFileAndPath.c_str(), _O_RDONLY | _O_BINARY, _S_IREAD);
+		if (hFile >= 0) {
+			unsigned __int64 dwLastAck = 0;
+
+			// if the user has chosen to resume a file, dwResumePos will contain a value (set using InterlockedExchange())
+			// and then the variables and the file pointer are changed accordingly.
+			if (dwResumePos && dwWhatNeedsDoing == FILERESUME_RESUME) {
+				_lseeki64(hFile, dwResumePos, SEEK_SET);
+				dwTotal = dwResumePos;
+				dwLastAck = dwResumePos;
+				pfts.totalProgress = dwResumePos;
+				pfts.currentFileProgress = dwResumePos;
+			}
+
+			// initial ack to set the 'percentage-ready meter' to the correct value
+			ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_DATA, (void *)di, (LPARAM)&pfts);
+
+			tLastActivity = time(0);
+
+			// create a packet receiver to handle receiving ack's from the remote computer.
+			HANDLE hPackrcver = (HANDLE)CallService(MS_NETLIB_CREATEPACKETRECVER, (WPARAM)con, sizeof(DWORD));
+			NETLIBPACKETRECVER npr;
+			npr.cbSize = sizeof(NETLIBPACKETRECVER);
+			npr.dwTimeout = 60 * 1000;
+			npr.bufferSize = sizeof(DWORD);
+			npr.bytesUsed = 0;
+
+			// until the connection is dropped it will spin around in this while() loop
+			while (con) {
+				// read a packet
+				int iRead = _read(hFile, chBuf, wPacketSize);
+				if (iRead <= 0)
+					break; // break out if everything has already been read
+
+				// send the package
+				int cbSent = NLSend((unsigned char*)chBuf, iRead);
+				if (cbSent <= 0)
+					break; // break out if connection is lost or a transmission error has occured
+
+				if (!con)
+					break;
+
+				dwTotal += cbSent;
+
+				// block connection and receive ack's from remote computer (if applicable)
+				if (m_proto->m_DCCMode == 0) {
+					DWORD dwRead = 0;
+					DWORD dwPacket = NULL;
+
+					do {
+						dwRead = CallService(MS_NETLIB_GETMOREPACKETS, (WPARAM)hPackrcver, (LPARAM)&npr);
+						npr.bytesUsed = sizeof(DWORD);
+
+						if (dwRead <= 0)
+							break; // connection closed, or a timeout occurred.
+
+						dwPacket = *(DWORD*)npr.buffer;
+						dwLastAck = ntohl(dwPacket);
+
+					}
+					while (con && dwTotal != dwLastAck);
+
+					if (!con || dwRead <= 0)
+						goto DCC_STOP;
+				}
+
+				if (m_proto->m_DCCMode == 1) {
+					DWORD dwRead = 0;
+					DWORD dwPacket = 0;
+
+					do {
+						dwRead = CallService(MS_NETLIB_GETMOREPACKETS, (WPARAM)hPackrcver, (LPARAM)&npr);
+						npr.bytesUsed = sizeof(DWORD);
+						if (dwRead <= 0)
+							break; // connection closed, or a timeout occurred.
+
+						dwPacket = *(DWORD*)npr.buffer;
+						dwLastAck = ntohl(dwPacket);
+					}
+					while (con && (di->dwSize != dwTotal
+					&& dwTotal - dwLastAck >= 100 * 1024
+					|| di->dwSize == dwTotal // get the last packets when the whole file has been sent
+					&& dwTotal != dwLastAck));
+
+					if (!con || dwRead <= 0)
+						goto DCC_STOP;
+				}
+
+				// update the filetransfer dialog's 'percentage-ready meter' once per second only to save cpu
+				if (tLastPercentageUpdate < time(0)) {
+					tLastPercentageUpdate = time(0);
+					pfts.totalProgress = dwTotal;
+					pfts.currentFileProgress = dwTotal;
+					ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_DATA, (void *)di, (LPARAM)&pfts);
+				}
+
+				// close the connection once the whole file has been sent an completely ack'ed
+				if (dwLastAck >= di->dwSize) {
+					Netlib_CloseHandle(con);
+					con = NULL;
+				}
+			}
+
+		DCC_STOP:
+			// need to close the connection if it isn't allready
+			if (con) {
+				Netlib_CloseHandle(con);
+				con = NULL;
+			}
+
+			// ack the progress one final time
+			tLastActivity = time(0);
+			pfts.totalProgress = dwTotal;
+			pfts.currentFileProgress = dwTotal;
+			ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_DATA, (void *)di, (LPARAM)&pfts);
+
+			_close(hFile);
+		}
+		else { // file was not possible to open for reading
+			ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_FAILED, (void *)di, 0);
+			if (con) {
+				Netlib_CloseHandle(con);
+				con = NULL;
+			}
+		}
+	}
+
+	delete[]chBuf;
+	delete this; // ... and hopefully all went right, cuz here the object is deleted in any case
+}
+
+// This is called when receiving a file from a remote computer.
+void CDccSession::DoReceiveFile()
+{
+	// initialize the filetransfer dialog
+	ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_INITIALISING, (void *)di, 0);
+
+	BYTE chBuf[1024 * 32 + 1];
+
+	// do some stupid thing so  the filetransfer dialog shows the right thing
+	ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_NEXTFILE, (void *)di, 0);
+
+	// open the file for writing (and reading in case it is a resume)
+	int hFile = _topen(di->sFileAndPath.c_str(),
+		(dwWhatNeedsDoing == FILERESUME_RESUME ? _O_APPEND : _O_TRUNC | _O_CREAT) | _O_RDWR | _O_BINARY,
+		_S_IREAD | _S_IWRITE);
+	if (hFile >= 0) {
+		unsigned __int64 dwLastAck = 0;
+
+		// dwResumePos and dwWhatNeedsDoing has possibly been set using InterlockedExchange()
+		// if set it is a resume and we adjust variables and the file pointer accordingly.
+		if (dwResumePos && dwWhatNeedsDoing == FILERESUME_RESUME) {
+			_lseeki64(hFile, dwResumePos, SEEK_SET);
+			dwTotal = dwResumePos;
+			dwLastAck = dwResumePos;
+			pfts.totalProgress = dwResumePos;
+			pfts.currentFileProgress = dwResumePos;
+		}
+
+		// send an initial ack for the percentage-ready meter
+		ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_DATA, (void *)di, (LPARAM)&pfts);
+
+		// the while loop will spin around till the connection is dropped, locally or by the remote computer.
+		while (con) {
+			// read
+			int cbRead = NLReceive((unsigned char*)chBuf, sizeof(chBuf));
+			if (cbRead <= 0)
+				break;
+
+			// write it to the file
+			_write(hFile, chBuf, cbRead);
+
+			dwTotal += cbRead;
+
+			// this snippet sends out an ack for every 4 kb received in send ahead
+			// or every packet for normal mode
+			if (!di->bTurbo) {
+				DWORD no = dwTotal;
+				no = htonl(no);
+				NLSend((unsigned char *)&no, sizeof(DWORD));
+				dwLastAck = dwTotal;
+			}
+			else dwLastAck = dwTotal;
+
+			// sets the 'last update time' to check for timed out connections, and also make sure we only
+			// ack the 'percentage-ready meter' only once a second to save CPU.
+			if (tLastPercentageUpdate < time(0)) {
+				tLastPercentageUpdate = time(0);
+				pfts.totalProgress = dwTotal;
+				pfts.currentFileProgress = dwTotal;
+				ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_DATA, (void *)di, (LPARAM)&pfts);
+			}
+
+			// if file size is known and everything is received then disconnect 
+			if (di->dwSize && di->dwSize == dwTotal) {
+				Netlib_CloseHandle(con);
+				con = NULL;
+			}
+		}
+		// receiving loop broken locally or by remote computer, just some cleaning up left....
+
+		pfts.totalProgress = dwTotal;
+		pfts.currentFileProgress = dwTotal;
+		ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_DATA, (void *)di, (LPARAM)&pfts);
+		_close(hFile);
+	}
+	else {
+		ProtoBroadcastAck(m_proto->m_szModuleName, di->hContact, ACKTYPE_FILE, ACKRESULT_FAILED, (void *)di, 0);
+		if (con) { // file not possible to open for writing so we ack FAILURE and close the handle
+			Netlib_CloseHandle(con);
+			con = NULL;
+		}
+	}
+
+	delete this; // and finally the object is deleted
+}
+
+// this function handles receiving text in dcc chats and then send it in the protochain. very uncomplicated...
+// For sending text the SendStuff() function is called (with the help of some function in CIrcProto to find the right
+// Dcc object). See CIrcProto for info on how the dcc objects are stored, retrieved and deleted.
+
+void CDccSession::DoChatReceive()
+{
+	char chBuf[1024 * 4 + 1];
+	int cbInBuf = 0;
+
+	// loop to spin around while there is a connection
+	while (con) {
+		int cbRead;
+		int nLinesProcessed = 0;
+
+		cbRead = NLReceive((unsigned char*)chBuf + cbInBuf, sizeof(chBuf)-cbInBuf - 1);
+		if (cbRead <= 0)
+			break;
+
+		cbInBuf += cbRead;
+		chBuf[cbInBuf] = '\0';
+
+		char* pStart = chBuf;
+		while (*pStart) {
+			char* pEnd;
+
+			// seek end-of-line
+			for (pEnd = pStart; *pEnd && *pEnd != '\r' && *pEnd != '\n'; ++pEnd)
+				;
+			if (*pEnd == '\0')
+				break; // uncomplete message. stop parsing.
+
+			++nLinesProcessed;
+
+			// replace end-of-line with NULLs and skip
+			while (*pEnd == '\r' || *pEnd == '\n')
+				*pEnd++ = '\0';
+
+			if (*pStart) {
+				// send it off to some messaging module
+				PROTORECVEVENT pre = { 0 };
+				pre.timestamp = (DWORD)time(NULL);
+				pre.szMessage = pStart;
+				ProtoChainRecvMsg(di->hContact, &pre);
+			}
+
+			cbInBuf -= pEnd - pStart;
+			pStart = pEnd;
+		}
+
+		// discard processed messages
+		if (nLinesProcessed != 0)
+			memmove(chBuf, pStart, cbInBuf + 1);
+	}
+
+	delete this; // delete the object when the connection is dropped
+}
+
+// disconnect the stuff
+int CDccSession::Disconnect()
+{
+	if (hBindPort) {
+		Netlib_CloseHandle(hBindPort);
+		hBindPort = NULL;
+	}
+
+	// if 'con' exists it is cuz a connection exists. 
+	// Terminating 'con' will cause any spawned threads to die and then the object will destroy itself.
+	if (con) {
+		Netlib_CloseHandle(con);
+		con = NULL;
+	}
+	else delete this; // if 'con' do not exist (no connection made so far from the object) the object is destroyed
+
+	return TRUE;
+}
+
+////////////////////////////////////////////////////////////////////
+// check if the dcc chats should disconnect ( default 5 minute timeout )
+
+VOID CALLBACK DCCTimerProc(HWND, UINT, UINT_PTR idEvent, DWORD)
+{
+	CIrcProto *ppro = GetTimerOwner(idEvent);
+	if (ppro)
+		ppro->CheckDCCTimeout();
+}
+
+// helper function for incoming dcc connections.
+void DoIncomingDcc(HANDLE hConnection, DWORD dwRemoteIP, void * p1)
+{
+	CDccSession* dcc = (CDccSession*)p1;
+	dcc->IncomingConnection(hConnection, dwRemoteIP);
+}
+
+// ident server
+
+void strdel(char* parBuffer, int len)
+{
+	char *p;
+	for (p = parBuffer + len; *p != 0; p++)
+		p[-len] = *p;
+
+	p[-len] = '\0';
+}
+
+void DoIdent(HANDLE hConnection, DWORD, void* extra)
+{
+	CIrcProto *ppro = (CIrcProto*)extra;
+
+	char szBuf[1024];
+	int cbTotal = 0;
+
+	while (true) {
+		int cbRead = Netlib_Recv(hConnection, szBuf + cbTotal, sizeof(szBuf)-1 - cbTotal, 0);
+		if (cbRead == SOCKET_ERROR || cbRead == 0)
+			break;
+
+		cbTotal += cbRead;
+		szBuf[cbTotal] = '\0';
+
+LBL_Parse:
+		char* EOLPos = strstr(szBuf, "\r\n");
+		if (EOLPos == NULL)
+			continue;
+
+		EOLPos[0] = EOLPos[1] = '\0';
+		rtrim(szBuf);
+		ppro->debugLogA("Got Ident request: %s", szBuf);
+
+		unsigned int PeerPortNrRcvd = 0, LocalPortNrRcvd = 0;
+		int iParamCnt = sscanf(szBuf, "%d , %d", &LocalPortNrRcvd, &PeerPortNrRcvd);
+
+		int cbLen = 0;
+		char buf[1024 * 4];
+
+		if (iParamCnt != 2)
+			cbLen = mir_snprintf(buf, SIZEOF(buf), "%s : ERROR : UNKNOWN-ERROR\r\n", szBuf);
+		else {
+			for (int i = 0; i < g_Instances.getCount(); i++) {
+				if (PeerPortNrRcvd == g_Instances[i]->m_info.iPort && LocalPortNrRcvd == g_Instances[i]->m_myLocalPort) {
+					cbLen = mir_snprintf(buf, SIZEOF(buf), "%s : USERID : %S : %S\r\n",
+						szBuf, g_Instances[i]->m_info.sIdentServerType.c_str(), g_Instances[i]->m_info.sUserID.c_str());
+					break;
+				}
+			}
+
+			if (cbLen == 0)
+				cbLen = mir_snprintf(buf, SIZEOF(buf), "%s : ERROR : INVALID-PORT\r\n", szBuf);
+		}
+
+		if (Netlib_Send(hConnection, (const char*)buf, cbLen, 0) > 0)
+			ppro->debugLogA("Sent Ident answer: %s", buf);
+		else
+			ppro->debugLogA("Sending Ident answer failed.");
+
+		if (ppro->m_identTimer)
+			break;
+
+		cbTotal -= EOLPos + 2 - szBuf;
+		strdel(szBuf, int(EOLPos + 2 - szBuf));
+		goto LBL_Parse;
+	}
+	Netlib_CloseHandle(hConnection);
+}