From f7c563ada4247c1cbed54001bf357289f15f7d3b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Robert=20P=C3=B6sel?= <robyer@seznam.cz>
Date: Tue, 30 Jul 2013 00:43:40 +0000
Subject: Facebook: Most awesome variant of getting unread messages at login -
 but NEED TESTING (and some improvements later)  - loads up to 21 unread
 messages per contact  - loads messages also from "Other" messaging tab  -
 uses most effective requests with ability for future function "loading
 contact history from server"

git-svn-id: http://svn.miranda-ng.org/main/trunk@5528 1316c22d-e87f-b044-9b9b-93d7a3e3ba9c
---
 protocols/FacebookRM/src/process.cpp | 233 ++++++++++++++++++++---------------
 1 file changed, 133 insertions(+), 100 deletions(-)

(limited to 'protocols/FacebookRM/src/process.cpp')

diff --git a/protocols/FacebookRM/src/process.cpp b/protocols/FacebookRM/src/process.cpp
index 64b85103ac..bb8b95f3ea 100644
--- a/protocols/FacebookRM/src/process.cpp
+++ b/protocols/FacebookRM/src/process.cpp
@@ -263,129 +263,150 @@ void FacebookProto::ProcessFriendList(void* data)
 
 void FacebookProto::ProcessUnreadMessages(void*)
 {
-	facy.handle_entry("messages");
+	facy.handle_entry("ProcessUnreadMessages");
 
-	int count = 0;
-	std::string page;
+	bool loadOther = true; // TODO: db setting? or use everytime?
 
-	while (count < 30) // allow max 30 unread threads to be parsed
-	{
-		std::string get_data = "&page=" + page;
+	std::string data = "folders[0]=inbox";
+	if (loadOther)
+		data += "&folders[1]=other";
+	data += "&client=mercury";
+	data += "__user=" + facy.self_.user_id;
+	data += "&fb_dtsg=" + (facy.dtsg_.length() ? facy.dtsg_ : "0");
+	data += "&__a=1&__dyn=&__req=&ttstamp=0";
 
-		http::response resp = facy.flap(REQUEST_UNREAD_THREADS, NULL, &get_data);
+	http::response resp = facy.flap(REQUEST_UNREAD_THREADS, &data);
+	facy.validate_response(&resp);
 
-		// Process result data
-		facy.validate_response(&resp);
+	if (resp.code == HTTP_CODE_OK) {
+		
+		CODE_BLOCK_TRY
+		
+		std::vector<std::string> threads;
 
-		if (resp.code == HTTP_CODE_OK)
-		{
-			std::string items = utils::text::source_get_value(&resp.data, 2, "<div id=\"threadlist_rows", "</body>");
+		facebook_json_parser* p = new facebook_json_parser(this);
+		p->parse_unread_threads(&resp.data, &threads);
+		delete p;
 
-			std::string::size_type pos = 0;
-			std::string::size_type pos2 = 0;
+		ForkThread(&FacebookProto::ProcessUnreadMessage, new std::vector<std::string>(threads));
 
-			while ((pos = items.find("id=\"threadlist_row_", pos)) != std::string::npos) {
-				std::string item = items.substr(pos, items.find("</div>", pos) - pos);
-				pos++; count++;
+		LOG("***** Unread threads list processed");
 
-				std::string tid = utils::text::source_get_value2(&item, "?tid=", "&\"");
-				if (tid.empty())
-					continue;
+		CODE_BLOCK_CATCH
 
-				ForkThread(&FacebookProto::ProcessUnreadMessage, new std::string(tid));
-			}
-
-			page = utils::text::source_get_value(&items, 3, "id=\"see_older_threads\"", "page=", "&");
-			if (page.empty())
-				break; // No more results
-		}
-	}
+		LOG("***** Error processing unread threads list: %s", e.what());
 
+		CODE_BLOCK_END
+	
+		facy.handle_success("ProcessUnreadMessages");
+	} else {
+		facy.handle_error("ProcessUnreadMessages");
+	}	
 }
 
