renaming FacebookRM folder

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

1 files changed, 646 insertions, 0 deletions

diff --git a/protocols/FacebookRM/process.cpp b/protocols/FacebookRM/process.cpp
new file mode 100644
index 0000000000..4136e1b323
--- /dev/null
+++ b/protocols/FacebookRM/process.cpp
@@ -0,0 +1,646 @@
+/*

+

+Facebook plugin for Miranda Instant Messenger

+_____________________________________________

+

+Copyright © 2009-11 Michal Zelinka, 2011-12 Robert Pösel

+

+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/>.

+

+*/

+

+#include "common.h"

+

+void FacebookProto::ProcessBuddyList( void* data )

+{

+	if ( data == NULL )

+		return;

+

+	ScopedLock s( facy.buddies_lock_ );

+

+	std::string* resp = (std::string*)data;

+

+	if ( isOffline() )

+		goto exit;

+

+	LOG("***** Starting processing buddy list");

+

+	CODE_BLOCK_TRY

+

+	facebook_json_parser* p = new facebook_json_parser( this );

+	p->parse_buddy_list( data, &facy.buddies );

+	delete p;

+

+	for ( List::Item< facebook_user >* i = facy.buddies.begin( ); i != NULL; )

+	{

+		LOG("      Now %s: %s", (i->data->status_id == ID_STATUS_OFFLINE ? "offline" : "online"), i->data->real_name.c_str());

+

+		facebook_user* fbu;

+

+		if ( i->data->status_id == ID_STATUS_OFFLINE || i->data->deleted )

+		{

+			fbu = i->data;

+

+			if (fbu->handle && !fbu->deleted)

+				DBWriteContactSettingWord(fbu->handle, m_szModuleName, "Status", ID_STATUS_OFFLINE);

+

+			std::string to_delete( i->key );

+			i = i->next;

+			facy.buddies.erase( to_delete );

+		} else {

+			fbu = i->data;

+			i = i->next;

+

+			if (!fbu->handle) { // just been added

+				fbu->handle = AddToContactList(fbu);

+

+				if (!fbu->real_name.empty()) {

+					DBWriteContactSettingUTF8String(fbu->handle,m_szModuleName,FACEBOOK_KEY_NAME,fbu->real_name.c_str());

+					DBWriteContactSettingUTF8String(fbu->handle,m_szModuleName,FACEBOOK_KEY_NICK,fbu->real_name.c_str());

+				}

+			}

+

+			if (DBGetContactSettingWord(fbu->handle,m_szModuleName,"Status", 0) != fbu->status_id ) {

+				DBWriteContactSettingWord(fbu->handle,m_szModuleName,"Status", fbu->status_id );

+			}

+

+			if (DBGetContactSettingByte(fbu->handle,m_szModuleName,FACEBOOK_KEY_CONTACT_TYPE, 0)) {

+				DBDeleteContactSetting(fbu->handle,m_szModuleName,FACEBOOK_KEY_CONTACT_TYPE); // Set type "on server-list" contact

+			}

+

+			// Wasn't contact removed from "server-list" someday?

+			if ( DBGetContactSettingDword(fbu->handle, m_szModuleName, FACEBOOK_KEY_DELETED, 0) ) {

+				DBDeleteContactSetting(fbu->handle, m_szModuleName, FACEBOOK_KEY_DELETED);

+

+				std::string url = FACEBOOK_URL_PROFILE + fbu->user_id;					

+

+				TCHAR* szTitle = mir_a2t_cp(fbu->real_name.c_str(), CP_UTF8);

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

+				NotifyEvent(szTitle, TranslateT("Contact is back on server-list."), fbu->handle, FACEBOOK_EVENT_OTHER, szUrl);

+				mir_free( szTitle );

+				// mir_free( szUrl ); // url is free'd in popup procedure

+			}

+

+			// Check avatar change

+			CheckAvatarChange(fbu->handle, fbu->image_url);

+		}

+	}

+

+	LOG("***** Buddy list processed");

+

+	CODE_BLOCK_CATCH

+

+	LOG("***** Error processing buddy list: %s", e.what());

+

+	CODE_BLOCK_END

+

+exit:

+	delete resp;

+}

+

+void FacebookProto::ProcessFriendList( void* data )

