#include "CreateFriendRequest.h"

DEFINE_LOGGER(logger, "CreateFriendRequest")

void CreateFriendRequest::run()

{

	LOG4CXX_INFO(logger, user << ": Sending follow request for " << frnd)

	replyMsg = "";

	success = twitObj->friendshipCreate(frnd, false);

	if(success) twitObj->getLastWebResponse(replyMsg);

}

void CreateFriendRequest::finalize()

{

	if(!success) {

		std::string error;

		twitObj->getLastCurlError(error);

		callBack(user, frnd, error);

	} else {

		std::string error;

		error = getErrorMessage(replyMsg);

		else LOG4CXX_INFO(logger, user << ": Now following " << frnd)

		callBack(user, frnd, error);

	}

}

	if(key == "" || secret == "") {			

		LOG4CXX_INFO(logger, "Intiating OAuth Flow for user " << user)

		tp->runAsThread(new OAuthFlow(np, sessions[user], user, sessions[user]->getTwitterUsername()));

	} else {

		LOG4CXX_INFO(logger, user << " is already registerd. Using the stored oauth key and secret")

		LOG4CXX_INFO(logger, key << " " << secret)	

		pinExchangeComplete(user, key, secret);

	}

}

// User logging out

void TwitterPlugin::handleLogoutRequest(const std::string &user, const std::string &legacyName) 

{

	delete sessions[user];

	sessions[user] = NULL;

	connectionState[user] = DISCONNECTED;

	onlineUsers.erase(user);

}

void TwitterPlugin::handleMessageSendRequest(const std::string &user, const std::string &legacyName, const std::string &message, const std::string &xhtml) 

{

	if(legacyName == "twitter-account") {

		//char ch;

		std::string cmd = "", data = "";

		int i;

		for(i=0 ; i<message.size() && message[i] != ' '; i++) cmd += message[i];

		while(i<message.size() && message[i] == ' ') i++;

		data = message.substr(i);

		//handleMessage(user, "twitter-account", cmd + " " + data);

		if(cmd == "#pin") tp->runAsThread(new PINExchangeProcess(np, sessions[user], user, data));

		else if(cmd == "#help") tp->runAsThread(new HelpMessageRequest(np, user));

		else if(cmd[0] == '@') {

			std::string username = cmd.substr(1); 

			tp->runAsThread(new DirectMessageRequest(sessions[user], user, username, data,

												     boost::bind(&TwitterPlugin::directMessageResponse, this, _1, _2, _3)));

		}

		else if(cmd == "#status") tp->runAsThread(new StatusUpdateRequest(np, sessions[user], user, data));

		else if(cmd == "#timeline") tp->runAsThread(new TimelineRequest(sessions[user], user, data, "",

														boost::bind(&TwitterPlugin::displayTweets, this, _1, _2, _3, _4)));

		else if(cmd == "#friends") tp->runAsThread(new FetchFriends(sessions[user], user,

													   boost::bind(&TwitterPlugin::displayFriendlist, this, _1, _2, _3)));

													   boost::bind(&TwitterPlugin::createFriendResponse, this, _1, _2, _3)));

													   boost::bind(&TwitterPlugin::deleteFriendResponse, this, _1, _2, _3)));

		else if(cmd == "#retweet") tp->runAsThread(new RetweetRequest(sessions[user], user, data,

													   boost::bind(&TwitterPlugin::RetweetResponse, this, _1, _2)));

		else handleMessage(user, "twitter-account", "Unknown command! Type #help for a list of available commands.");

	} 

	else {

		tp->runAsThread(new DirectMessageRequest(sessions[user], user, legacyName, message,

												 boost::bind(&TwitterPlugin::directMessageResponse, this, _1, _2, _3)));

	}

}

void TwitterPlugin::handleBuddyUpdatedRequest(const std::string &user, const std::string &buddyName, const std::string &alias, const std::vector<std::string> &groups) 

{

	if(connectionState[user] != CONNECTED) {

		LOG4CXX_ERROR(logger, user << " is not connected to twitter!")

		return;

	}

	tp->runAsThread(new CreateFriendRequest(sessions[user], user, buddyName, 

											boost::bind(&TwitterPlugin::createFriendResponse, this, _1, _2, _3)));

}

void TwitterPlugin::handleBuddyRemovedRequest(const std::string &user, const std::string &buddyName, const std::vector<std::string> &groups) 

{

	if(connectionState[user] != CONNECTED) {

		LOG4CXX_ERROR(logger, user << " is not connected to twitter!")

		return;

	}

	tp->runAsThread(new DestroyFriendRequest(sessions[user], user, buddyName, 

											 boost::bind(&TwitterPlugin::deleteFriendResponse, this, _1, _2, _3)));

}

void TwitterPlugin::pollForTweets()

{

	boost::mutex::scoped_lock lock(userlock);

	std::set<std::string>::iterator it = onlineUsers.begin();

	while(it != onlineUsers.end()) {

		std::string user = *it;

		tp->runAsThread(new TimelineRequest(sessions[user], user, "", mostRecentTweetID[user],

											boost::bind(&TwitterPlugin::displayTweets, this, _1, _2, _3, _4)));

		it++;

	}

	tweet_timer->start();

}

void TwitterPlugin::pollForDirectMessages()

{

	boost::mutex::scoped_lock lock(userlock);

	std::set<std::string>::iterator it = onlineUsers.begin();

	while(it != onlineUsers.end()) {

		std::string user = *it;

		tp->runAsThread(new DirectMessageRequest(sessions[user], user, "", mostRecentDirectMessageID[user],

											boost::bind(&TwitterPlugin::directMessageResponse, this, _1, _2, _3)));

		it++;

	}

	message_timer->start();

}

bool TwitterPlugin::getUserOAuthKeyAndSecret(const std::string user, std::string &key, std::string &secret) 

{

	boost::mutex::scoped_lock lock(dblock);

	UserInfo info;

	if(storagebackend->getUser(user, info) == false) {

		LOG4CXX_ERROR(logger, "Didn't find entry for " << user << " in the database!")

		return false;