blob: b71ff70408c5c9edcdde0f0ff4da22582f027402 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
|
#include "client.h"
#include <curl_easy.h>
#include <curl_header.h>
#include <sstream>
#include <set>
#include <algorithm>
#include <liboauthcpp/liboauthcpp.h>
namespace twitter {
client::client(const auth& _arg)
{
_oauth_consumer = new OAuth::Consumer(_arg.getConsumerKey(), _arg.getConsumerSecret());
_oauth_token = new OAuth::Token(_arg.getAccessKey(), _arg.getAccessSecret());
_oauth_client = new OAuth::Client(_oauth_consumer, _oauth_token);
}
client::~client()
{
delete _oauth_client;
delete _oauth_token;
delete _oauth_consumer;
}
response client::updateStatus(std::string msg, tweet& result)
{
std::ostringstream output;
curl::curl_ios<std::ostringstream> ios(output);
curl::curl_easy conn(ios);
std::stringstream datastrstream;
datastrstream << "status=" << OAuth::PercentEncode(msg);
std::string datastr = datastrstream.str();
std::string url = "https://api.twitter.com/1.1/statuses/update.json";
curl::curl_header headers;
std::string oauth_header = _oauth_client->getFormattedHttpHeader(OAuth::Http::Post, url, datastr);
if (!oauth_header.empty())
{
headers.add(oauth_header);
}
try {
conn.add<CURLOPT_URL>(url.c_str());
conn.add<CURLOPT_COPYPOSTFIELDS>(datastr.c_str());
conn.add<CURLOPT_POST>(1);
conn.add<CURLOPT_HTTPHEADER>(headers.get());
conn.perform();
} catch (curl::curl_easy_exception error)
{
error.print_traceback();
return response::curl_error;
}
long response_code = conn.get_info<CURLINFO_RESPONSE_CODE>().get();
json response_data = json::parse(output.str());
if (response_code == 200)
{
result = tweet(response_data);
return response::ok;
}
std::set<int> error_codes;
if (response_data.find("errors") != response_data.end())
{
std::transform(std::begin(response_data["errors"]), std::end(response_data["errors"]), std::inserter(error_codes, std::begin(error_codes)), [] (const json& error) {
return error["code"].get<int>();
});
}
if (error_codes.count(32) == 1 || error_codes.count(135) == 1 || error_codes.count(215) == 1)
{
return response::bad_auth;
} else if (error_codes.count(64) == 1)
{
return response::suspended;
} else if (error_codes.count(88) == 1 || error_codes.count(185) == 1)
{
return response::limited;
} else if (error_codes.count(89) == 1)
{
return response::bad_token;
} else if (error_codes.count(130) == 1)
{
return response::server_overloaded;
} else if (error_codes.count(131) == 1)
{
return response::server_error;
} else if (error_codes.count(186) == 1)
{
return response::bad_length;
} else if (error_codes.count(187) == 1)
{
return response::duplicate_status;
} else if (error_codes.count(226) == 1)
{
return response::suspected_spam;
} else if (error_codes.count(261) == 1)
{
return response::write_restricted;
} else if (response_code == 429)
{
return response::limited;
} else if (response_code == 500)
{
return response::server_error;
} else if (response_code == 502)
{
return response::server_unavailable;
} else if (response_code == 503)
{
return response::server_overloaded;
} else if (response_code == 504)
{
return response::server_timeout;
} else {
return response::unknown_error;
}
}
};
|