+{

+	if ( data == NULL )

+		return;

+

+	std::string* resp = (std::string*)data;

+

+	LOG("***** Starting processing friend list");

+

+	CODE_BLOCK_TRY

+

+	std::map<std::string, facebook_user*> friends;

+

+	facebook_json_parser* p = new facebook_json_parser( this );

+	p->parse_friends( data, &friends );

+	delete p;

+

+

+	// Check and update old contacts

+	for(HANDLE hContact = (HANDLE)CallService(MS_DB_CONTACT_FINDFIRST,0,0);

+	    hContact;

+	    hContact = (HANDLE)CallService(MS_DB_CONTACT_FINDNEXT,(WPARAM)hContact,0) )

+	{

+		if(!IsMyContact(hContact))

+			continue;

+

+		DBVARIANT dbv;

+		facebook_user *fbu;

+		if( !DBGetContactSettingString(hContact,m_szModuleName,FACEBOOK_KEY_ID,&dbv) ) {

+			std::string id = dbv.pszVal;

+			DBFreeVariant(&dbv);

+			

+			std::map< std::string, facebook_user* >::iterator iter;

+			

+			if ((iter = friends.find(id)) != friends.end()) {

+				// Found contact, update it and remove from map

+				fbu = iter->second;

+

+				DBVARIANT dbv;

+				bool update_required = true;

+

+				// TODO RM: remove, because contacts cant change it, so its only for "first run"

+					// - but what with contacts, that was added after logon?

+				// Update gender

+				if ( DBGetContactSettingByte(hContact, m_szModuleName, "Gender", 0) != fbu->gender )

+					DBWriteContactSettingByte(hContact, m_szModuleName, "Gender", fbu->gender);

+

+				// TODO: Remove in next version

+				if( !DBGetContactSettingString(hContact, m_szModuleName, "MirVer", &dbv) ) {

+					update_required = strcmp( dbv.pszVal, FACEBOOK_NAME ) != 0;

+					DBFreeVariant(&dbv);

+				}

+				if (update_required) {

+					DBWriteContactSettingString(hContact, m_szModuleName, "MirVer", FACEBOOK_NAME);

+				}

+

+				// Update real name

+				if ( !DBGetContactSettingUTF8String(hContact, m_szModuleName, FACEBOOK_KEY_NAME, &dbv) )

+				{

+					update_required = strcmp( dbv.pszVal, fbu->real_name.c_str() ) != 0;

+					DBFreeVariant(&dbv);

+				}

+				if ( update_required )

+				{

+					DBWriteContactSettingUTF8String(hContact, m_szModuleName, FACEBOOK_KEY_NAME, fbu->real_name.c_str());

+					DBWriteContactSettingUTF8String(hContact, m_szModuleName, FACEBOOK_KEY_NICK, fbu->real_name.c_str());

+				}

+

+				if (DBGetContactSettingByte(fbu->handle,m_szModuleName,FACEBOOK_KEY_CONTACT_TYPE, 0)) {

+					DBDeleteContactSetting(fbu->handle,m_szModuleName,FACEBOOK_KEY_CONTACT_TYPE); // Has type "on server-list" contact

+				}

+

+				// Wasn't contact removed from "server-list" someday?

+				if ( DBGetContactSettingDword(hContact, m_szModuleName, FACEBOOK_KEY_DELETED, 0) ) {

+					DBDeleteContactSetting(hContact, m_szModuleName, FACEBOOK_KEY_DELETED);

+

+					std::string url = FACEBOOK_URL_PROFILE + fbu->user_id;					

+

+					TCHAR* szTitle = mir_a2t_cp(fbu->real_name.c_str(), CP_UTF8);

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

+					NotifyEvent(szTitle, TranslateT("Contact is back on server-list."), hContact, FACEBOOK_EVENT_OTHER, szUrl);					

+					mir_free( szTitle );

+					// mir_free( szUrl ); // url is free'd in popup procedure

+				}

+

+				// Check avatar change

+				CheckAvatarChange(hContact, fbu->image_url);

+			

+				delete fbu;

+				friends.erase(iter);

+			} else {

+				// Contact was removed from "server-list", notify it

+

+				// Wasnt we already been notified about this contact?

+				if ( !DBGetContactSettingDword(hContact, m_szModuleName, FACEBOOK_KEY_DELETED, 0) 

+					&& !DBGetContactSettingByte(hContact, m_szModuleName, FACEBOOK_KEY_CONTACT_TYPE, 0)	) { // And is this contact "on-server" contact?

+

+					DBWriteContactSettingDword(hContact, m_szModuleName, FACEBOOK_KEY_DELETED, ::time(NULL));

+

+					std::string contactname = id;

+					if ( !DBGetContactSettingUTF8String(hContact, m_szModuleName, FACEBOOK_KEY_NAME, &dbv) ) {

+						contactname = dbv.pszVal;

+						DBFreeVariant(&dbv);

+					}

+

+					std::string url = FACEBOOK_URL_PROFILE + id;

+

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

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

+					NotifyEvent(szTitle, TranslateT("Contact is no longer on server-list."), hContact, FACEBOOK_EVENT_OTHER, szUrl);

+					mir_free( szTitle );

+					// mir_free( szUrl ); // url is free'd in popup procedure

+				}

+			}

+		}

+	}

+

+	// Check remain contacts in map and add it to contact list

+	for ( std::map< std::string, facebook_user* >::iterator iter = friends.begin(); iter != friends.end(); ++iter )

+	{

+		facebook_user *fbu = iter->second;

+		

+		HANDLE hContact = AddToContactList(fbu, true); // This contact is surely new

+

+		DBWriteContactSettingByte(hContact, m_szModuleName, "Gender", fbu->gender );

+		DBWriteContactSettingUTF8String(hContact, m_szModuleName, FACEBOOK_KEY_NAME, fbu->real_name.c_str());

+		DBWriteContactSettingUTF8String(hContact, m_szModuleName, FACEBOOK_KEY_NICK, fbu->real_name.c_str());

+		DBWriteContactSettingString(hContact, m_szModuleName, FACEBOOK_KEY_AV_URL, fbu->image_url.c_str());

+//		DBWriteContactSettingWord(hContact, m_szModuleName, "Status", ID_STATUS_OFFLINE );

+	}

+

+	LOG("***** Friend list processed");

+

+	CODE_BLOCK_CATCH

+

+	LOG("***** Error processing friend list: %s", e.what());

+

+	CODE_BLOCK_END

+

+	delete resp;

+}

