LOG4CXX_ERROR(logger, "Couldn't connect to chatroom - " << room <<"! Try twitter-chatroom as the chatroom to access Twitter account")

		handleMessage(user, adminLegacyName, "Couldn't connect to chatroom! Try twitter-chatroom as the chatroom to access Twitter account");

	}	

}

// User leaving a Chatroom

void TwitterPlugin::handleLeaveRoomRequest(const std::string &user, const std::string &room)

{

	if(room == adminChatRoom && onlineUsers.count(user)) {

		LOG4CXX_INFO(logger, "Leaving chatroom! Switching back to default mode 0")

		setTwitterMode(user, 0);

		handleBuddyChanged(user, adminLegacyName, adminAlias, std::vector<std::string>(), pbnetwork::STATUS_ONLINE);

	}

}

// Messages to be sent to Twitter 

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

{

	LOG4CXX_INFO(logger, "Received " << user << " --> " << legacyName << " - " << message)

	if(legacyName == adminLegacyName || legacyName == adminChatRoom)  {

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

		/** Parsing the message - Assuming message format to be <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);

		/***********************************************************************/

		if(cmd == "#pin") 

			tp->runAsThread(new PINExchangeProcess(np, userdb[user].sessions, user, data));

		else if(cmd == "#help") 

			tp->runAsThread(new HelpMessageRequest(user, boost::bind(&TwitterPlugin::helpMessageResponse, this, _1, _2)));

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

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

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

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

		}

		else if(cmd == "#status") 

			tp->runAsThread(new StatusUpdateRequest(userdb[user].sessions, user, data,

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

		else if(cmd == "#timeline") 

			tp->runAsThread(new TimelineRequest(userdb[user].sessions, user, data, "",

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

		else if(cmd == "#friends") 

			tp->runAsThread(new FetchFriends(userdb[user].sessions, user,

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

		else if(cmd == "#follow") 

			tp->runAsThread(new CreateFriendRequest(userdb[user].sessions, user, data.substr(0,data.find('@')),

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

		else if(cmd == "#unfollow") 

			tp->runAsThread(new DestroyFriendRequest(userdb[user].sessions, user, data.substr(0,data.find('@')),

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

		else if(cmd == "#retweet") 

			tp->runAsThread(new RetweetRequest(userdb[user].sessions, user, data,

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

		else if(cmd == "#mode") {

			int m = 0;

			m = atoi(data.c_str());

			mode prevm = userdb[user].twitterMode;

			if((mode)m == userdb[user].twitterMode) return; //If same as current mode return

			if(m < 0 || m > 2) { // Invalid modes

				handleMessage(user, adminLegacyName, std::string("Error! Unknown mode ") + data + ". Allowed values 0,1,2." );

				return;

			}

			setTwitterMode(user, m);

			if((userdb[user].twitterMode == SINGLECONTACT || userdb[user].twitterMode == CHATROOM) && prevm == MULTIPLECONTACT) clearRoster(user);

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

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

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

								std::string("Changed mode to ") + data, userdb[user].twitterMode == CHATROOM ? adminNickName : "");

			LOG4CXX_INFO(logger, user << ": Changed mode to " << data  << " <" << (userdb[user].twitterMode == CHATROOM ? adminNickName : "") << ">" )

		}

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

			std::string buddy = message.substr(0, message.find(":"));

			if(userdb[user].buddies.count(buddy) == 0) {

				tp->runAsThread(new StatusUpdateRequest(userdb[user].sessions, user, message,

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

			} else {

				data = message.substr(message.find(":")+1); //Can parse better??:P

				tp->runAsThread(new DirectMessageRequest(userdb[user].sessions, user, buddy, data,

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

			}

		}

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

				                 "Unknown command! Type #help for a list of available commands.", userdb[user].twitterMode == CHATROOM ? adminNickName : "");

	} 

	else {	

		if(userdb[user].twitterMode == CHATROOM) buddy = legacyName.substr(legacyName.find("/") + 1);

		if(legacyName != "twitter") {

			tp->runAsThread(new DirectMessageRequest(userdb[user].sessions, user, buddy, message,

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

		}

	}

}

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

{

	if(userdb[user].connectionState != CONNECTED) {

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

		return;

	}

	LOG4CXX_INFO(logger, user << " - Adding Twitter contact " << buddyName)

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

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

}

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

{

	if(userdb[user].connectionState != CONNECTED) {

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

		return;

	}

	LOG4CXX_INFO(logger, user << " - Removing Twitter contact " << buddyName)

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

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

}

void TwitterPlugin::handleVCardRequest(const std::string &user, const std::string &legacyName, unsigned int id)

{

	if(userdb[user].connectionState != CONNECTED) {

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

		return;

	}

	LOG4CXX_INFO(logger, user << " - VCardRequest for " << legacyName << ", " << userdb[user].buddiesInfo[legacyName].getProfileImgURL())

	if(getTwitterMode(user) != SINGLECONTACT && userdb[user].buddies.count(legacyName) 

		&& userdb[user].buddiesInfo[legacyName].getProfileImgURL().length()) {

		if(userdb[user].buddiesImgs.count(legacyName) == 0) {

			tp->runAsThread(new ProfileImageRequest(config, user, legacyName, userdb[user].buddiesInfo[legacyName].getProfileImgURL(), id,

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

		}

		handleVCard(user, id, legacyName, legacyName, "", userdb[user].buddiesImgs[legacyName]);

	}

}

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(userdb[user].sessions, user, "", getMostRecentTweetIDUnsafe(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(userdb[user].sessions, user, "", userdb[user].mostRecentDirectMessageID,

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

		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;

	}

	key="", secret=""; int type;

	storagebackend->getUserSetting((long)info.id, OAUTH_KEY, type, key);

	storagebackend->getUserSetting((long)info.id, OAUTH_SECRET, type, secret);

	return true;

}

bool TwitterPlugin::checkSpectrum1User(const std::string user) 

{