Added Facebook RM

git-svn-id: http://miranda-plugins.googlecode.com/svn/trunk@191 e753b5eb-9565-29b2-b5c5-2cc6f99dfbcb

1 files changed, 452 insertions, 0 deletions

diff --git a/FacebookRM/json.cpp b/FacebookRM/json.cpp
new file mode 100644
index 0000000..1c57f00
--- /dev/null
+++ b/FacebookRM/json.cpp
@@ -0,0 +1,452 @@
+/*

+

+Facebook plugin for Miranda Instant Messenger

+_____________________________________________

+

+Copyright © 2009-11 Michal Zelinka

+

+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, see <http://www.gnu.org/licenses/>.

+

+File name      : $HeadURL: http://eternityplugins.googlecode.com/svn/trunk/facebook/json.cpp $

+Revision       : $Revision: 94 $

+Last change by : $Author: n3weRm0re.ewer $

+Last change on : $Date: 2011-02-05 16:57:18 +0100 (so, 05 2 2011) $

+

+*/

+

+#include "common.h"

+#include "JSON_CAJUN/reader.h"

+#include "JSON_CAJUN/writer.h"

+#include "JSON_CAJUN/elements.h"

+

+int facebook_json_parser::parse_buddy_list( void* data, List::List< facebook_user >* buddy_list )

+{

+	using namespace json;

+

+	try

+	{

+		facebook_user* current = NULL;

+		std::string buddyData = static_cast< std::string* >( data )->substr( 9 );

+		std::istringstream sDocument( buddyData );

+		Object objDocument;

+		Reader::Read(objDocument, sDocument);

+

+		const Object& objRoot = objDocument;

+/*		const Array& wasAvailableIDs = objRoot["payload"]["buddy_list"]["wasAvailableIDs"];

+

+		for ( Array::const_iterator itWasAvailable( wasAvailableIDs.Begin() );

+			itWasAvailable != wasAvailableIDs.End(); ++itWasAvailable)

+		{

+			const Number& member = *itWasAvailable;

+			char was_id[32];

+			lltoa( member.Value(), was_id, 10 );

+

+			current = buddy_list->find( std::string( was_id ) );

+			if ( current != NULL )

+				current->status_id = ID_STATUS_OFFLINE;

+		}*/ // Facebook removed support for "wasAvailableIDs"

+

+		// Set all contacts in map to offline

+		for ( List::Item< facebook_user >* i = buddy_list->begin( ); i != NULL; i = i->next ) {

+			i->data->status_id = ID_STATUS_OFFLINE;

+		}

+

+		const Object& nowAvailableList = objRoot["payload"]["buddy_list"]["nowAvailableList"];

+

+		for (Object::const_iterator itAvailable(nowAvailableList.Begin());

+			itAvailable != nowAvailableList.End(); ++itAvailable)

+		{

+			const Object::Member& member = *itAvailable;

+			const Object& objMember = member.element;

+			const Boolean idle = objMember["i"]; // In new version of Facebook "i" means "offline"

+

+			current = buddy_list->find( member.name );

+			if ( current == NULL) {

+				if (idle) continue; // Just little optimalization

+

+				buddy_list->insert( std::make_pair( member.name, new facebook_user( ) ) );

+				current = buddy_list->find( member.name );

+				current->user_id = current->real_name = member.name;	

+			}			

+						

+			current->status_id = (idle ? ID_STATUS_OFFLINE : ID_STATUS_ONLINE);

+		}

+

+		const Object& userInfosList = objRoot["payload"]["buddy_list"]["userInfos"];

+

+		for (Object::const_iterator itUserInfo(userInfosList.Begin());

+			itUserInfo != userInfosList.End(); ++itUserInfo)

+		{

+			const Object::Member& member = *itUserInfo;

+

+			current = buddy_list->find( member.name );

+			if ( current == NULL )

+				continue;

+

+			const Object& objMember = member.element;

+			const String& realName = objMember["name"];

+			const String& imageUrl = objMember["thumbSrc"];

+

+			current->real_name = utils::text::slashu_to_utf8(

+			    utils::text::special_expressions_decode( realName.Value( ) ) );

+			current->image_url = utils::text::slashu_to_utf8(

+			    utils::text::special_expressions_decode( imageUrl.Value( ) ) );

+		}

+	}

+	catch (Reader::ParseException& e)

+	{

+		proto->Log( "!!!!! Caught json::ParseException: %s", e.what() );

+		proto->Log( "      Line/offset: %d/%d", e.m_locTokenBegin.m_nLine + 1, e.m_locTokenBegin.m_nLineOffset + 1 );

+	}

+	catch (const Exception& e)

+	{

+		proto->Log( "!!!!! Caught json::Exception: %s", e.what() );

+	}

+	catch (const std::exception& e)

+	{

+		proto->Log( "!!!!! Caught std::exception: %s", e.what() );

+	}

+

+	return EXIT_SUCCESS;

+}