+

+void FacebookProto::ProcessUnreadMessages( void* )

+{

+	facy.handle_entry( "messages" );

+

+	std::string get_data = "sk=inbox&query=is%3Aunread";

+

+	std::string data = "post_form_id=";

+	data += ( facy.post_form_id_.length( ) ) ? facy.post_form_id_ : "0";

+	data += "&fb_dtsg=" + facy.dtsg_;

+	data += "&post_form_id_source=AsyncRequest&lsd=&phstamp=";

+	data += utils::time::mili_timestamp();

+	data += "&__user=";

+	data += facy.self_.user_id;

+

+	// Get unread inbox threads

+	http::response resp = facy.flap( FACEBOOK_REQUEST_ASYNC, &data, &get_data );

+

+	// sk=inbox,  sk=other

+

+	// Process result data

+	facy.validate_response(&resp);	

+

+	if (resp.code != HTTP_CODE_OK) {

+		facy.handle_error( "messages" );

+		return;

+	}

+

+	std::string threadlist = utils::text::slashu_to_utf8(resp.data);

+	

+	std::string::size_type pos = 0;

+

+	while ( ( pos = threadlist.find( "<li class=\\\"threadRow noDraft unread", pos ) ) != std::string::npos )

+	{

+		std::string::size_type pos2 = threadlist.find( "/li>", pos );

+		std::string thread_content = threadlist.substr( pos, pos2 - pos );

+

+		pos = pos2;

+

+		get_data = "sk=inbox&query=is%3Aunread&thread_query=is%3Aunread&action=read&tid=";

+		get_data += utils::text::source_get_value( &thread_content, 2, "id=\\\"", "\\\"" );

+		

+		resp = facy.flap( FACEBOOK_REQUEST_ASYNC, &data, &get_data );

+		// TODO: move this to new thread...

+

+		facy.validate_response(&resp);

+

+		if (resp.code != HTTP_CODE_OK) {

+			LOG(" !! !! Error when getting messages list");

+			continue;

+		}

+		

+		std::string messageslist = utils::text::slashu_to_utf8(resp.data);		

+		

+		std::string user_id = utils::text::source_get_value( &messageslist, 2, "single_thread_id\":", "," );

+		if (user_id.empty()) {

+			LOG(" !! !! Thread id is empty - this is groupchat message."); // TODO: remove as this is not such 'error'

+			continue;

+		}

+

+		facebook_user fbu;

+		fbu.user_id = user_id;

+

+		HANDLE hContact = AddToContactList(&fbu);

+		// TODO: if contact is newly added, get his user info

+		// TODO: maybe create new "receiveMsg" function and use it for offline and channel messages?

+

+		pos2 = 0;

+		while ( ( pos2 = messageslist.find( "class=\\\"MessagingMessage ", pos2 ) ) != std::string::npos ) {

+			pos2 += 8;

+			std::string strclass = messageslist.substr(pos2, messageslist.find("\\\"", pos2) - pos2);

+

+			if (strclass.find("MessagingMessageUnread") == std::string::npos)

+				continue; // ignoring old messages

+

+			//std::string::size_type pos3 = messageslist.find( "/li>", pos2 ); // TODO: ne proti tomuhle li, protože i přílohy mají li...

+			std::string::size_type pos3 = messageslist.find( "class=\\\"MessagingMessage ", pos2 );

+			std::string messagesgroup = messageslist.substr( pos2, pos3 - pos2 );

+

+			DWORD timestamp = NULL;

+			std::string strtime = utils::text::source_get_value( &messagesgroup, 2, "data-utime=\\\"", "\\\"" );

+			if (!utils::conversion::from_string<DWORD>(timestamp, strtime, std::dec)) {

+				timestamp = static_cast<DWORD>(::time(NULL));

+			}

+

+			pos3 = 0;

+			while ( ( pos3 = messagesgroup.find( "class=\\\"content noh", pos3 ) ) != std::string::npos )

+			{

+

+				std::string message_attachments = "";

+				std::string::size_type pos4 = 0;

+				if ((pos4 = messagesgroup.find( "class=\\\"attachments\\\"", pos4)) != std::string::npos) {

+					std::string attachments = messagesgroup.substr( pos4, messagesgroup.find("<\\/ul", pos4) - pos4 );

+

+					pos4 = 0;

+					while ( ( pos4 = attachments.find("<li", pos4) ) != std::string::npos ) {

+						std::string attachment = attachments.substr( pos4, attachments.find("<\\/li>", pos4) - pos4 );

+						std::string link = utils::text::source_get_value( &attachment, 4, "<a class=", "attachment", "href=\\\"", "\\\"" );

+

+						link = utils::text::trim(

+								utils::text::special_expressions_decode( link ) );

+

+						// or first: std::string name = utils::text::source_get_value( &attachment, 4, "<a class=", "attachment", ">", "<\\/a>" );

+						std::string name = utils::text::trim(

+								utils::text::special_expressions_decode(

+									utils::text::remove_html( attachment ) ) );

+

+						if (link.find("/ajax/messaging/attachments/photo/dialog.php?uri=") != std::string::npos) {

+							link = link.substr(49);

+							link = utils::url::decode(link);

+						}

+

+						message_attachments += "< " + name + " > " + FACEBOOK_URL_HOMEPAGE;

+						message_attachments += link + "\r\n";

+

+						pos4++;

+					}

+

+				}

+

+				std::string message_text = messagesgroup.substr(pos3, messagesgroup.find( "<\\/div", pos3 ) + 6 - pos3);

+				message_text = utils::text::source_get_value( &message_text, 2, "\\\">", "<\\/div" );

+				message_text = utils::text::trim(

+								utils::text::special_expressions_decode(

+									utils::text::remove_html( message_text ) ) );

+

+				if (!message_attachments.empty()) {

+					if (!message_text.empty())

+						message_text += "\r\n\r\n";

+

+					message_text += Translate("Attachments:");

+					message_text += "\r\n" + message_attachments;

+				}

+

+				PROTORECVEVENT recv = {0};

+				CCSDATA ccs = {0};

+

+				recv.flags = PREF_UTF;

+				recv.szMessage = const_cast<char*>(message_text.c_str());

+				recv.timestamp = timestamp;

+

+				ccs.hContact = hContact;

+				ccs.szProtoService = PSR_MESSAGE;

+				ccs.lParam = reinterpret_cast<LPARAM>(&recv);

+				CallService(MS_PROTO_CHAINRECV,0,reinterpret_cast<LPARAM>(&ccs));

+

+				pos3++;

+			}

+

+		}

+		

+	}

+

+}

