/*

Facebook plugin for Miranda Instant Messenger
_____________________________________________

Copyright © 2009-11 Michal Zelinka, 2011-13 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"

bool FacebookProto::IsMyContact(HANDLE hContact, bool include_chat)
{
	const char *proto = GetContactProto(hContact);
	if(proto && strcmp(m_szModuleName, proto) == 0)
	{
		if(include_chat)
			return true;
		else
			return db_get_b(hContact,m_szModuleName,"ChatRoom",0) == 0;
	} else {
		return false;
	}
}

HANDLE FacebookProto::ChatIDToHContact(std::string chat_id)
{
	for (HANDLE hContact = db_find_first(m_szModuleName); hContact; hContact = db_find_next(hContact, m_szModuleName)) {
		if(!IsMyContact(hContact, true))
			continue;

		DBVARIANT dbv;
		if(!db_get_s(hContact,m_szModuleName,"ChatRoomID",&dbv))
		{
			bool found = strcmp(chat_id.c_str(), dbv.pszVal) == 0;
			db_free(&dbv);
			if (found)
				return hContact;
		}
	}

	return 0;
}

HANDLE FacebookProto::ContactIDToHContact(std::string user_id)
{
	for (HANDLE hContact = db_find_first(m_szModuleName); hContact; hContact = db_find_next(hContact, m_szModuleName)) {
		if (!IsMyContact(hContact))
			continue;

		DBVARIANT dbv;
		if(!db_get_s(hContact,m_szModuleName,FACEBOOK_KEY_ID,&dbv))
		{
			if(strcmp(user_id.c_str(),dbv.pszVal) == 0)
			{
				db_free(&dbv);
				return hContact;
			} else {
				db_free(&dbv);
			}
		}
	}

	return 0;
}

HANDLE FacebookProto::AddToContactList(facebook_user* fbu, BYTE type, bool dont_check, const char *new_name)
{
	HANDLE hContact;

	if (!dont_check) {
		// First, check if this contact exists
		hContact = ContactIDToHContact(fbu->user_id);
		if(hContact)
			return hContact;
	}

	// If not, make a new contact!
	hContact = (HANDLE)CallService(MS_DB_CONTACT_ADD, 0, 0);
	if(hContact)
	{
		if(CallService(MS_PROTO_ADDTOCONTACT,(WPARAM)hContact,(LPARAM)m_szModuleName) == 0)
		{
			db_set_s(hContact,m_szModuleName,FACEBOOK_KEY_ID,fbu->user_id.c_str());
      
			std::string homepage = FACEBOOK_URL_PROFILE + fbu->user_id;
			db_set_s(hContact, m_szModuleName,"Homepage", homepage.c_str());			
			db_set_s(hContact, m_szModuleName, "MirVer", fbu->status_id == ID_STATUS_ONTHEPHONE ? FACEBOOK_MOBILE : FACEBOOK_NAME);

			db_unset(hContact, "CList", "MyHandle");

			DBVARIANT dbv;
			if(!db_get_ts(NULL,m_szModuleName,FACEBOOK_KEY_DEF_GROUP,&dbv))
			{
				db_set_ts(hContact,"CList","Group",dbv.ptszVal);
				db_free(&dbv);
			}

			if (strlen(new_name) > 0)
			{
				db_set_utf(hContact, m_szModuleName, FACEBOOK_KEY_NAME, new_name);
				db_set_utf(hContact, m_szModuleName, FACEBOOK_KEY_NICK, new_name);
			}
			
			db_set_b(hContact, m_szModuleName, FACEBOOK_KEY_CONTACT_TYPE, type);

			if (getByte(FACEBOOK_KEY_DISABLE_STATUS_NOTIFY, 0))
				CallService(MS_IGNORE_IGNORE, (WPARAM)hContact, (LPARAM)IGNOREEVENT_USERONLINE);

			return hContact;
		}
		
		CallService(MS_DB_CONTACT_DELETE,(WPARAM)hContact,0);
	}

	return 0;
}

void FacebookProto::SetAllContactStatuses(int status, bool reset_client)
{
	for (HANDLE hContact = db_find_first(); hContact; hContact = db_find_next(hContact)) {
		if (db_get_b(hContact,m_szModuleName,"ChatRoom",0))
			continue;
		
		if (reset_client) {
			DBVARIANT dbv;
			if (!db_get_ts(hContact,m_szModuleName,"MirVer",&dbv)) {
				if (_tcscmp(dbv.ptszVal, _T(FACEBOOK_NAME)))
					db_set_ts(hContact,m_szModuleName,"MirVer", _T(FACEBOOK_NAME));
				db_free(&dbv);
			}


			/*std::tstring foldername = GetAvatarFolder() + L"\\smileys\\";
			TCHAR *path = _tcsdup(foldername.c_str());
	
			if (db_get_b(NULL,m_szModuleName,FACEBOOK_KEY_CUSTOM_SMILEYS, DEFAULT_CUSTOM_SMILEYS)) {
				SMADD_CONT cont;
				cont.cbSize = sizeof(SMADD_CONT);
				cont.hContact = hContact;
				cont.type = 0;
				cont.path = path;
				CallService(MS_SMILEYADD_LOADCONTACTSMILEYS, 0, (LPARAM)&cont);
				mir_free(path);
			}*/
		}

		if (db_get_w(hContact,m_szModuleName,"Status",ID_STATUS_OFFLINE) != status)
			db_set_w(hContact,m_szModuleName,"Status",status);
	}
}