+

+int facebook_json_parser::parse_friends( void* data, std::map< std::string, facebook_user* >* friends )

+{

+	using namespace json;

+

+	try

+	{

+		std::string buddyData = static_cast< std::string* >( data )->substr( 9 );

+		std::istringstream sDocument( buddyData );

+		Object objDocument;

+		Reader::Read(objDocument, sDocument);

+

+		const Object& objRoot = objDocument;

+		const Object& payload = objRoot["payload"];

+

+		for ( Object::const_iterator payload_item( payload.Begin() ); payload_item != payload.End(); ++payload_item)

+		{

+			const Object::Member& member = *payload_item;

+

+			const Object& objMember = member.element;

+

+			const String& realName = objMember["name"];

+			const String& imageUrl = objMember["thumbSrc"];

+			//const String& vanity = objMember["vanity"];

+			const Number& gender = objMember["gender"];

+			

+			facebook_user *fbu = new facebook_user();

+

+			fbu->user_id = member.name;

+			fbu->real_name = utils::text::slashu_to_utf8(

+			    utils::text::special_expressions_decode( realName.Value() ) );

+			fbu->image_url = utils::text::slashu_to_utf8(

+			    utils::text::special_expressions_decode( imageUrl.Value() ) );

+

+			if (gender.Value() == 1) {

+				fbu->gender = 70; // female

+			} else if (gender.Value() == 2) {

+				fbu->gender = 77; // male

+			}

+

+			friends->insert( std::make_pair( member.name, fbu ) );

+		}

+	}

+	catch (Reader::ParseException& e)

+	{

+		proto->Log( "!!!!! Caught json::ParseException: %s", e.what() );

+		proto->Log( "      Line/offset: %d/%d", e.m_locTokenBegin.m_nLine + 1, e.m_locTokenBegin.m_nLineOffset + 1 );

+	}

+	catch (const Exception& e)

+	{

+		proto->Log( "!!!!! Caught json::Exception: %s", e.what() );

+	}

+	catch (const std::exception& e)

+	{

+		proto->Log( "!!!!! Caught std::exception: %s", e.what() );

+	}

+

+	return EXIT_SUCCESS;

+}

+

+

+int facebook_json_parser::parse_notifications( void *data, std::vector< facebook_notification* > *notifications ) 

+{

+	using namespace json;

+

+	try

+	{

+		std::string notificationsData = static_cast< std::string* >( data )->substr( 9 );

+		std::istringstream sDocument( notificationsData );

+		Object objDocument;

+		Reader::Read(objDocument, sDocument);

+

+		const Object& objRoot = objDocument;

+		const Object& payload = objRoot["payload"]["markup_map"];

+

+		for ( Object::const_iterator payload_item( payload.Begin() ); payload_item != payload.End(); ++payload_item)

+		{

+			const Object::Member& member = *payload_item;

+

+			const String& content = member.element;

+

+			std::string text = utils::text::slashu_to_utf8(

+								utils::text::special_expressions_decode( content.Value() ) );

+

+			if (text.find("jewelItemNew") == std::string::npos)

+				continue; // we want only unread notifications

+

+			facebook_notification* notification = new facebook_notification( );

+			

+			notification->text = utils::text::remove_html( utils::text::source_get_value(&text, 1, "<abbr") );

+			notification->link = utils::text::source_get_value(&text, 2, "<a href=\"", "\"");

+

+			notifications->push_back( notification );

+		}

+

+	}

+	catch (Reader::ParseException& e)

+	{

+		proto->Log( "!!!!! Caught json::ParseException: %s", e.what() );

+		proto->Log( "      Line/offset: %d/%d", e.m_locTokenBegin.m_nLine + 1, e.m_locTokenBegin.m_nLineOffset + 1 );

+	}

+	catch (const Exception& e)

+	{

+		proto->Log( "!!!!! Caught json::Exception: %s", e.what() );

+	}

+	catch (const std::exception& e)

+	{

+		proto->Log( "!!!!! Caught std::exception: %s", e.what() );

+	}

+

+	return EXIT_SUCCESS;

+}

+