+

+void FacebookProto::ProcessMessages( void* data )

+{

+	if ( data == NULL )

+		return;

+

+	std::string* resp = (std::string*)data;

+

+	if ( isOffline() )

+		goto exit;

+

+	LOG("***** Starting processing messages");

+

+	CODE_BLOCK_TRY

+

+	std::vector< facebook_message* > messages;

+	std::vector< facebook_notification* > notifications;

+

+	facebook_json_parser* p = new facebook_json_parser( this );

+	p->parse_messages( data, &messages, &notifications );

+	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;

+

+			HANDLE hContact = AddToContactList(&fbu, false, messages[i]->sender_name.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?

+

+			PROTORECVEVENT recv = {0};

+			CCSDATA ccs = {0};

+

+			recv.flags = PREF_UTF;

+			recv.szMessage = const_cast<char*>(messages[i]->message_text.c_str());

+			recv.timestamp = static_cast<DWORD>(messages[i]->time);

+

+			ccs.hContact = hContact;

+			ccs.szProtoService = PSR_MESSAGE;

+			ccs.lParam = reinterpret_cast<LPARAM>(&recv);

+			CallService(MS_PROTO_CHAINRECV,0,reinterpret_cast<LPARAM>(&ccs));

+		}

+		delete messages[i];

+	}

