Changeset - dcdaeff7f2a4
[Not reviewed]
backends/twitter/Requests/CreateFriendRequest.cpp
Show inline comments
 
@@ -11,19 +11,19 @@ void CreateFriendRequest::run()
 

	
 
void CreateFriendRequest::finalize()
 
{
 
	if(!success) {
 
		std::string error;
 
		twitObj->getLastCurlError(error);
 
		LOG4CXX_ERROR(logger, user << " Curl error: " << error)
 
		LOG4CXX_ERROR(logger, user << " - Curl error: " << error)
 
		callBack(user, frnd, error);
 
	} else {
 
		std::string error;
 
		error = getErrorMessage(replyMsg);
 
		if(error.length()) {
 
			LOG4CXX_ERROR(logger, user << " " << error)
 
			LOG4CXX_ERROR(logger, user << " " << replyMsg)
 
			LOG4CXX_ERROR(logger, user << " - " << error)
 
			//LOG4CXX_ERROR(logger, user << " " << replyMsg)
 
		}
 
		else LOG4CXX_INFO(logger, user << ": Now following " << frnd)
 
		callBack(user, frnd, error);
 
	}
 
}
backends/twitter/Requests/DestroyFriendRequest.cpp
Show inline comments
 
@@ -10,15 +10,15 @@ void DestroyFriendRequest::run()
 

	
 
void DestroyFriendRequest::finalize()
 
{
 
	if(!success) {
 
		std::string error;
 
		twitObj->getLastCurlError(error);
 
		LOG4CXX_ERROR(logger, user << " " << error)
 
		LOG4CXX_ERROR(logger, user << " Curl error: " << error)
 
		callBack(user, frnd, error);
 
	} else {
 
		std::string error;
 
		error = getErrorMessage(replyMsg);
 
		if(error.length()) LOG4CXX_ERROR(logger, user << " " << error)
 
		if(error.length()) LOG4CXX_ERROR(logger, user << " - " << error)
 
		callBack(user, frnd, error);
 
	}
 
}
backends/twitter/Requests/DirectMessageRequest.cpp
Show inline comments
 
@@ -14,14 +14,14 @@ void DirectMessageRequest::run()
 
	}
 
}
 

	
 
void DirectMessageRequest::finalize()
 