-void FacebookProto::ProcessUnreadMessage(void *tid_data)
+void FacebookProto::ProcessUnreadMessage(void *p)
 {
-	if (tid_data == NULL)
+	if (p == NULL)
 		return;
 
-	// TODO: get them from /ajax/mercury/thread_info.php
-
-	std::string get_data = "tid=" + *(std::string*)tid_data;
-	delete (std::string*)tid_data;
-
-	http::response resp = facy.flap(REQUEST_UNREAD_MESSAGES, NULL, &get_data);
-	facy.validate_response(&resp);
-
-	if (resp.code != HTTP_CODE_OK) {
-		LOG(" !! !! Error when getting messages list");
-		return;
-	}
+	facy.handle_entry("ProcessUnreadMessage");
 
-	if (resp.data.find("<option value=\"leave_conversation\">") != std::string::npos) {
-		LOG(" !! !! This is multi user chat");
-		return;
-	}
+	std::vector<std::string> threads = *(std::vector<std::string>*)p;
+	delete (std::vector<std::string>*)p;
 
-	std::string messageslist = utils::text::source_get_value(&resp.data, 2, "id=\"messageGroup\">", "</form>");
+	int offset = 0;
+	int limit = 21;
 
-	facebook_user fbu;
-	HANDLE hContact = NULL;
+	bool local_timestamp = getBool(FACEBOOK_KEY_LOCAL_TIMESTAMP, 0);
 
-	std::string::size_type pos = 0, pos2 = 0;
-	while ((pos2 = messageslist.find("class=\"acw apl abt", pos2)) != std::string::npos) {
-		pos2 += 19;
-		std::string group = messageslist.substr(pos2, messageslist.find("class=\"actions ", pos2) - pos2);
+	http::response resp;
 
-		if (group.find("has_attachment&quot;:true") != std::string::npos) {
-			// TODO: do something different for attachements? (inspiration in revision <5236)
+	while (!threads.empty()) {
+		std::string data = "client=mercury";
+		data += "&__user=" + facy.self_.user_id;
+		data += "&fb_dtsg=" + (facy.dtsg_.length() ? facy.dtsg_ : "0");
+		data += "&__a=1&__dyn=&__req=&ttstamp=0";
+	
+		for (std::vector<std::string>::size_type i = 0; i < threads.size(); i++) {
+			// request messages from thread
+			data += "&messages[thread_ids][" + threads[i];
+			data += "][offset]=" + utils::conversion::to_string(&offset, UTILS_CONV_SIGNED_NUMBER);
+			data += "&messages[thread_ids][" + threads[i];
+			data += "][limit]=" + utils::conversion::to_string(&limit, UTILS_CONV_SIGNED_NUMBER);
+			
+			// request info about thread
+			data += "&threads[thread_ids][" + utils::conversion::to_string(&i, UTILS_CONV_UNSIGNED_NUMBER);
+			data += "]=" + threads[i];
 		}
 
-		while ((pos = group.find("<div data-store=", pos)) != std::string::npos) {
-			std::string message = group.substr(pos, group.find("</div>", pos) - pos);
-			pos++;
-
-			std::string author = utils::text::source_get_value2(&message, "author&quot;:", ",}");
-
-			// Ignore our messages
-			if (author == facy.self_.user_id)
-				continue;
+		resp = facy.flap(REQUEST_THREAD_INFO, &data);
+		facy.validate_response(&resp);
 
-			// Get/create contact
-			if (hContact == NULL) {
-				fbu.user_id = author;
-				fbu.real_name = utils::text::slashu_to_utf8(utils::text::source_get_value(&group, 2, "name&quot;:&quot;", "&quot;"));
-				hContact = AddToContactList(&fbu, CONTACT_NONE);
-				// TODO: if contact is newly added, get his user info
-				// TODO: maybe create new "receiveMsg" function and use it for offline and channel messages?
+		if (resp.code == HTTP_CODE_OK) {
+		
+			CODE_BLOCK_TRY
+		
+			std::vector<facebook_message*> messages;
+
+			facebook_json_parser* p = new facebook_json_parser(this);
+			p->parse_thread_messages(&resp.data, &messages, true, limit);
+			delete p;	
+
+			for(std::vector<facebook_message*>::size_type i = 0; i < messages.size(); i++) {
+				if (messages[i]->user_id != facy.self_.user_id) {
+					LOG("      Got message: %s", messages[i]->message_text.c_str());
+					facebook_user fbu;
+					fbu.user_id = messages[i]->user_id;
+					fbu.real_name = messages[i]->sender_name;
+
+					// TODO: optimize this?
+					HANDLE hContact = AddToContactList(&fbu, CONTACT_NONE);
+					setString(hContact, FACEBOOK_KEY_MESSAGE_ID, messages[i]->message_id.c_str());
+
+					// TODO: if contact is newly added, get his user info
+					// TODO: maybe create new "receiveMsg" function and use it for offline and channel messages?
+
+					ParseSmileys(messages[i]->message_text, hContact);
+
+					if (messages[i]->isIncoming) {
+						PROTORECVEVENT recv = {0};
+						recv.flags = PREF_UTF;
+						recv.szMessage = const_cast<char*>(messages[i]->message_text.c_str());
+						recv.timestamp = local_timestamp || !messages[i]->time ? ::time(NULL) : messages[i]->time;
+						ProtoChainRecvMsg(hContact, &recv);
+					} else {
+						DBEVENTINFO dbei = {0};
+						dbei.cbSize = sizeof(dbei);
+						dbei.eventType = EVENTTYPE_MESSAGE;
+						dbei.flags = DBEF_SENT | DBEF_UTF;
+						dbei.szModule = m_szModuleName;
+						dbei.timestamp = local_timestamp || !messages[i]->time ? ::time(NULL) : messages[i]->time;
+						dbei.cbBlob = (DWORD)messages[i]->message_text.length() + 1;
+						dbei.pBlob = (PBYTE)messages[i]->message_text.c_str();
+						db_event_add(hContact, &dbei);
+					}
+				}
+				delete messages[i];
 			}
+			messages.clear();			
 
-			DWORD timestamp = utils::conversion::to_timestamp(utils::text::source_get_value2(&message, "timestamp&quot;:", ",}"));
-			std::string text = utils::text::source_get_value(&message, 2, "<span>", "</span>");
+			LOG("***** Unread messages processed");
 
-			text = utils::text::trim(utils::text::special_expressions_decode(utils::text::remove_html(text)));
-			// TODO: fix smileys in text
-			/*
-			<img src="https://fbstatic-a.akamaihd.net/rsrc.php/v2/yH/r/SOe5wIZyutW.png" width="16" height="16" class="img"/>
+			CODE_BLOCK_CATCH
 
-			"yH/r/viyyiQhRqLr.png" -> :-P
-			"yo/r/X8YPpi6kcyo.png" -> :-)
-			"yH/r/SOe5wIZyutW.png" -> :-D
-			...
-			*/
+			LOG("***** Error processing unread messages: %s", e.what());
 
-			if (text.empty() || hContact == NULL)
-				continue;
-
-			LOG("Got unread message: \"%s\"", text.c_str());
-
-			ParseSmileys(text, hContact);
-
-			PROTORECVEVENT recv = {0};
-			recv.flags = PREF_UTF;
-			recv.szMessage = const_cast<char*>(text.c_str());
-			recv.timestamp = timestamp;
-			ProtoChainRecvMsg(hContact, &recv);
+			CODE_BLOCK_END
+	
+			facy.handle_success("ProcessUnreadMessage");
+		} else {
+			facy.handle_error("ProcessUnreadMessage");
 		}
+
+		offset += limit;
+		limit = 20; // TODO: use better limits?
+		
+		threads.clear(); // TODO: if we have limit messages from one user, there may be more unread messages... continue with it... otherwise remove that threadd from threads list -- or do it in json parser? hm			 = allow more than "limit" unread messages to be parsed
 	}
 }
 
@@ -429,11 +450,23 @@ void FacebookProto::ProcessMessages(void* data)
 
 			ParseSmileys(messages[i]->message_text, hContact);
 
-			PROTORECVEVENT recv = {0};
-			recv.flags = PREF_UTF;
-			recv.szMessage = const_cast<char*>(messages[i]->message_text.c_str());
-			recv.timestamp = local_timestamp ? ::time(NULL) : messages[i]->time;
-			ProtoChainRecvMsg(hContact, &recv);
+			if (messages[i]->isIncoming) {
+				PROTORECVEVENT recv = {0};
+				recv.flags = PREF_UTF;
+				recv.szMessage = const_cast<char*>(messages[i]->message_text.c_str());
+				recv.timestamp = local_timestamp || !messages[i]->time ? ::time(NULL) : messages[i]->time;
+				ProtoChainRecvMsg(hContact, &recv);
+			} else {
+				DBEVENTINFO dbei = {0};
+				dbei.cbSize = sizeof(dbei);
+				dbei.eventType = EVENTTYPE_MESSAGE;
+				dbei.flags = DBEF_SENT | DBEF_UTF;
+				dbei.szModule = m_szModuleName;
+				dbei.timestamp = local_timestamp || !messages[i]->time ? ::time(NULL) : messages[i]->time;
+				dbei.cbBlob = (DWORD)messages[i]->message_text.length() + 1;
+				dbei.pBlob = (PBYTE)messages[i]->message_text.c_str();
+				db_event_add(hContact, &dbei);
+			}
 		}
 		delete messages[i];
 	}
@@ -862,4 +895,4 @@ void FacebookProto::SearchIdAckThread(void *targ)
 
 	mir_free(targ);
 	mir_free(arg);
-}
\ No newline at end of file
+}
-- 
cgit v1.2.3