+	messages.clear();

+

+	for(std::vector<facebook_notification*>::size_type i=0; i<notifications.size( ); i++)

+	{

+		LOG("      Got notification: %s", notifications[i]->text.c_str());

+		TCHAR* szTitle = mir_a2t_cp(this->m_szModuleName, CP_UTF8);

+		TCHAR* szText = mir_a2t_cp(notifications[i]->text.c_str(), CP_UTF8);

+		TCHAR* szUrl = mir_a2t_cp(notifications[i]->link.c_str(), CP_UTF8);

+		NotifyEvent( szTitle, szText, ContactIDToHContact(notifications[i]->user_id), FACEBOOK_EVENT_NOTIFICATION, szUrl );

+		mir_free( szTitle );

+		mir_free( szText );

+//		mir_free( szUrl ); // URL is free'd in popup procedure

+

+		delete notifications[i];

+	}

+	notifications.clear();

+

+	LOG("***** Messages processed");

+

+	CODE_BLOCK_CATCH

+

+	LOG("***** Error processing messages: %s", e.what());

+

+	CODE_BLOCK_END

+

+exit:

+	delete resp;

+}

+

+void FacebookProto::ProcessNotifications( void* )

+{

+	if ( isOffline() )

+		return;

+

+	if (!getByte( FACEBOOK_KEY_EVENT_NOTIFICATIONS_ENABLE, DEFAULT_EVENT_NOTIFICATIONS_ENABLE ))

+		return;

+

+	facy.handle_entry( "notifications" );

+

+	// Get notifications

+	http::response resp = facy.flap( FACEBOOK_REQUEST_NOTIFICATIONS );

+

+	// Process result data

+	facy.validate_response(&resp);

+  

+	if (resp.code != HTTP_CODE_OK) {

+		facy.handle_error( "notifications" );

+		return;

+	}

+

+

+	// Process notifications

+	LOG("***** Starting processing notifications");

+

+	CODE_BLOCK_TRY

+

+	std::vector< facebook_notification* > notifications;

+

+	facebook_json_parser* p = new facebook_json_parser( this );

+	p->parse_notifications( &(resp.data), &notifications );

+	delete p;

+

+	for(std::vector<facebook_notification*>::size_type i=0; i<notifications.size( ); i++)

+	{

+		LOG("      Got notification: %s", notifications[i]->text.c_str());

+		TCHAR* szTitle = mir_a2t_cp(this->m_szModuleName, CP_UTF8);

+		TCHAR* szText = mir_a2t_cp(notifications[i]->text.c_str(), CP_UTF8);

+		TCHAR* szUrl = mir_a2t_cp(notifications[i]->link.c_str(), CP_UTF8);

+		NotifyEvent( szTitle, szText, ContactIDToHContact(notifications[i]->user_id), FACEBOOK_EVENT_NOTIFICATION, szUrl );

+		mir_free( szTitle );

+		mir_free( szText );

+//		mir_free( szUrl ); // URL is free'd in popup procedure

+

+		delete notifications[i];

+	}

+	notifications.clear();

+

+	LOG("***** Notifications processed");

+

+	CODE_BLOCK_CATCH

+

+	LOG("***** Error processing notifications: %s", e.what());

+

+	CODE_BLOCK_END

+}