void FacebookProto::DeleteContactFromServer(void *data)
{
	facy.handle_entry("DeleteContactFromServer");

	if (data == NULL)
		return;

	std::string id = (*(std::string*)data);
	delete data;
	
	std::string query = "norefresh=true&unref=button_dropdown&confirmed=1&phstamp=0&__a=1";
	query += "&fb_dtsg=" + facy.dtsg_;
	query += "&uid=" + id;
	query += "&__user=" + facy.self_.user_id;	

	std::string get_query = "norefresh=true&unref=button_dropdown&uid=" + id;
	
	// Get unread inbox threads
	http::response resp = facy.flap(FACEBOOK_REQUEST_DELETE_FRIEND, &query, &get_query);

	// Process result data
	facy.validate_response(&resp);

	if (resp.data.find("\"payload\":null", 0) != std::string::npos)
	{		
		facebook_user* fbu = facy.buddies.find(id);
		if (fbu != NULL)
			fbu->deleted = true;

		HANDLE hContact = ContactIDToHContact(id);		
		
		// If contact wasn't deleted from database
		if (hContact != NULL)
		{
			db_set_w(hContact, m_szModuleName, "Status", ID_STATUS_OFFLINE);
			db_set_b(hContact, m_szModuleName, FACEBOOK_KEY_CONTACT_TYPE, FACEBOOK_CONTACT_NONE);
			db_set_dw(hContact, m_szModuleName, FACEBOOK_KEY_DELETED, ::time(NULL));
		}
		
		NotifyEvent(m_tszUserName, TranslateT("Contact was removed from your server list."), NULL, FACEBOOK_EVENT_OTHER);
	} else {
		facy.client_notify(TranslateT("Error occured when removing contact from server."));
	}

	if (resp.code != HTTP_CODE_OK)
		facy.handle_error("DeleteContactFromServer");	
}

void FacebookProto::AddContactToServer(void *data)
{
	facy.handle_entry("AddContactToServer");

	if (data == NULL)
		return;

	std::string id = (*(std::string*)data);
	delete data;
	
	std::string query = "action=add_friend&how_found=profile_button&ref_param=ts&outgoing_id=&unwanted=&logging_location=&no_flyout_on_click=false&ego_log_data=&lsd=";
	query += "&fb_dtsg=" + facy.dtsg_;
	query += "&to_friend=" + id;
	query += "&__user=" + facy.self_.user_id;

	// Get unread inbox threads
	http::response resp = facy.flap(FACEBOOK_REQUEST_REQUEST_FRIEND, &query);

	// Process result data
	facy.validate_response(&resp);

	if (resp.data.find("\"success\":true", 0) != std::string::npos)
	{
		HANDLE hContact = ContactIDToHContact(id);		
		
		// If contact wasn't deleted from database
		if (hContact != NULL)
		{
			db_set_b(hContact, m_szModuleName, FACEBOOK_KEY_CONTACT_TYPE, FACEBOOK_CONTACT_REQUEST);
		}
				
		NotifyEvent(m_tszUserName, TranslateT("Request for friendship was sent."), NULL, FACEBOOK_EVENT_OTHER);
	} else {
		facy.client_notify(TranslateT("Error occured when requesting friendship."));
	}

	if (resp.code != HTTP_CODE_OK)
		facy.handle_error("AddContactToServer");

}

