void TwitterPlugin::OAuthFlowComplete(const std::string user, twitCurl *obj) 

{

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

	delete userdb[user].sessions;

	userdb[user].sessions = obj->clone();	

	userdb[user].connectionState = WAITING_FOR_PIN;

}	

void TwitterPlugin::pinExchangeComplete(const std::string user, const std::string OAuthAccessTokenKey, const std::string OAuthAccessTokenSecret) 

{

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

	userdb[user].sessions->getOAuth().setOAuthTokenKey( OAuthAccessTokenKey );

	userdb[user].sessions->getOAuth().setOAuthTokenSecret( OAuthAccessTokenSecret );

	userdb[user].connectionState = CONNECTED;

	userdb[user].twitterMode = (mode)getTwitterMode(user);

	if(userdb[user].twitterMode == MULTIPLECONTACT) {

		tp->runAsThread(new FetchFriends(userdb[user].sessions, user, boost::bind(&TwitterPlugin::populateRoster, this, _1, _2, _3, _4)));

	}

	onlineUsers.insert(user);

	userdb[user].mostRecentTweetID = "";

	userdb[user].mostRecentDirectMessageID = "";

}	

void TwitterPlugin::updateLastTweetID(const std::string user, const std::string ID)

{

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

	userdb[user].mostRecentTweetID = ID;

	UserInfo info;

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

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

		return;

	}

	storagebackend->updateUserSetting((long)info.id, "twitter_last_tweet", ID);

}

std::string TwitterPlugin::getMostRecentTweetIDUnsafe(const std::string user)

{	

	std::string ID = "";

	if(onlineUsers.count(user)) {

		ID = userdb[user].mostRecentTweetID;

		if (ID.empty()) {

			int type;

			UserInfo info;

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

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

			}

			else {

				storagebackend->getUserSetting(info.id, "twitter_last_tweet", type, ID);

			}

		}

	}

	return ID;

}

std::string TwitterPlugin::getMostRecentTweetID(const std::string user)

{	

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

	return getMostRecentTweetIDUnsafe(user);

}

void TwitterPlugin::updateLastDMID(const std::string user, const std::string ID)

{

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

	userdb[user].mostRecentDirectMessageID = ID;

	UserInfo info;

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

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

		return;

	}

	storagebackend->updateUserSetting((long)info.id, "twitter_last_dm", ID);

}

std::string TwitterPlugin::getMostRecentDMIDUnsafe(const std::string user) {

	std::string ID = "";

	if(onlineUsers.count(user)) {

		ID = userdb[user].mostRecentDirectMessageID;

		if (ID.empty()) {

			int type;

			UserInfo info;

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

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

			}

			else {

				storagebackend->getUserSetting(info.id, "twitter_last_dm", type, ID);

			}

		}

	}

}

std::string TwitterPlugin::getMostRecentDMID(const std::string user)

{

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

	return getMostRecentDMIDUnsafe(user);

}

/************************************** Twitter response functions **********************************/

void TwitterPlugin::statusUpdateResponse(std::string &user, Error &errMsg)

{

	if(errMsg.getMessage().length()) {

		if (errMsg.isCurlError()) {

			handleDisconnected(user, 3, errMsg.getMessage());

			return;

		}

		handleMessage(user, userdb[user].twitterMode == CHATROOM ? adminChatRoom : adminLegacyName,

							errMsg.getMessage(), userdb[user].twitterMode == CHATROOM ? adminNickName : "");

	} else {

		handleMessage(user, userdb[user].twitterMode == CHATROOM ? adminChatRoom : adminLegacyName,

							"Status Update successful", userdb[user].twitterMode == CHATROOM ? adminNickName : "");

	}

}

void TwitterPlugin::helpMessageResponse(std::string &user, std::string &msg)

{

	handleMessage(user, userdb[user].twitterMode == CHATROOM ? adminChatRoom : adminLegacyName,

						msg, userdb[user].twitterMode == CHATROOM ? adminNickName : "");

}

void TwitterPlugin::clearRoster(const std::string user)

{

	if(userdb[user].buddies.size() == 0) return;

	std::set<std::string>::iterator it = userdb[user].buddies.begin();

	while(it != userdb[user].buddies.end()) {

		handleBuddyRemoved(user, *it);

		it++;

	}

	userdb[user].buddies.clear();

}

void TwitterPlugin::populateRoster(std::string &user, std::vector<User> &friends, std::vector<std::string> &friendAvatars, Error &errMsg) 

{

	if(errMsg.getMessage().length() == 0) 

	{

		for(int i=0 ; i<friends.size() ; i++) {

			userdb[user].buddies.insert(friends[i].getScreenName());

			userdb[user].buddiesInfo[friends[i].getScreenName()] = friends[i];

			userdb[user].buddiesImgs[friends[i].getScreenName()] = friendAvatars[i];

			if(userdb[user].twitterMode == MULTIPLECONTACT) {

				std::string lastTweet = friends[i].getLastStatus().getTweet();

				//LOG4CXX_INFO(logger, user << " - " << SHA(friendAvatars[i]))

				handleBuddyChanged(user, friends[i].getScreenName(), friends[i].getUserName(), std::vector<std::string>(), 

								   pbnetwork::STATUS_ONLINE, lastTweet, SHA(friendAvatars[i]));

			}

			else if(userdb[user].twitterMode == CHATROOM)

				handleParticipantChanged(user, friends[i].getScreenName(), adminChatRoom, 0, pbnetwork::STATUS_ONLINE);

			/*handleMessage(user, userdb[user].twitterMode == CHATROOM ? adminChatRoom : adminLegacyName,

							   	friends[i].getScreenName() + " - " + friends[i].getLastStatus().getTweet(), 

								userdb[user].twitterMode == CHATROOM ? adminNickName : "");*/

		}

	} else {

		if (errMsg.isCurlError()) {

			handleDisconnected(user, 3, errMsg.getMessage());

			return;

		}

		handleMessage(user, userdb[user].twitterMode == CHATROOM ? adminChatRoom : adminLegacyName,

							   std::string("Error populating roster - ") + errMsg.getMessage(), userdb[user].twitterMode == CHATROOM ? adminNickName : "");

	}

	if(userdb[user].twitterMode == CHATROOM) handleParticipantChanged(user, userdb[user].nickName, adminChatRoom, 0, pbnetwork::STATUS_ONLINE);

}

void TwitterPlugin::displayFriendlist(std::string &user, std::vector<User> &friends, std::vector<std::string> &friendAvatars, Error &errMsg)

{

	if(errMsg.getMessage().length() == 0) 

	{

		std::string userlist = "\n***************USER LIST****************\n";

		for(int i=0 ; i < friends.size() ; i++) {

			userlist += " - " + friends[i].getUserName() + " (" + friends[i].getScreenName() + ")\n";

		}	

		userlist += "***************************************\n";

		handleMessage(user, userdb[user].twitterMode == CHATROOM ? adminChatRoom : adminLegacyName,

							userlist, userdb[user].twitterMode == CHATROOM ? adminNickName : "");	

	} else {

		if (errMsg.isCurlError()) {

			handleDisconnected(user, 3, errMsg.getMessage());

			return;

		}

		handleMessage(user, userdb[user].twitterMode == CHATROOM ? adminChatRoom : adminLegacyName, 

							   errMsg.getMessage(), userdb[user].twitterMode == CHATROOM ? adminNickName : "");	

	}

}