Changeset - ae2c0acb5058
[Not reviewed]
0 2 0
Sarang Bharadwaj - 13 years ago 2012-05-30 20:14:41
sarang.bh@gmail.com
Directed Message
2 files changed with 33 insertions and 4 deletions:
0 comments (0 inline, 0 general)
backends/twitter/TwitterResponseParser.cpp
Show inline comments
 
#include "TwitterResponseParser.h"
 
#include "transport/logging.h"
 

	
 
DEFINE_LOGGER(logger, "TwitterResponseParser")
 

	
 
User getUser(const Swift::ParserElement::ref &element, const std::string xmlns) 
 
{
 
	User user;
 
	if(element->getName() != "user") {
 
		std::cerr << "Not a user element!" << std::endl;
 
		LOG4CXX_ERROR(logger, "Not a user element!")
 
		return user;
 
	}
 

	
 
@@ -19,7 +22,7 @@ Status getStatus(const Swift::ParserElement::ref &element, const std::string xml
 
{
 
	Status status;
 
	if(element->getName() != "status") {
 
		std::cerr << "Not a status element!" << std::endl;
 
		LOG4CXX_ERROR(logger, "Not a status element!")
 
		return status;
 
	}
 

	
 
@@ -43,7 +46,7 @@ std::vector<Status> getTimeline(std::string &xml)
 
	Swift::ParserElement::ref rootElement = Swift::StringTreeParser::parse(xml);
 
	
 
	if(rootElement->getName() != "statuses") {
 
		std::cerr << "XML doesnt correspond to timline\n";
 
		LOG4CXX_ERROR(logger, "XML doesnt correspond to timline")
 
		return statuses;
 
	}
 

	
backends/twitter/main.cpp
Show inline comments
 
@@ -203,6 +203,30 @@ class TwitterPlugin : public NetworkPlugin {
 
					LOG4CXX_INFO(logger, "Sent PIN " << data << " and obtained access token");
 
				}
 

	
 
				if(cmd == "#help") {
 
					std::string helpMsg = "\nHELP\n\
 
status:<your status> - Update your status\n\
 
#timeline - Retrieve your timeline\n\
 
@<username>:<message> - Send a directed message to the user <username>\n\
 
#help - print this help message\n";
 

	
 
					handleMessage(user, "twitter-account", helpMsg);
 
				}
 

	
 
				if(cmd[0] == '@') {
 
					std::string username = cmd.substr(1);
 
					if(sessions[user]->directMessageSend(username, data, false) == false) {
 
						LOG4CXX_ERROR(logger, "Error while sending directed message to user " << username );
 
						return;
 
					}
 

	
 
					LOG4CXX_INFO(logger, "Sending " << data << " to " << username)
 

	
 
					std::string replyMsg;
 
					sessions[user]->getLastWebResponse( replyMsg );
 
					LOG4CXX_INFO(logger, replyMsg);
 
				}
 

	
 
				if(cmd == "status") {
 
					if(connectionState[user] != CONNECTED) {
 
						LOG4CXX_ERROR(logger, "Trying to update status for " << user << " when not connected!");
 
@@ -238,9 +262,11 @@ class TwitterPlugin : public NetworkPlugin {
 
						LOG4CXX_INFO(logger, "twitCurl::timeline web response: " << replyMsg );
 
						
 
						std::vector<Status> tweets = getTimeline(replyMsg);
 
						std::string timeline = "\n";
 
						for(int i=0 ; i<tweets.size() ; i++) {
 
							handleMessage(user, "twitter-account", tweets[i].getTweet() + "\n");
 
							timeline += tweets[i].getTweet() + "\n";
 
						}
 
						handleMessage(user, "twitter-account", timeline);
 
					} else {
 
						sessions[user]->getLastCurlError( replyMsg );
 
						LOG4CXX_INFO(logger, "twitCurl::timeline error: " << replyMsg );
0 comments (0 inline, 0 general)