{
 
	if(!success) {
 
		LOG4CXX_ERROR(logger, user << ": Error while sending directed message to " << username );
 
		twitObj->getLastCurlError( replyMsg );
 
		LOG4CXX_ERROR(logger, user << " Curl error: " << replyMsg);
 
		callBack(user, username, messages, replyMsg);
 
	} else {
 
		std::string error = getErrorMessage(replyMsg);
 
		if(error.length()) LOG4CXX_ERROR(logger,  user << " - " << error)
 
		else LOG4CXX_INFO(logger, user << " - " << replyMsg)
 
		callBack(user, username, messages, error);	
backends/twitter/Requests/FetchFriends.cpp
Show inline comments
 
@@ -6,20 +6,20 @@ void FetchFriends::run()
 
	replyMsg = ""; 
 

	
 
	success = twitObj->friendsIdsGet(twitObj->getTwitterUsername());
 
	if(!success) return;	
 

	
 
	twitObj->getLastWebResponse( replyMsg );
 
	LOG4CXX_INFO(logger, user << " - " << replyMsg.length() << " " << replyMsg << "\n" );
 
	//LOG4CXX_INFO(logger, user << " - " << replyMsg.length() << " " << replyMsg << "\n" );
 
	std::vector<std::string> IDs = getIDs( replyMsg );
 
	
 
	success = twitObj->userLookup(IDs, true);
 
	if(!success) return;
 

	
 
	twitObj->getLastWebResponse( replyMsg );
 
	LOG4CXX_INFO(logger, user << " - UserLookUp web response - " << replyMsg.length() << " " << replyMsg << "\n" );
 
	//LOG4CXX_INFO(logger, user << " - UserLookUp web response - " << replyMsg.length() << " " << replyMsg << "\n" );
 
	friends = getUsers( replyMsg );
 
}
 

	
 
void FetchFriends::finalize()
 
{
 
	if(!success) {
backends/twitter/Requests/RetweetRequest.cpp
Show inline comments
 
@@ -8,16 +8,16 @@ void RetweetRequest::run()
 

	
 
void RetweetRequest::finalize()
 
{
 
	replyMsg = "";
 
	if(!success) {
 
		twitObj->getLastCurlError( replyMsg );
 
		LOG4CXX_ERROR(logger, user << " " << replyMsg)
 
		LOG4CXX_ERROR(logger, user << " Curl error: " << replyMsg)
 
		callBack(user, replyMsg);
 
	} else {
 
		twitObj->getLastWebResponse( replyMsg );
 
		std::string error = getErrorMessage( replyMsg );
 
		if(error.length()) LOG4CXX_ERROR(logger, user << " " << error)
 
		if(error.length()) LOG4CXX_ERROR(logger, user << " - " << error)
 
		else LOG4CXX_INFO(logger, user << " " << replyMsg);
 
		callBack(user, error);
 
	}
 
}
backends/twitter/Requests/StatusUpdateRequest.cpp
Show inline comments
 
@@ -13,15 +13,15 @@ void StatusUpdateRequest::run()
 
}
 

	
 
void StatusUpdateRequest::finalize()
 
{
 
	if(!success) {
 
		twitObj->getLastCurlError( replyMsg );
 
		LOG4CXX_ERROR(logger, user << ": CurlError - " << replyMsg );
 
		LOG4CXX_ERROR(logger, user << " - Curl error: " << replyMsg );
 
		callBack(user, replyMsg);
 
	} else {
 
		std::string error = getErrorMessage(replyMsg);
 
		if(error.length()) LOG4CXX_ERROR(logger, user << ": " << error)
 
		if(error.length()) LOG4CXX_ERROR(logger, user << " - " << error)
 
		else LOG4CXX_INFO(logger, "Updated status for " << user << ": " << data);
 
		callBack(user, error);
 
	}
 
}
backends/twitter/Requests/TimelineRequest.cpp
Show inline comments
 
@@ -5,27 +5,24 @@ void TimelineRequest::run()
 
	LOG4CXX_INFO(logger, "Sending timeline request for user " << userRequested)
 
	
 
	if(userRequested != "") success = twitObj->timelineUserGet(false, false, 20, userRequested, false);
 
	else success = twitObj->timelineHomeGet(since_id);
 
	
 
	if(!success) return;
 

	
 
	replyMsg = ""; 
 
	
 
	replyMsg = ""; 
 
	twitObj->getLastWebResponse( replyMsg );
 

	
 
	LOG4CXX_INFO(logger, user << " - " << replyMsg.length() << " " << replyMsg << "\n" );
 
	
 
	//LOG4CXX_INFO(logger, user << " - " << replyMsg.length() << " " << replyMsg << "\n" );
 
	tweets = getTimeline(replyMsg);
 
}
 

	
 
void TimelineRequest::finalize()
 
{
 
	if(!success) {
 
		twitObj->getLastCurlError( replyMsg );
 
		LOG4CXX_ERROR(logger,  user << " - " << replyMsg)
 
		LOG4CXX_ERROR(logger,  user << " - Curl error: " << replyMsg)
 
		callBack(user, userRequested, tweets, replyMsg);
 
	} else {
 
		std::string error = getErrorMessage(replyMsg);
 
		if(error.length()) LOG4CXX_ERROR(logger,  user << " - " << error)
 
		callBack(user, userRequested, tweets, error);
 
	} 
backends/twitter/TwitterPlugin.cpp
Show inline comments
 
@@ -447,15 +447,15 @@ void TwitterPlugin::pinExchangeComplete(const std::string user, const std::strin
 
		
 
	sessions[user]->getOAuth().setOAuthTokenKey( OAuthAccessTokenKey );
 
	sessions[user]->getOAuth().setOAuthTokenSecret( OAuthAccessTokenSecret );
 
	connectionState[user] = CONNECTED;
 
	twitterMode[user] = (mode)getTwitterMode(user);
 
	
 
	//if(twitterMode[user] == MULTIPLECONTACT) {
 
	tp->runAsThread(new FetchFriends(sessions[user], user, boost::bind(&TwitterPlugin::populateRoster, this, _1, _2, _3)));
 
	//}
 
	if(twitterMode[user] == MULTIPLECONTACT) {
 
		tp->runAsThread(new FetchFriends(sessions[user], user, boost::bind(&TwitterPlugin::populateRoster, this, _1, _2, _3)));
 
	}
 

	
 
	onlineUsers.insert(user);
 
	mostRecentTweetID[user] = "";
 
	mostRecentDirectMessageID[user] = "";
 
}	
 

	
 
@@ -508,28 +508,29 @@ void TwitterPlugin::helpMessageResponse(std::string &user, std::string &msg)
 
void TwitterPlugin::clearRoster(const std::string user)
 
{
 
	if(buddies[user].size() == 0) return;
 
	std::set<std::string>::iterator it = buddies[user].begin();
 
	while(it != buddies[user].end()) {
 
		handleBuddyChanged(user, *it, *it, std::vector<std::string>(), pbnetwork::STATUS_NONE);
 
		//handleBuddyRemoved(user, *it);
 
		handleBuddyRemoved(user, *it);
 
		it++;
 
	}
 
	//buddies[user].clear();
 
	buddies[user].clear();
 
}
 

	
 
void TwitterPlugin::populateRoster(std::string &user, std::vector<User> &friends, std::string &errMsg) 
 
{
 
	if(errMsg.length() == 0) 
 
	{
 
		for(int i=0 ; i<friends.size() ; i++) {
 
			if(twitterMode[user] == MULTIPLECONTACT)
 
				handleBuddyChanged(user, friends[i].getScreenName(), friends[i].getScreenName(), std::vector<std::string>(), pbnetwork::STATUS_ONLINE);
 
			else if(twitterMode[user] == CHATROOM) 
 
			else if(twitterMode[user] == CHATROOM) {
 
				handleParticipantChanged(user, friends[i].getScreenName(), adminChatRoom, 0, pbnetwork::STATUS_ONLINE);
 
			buddies[user].insert(friends[i].getScreenName());
 
				buddies[user].insert(friends[i].getScreenName());
 
			}
 
		}
 
	} else handleMessage(user, twitterMode[user] == CHATROOM ? adminChatRoom : adminLegacyName,
 
							   std::string("Error populating roster - ") + errMsg, twitterMode[user] == CHATROOM ? adminNickName : "");	
 

	
 
	if(twitterMode[user] == CHATROOM) handleParticipantChanged(user, nickName[user], adminChatRoom, 0, pbnetwork::STATUS_ONLINE);
 
}
 
@@ -635,18 +636,20 @@ void TwitterPlugin::createFriendResponse(std::string &user, std::string &frnd, s
 
							errMsg, twitterMode[user] == CHATROOM ? adminNickName : "");
 
		return;
 
	}
 

	
 
	handleMessage(user, twitterMode[user] == CHATROOM ? adminChatRoom : adminLegacyName,
 
						std::string("You are now following ") + frnd, twitterMode[user] == CHATROOM ? adminNickName : "");
 
	buddies[user].insert(frnd);
 
	handleBuddyChanged(user, frnd, frnd, std::vector<std::string>(), pbnetwork::STATUS_NONE);
 
	
 
	//buddies[user].insert(frnd);
 
	//handleBuddyChanged(user, frnd, frnd, std::vector<std::string>(), pbnetwork::STATUS_NONE);
 

	
 
	if(twitterMode[user] == MULTIPLECONTACT) {
 
		handleBuddyChanged(user, frnd, frnd, std::vector<std::string>(), pbnetwork::STATUS_ONLINE);
 
	} else if(twitterMode[user] == CHATROOM) {
 
		buddies[user].insert(frnd);
 
		handleParticipantChanged(user, frnd, adminChatRoom, 0, pbnetwork::STATUS_ONLINE);
 
	}
 
}
 

	
 