void FacebookProto::ApproveContactToServer(void *data)
{
	facy.handle_entry("ApproveContactToServer");

	if (data == NULL)
		return;

	HANDLE hContact = (*(HANDLE*)data);
	delete data;

	std::string post_data = "fb_dtsg=" + facy.dtsg_;
	post_data += "&charset_test=%e2%82%ac%2c%c2%b4%2c%e2%82%ac%2c%c2%b4%2c%e6%b0%b4%2c%d0%94%2c%d0%84&confirm_button=";

	std::string get_data = "id=";

	DBVARIANT dbv;
	if (!db_get_s(hContact, m_szModuleName, FACEBOOK_KEY_ID, &dbv))
	{
		get_data += dbv.pszVal;
		db_free(&dbv);
	}

	http::response resp = facy.flap(FACEBOOK_REQUEST_APPROVE_FRIEND, &post_data, &get_data);

	// Process result data
	facy.validate_response(&resp);

	db_set_b(hContact, m_szModuleName, FACEBOOK_KEY_CONTACT_TYPE, FACEBOOK_CONTACT_FRIEND);
}

void FacebookProto::CancelFriendsRequest(void *data)
{
	facy.handle_entry("CancelFriendsRequest");

	if (data == NULL)
		return;

	HANDLE hContact = (*(HANDLE*)data);
	delete data;
	
	std::string query = "phstamp=0&confirmed=1";	
	query += "&fb_dtsg=" + facy.dtsg_;
	query += "&__user=" + facy.self_.user_id;

	DBVARIANT dbv;
	if (!db_get_s(hContact, m_szModuleName, FACEBOOK_KEY_ID, &dbv))
	{
		query += "&friend=" + std::string(dbv.pszVal);
		db_free(&dbv);
	}

	// Get unread inbox threads
	http::response resp = facy.flap(FACEBOOK_REQUEST_CANCEL_REQUEST, &query);

	// Process result data
	facy.validate_response(&resp);

	if (resp.data.find("\"payload\":null", 0) != std::string::npos)
	{		
		db_set_b(hContact, m_szModuleName, FACEBOOK_KEY_CONTACT_TYPE, FACEBOOK_CONTACT_NONE);
		NotifyEvent(m_tszUserName, TranslateT("Request for friendship was canceled."), NULL, FACEBOOK_EVENT_OTHER);
	} else {
		facy.client_notify(TranslateT("Error occured when canceling friendship request."));
	}

	if (resp.code != HTTP_CODE_OK)
		facy.handle_error("CancelFriendsRequest");
}

void FacebookProto::SendPokeWorker(void *p)
{
	facy.handle_entry("SendPokeWorker");

	if (p == NULL)
		return;

	std::string id = (*(std::string*)p);
	delete p;

	std::string data = "uid=" + id;
	data += "&phstamp=0&pokeback=0&ask_for_confirm=0";
	data += "&fb_dtsg=" + (facy.dtsg_.length() ? facy.dtsg_ : "0");
	data += "&__user=" + facy.self_.user_id;

	// Send poke
	http::response resp = facy.flap(FACEBOOK_REQUEST_POKE, &data);

	// Process result data
	facy.validate_response(&resp);

	if (resp.data.find("\"payload\":null", 0) != std::string::npos) {
		
		std::string message = utils::text::special_expressions_decode(
			utils::text::remove_html(
				utils::text::slashu_to_utf8(
					utils::text::source_get_value(&resp.data, 3, "\"body\":", "__html\":\"", "\"}"))));

		TCHAR* tmessage = mir_utf8decodeT(message.c_str());
		NotifyEvent(m_tszUserName, tmessage, NULL, FACEBOOK_EVENT_OTHER);
		mir_free(tmessage);
	}

	facy.handle_success("SendPokeWorker");
}


HANDLE FacebookProto::GetAwayMsg(HANDLE hContact)
{
	return 0; // Status messages are disabled
}

int FacebookProto::OnContactDeleted(WPARAM wParam,LPARAM)
{
	CancelFriendship(wParam, 1);

	return 0;
}