modified: main.h

	modified:   messages.cpp
	modified:   options.cpp
	modified:   utilities.cpp
	modified:   utilities.h

1 files changed, 223 insertions, 2 deletions

diff --git a/messages.cpp b/messages.cpp
index a026bcc..12dede3 100644
--- a/messages.cpp
+++ b/messages.cpp
@@ -41,6 +41,116 @@ int RecvMsgSvc(WPARAM w, LPARAM l)
 		wstring str = toUTF16(msg);
 		wstring::size_type s1 = wstring::npos, s2 = wstring::npos;
 
+		if((str.find(_T("-----PGP KEY RESPONSE-----")) != wstring::npos) && !metaIsProtoMetaContacts(ccs->hContact))
+		{
+			s2 = str.find(_T("-----END PGP PUBLIC KEY BLOCK-----"));
+			s1 = str.find(_T("-----BEGIN PGP PUBLIC KEY BLOCK-----"));
+			if(s1 != wstring::npos && s2 != wstring::npos)
+			{
+				s2 += _tcslen(_T("-----END PGP PUBLIC KEY BLOCK-----"));
+				DBWriteContactSettingTString(hContact, szGPGModuleName, "GPGPubKey", str.substr(s1,s2-s1).c_str());
+				DBWriteContactSettingByte(hContact, szGPGModuleName, "GPGEncryption", 1);

+				{ //gpg execute block

+					wstring cmd;

+					TCHAR tmp2[MAX_PATH] = {0};

+					TCHAR *ptmp;

+					string output;

+					DWORD exitcode;

+					{

+						ptmp = UniGetContactSettingUtf(NULL, szGPGModuleName, "szHomePath", _T(""));

+						_tcscpy(tmp2, ptmp);

+						mir_free(ptmp);

+						_tcscat(tmp2, _T("\\"));

+						_tcscat(tmp2, _T("temporary_exported.asc"));

+						DeleteFile(tmp2);

+						wfstream f(tmp2, std::ios::out);

+						ptmp = UniGetContactSettingUtf(hContact, szGPGModuleName, "GPGPubKey", _T(""));

+						wstring new_key = ptmp;

+						mir_free(ptmp);

+						f<<new_key.c_str();

+						f.close();

+						cmd += _T(" --batch ");

+						cmd += _T(" --import \"");

+						cmd += tmp2;

+						cmd += _T("\"");

+					}

+					gpg_execution_params params;

+					pxResult result;

+					params.cmd = &cmd;

+					params.useless = "";

+					params.out = &output;

+					params.code = &exitcode;

+					params.result = &result;

+					boost::thread gpg_thread(boost::bind(&pxEexcute_thread, &params));

+					if(!gpg_thread.timed_join(boost::posix_time::seconds(10)))

+					{

+						gpg_thread.~thread();

+						MessageBox(0, _T("GPG execution timed out, aborted"), _T(""), MB_OK);

+						return 1;

+					}

+					if(result == pxNotFound)

+					{

+						MessageBox(0, _T("Set path to gpg.exe first!"), _T("Warning"), MB_OK);				  

+						return 1;

+					}
+					{

+						char *tmp = NULL;

+						string::size_type s = output.find("gpg: key ") + strlen("gpg: key ");

+						string::size_type s2 = output.find(":", s);

+						DBWriteContactSettingString(hContact, szGPGModuleName, "KeyID", output.substr(s,s2-s).c_str());

+						s2+=2;

+						s = output.find("“", s2);

+						if(s == string::npos)

+						{

+							s = output.find("\"", s2);

+							s += 1;

+						}

+						else

+							s += 3;

+						if((s2 = output.find("(", s)) == string::npos)

+							s2 = output.find("<", s);

+						else if(s2 > output.find("<", s))

+							s2 = output.find("<", s);

+						tmp = new char [output.substr(s,s2-s-1).length()+1];

+						strcpy(tmp, output.substr(s,s2-s-1).c_str());

+						mir_utf8decode(tmp, 0);

+						DBWriteContactSettingString(hContact, szGPGModuleName, "KeyMainName", tmp);

+						mir_free(tmp);

+						if((s = output.find(")", s2)) == string::npos)

+							s = output.find(">", s2);

+						else if(s > output.find(">", s2))

+							s = output.find(">", s2);

+						s2++;

+						if(output[s] == ')')

+						{

+							tmp = new char [output.substr(s2,s-s2).length()+1];

+							strcpy(tmp, output.substr(s2,s-s2).c_str());

+							mir_utf8decode(tmp, 0);

+							DBWriteContactSettingString(hContact, szGPGModuleName, "KeyComment", tmp);

+							mir_free(tmp);

+							s+=3;

+							s2 = output.find(">", s);

+							tmp = new char [output.substr(s,s2-s).length()+1];

+							strcpy(tmp, output.substr(s,s2-s).c_str());

+							mir_utf8decode(tmp, 0);

+							DBWriteContactSettingString(hContact, szGPGModuleName, "KeyMainEmail", tmp);

+							mir_free(tmp);

+						}

+						else

+						{

+							tmp = new char [output.substr(s2,s-s2).length()+1];

+							strcpy(tmp, output.substr(s2,s-s2).c_str());

+							mir_utf8decode(tmp, 0);

+							DBWriteContactSettingString(hContact, szGPGModuleName, "KeyMainEmail", output.substr(s2,s-s2).c_str());

+							mir_free(tmp);

+						}

+						DBWriteContactSettingByte(hContact, szGPGModuleName, "bAlwatsTrust", 1);
+					}
+				}
+				hcontact_data[hContact].msgs_to_ignore.push_back(msg);
+				return 1;
+			}
+		}
 		if((str.find(_T("-----END PGP PUBLIC KEY BLOCK-----")) != wstring::npos) && (str.find(_T("-----BEGIN PGP PUBLIC KEY BLOCK-----")) != wstring::npos))
 		{
 			s2 = str.find(_T("-----END PGP PUBLIC KEY BLOCK-----"));
@@ -56,12 +166,12 @@ int RecvMsgSvc(WPARAM w, LPARAM l)
 			if(metaIsSubcontact(hContact))
 				return CallService(MS_PROTO_CHAINRECV, w, l); //yet another metacontacts problem
 			debuglog<<"info: "<<"received key from: "<<(TCHAR*)CallService(MS_CLIST_GETCONTACTDISPLAYNAME, (WPARAM)hContact, GCDNF_TCHAR)<<"\n";
-			void ShowNewKeyDialog();
 			s1 = 0;
 			while((s1 = str.find(_T("\r"), s1)) != wstring::npos)
 			{
 				str.erase(s1, 1);
 			}
+			void ShowNewKeyDialog();
 			if((str.find(_T("-----END PGP PUBLIC KEY BLOCK-----")) != wstring::npos) && (str.find(_T("-----BEGIN PGP PUBLIC KEY BLOCK-----")) != wstring::npos))
 			{
 				s2 = str.find(_T("-----END PGP PUBLIC KEY BLOCK-----"));
@@ -80,6 +190,62 @@ int RecvMsgSvc(WPARAM w, LPARAM l)
 			ShowNewKeyDialog();
 			return CallService(MS_PROTO_CHAINRECV, w, l);
 		}
+		if(bAutoExchange && strstr(msg, "-----PGP KEY REQUEST-----") && isGPGConfigured())
+		{
+			char *tmp = UniGetContactSettingUtf(NULL, szGPGModuleName, "GPGPubKey", "");
+			if(tmp[0])
+			{
+				DBWriteContactSettingByte(hContact, szGPGModuleName, "GPGEncryption", 0);
+				string str = "-----PGP KEY RESPONSE-----";
+				str.append(tmp);
+				CallContactService(hContact, PSS_MESSAGE, (WPARAM)PREF_UTF, (LPARAM)str.c_str());
+				DBWriteContactSettingByte(hContact, szGPGModuleName, "GPGEncryption", 1);
+			}
+			mir_free(tmp);
+			if(!isContactHaveKey(hContact) && bAutoExchange && isGPGConfigured())
+			{
+				LPSTR proto = (LPSTR)CallService(MS_PROTO_GETCONTACTBASEPROTO, (WPARAM)hContact, 0);
+				DWORD uin = DBGetContactSettingDword(hContact, proto, "UIN", 0);
+				if(uin)
+				{
+					if(ServiceExists("ICQ"PS_ICQ_CHECKCAPABILITY))
+					{
+						ICQ_CUSTOMCAP cap = {0};
+						strcpy(cap.caps, "GPG AutoExchange");
+						if(CallService("ICQ"PS_ICQ_CHECKCAPABILITY, (WPARAM)hContact, (LPARAM)&cap))
+							CallContactService(hContact, PSS_MESSAGE, (WPARAM)PREF_UTF, (LPARAM)"-----PGP KEY REQUEST-----");
+					}
+				}
+				else
+				{
+					TCHAR *jid = UniGetContactSettingUtf(hContact, proto, "jid", _T(""));
+					if(jid[0])

+					{

+						extern list <JabberAccount*> Accounts;

+						list<JabberAccount*>::iterator end = Accounts.end();

+						for(list<JabberAccount*>::iterator p = Accounts.begin(); p != end; p++)

+						{

+							TCHAR *caps = (*p)->getJabberInterface()->Net()->GetResourceFeatures(jid);

+							if(caps)

+							{

+								wstring str;

+								for(int i =0;;i++)

+								{

+									str.push_back(caps[i]);

+									if(caps[i] == '\0')

+										if(caps[i+1] == '\0')

+											break;

+								}

+								mir_free(caps);

+								if(str.find(_T("GPG_Key_Auto_Exchange:0")) != string::npos)

+									CallContactService(hContact, PSS_MESSAGE, (WPARAM)PREF_UTF, (LPARAM)"-----PGP KEY REQUEST-----");

+							}
+						}
+					}
+				}
+			}
+			return 1;
+		}
 		s1 = str.find(_T("-----BEGIN PGP MESSAGE-----"));
 		s2 = str.find(_T("-----END PGP MESSAGE-----"));
 		if((s2 != wstring::npos) && (s1 != wstring::npos))
@@ -377,7 +543,62 @@ int SendMsgSvc(WPARAM w, LPARAM l)
 		hcontact_data[ccs->hContact].msgs_to_ignore.push_back((char*)ccs->lParam);
 		return CallService(MS_PROTO_CHAINSEND, w, l); 
 	}