+int facebook_json_parser::parse_messages( void* data, std::vector< facebook_message* >* messages, std::vector< facebook_notification* >* notifications )

+{

+	using namespace json;

+

+	try

+	{

+		std::string messageData = static_cast< std::string* >( data )->substr( 9 );

+		std::istringstream sDocument( messageData );

+		Object objDocument;

+		Reader::Read(objDocument, sDocument);

+

+		const Object& objRoot = objDocument;

+		const Array& messagesArray = objRoot["ms"];

+

+		std::string last_msg = "";

+

+		for (Array::const_iterator itMessage(messagesArray.Begin());

+			itMessage != messagesArray.End(); ++itMessage)

+		{

+			const Object& objMember = *itMessage;

+

+			const String& type = objMember["type"];

+

+			if ( type.Value( ) == "msg" ) // chat message

+			{

+				const Number& from = objMember["from"];

+				char was_id[32];

+				lltoa( from.Value(), was_id, 10 );

+				

+				const Object& messageContent = objMember["msg"];

+				const String& text = messageContent["text"];

+        

+				//const Number& time_sent = messageContent["time"];

+

+//				proto->Log("????? Checking time %15.2f > %15.2f", time_sent.Value(), proto->facy.last_message_time_);

+

+				if (last_msg != text.Value())

+/*				if (time_sent.Value() > proto->facy.last_message_time_

+						|| (time_sent.Value() < 0 && proto->facy.last_message_time_ >= 0)) // Check agains duplicit messages*/

+				{

+					last_msg = text.Value();

+					//proto->facy.last_message_time_ = time_sent.Value();

+

+  					facebook_message* message = new facebook_message( );

+					message->message_text= utils::text::special_expressions_decode(

+						utils::text::slashu_to_utf8( text.Value( ) ) );

+					message->time = ::time( NULL );

+					message->user_id = was_id;

+

+					messages->push_back( message );

+				} else {

+					std::string msg = "????? Got duplicit message?\n";

+					msg += utils::text::special_expressions_decode(utils::text::slashu_to_utf8(text.Value()));

+					proto->Log(msg.c_str());

+				}

+			}

+			else if ( type.Value( ) == "messaging" ) // inbox message

+			{				

+				const String& type = objMember["event"];

+

+				if (type.Value() == "deliver") {

+					const Object& messageContent = objMember["message"];

+

+					const Number& from = messageContent["sender_fbid"];

+					char was_id[32];

+					lltoa( from.Value(), was_id, 10 );

+				

+					const String& text = messageContent["body"];

+

+					// TODO RM: include sender name

+					// const String& name = messageContent["sender_name"];

+        

+					//const Number& time_sent = messageContent["timestamp"];

+

+					//proto->Log("????? Checking time %15.2f > %15.2f", time_sent.Value(), proto->facy.last_message_time_);

+

+					if (last_msg != text.Value())

+/*					if (time_sent.Value() > proto->facy.last_message_time_

+						|| (time_sent.Value() < 0 && proto->facy.last_message_time_ >= 0)) // Check agains duplicit messages*/

+					{

+						last_msg = text.Value();

+						//proto->facy.last_message_time_ = time_sent.Value();

+

+  						facebook_message* message = new facebook_message( );

+						message->message_text= utils::text::special_expressions_decode(

+							utils::text::slashu_to_utf8( text.Value( ) ) );

+

+						message->time = ::time( NULL );

+

+						message->user_id = was_id;

+

+						messages->push_back( message );

+					} else {

+						std::string msg = "????? Got duplicit inbox message?\n";

+						msg += utils::text::special_expressions_decode(utils::text::slashu_to_utf8(text.Value()));

+						proto->Log(msg.c_str());

+					}

+				}

+			}

+			else if ( type.Value( ) == "group_msg" ) // chat message

+			{

+				if ( (::time(NULL) - proto->facy.last_grpmessage_time_) < 15 ) // TODO RM: remove dont notify more than once every 15 secs

+					continue;

+

+				proto->facy.last_grpmessage_time_ = ::time(NULL);

+        

+				const String& from_name = objMember["from_name"];

+				const String& group_name = objMember["to_name"];

+

+				const Number& to = objMember["to"];

+				char group_id[32];

+				lltoa( to.Value(), group_id, 10 );

+	

+				const Number& from = objMember["from"];

+				char was_id[32];

+				lltoa( from.Value(), was_id, 10 );

+

+				// Ignore if message is from self user

+				if (was_id == proto->facy.self_.user_id)

+					continue;

+

+				const Object& messageContent = objMember["msg"];

+  				const String& text = messageContent["text"];

+

+				std::string popup_text = utils::text::remove_html(

+					utils::text::special_expressions_decode(

+						utils::text::slashu_to_utf8( from_name.Value( ) ) ) );

+				popup_text += ": ";

+				popup_text += utils::text::remove_html(

+					utils::text::special_expressions_decode(

+						utils::text::slashu_to_utf8( text.Value( ) ) ) );

+

+				std::string title = Translate("Groupchat");

+				title += ": ";

+				title += utils::text::remove_html(

+					utils::text::special_expressions_decode(

+						utils::text::slashu_to_utf8( group_name.Value( ) ) ) );

+

+				std::string url = "/home.php?sk=group_";

+				url += group_id;

+

+				proto->Log("      Got groupchat message");

+		    

+				TCHAR* szTitle = mir_a2t_cp(title.c_str(), CP_UTF8);

+				TCHAR* szText = mir_a2t_cp(popup_text.c_str(), CP_UTF8);

+				TCHAR* szUrl = mir_a2t_cp(url.c_str(), CP_UTF8);

+				proto->NotifyEvent(szTitle,szText,NULL,FACEBOOK_EVENT_OTHER, szUrl);

+				mir_free(szTitle);

+				mir_free(szText);

+			}

+			else if ( type.Value( ) == "app_msg" ) // event notification

+			{

+				if (!DBGetContactSettingByte(NULL, proto->m_szModuleName, FACEBOOK_KEY_EVENT_NOTIFICATIONS_ENABLE, DEFAULT_EVENT_NOTIFICATIONS_ENABLE))

+					continue;

+				

+				const String& text = objMember["response"]["payload"]["title"];

+				const String& link = objMember["response"]["payload"]["link"];

+				// TODO RM: include additional text of notification if exits? (e.g. comment text)

+				//const String& text2 = objMember["response"]["payload"]["alert"]["text"];

+

+				const Number& time_sent = objMember["response"]["payload"]["alert"]["time_sent"];        

+				if (time_sent.Value() > proto->facy.last_notification_time_) // Check agains duplicit notifications

+				{

+					proto->facy.last_notification_time_ = time_sent.Value();

+

+					facebook_notification* notification = new facebook_notification( );

+					notification->text = utils::text::remove_html(

+  						utils::text::special_expressions_decode(

+							utils::text::slashu_to_utf8( text.Value( ) ) ) );

+

+  					notification->link = utils::text::special_expressions_decode( link.Value( ) );

+

+					notifications->push_back( notification );

+				}

+			}

+			else if ( type.Value( ) == "typ" ) // chat typing notification

+			{

+				const Number& from = objMember["from"];

+				char user_id[32];

+				lltoa( from.Value(), user_id, 10 );

+

+				facebook_user fbu;

+				fbu.user_id = user_id;

+

+				HANDLE hContact = proto->AddToContactList(&fbu);

+				

+				if ( DBGetContactSettingWord(hContact,proto->m_szModuleName,"Status", 0) == ID_STATUS_OFFLINE )

+					DBWriteContactSettingWord(hContact,proto->m_szModuleName,"Status",ID_STATUS_ONLINE);

+

+				const Number& state = objMember["st"];

+				if (state.Value() == 1)

+					CallService(MS_PROTO_CONTACTISTYPING, (WPARAM)hContact, (LPARAM)60);

+				else

+					CallService(MS_PROTO_CONTACTISTYPING, (WPARAM)hContact, (LPARAM)PROTOTYPE_CONTACTTYPING_OFF);

+			}

+			else if ( type.Value( ) == "visibility" ) // change of chat status

+			{

+				const Boolean visibility = objMember["visibility"];

+				proto->Log("      Requested chat switch to %s", visibility ? "Online" : "Offline");

+				proto->SetStatus( visibility ? ID_STATUS_ONLINE : ID_STATUS_INVISIBLE );				

+			}

+			else

+				continue;

+		}

+	}

+	catch (Reader::ParseException& e)

+	{

+		proto->Log( "!!!!! Caught json::ParseException: %s", e.what() );

+		proto->Log( "      Line/offset: %d/%d", e.m_locTokenBegin.m_nLine + 1, e.m_locTokenBegin.m_nLineOffset + 1 );

+	}

+	catch (const Exception& e)

+	{

+		proto->Log ( "!!!!! Caught json::Exception: %s", e.what() );

+	}

+

+	return EXIT_SUCCESS;

+}