HTTP/GETの実装(#66)

2021-03-19 22:18:39 +09:00
parent bafa269c4e
commit 38e8795e06
2 changed files with 121 additions and 0 deletions
@@ -0,0 +1,98 @@
+#include <cocoatweet/api/interface/httpGet.h>
+#include "cocoatweet/util/util.h"
+#include <iterator>
+#include <memory>
+#include <vector>
+#include <sstream>
+#include <stdexcept>
+extern "C" {
+#include <curl/curl.h>
+}
+
+#ifndef NDEBUG
+#include <iostream>
+#endif
+
+namespace CocoaTweet::API::Interface {
+void HttpGet::process(std::weak_ptr<CocoaTweet::OAuth::OAuth1> _oauth,
+                      std::function<void(const unsigned int, const std::string&)> _callback) {
+  auto url = url_;
+
+  // エンドポイントへのパラメータにOAuthパラメータを付加して署名作成
+  auto oauth       = _oauth.lock();
+  auto oauthParam  = oauth->oauthParam();
+  auto sigingParam = oauthParam;
+  if (contentType_ == "application/x-www-form-urlencoded") {
+    for (const auto [k, v] : bodyParam_) {
+      sigingParam.insert_or_assign(k, v);
+    }
+  }
+
+  auto signature = oauth->signature(sigingParam, "GET", url_);
+
+  // 作成した署名をエンドポイントへのパラメータ及びOAuthパラメータに登録
+  oauthParam.merge(signature);
+
+  // URLの構築
+  {
+    std::vector<std::string> tmp;
+    for (const auto& [key, value] : bodyParam_) {
+      tmp.push_back(key + "=" + value);
+    }
+    url_ += std::string("?" + CocoaTweet::Util::join(tmp, "&"));
+  }
+
+  // ヘッダの構築
+  std::string oauthHeader = "authorization: OAuth ";
+  {
+    std::vector<std::string> tmp;
+    for (const auto& [key, value] : oauthParam) {
+      tmp.push_back(key + "=" + CocoaTweet::Util::urlEncode(value));
+    }
+    oauthHeader += CocoaTweet::Util::join(tmp, ",");
+  }
+
+  // do post
+  CURL* curl;
+  CURLcode res;
+  std::string rcv;
+  long responseCode;
+  curl = curl_easy_init();
+  url_ = url_;
+  if (curl) {
+    curl_easy_setopt(curl, CURLOPT_URL, url_.c_str());
+    curl_easy_setopt(curl, CURLOPT_SSL_VERIFYPEER, 0L);
+    curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, curlCallback_);
+    curl_easy_setopt(curl, CURLOPT_WRITEDATA, (std::string*)&rcv);
+#ifndef NDEBUG
+    curl_easy_setopt(curl, CURLOPT_VERBOSE, 1L);
+#endif
+    // Headerを保持するcurl_slist*を初期化
+    struct curl_slist* headers = NULL;
+    // Authorizationをヘッダに追加
+    headers = curl_slist_append(headers, oauthHeader.c_str());
+
+    std::string contentType = "";
+    if (contentType_ == "application/x-www-form-urlencoded") {
+      contentType = contentType_;
+    } else if (contentType_ == "multipart/form-data") {
+      contentType = contentType_ + "; boundary=milkcocoa0902";
+    }
+
+    headers = curl_slist_append(headers, ("Content-Type: " + contentType).c_str());
+    curl_easy_setopt(curl, CURLOPT_HTTPHEADER, headers);
+    res = curl_easy_perform(curl);
+    curl_easy_getinfo(curl, CURLINFO_RESPONSE_CODE, &responseCode);
+    curl_easy_cleanup(curl);
+  }
+
+  if (res != CURLE_OK) {
+    throw std::runtime_error(std::string("INTERNAL ERROR : curl(") + std::to_string(res) + ")");
+    exit(1);
+  }
+
+  if (_callback) {
+    _callback(responseCode, rcv);
+  }
+}
+} // namespace CocoaTweet::API::Interface