milkcocoa0902/CocoaTweet
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

とりあえずcURLを使って投げられるようなデータは作成できた(#47)(#48)(#49)

Browse Source
This commit is contained in:
keita
2021-02-17 00:03:57 +09:00
parent 0a7785ef73
commit 35394bd0ea
13 changed files with 333 additions and 299 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/cocoatweet/api/api.cc
+9 -9
View File
@@ -1,12 +1,12 @@
#include <cocoatweet/api/api.h>
namespace CocoaTweet::API{
API::API(CocoaTweet::OAuth::Key _key){
oauth_ = std::make_shared<CocoaTweet::OAuth::OAuth1>(_key);
status_ = Statuses::Status(oauth_);
}
namespace CocoaTweet::API {
API::API(CocoaTweet::OAuth::Key _key) {
oauth_ = std::make_shared<CocoaTweet::OAuth::OAuth1>(_key);
status_ = Statuses::Status(oauth_);
}
Statuses::Status API::status() const{
return status_;
}
}
Statuses::Status API::status() const {
return status_;
}
} // namespace CocoaTweet::API
src/cocoatweet/api/api.h
+10 -9
View File
@@ -4,15 +4,16 @@
#include "cocoatweet/api/status/status.h"
#include "cocoatweet/oauth/oauth.h"
namespace CocoaTweet::API{
class API{
public:
API(CocoaTweet::OAuth::Key _key);
Statuses::Status status() const;
private:
Statuses::Status status_;
std::shared_ptr<CocoaTweet::OAuth::OAuth1> oauth_;
namespace CocoaTweet::API {
class API {
public:
API(CocoaTweet::OAuth::Key _key);
Statuses::Status status() const;
private:
Statuses::Status status_;
std::shared_ptr<CocoaTweet::OAuth::OAuth1> oauth_;
};
}
} // namespace CocoaTweet::API
#endif
src/cocoatweet/api/groupInterface.h
+4 -4
View File
@@ -4,11 +4,11 @@
#include <memory>
#include "cocoatweet/oauth/oauth.h"
namespace CocoaTweet::API{
class groupInterface{
namespace CocoaTweet::API {
class groupInterface {
protected:
std::weak_ptr<CocoaTweet::OAuth::OAuth1> oauth_;
std::weak_ptr<CocoaTweet::OAuth::OAuth1> oauth_;
};
}
} // namespace CocoaTweet::API
#endif
src/cocoatweet/api/interface.cc
+6 -6
View File
@@ -1,9 +1,9 @@
#include <cocoatweet/api/interface.h>
namespace CocoaTweet::API{
size_t Interface::curlCallback_(char* _ptr, size_t _size, size_t _nmemb, std::string* _stream){
int realsize = _size * _nmemb;
_stream->append(_ptr, realsize);
return realsize;
}
namespace CocoaTweet::API {
size_t Interface::curlCallback_(char* _ptr, size_t _size, size_t _nmemb, std::string* _stream) {
int realsize = _size * _nmemb;
_stream->append(_ptr, realsize);
return realsize;
}
} // namespace CocoaTweet::API
src/cocoatweet/api/interface.h
+10 -8
View File
@@ -4,16 +4,18 @@
#include <functional>
#include "cocoatweet/oauth/oauth.h"
namespace CocoaTweet::API{
class Interface{
namespace CocoaTweet::API {
class Interface {
public:
virtual void process(std::weak_ptr<CocoaTweet::OAuth::OAuth1> _oauth, std::function<void(std::string)> _callback) = 0;
virtual void process(std::weak_ptr<CocoaTweet::OAuth::OAuth1> _oauth,
std::function<void(std::string)> _callback) = 0;
protected:
std::weak_ptr<CocoaTweet::OAuth::OAuth1> oauth_;
std::map<std::string, std::string> param_;
std::string url_;
static size_t curlCallback_(char* _ptr, size_t _size, size_t _nmemb, std::string* _stream);
std::weak_ptr<CocoaTweet::OAuth::OAuth1> oauth_;
std::map<std::string, std::string> param_;
std::string url_;
static size_t curlCallback_(char* _ptr, size_t _size, size_t _nmemb, std::string* _stream);
};
}
} // namespace CocoaTweet::API
#endif
src/cocoatweet/api/status/status.cc
+10 -10
View File
@@ -3,14 +3,14 @@
#include "cocoatweet/api/status/status.h"
#include "cocoatweet/api/status/update.h"
namespace CocoaTweet::API::Statuses{
Status::Status(std::shared_ptr<CocoaTweet::OAuth::OAuth1> _oauth){
oauth_ = _oauth;
}
void Status::Update(const std::string& _status)const{
CocoaTweet::API::Statuses::Update update;
update.status(_status);
update.process(oauth_, [](std::string _rcv){std::cout << _rcv << std::endl;});
}
namespace CocoaTweet::API::Statuses {
Status::Status(std::shared_ptr<CocoaTweet::OAuth::OAuth1> _oauth) {
oauth_ = _oauth;
}
void Status::Update(const std::string& _status) const {
CocoaTweet::API::Statuses::Update update;
update.status(_status);
update.process(oauth_, [](std::string _rcv) { std::cout << _rcv << std::endl; });
}
} // namespace CocoaTweet::API::Statuses
src/cocoatweet/api/status/status.h
+9 -8
View File
@@ -4,14 +4,15 @@
#include "cocoatweet/api/groupInterface.h"
#include "cocoatweet/oauth/oauth.h"
namespace CocoaTweet::API::Statuses{
class Status : public groupInterface{
public:
Status() = default;
Status(std::shared_ptr<CocoaTweet::OAuth::OAuth1> _oauth);
void Update(const std::string& _status) const;
private:
namespace CocoaTweet::API::Statuses {
class Status : public groupInterface {
public:
Status() = default;
Status(std::shared_ptr<CocoaTweet::OAuth::OAuth1> _oauth);
void Update(const std::string& _status) const;
private:
};
}
} // namespace CocoaTweet::API::Statuses
#endif
src/cocoatweet/api/status/update.cc
+84 -83
View File
@@ -1,4 +1,5 @@
#include "cocoatweet/api/status/update.h"
#include "cocoatweet/util/util.h"
#include <iterator>
#include <memory>
#include <vector>
@@ -8,87 +9,87 @@ extern "C" {
#include <curl/curl.h>
}
namespace CocoaTweet::API::Statuses{
Update::Update(){
url_ = "https://api.twitter.com/1.1/statuses/update.json";
}
void Update::status(const std::string _status){
status_ = _status;
param_.insert_or_assign("status", status_);
}
void Update::process(std::weak_ptr<CocoaTweet::OAuth::OAuth1> _oauth, std::function<void(std::string)> _callback){
// エンドポイントへのパラメータにOAuthパラメータを付加して署名作成
auto oauth = _oauth.lock();
param_.merge(oauth->oauthParam());
auto signature = oauth->signature(param_, "POST", url_);
// 作成した署名をエンドポイントへのパラメータ及びOAuthパラメータに登録
param_.insert_or_assign("oauth_signature", signature["oauth_signature"]);
auto header = oauth->oauthParam();
std::cout << "signature : " << signature["oauth_signature"] << std::endl;
header.insert_or_assign("oauth_signature", signature["oauth_signature"]);
// リクエストボディの構築
std::string requestBody = "";
{
std::vector<std::string> tmp;
for(const auto& [key, value] : param_){
tmp.push_back(key + "=" + value);
}
std::stringstream os;
std::copy(tmp.begin(), tmp.end(), std::ostream_iterator<std::string>(os, "&"));
requestBody = os.str();
requestBody.erase(requestBody.size() - std::char_traits<char>::length("&"));
}
std::cout << "Body : " << requestBody << std::endl;
// ヘッダの構築
std::string oauthHeader = "Authorization: OAuth ";
{
std::vector<std::string> tmp;
for(const auto& [key, value] : header){
tmp.push_back(key + "=" + value);
}
std::stringstream os;
std::copy(tmp.begin(), tmp.end(), std::ostream_iterator<std::string>(os, ","));
oauthHeader += os.str();
oauthHeader.erase(oauthHeader.size() - std::char_traits<char>::length(","));
}
std::cout << "OAuth Header : " << oauthHeader << std::endl;
// do post
CURL *curl;
CURLcode res;
std::string rcv;
curl = curl_easy_init();
std::cout << "URL : " << url_ << std::endl;
if (curl){
curl_easy_setopt(curl, CURLOPT_URL, url_.c_str());
curl_easy_setopt(curl, CURLOPT_POST, 1);
curl_easy_setopt(curl, CURLOPT_POSTFIELDS, requestBody);
curl_easy_setopt(curl, CURLOPT_POSTFIELDSIZE, requestBody.length());
curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, curlCallback_);
curl_easy_setopt(curl, CURLOPT_WRITEDATA, (std::string*)&rcv);
curl_easy_setopt(curl, CURLOPT_PROXY, "");
//Headerを保持するcurl_slist*を初期化
struct curl_slist *headers = NULL;
//Authorizationをヘッダに追加
headers = curl_slist_append(headers, oauthHeader.c_str());
curl_easy_setopt(curl, CURLOPT_HEADER, headers);
res = curl_easy_perform(curl);
curl_easy_cleanup(curl);
}
if (res != CURLE_OK) {
std::cout << "curl error : " << res << std::endl;
exit (1);
}
if(_callback){
_callback(rcv);
}
}
namespace CocoaTweet::API::Statuses {
Update::Update() {
url_ = "https://api.twitter.com/1.1/statuses/update.json";
}
void Update::status(const std::string _status) {
status_ = _status;
param_.insert_or_assign("status", status_);
}
void Update::process(std::weak_ptr<CocoaTweet::OAuth::OAuth1> _oauth,
std::function<void(std::string)> _callback) {
// エンドポイントへのパラメータにOAuthパラメータを付加して署名作成
auto oauth = _oauth.lock();
param_.merge(oauth->oauthParam());
auto signature = oauth->signature(param_, "POST", url_);
// 作成した署名をエンドポイントへのパラメータ及びOAuthパラメータに登録
param_.insert_or_assign("oauth_signature", signature["oauth_signature"]);
auto header = oauth->oauthParam();
std::cout << "signature : " << signature["oauth_signature"] << std::endl;
header.insert_or_assign("oauth_signature", signature["oauth_signature"]);
// リクエストボディの構築
std::string requestBody = "";
{
std::vector<std::string> tmp;
for (const auto& [key, value] : param_) {
tmp.push_back(key + "=" + value);
}
std::stringstream os;
std::copy(tmp.begin(), tmp.end(), std::ostream_iterator<std::string>(os, "&"));
requestBody = os.str();
requestBody.erase(requestBody.size() - std::char_traits<char>::length("&"));
}
requestBody += (std::string("&") + "oauth_signature=" + signature["oauth_signature"]);
std::cout << "request Body -> " << requestBody << std::endl;
// ヘッダの構築
std::string oauthHeader = "Authorization: OAuth ";
{
std::vector<std::string> tmp;
for (const auto& [key, value] : header) {
tmp.push_back(key + "=" + value);
}
std::stringstream os;
std::copy(tmp.begin(), tmp.end(), std::ostream_iterator<std::string>(os, ","));
oauthHeader += os.str();
oauthHeader.erase(oauthHeader.size() - std::char_traits<char>::length(","));
}
//oauthHeader += (std::string(",") + "oauth_signature=" + signature["oauth_signature"]);
std::cout << "OAuth Header -> " << oauthHeader << std::endl;
// do post
CURL* curl;
CURLcode res;
std::string rcv;
curl = curl_easy_init();
std::cout << "URL : " << url_ << std::endl;
if (curl) {
curl_easy_setopt(curl, CURLOPT_URL, url_.c_str());
curl_easy_setopt(curl, CURLOPT_POST, 1);
curl_easy_setopt(curl, CURLOPT_POSTFIELDS, requestBody);
curl_easy_setopt(curl, CURLOPT_POSTFIELDSIZE, requestBody.length());
curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, curlCallback_);
curl_easy_setopt(curl, CURLOPT_WRITEDATA, (std::string*)&rcv);
curl_easy_setopt(curl, CURLOPT_PROXY, "");
// Headerを保持するcurl_slist*を初期化
struct curl_slist* headers = NULL;
// Authorizationをヘッダに追加
headers = curl_slist_append(headers, oauthHeader.c_str());
curl_easy_setopt(curl, CURLOPT_HEADER, headers);
res = curl_easy_perform(curl);
curl_easy_cleanup(curl);
}
if (res != CURLE_OK) {
std::cout << "curl error : " << res << std::endl;
exit(1);
}
if (_callback) {
_callback(rcv);
}
}
} // namespace CocoaTweet::API::Statuses
src/cocoatweet/api/status/update.h
+9 -7
View File
@@ -6,15 +6,17 @@
#include "cocoatweet/api/interface.h"
//#include "cocoatweet/oauth/oauth.h"
namespace CocoaTweet::API::Statuses{
class Update :public Interface{
namespace CocoaTweet::API::Statuses {
class Update : public Interface {
public:
Update();
void status(const std::string _status);
void process(std::weak_ptr<CocoaTweet::OAuth::OAuth1> _oauth, std::function<void(std::string)> _callback);
Update();
void status(const std::string _status);
void process(std::weak_ptr<CocoaTweet::OAuth::OAuth1> _oauth,
std::function<void(std::string)> _callback);
private:
std::string status_;
std::string status_;
};
}
} // namespace CocoaTweet::API::Statuses
#endif