libtransport.git Changeset - 1ba04372cbe3

Changeset - 1ba04372cbe3

Parent rev.

Child rev.

[Not reviewed]

0 1 0

Sarang Bharadwaj - 13 years ago 2012-05-29 14:32:47
sarang.bh@gmail.com

Added code to fetch user timeline

1 file changed with 32 insertions and 9 deletions:

backends/twitter/main.cpp

0 comments (0 inline, 0 general)

backends/twitter/main.cpp

➞

Show inline comments

@@ @@ -108,11 +108,13 @@ class TwitterPlugin : public NetworkPlugin { @@
 				std::string ppasswd = CONFIG_STRING(config,"proxy.password");
 				LOG4CXX_INFO(logger, ip << " " << port << " " << puser << " " << ppasswd)
 				sessions[user]->setProxyServerIp(ip);
 		        sessions[user]->setProxyServerPort(port);
 		        sessions[user]->setProxyUserName(puser);
 		        sessions[user]->setProxyPassword(ppasswd);
 				if(ip != "localhost" && port != "0") {
 					sessions[user]->setProxyServerIp(ip);
 		        	sessions[user]->setProxyServerPort(port);
 		        	sessions[user]->setProxyUserName(puser);
 		        	sessions[user]->setProxyPassword(ppasswd);
+				}
+			}
 			connectionState[user] = NEW;
@@ @@ -173,13 +175,16 @@ class TwitterPlugin : public NetworkPlugin { @@
 				if(cmd == "pin") {
 					sessions[user]->getOAuth().setOAuthPin( data );
 					sessions[user]->oAuthAccessToken();
 					if (sessions[user]->oAuthAccessToken() == false) {
 						LOG4CXX_ERROR(logger, "Error while exchanging PIN with AcessToken!")
 						handleLogoutRequest(user, "");
 						return;
+					}
 					std::string OAuthAccessTokenKey, OAuthAccessTokenSecret;
 					sessions[user]->getOAuth().getOAuthTokenKey( OAuthAccessTokenKey );
 					sessions[user]->getOAuth().getOAuthTokenSecret( OAuthAccessTokenSecret );
 					//db->insert(UserData(user, OAuthAccessTokenKey, OAuthAccessTokenSecret));
 					//registeredUsers.insert(user);
 					UserInfo info;
@@ @@ -206,15 +211,33 @@ class TwitterPlugin : public NetworkPlugin { @@
 					std::string replyMsg;
 					if( sessions[user]->statusUpdate( data ) ) {
 						sessions[user]->getLastWebResponse( replyMsg );
-						LOG4CXX_INFO(logger, "twitterClient:: twitCurl::statusUpdate web response: " << replyMsg );
 						LOG4CXX_INFO(logger, "twitCurl:statusUpdate web response: " << replyMsg );
+					}
 					else {
 						sessions[user]->getLastCurlError( replyMsg );
-						LOG4CXX_INFO(logger, "twitterClient:: twitCurl::statusUpdate error: " << replyMsg );
 						LOG4CXX_INFO(logger, "twitCurl::statusUpdate error: " << replyMsg );
+					}
 					LOG4CXX_INFO(logger, "Updated status for " << user << ": " << data);
+				}
 				if(cmd == "#timeline") {
 					if(connectionState[user] != CONNECTED) {
 						LOG4CXX_ERROR(logger, "Trying to update status for " << user << " when not connected!");
 						return;
+					}
 					std::string replyMsg;
 					if( sessions[user]->timelinePublicGet() ) {
 						sessions[user]->getLastWebResponse( replyMsg );
 						LOG4CXX_INFO(logger, "twitCurl::timeline web response: " << replyMsg );
 						handleMessage(user, "twitter-account", replyMsg);
 					} else {
 						sessions[user]->getLastCurlError( replyMsg );
 						LOG4CXX_INFO(logger, "twitCurl::timeline error: " << replyMsg );
+					}
+				}
+			}
+		}

0 comments (0 inline, 0 general)