GmailNotifier rename

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

1 files changed, 185 insertions, 0 deletions

diff --git a/plugins/GmailNotifier/src/check.cpp b/plugins/GmailNotifier/src/check.cpp
new file mode 100644
index 0000000000..a57a12879e
--- /dev/null
+++ b/plugins/GmailNotifier/src/check.cpp
@@ -0,0 +1,185 @@
+#include "gmail.h"

+

+//		#include <stdio.h>

+

+void CheckMailInbox(Account *curAcc)

+{

+	HINTERNET hHTTPOpen;			// internet open handle

+	HINTERNET hHTTPConnection;		// internet connection hadle

+	HINTERNET hHTTPRequest;		    // internet request hadle

+

+	DBVARIANT dbv;

+	static char *contentType = "Content-Type: application/x-www-form-urlencoded";

+	char requestBuffer[256] = "continue=https%3A%2F%2Fmail.google.com%2Fa%2F";

+	char fileBuffer[_MAX_DOWN_BUFFER] = "";

+	char *tail;

+	char str[64];

+	char temp[_MAX_DOWN_BUFFER] = "";

+	unsigned long bufferLength;

+

+	if (curAcc->IsChecking)

+		return;

+

+	curAcc->IsChecking = TRUE;

+

+	if (!db_get_s(curAcc->hContact, "CList", "MyHandle", &dbv)) {

+		lstrcpyA(curAcc->results.content, dbv.pszVal);

+		db_free(&dbv);

+	}

+	else lstrcpyA(curAcc->results.content, curAcc->name);

+

+	tail = strstr(curAcc->results.content, " [");

+	if (tail) *tail = '\0';

+	lstrcatA(curAcc->results.content, " [");

+

+	lstrcpyA(str, curAcc->results.content);

+	lstrcatA(str, Translate("Checking..."));

+	lstrcatA(str, "]");

+

+	db_set_s(curAcc->hContact, "CList", "MyHandle", str);

+	hHTTPOpen = InternetOpenA("", INTERNET_OPEN_TYPE_PRECONFIG, "", "", 0);

+	if (!hHTTPOpen) {

+		lstrcatA(curAcc->results.content, Translate("Can't open Internet!"));

+		goto error_handle;

+	}

+

+	if (curAcc->hosted[0]) {

+		hHTTPConnection = InternetConnectA(hHTTPOpen,

+			"www.google.com",

+			INTERNET_DEFAULT_HTTPS_PORT,

+			NULL,

+			NULL,

+			INTERNET_SERVICE_HTTP,

+			0,

+			0);

+

+		if (!hHTTPConnection) {

+			lstrcatA(curAcc->results.content, Translate("Can't reach server!"));

+			goto error_handle;

+		}

+		lstrcpyA(str, "/a/");

+		lstrcatA(str, curAcc->hosted);

+		lstrcatA(str, "/LoginAction");

+		hHTTPRequest = HttpOpenRequestA(hHTTPConnection, "POST", str, HTTP_VERSIONA, NULL, NULL, INTERNET_FLAG_SECURE, 0);

+		lstrcatA(requestBuffer, curAcc->hosted);

+		lstrcatA(requestBuffer, "%2Ffeed%2Fatom&service=mail&userName=");

+		lstrcatA(requestBuffer, curAcc->name);

+		tail = strchr(requestBuffer, '@');

+		*tail = '\0';

+		lstrcatA(requestBuffer, "&password=");

+		lstrcatA(requestBuffer, curAcc->pass);

+		if (!HttpSendRequestA(hHTTPRequest, contentType, (int)strlen(contentType) + 1, requestBuffer, (int)strlen(requestBuffer) + 1)) {

+			lstrcpyA(curAcc->results.content, Translate("Can't send account data!"));

+			goto error_handle;

+		}

+

+		InternetCloseHandle(hHTTPConnection);

+		InternetCloseHandle(hHTTPRequest);

+	}

+

+	hHTTPConnection = InternetConnectA(hHTTPOpen, "mail.google.com", INTERNET_DEFAULT_HTTPS_PORT, NULL, NULL, INTERNET_SERVICE_HTTP, 0, 0);

+	if (!hHTTPConnection) {

+		lstrcatA(curAcc->results.content, Translate("Can't reach server!"));

+		goto error_handle;

+	}

+	if (curAcc->hosted[0]) {

+		lstrcpyA(str, "/a/");

+		lstrcatA(str, curAcc->hosted);

+		lstrcatA(str, "/feed/atom");

+	}

+	else lstrcpyA(str, "/mail/feed/atom");

+

+	hHTTPRequest = HttpOpenRequest(hHTTPConnection, _T("GET"), _A2T(str), NULL, NULL, NULL, INTERNET_FLAG_SECURE | INTERNET_FLAG_DONT_CACHE | INTERNET_FLAG_RELOAD, 0);

+	InternetSetOption(hHTTPRequest, INTERNET_OPTION_USERNAME, _A2T(curAcc->name), (int)strlen(curAcc->name) + 1);

+	InternetSetOption(hHTTPRequest, INTERNET_OPTION_PASSWORD, _A2T(curAcc->pass), (int)strlen(curAcc->pass) + 1);

+	if (!HttpSendRequest(hHTTPRequest, NULL, 0, NULL, 0)) {

+		lstrcatA(curAcc->results.content, Translate("Can't get rss feed!"));

+		goto error_handle;

+	}

+	while (InternetReadFile(hHTTPRequest, temp, _MAX_DOWN_BUFFER, &bufferLength) && bufferLength > 0) {

+		temp[bufferLength] = '\0';

+		lstrcatA(fileBuffer, temp);

+	}

+

+	fileBuffer[_MAX_DOWN_BUFFER - 1] = '\0';

+	curAcc->results_num = ParsePage(fileBuffer, &curAcc->results);

+	if (curAcc->results_num == -1) {

+		lstrcatA(curAcc->results.content, Translate("Wrong name or password!"));

+		goto error_handle;

+	}

+	InternetCloseHandle(hHTTPOpen);

+	InternetCloseHandle(hHTTPConnection);

+	InternetCloseHandle(hHTTPRequest);

+

+	lstrcatA(curAcc->results.content, _itoa(curAcc->results_num, str, 10));

+	lstrcatA(curAcc->results.content, "]");

+

+	curAcc->IsChecking = FALSE;

+	return;

+

+error_handle:

+	curAcc->results_num = -1;

+	InternetCloseHandle(hHTTPOpen);

+	InternetCloseHandle(hHTTPConnection);

+	InternetCloseHandle(hHTTPRequest);

+

+	lstrcatA(curAcc->results.content, "]");

+

+	curAcc->IsChecking = FALSE;

+}

