From 48540940b6c28bb4378abfeb500ec45a625b37b6 Mon Sep 17 00:00:00 2001
From: Vadim Dashevskiy <watcherhd@gmail.com>
Date: Tue, 15 May 2012 10:38:20 +0000
Subject: initial commit

git-svn-id: http://svn.miranda-ng.org/main/trunk@2 1316c22d-e87f-b044-9b9b-93d7a3e3ba9c
---
 plugins/SecureIM/crypt_misc.cpp | 139 ++++++++++++++++++++++++++++++++++++++++
 1 file changed, 139 insertions(+)
 create mode 100644 plugins/SecureIM/crypt_misc.cpp

(limited to 'plugins/SecureIM/crypt_misc.cpp')

diff --git a/plugins/SecureIM/crypt_misc.cpp b/plugins/SecureIM/crypt_misc.cpp
new file mode 100644
index 0000000000..9be742e78f
--- /dev/null
+++ b/plugins/SecureIM/crypt_misc.cpp
@@ -0,0 +1,139 @@
+#include "commonheaders.h"
+
+
+int SendBroadcast( HANDLE hContact, int type, int result, HANDLE hProcess, LPARAM lParam ) {
+	ACKDATA ack;
+	memset(&ack,0,sizeof(ack));
+	ack.cbSize = sizeof( ACKDATA );
+	ack.szModule = 	(char*)CallService(MS_PROTO_GETCONTACTBASEPROTO, (WPARAM)hContact, 0);
+	ack.hContact = hContact;
+	ack.type = type;
+	ack.result = result;
+	ack.hProcess = hProcess;
+	ack.lParam = lParam;
+	return CallService( MS_PROTO_BROADCASTACK, 0, ( LPARAM )&ack );
+}
+
+
+unsigned __stdcall sttFakeAck( LPVOID param ) {
+
+	TFakeAckParams* tParam = ( TFakeAckParams* )param;
+	WaitForSingleObject( tParam->hEvent, INFINITE );
+
+	Sleep( 100 );
+	if ( tParam->msg == NULL )
+		SendBroadcast( tParam->hContact, ACKTYPE_MESSAGE, ACKRESULT_SUCCESS, ( HANDLE )tParam->id, 0 );
+	else
+		SendBroadcast( tParam->hContact, ACKTYPE_MESSAGE, ACKRESULT_FAILED, ( HANDLE )tParam->id, LPARAM( tParam->msg ));
+
+	CloseHandle( tParam->hEvent );
+	delete tParam;
+
+	return 0;
+}
+
+
+unsigned __stdcall sttWaitForExchange( LPVOID param ) {
+
+	TWaitForExchange* tParam = ( TWaitForExchange* )param;
+	WaitForSingleObject( tParam->hEvent, INFINITE );
+
+	pUinKey ptr = getUinKey(tParam->hContact);
+	delete tParam;
+
+	if( !ptr ) return 0;
+
+	for(int i=0;i<DBGetContactSettingWord(0,szModuleName,"ket",10)*10; i++) {
+		Sleep( 100 );
+		if( ptr->waitForExchange != 1 ) break;
+	} // for
+
+#if defined(_DEBUG) || defined(NETLIB_LOG)
+	Sent_NetLog("sttWaitForExchange: %d",ptr->waitForExchange);
+#endif
+   	// if keyexchange failed or timeout
+   	if( ptr->waitForExchange==1 || ptr->waitForExchange==3 ) { // протухло - отправляем незашифрованно, если надо
+   		if( ptr->msgQueue && msgbox1(0,sim104,szModuleName,MB_YESNO|MB_ICONQUESTION)==IDYES ) {
+	   		EnterCriticalSection(&localQueueMutex);
+	   		ptr->sendQueue = true;
+	   		pWM ptrMessage = ptr->msgQueue;
+   			while( ptrMessage ) {
+#if defined(_DEBUG) || defined(NETLIB_LOG)
+				Sent_NetLog("Sent (unencrypted) message from queue: %s",ptrMessage->Message);
+#endif
+   				// send unencrypted messages
+   				CallContactService(ptr->hContact,PSS_MESSAGE,(WPARAM)ptrMessage->wParam|PREF_METANODB,(LPARAM)ptrMessage->Message);
+   				mir_free(ptrMessage->Message);
+   				pWM tmp = ptrMessage;
+   				ptrMessage = ptrMessage->nextMessage;
+   				mir_free(tmp);
+   			}
+   			ptr->msgQueue = NULL;
+	   		ptr->sendQueue = false;
+	   		LeaveCriticalSection(&localQueueMutex);
+   		}
+		ptr->waitForExchange = 0;
+   		ShowStatusIconNotify(ptr->hContact);
+   	}
+   	else
+   	if( ptr->waitForExchange==2 ) { // дослать очередь через установленное соединение
+		EnterCriticalSection(&localQueueMutex);
+		// we need to resend last send back message with new crypto Key
+		pWM ptrMessage = ptr->msgQueue;
+		while (ptrMessage) {
+#if defined(_DEBUG) || defined(NETLIB_LOG)
+			Sent_NetLog("Sent (encrypted) message from queue: %s",ptrMessage->Message);
+#endif
+			// send unencrypted messages
+			CallContactService(ptr->hContact,PSS_MESSAGE,(WPARAM)ptrMessage->wParam|PREF_METANODB,(LPARAM)ptrMessage->Message);
+			mir_free(ptrMessage->Message);
+			pWM tmp = ptrMessage;
+			ptrMessage = ptrMessage->nextMessage;
+			mir_free(tmp);
+		}
+		ptr->msgQueue = NULL;
+		ptr->waitForExchange = 0;
+		LeaveCriticalSection(&localQueueMutex);
+   	}
+   	else
+   	if( ptr->waitForExchange==0 ) { // очистить очередь
+		EnterCriticalSection(&localQueueMutex);
+		// we need to resend last send back message with new crypto Key
+		pWM ptrMessage = ptr->msgQueue;
+		while (ptrMessage) {
+			mir_free(ptrMessage->Message);
+			pWM tmp = ptrMessage;
+			ptrMessage = ptrMessage->nextMessage;
+			mir_free(tmp);
+		}
+		ptr->msgQueue = NULL;
+		LeaveCriticalSection(&localQueueMutex);
+   	}
+   	return 0;
+}
+
+
+// set wait flag and run thread
+void waitForExchange(pUinKey ptr, int flag) {
+	switch( flag ) {
+	case 0: // сбросить
+	case 2: // дослать шифровано
+	case 3: // дослать нешифровано
+		if( ptr->waitForExchange ) 
+			ptr->waitForExchange = flag;
+		break;
+	case 1: // запустить
+		if( ptr->waitForExchange ) 
+			break;
+		ptr->waitForExchange = 1;
+		// запускаем трэд
+		HANDLE hEvent = CreateEvent( NULL, TRUE, FALSE, NULL );
+		unsigned int tID;
+		CloseHandle( (HANDLE) _beginthreadex(NULL, 0, sttWaitForExchange, new TWaitForExchange(hEvent,ptr->hContact), 0, &tID) );
+		SetEvent( hEvent );
+		break;
+	}
+}
+
+
+// EOF
-- 
cgit v1.2.3