stv0g/spectrum2
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Directed Message

Browse source
This commit is contained in:
Sarang Bharadwaj 2012-05-30 23:44:41 +05:30
parent 929b49d641
commit ae2c0acb50
2 changed files with 33 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
backends/twitter/TwitterResponseParser.cpp
View file

@ -1,10 +1,13 @@
#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;
}

28
backends/twitter/main.cpp
View file

@ -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 );