+

+void __cdecl Check_ThreadFunc(LPVOID lpParam)

+{

+	InternetSetCookieA("https://mail.google.com/mail/", "GX", "");

+	if (lpParam) {

+		CheckMailInbox((Account *)lpParam);

+		NotifyUser((Account *)lpParam);

+	}

+	else {

+		for (int i = 0; i < acc_num && GetContactProto(acc[i].hContact); i++) {

+			CheckMailInbox(&acc[i]);

+			NotifyUser(&acc[i]);

+		}

+	}

+}

+

+int ParsePage(char *page, resultLink *prst)

+{

+	char *str_head;

+	char *str_tail;

+	char name[64], title[64];

+	int num = 0;

+	wchar_t str[64];

+

+	prst->next = NULL;

+	if (strstr(page, "Unauthorized"))

+		return -1;

+	if (!(str_head = strstr(page, "<entry>")))

+		return 0;

+

+	while (str_head = strstr(str_head, "<title>")) {

+		prst = prst->next = (resultLink *)malloc(sizeof(resultLink));

+		str_head += 7;

+		str_tail = strstr(str_head, "</title>");

+		*str_tail = '\0';

+		lstrcpynA(title, str_head, 41);

+		if (lstrlenA(title) == 40)

+			lstrcatA(title, "...");

+		*str_tail = ' ';

+

+		str_head = strstr(str_head, "<name>") + 6;

+		str_tail = strstr(str_head, "</name>");

+		*str_tail = '\0';

+		lstrcpynA(name, str_head, 11);

+		lstrcatA(name, ": ");

+		*str_tail = ' ';

+

+		lstrcpyA(prst->content, name);

+		lstrcatA(prst->content, title);

+		MultiByteToWideChar(CP_UTF8, 0, prst->content, -1, str, 64);

+		WideCharToMultiByte(CP_ACP, 0, str, -1, prst->content, 64, NULL, NULL);

+		num++;

+	}

+	prst->next = NULL;

+	return num;

+}