void TwitterPlugin::deleteFriendResponse(std::string &user, std::string &frnd, std::string &errMsg)
 
{
 
@@ -655,20 +658,22 @@ void TwitterPlugin::deleteFriendResponse(std::string &user, std::string &frnd, s
 
							errMsg, twitterMode[user] == CHATROOM ? adminNickName : "");
 
		return;
 
	} 
 
	
 
	handleMessage(user, twitterMode[user] == CHATROOM ? adminChatRoom : adminLegacyName,
 
						std::string("You are not following ") + frnd + " anymore", twitterMode[user] == CHATROOM ? adminNickName : "");
 
	
 
	if (twitterMode[user] == CHATROOM) {
 
		handleParticipantChanged(user, frnd, adminLegacyName, 0, pbnetwork::STATUS_NONE);
 
		buddies[user].erase(frnd);
 
	}
 
	buddies[user].erase(frnd);
 
	handleBuddyRemoved(user, frnd);
 
	//if(twitterMode[user] == MULTIPLECONTACT) {
 
	//	handleBuddyRemoved(user, frnd);
 
	//} 
 
	//buddies[user].erase(frnd);
 
	//handleBuddyRemoved(user, frnd);
 
	if(twitterMode[user] == MULTIPLECONTACT) {
 
		handleBuddyRemoved(user, frnd);
 
	} 
 
}
 

	
 

	
 
void TwitterPlugin::RetweetResponse(std::string &user, std::string &errMsg)
 
{
 
	if(errMsg.length()) {
0 comments (0 inline, 0 general)