+

+

+void FacebookProto::ProcessFeeds( void* data )

+{

+	if ( data == NULL )

+		return;

+

+	std::string* resp = (std::string*)data;

+

+	if (!isOnline())

+		goto exit;

+

+	CODE_BLOCK_TRY

+

+	LOG("***** Starting processing feeds");

+

+	std::vector< facebook_newsfeed* > news;

+

+	std::string::size_type pos = 0;

+	UINT limit = 0;

+

+	*resp = utils::text::slashu_to_utf8(*resp);	

+	*resp = utils::text::source_get_value(resp, 2, "\"html\":\"", ">\"");

+

+	while ( ( pos = resp->find( "<div class=\\\"mainWrapper\\\"", pos ) ) != std::string::npos && limit <= 25 )

+	{		

+		std::string::size_type pos2 = resp->find( "<div class=\\\"mainWrapper\\\"", pos+5 );

+		if (pos2 == std::string::npos)

+			pos2 = resp->length();

+		

+		std::string post = resp->substr( pos, pos2 - pos );

+		pos += 5;

+

+		std::string post_header = utils::text::source_get_value(&post, 4, "<h6 class=", "uiStreamHeadline", ">", "<\\/h6>");

+		std::string post_message = utils::text::source_get_value(&post, 3, "<h6 class=\\\"uiStreamMessage\\\"", ">", "<\\/h6>");

+		std::string post_link = utils::text::source_get_value(&post, 3, "<span class=\\\"uiStreamSource\\\"", ">", "<\\/span>");

+		std::string post_attach = utils::text::source_get_value(&post, 4, "<div class=", "uiStreamAttachments", ">", "<form");

+

+		// in title keep only name, end of events like "X shared link" put into message

+		pos2 = post_header.find("<\\/a>") + 5;

+		post_message = post_header.substr(pos2, post_header.length() - pos2) + post_message;

+		post_header = post_header.substr(0, pos2);

+

+		// append attachement to message (if any)

+		post_message += utils::text::trim( post_attach );

+

+		facebook_newsfeed* nf = new facebook_newsfeed;

+

+		nf->title = utils::text::trim(

+			utils::text::special_expressions_decode(

+				utils::text::remove_html( post_header ) ) );

+

+		nf->user_id = utils::text::source_get_value( &post_header, 2, "user.php?id=", "\\\"" );

+		

+		nf->link = utils::text::special_expressions_decode(

+				utils::text::source_get_value( &post_link, 2, "href=\\\"", "\\\">" ) );

+

+		nf->text = utils::text::trim(

+			utils::text::special_expressions_decode(

+				utils::text::remove_html(

+					utils::text::edit_html( post_message ) ) ) );

+

+		if ( !nf->title.length() || !nf->text.length() )

+		{

+			delete nf;

+			continue;

+		}

+

+		if (nf->text.length() > 500)

+		{

+			nf->text = nf->text.substr(0, 500);

+			nf->text += "...";

+		}

+

+		news.push_back( nf );

+		pos++;

+		limit++;

+	}

+

+	for(std::vector<facebook_newsfeed*>::size_type i=0; i<news.size( ); i++)

+	{

+		LOG("      Got newsfeed: %s %s", news[i]->title.c_str(), news[i]->text.c_str());

+		TCHAR* szTitle = mir_a2t_cp(news[i]->title.c_str(), CP_UTF8);

+		TCHAR* szText = mir_a2t_cp(news[i]->text.c_str(), CP_UTF8);

+		TCHAR* szUrl = mir_a2t_cp(news[i]->link.c_str(), CP_UTF8);

+		NotifyEvent(szTitle,szText,this->ContactIDToHContact(news[i]->user_id),FACEBOOK_EVENT_NEWSFEED, szUrl);

+		mir_free(szTitle);

+		mir_free(szText);

+//		mir_free(szUrl); // URL is free'd in popup procedure

+		delete news[i];

+	}

+	news.clear();

+

+	this->facy.last_feeds_update_ = ::time(NULL);

+

+	LOG("***** Feeds processed");

+

+	CODE_BLOCK_CATCH

+

+	LOG("***** Error processing feeds: %s", e.what());

+

+	CODE_BLOCK_END

+

+exit:

+	delete resp;

+}