-	if(!DBGetContactSettingByte(hContact, szGPGModuleName, "GPGEncryption", 0))
+	if(!isContactHaveKey(hContact) && bAutoExchange && !strstr(msg, "-----PGP KEY REQUEST-----") && !strstr(msg, "-----BEGIN PGP PUBLIC KEY BLOCK-----") && isGPGConfigured()) //TODO: add all mesages to list, and send after key exchange done, encrypted
+	{
+		void send_encrypted_msgs_thread(HANDLE hContact);
+		LPSTR proto = (LPSTR)CallService(MS_PROTO_GETCONTACTBASEPROTO, (WPARAM)hContact, 0);
+		DWORD uin = DBGetContactSettingDword(hContact, proto, "UIN", 0);
+		if(uin)
+		{
+			if(ServiceExists("ICQ"PS_ICQ_CHECKCAPABILITY))
+			{
+				ICQ_CUSTOMCAP cap = {0};
+				strcpy(cap.caps, "GPG AutoExchange");
+				if(CallService("ICQ"PS_ICQ_CHECKCAPABILITY, (WPARAM)hContact, (LPARAM)&cap))
+				{
+					CallContactService(hContact, PSS_MESSAGE, (WPARAM)PREF_UTF, (LPARAM)"-----PGP KEY REQUEST-----");
+					hcontact_data[hContact].msgs_to_ignore.push_back(msg);
+					hcontact_data[hContact].msgs_to_send.push_back(msg);
+					boost::thread *thr = new boost::thread(boost::bind(send_encrypted_msgs_thread, hContact));
+					return returnNoError(hContact);
+				}
+			}
+		}
+		else
+		{
+			TCHAR *jid = UniGetContactSettingUtf(hContact, proto, "jid", _T(""));
+			if(jid[0])
+			{
+				extern list <JabberAccount*> Accounts;

+				list<JabberAccount*>::iterator end = Accounts.end();

+				for(list<JabberAccount*>::iterator p = Accounts.begin(); p != end; p++)

+				{

+					TCHAR *caps = (*p)->getJabberInterface()->Net()->GetResourceFeatures(jid);

+					if(caps)

+					{

+						wstring str;

+						for(int i =0;;i++)

+						{

+							str.push_back(caps[i]);

+							if(caps[i] == '\0')

+								if(caps[i+1] == '\0')

+									break;

+						}

+						mir_free(caps);

+						if(str.find(_T("GPG_Key_Auto_Exchange:0")) != string::npos)

+						{

+							CallContactService(hContact, PSS_MESSAGE, (WPARAM)PREF_UTF, (LPARAM)"-----PGP KEY REQUEST-----");

+							hcontact_data[hContact].msgs_to_ignore.push_back(msg);

+							hcontact_data[hContact].msgs_to_send.push_back(msg);

+							boost::thread *thr = new boost::thread(boost::bind(send_encrypted_msgs_thread, hContact));

+							return returnNoError(hContact);

+						}

+					}

+				}

+			}
+		}
+	}
+	if(!isContactSecured(hContact))
 		return CallService(MS_PROTO_CHAINSEND, w, l);