C++を利用してTwitterクライアントプログラムを開発したいです。 外部ライブラリはOpenSSL(暗号化)とcpprestsdk(HTTP通信)のみです。 OAuth認証も自分で実装しようと思うのですが、うまくいきません。 具体的にはシグネチャ?の作成とPOSTするデータ(パラメータ)の作成がうまく行っていないのかも...と思っています。 <a href="https://soramimi.jp/twicpps/index.html">Twicpps</a>と<a href="https://qiita.com/alpha_kai_NET/items/cdd3ec27a70a77e06c59">このサイト様</a>を参考にさせていただいているのですが、サイトだとHTTPリクエストヘッダに*Authorization*というヘッダを作り、そこにもOAuth認証情報を記載するとの事が書いてあるのですが、Twicppsのコードを見ているとそのようなことをしているようには見えません。 パラメータの作成は行っていますが、urlとパラメータだけを乗っけてPOSTしているようなコードです。 以下のコード(.hpp)で通信はできるのですが、スターテスコード400で帰ってきて、レスポンスは以下のとおりです。 ``` {"errors":[{"code":215,"message":"Bad Authentication data."}]} ``` 基本はTwicpps寄りで開発してきたのですが、*Authorization*をつけないと認証はできないようです。 以下のコード全文を載せます。cppの方はmain関数からtweet関数を呼び出しているだけですので掲載しません。 どこがおかしいのか指摘して頂けると光栄です。 よろしくおねがいします。 OS:Windows10 Home IDE:Visual Studio 2019 Community OpenSSL:OpenSSL-Win32 1.0.2r cpprestsdk:cpprestsdk v141 ``` [Header.hpp] #pragma once #include <sstream> #include <fstream> #include <vector> #include <locale> #include <winstring.h> #include <algorithm> #include <iomanip> #include <queue> #include <time.h> #include <cpprest/http_client.h> #include <openssl/hmac.h> #include <openssl/ssl.h> #pragma comment(lib,"libeay32.lib") using namespace std; using namespace web; using namespace web::http; using namespace web::http::client; #define REST_POST_PATH "C:\\ProgramData\\System72\\CAIOS\\CAIOS\\REST_POST_RESPONSE.json" #define REST_GET_PATH "C:\\ProgramData\\System72\\CAIOS\\CAIOS\\REST_GET_RESPONSE.json" #define TWITTER_URL "https://api.twitter.com/1.1/statuses/update.json" typedef enum { POST, GET } METHOD; enum CodePageID : unsigned int { ANSI = CP_ACP, // ANSI OEM = CP_OEMCP, // OEM(依存) MAC = CP_MACCP, // MAC UTF7 = CP_UTF7, // UTF-7 UTF8 = CP_UTF8 // UTF-8 }; struct Request { string url; string post; }; struct TwitterAPI_Keys { string Consumer_Key = "ここにキーを代入"; string Consumer_Sec = "ここにキーを代入"; string Accesstoken = "ここにキーを代入"; string Accesstoken_Aec = "ここにキーを代入"; }; namespace CAIOS { namespace String { static string UTF8_to_SJIS(string message) { int n; wchar_t ucs2[1000]; char utf8[1000]; n = MultiByteToWideChar(CP_UTF8, 0, message.c_str(), message.size(), ucs2, 1000); n = WideCharToMultiByte(CP_ACP, 0, ucs2, n, utf8, 1000, 0, 0); return std::string(utf8, n); } static string SJIS_to_UTF8(std::string const& message) { int n; wchar_t ucs2[1000]; char utf8[1000]; n = MultiByteToWideChar(CP_ACP, 0, message.c_str(), message.size(), ucs2, 1000); n = WideCharToMultiByte(CP_UTF8, 0, ucs2, n, utf8, 1000, 0, 0); return std::string(utf8, n); } // string から wstring 変換 static wstring StringToWString(const string& refSrc, unsigned int codePage = CodePageID::ANSI) { vector<wchar_t> buffer(MultiByteToWideChar(codePage, 0, refSrc.c_str(), -1, nullptr, 0)); MultiByteToWideChar(codePage, 0, refSrc.c_str(), -1, &buffer.front(), buffer.size()); return wstring(buffer.begin(), buffer.end()); } // wstring から string 変換 static string WStringToString(const wstring& refSrc, unsigned int codePage = CodePageID::OEM) { vector<char> buffer(WideCharToMultiByte(codePage, 0, refSrc.c_str(), -1, nullptr, 0, nullptr, nullptr)); WideCharToMultiByte(codePage, 0, refSrc.c_str(), -1, &buffer.front(), buffer.size(), nullptr, nullptr); return string(buffer.begin(), buffer.end()); } static string EraseString(string str, string erase) { for (size_t c = str.find_first_of(erase); c != string::npos; c = c = str.find_first_of(erase)) { str.erase(c, 1); } return str; } } namespace REST { static string GET(Request req) { try { using namespace CAIOS::String; http_client client(StringToWString(req.url)); cout << " -> HTTP request mode [POST]" << endl; cout << " -> HTTP request to " << req.url << endl; auto response = client.request(methods::GET).get(); auto str = response.extract_string(); cout << " -> Server returned returned status code " << response.status_code() << '.' << endl; cout << " -> Content length is " << response.headers().content_length() << " bytes.\n" << endl; ofstream ofs(REST_POST_PATH); ofs << WStringToString(str.get().c_str()) << endl; ofs.close(); return WStringToString(str.get().c_str()); } catch (...) { cout << "HTTP通信中に例外が発生しました [GET]" << endl; } } static string POST(Request req) { try { using namespace CAIOS::String; http_client client(StringToWString(req.url)); http_request request(methods::POST); cout << " -> HTTP request mode [POST]" << endl; cout << " -> HTTP request to " << req.url << endl; char body[3000]; sprintf_s(body, 3000, "Authorization: OAuth %s", req.post); request.headers().add(L"Content-Type", L"application/x-www-form-urlencoded"); request.set_body((wchar_t*)body); auto response = client.request(request).get(); auto str = response.extract_string(); cout << " -> Server returned returned status code " << response.status_code() << '.' << endl; cout << " -> Content length is " << response.headers().content_length() << " bytes.\n" << endl; ofstream ofs(REST_POST_PATH); ofs << WStringToString(str.get().c_str()) << endl; ofs.close(); return WStringToString(str.get().c_str()); } catch (...) { cout << "HTTP通信中に例外が発生しました [POST]" << endl; } } static string URL_encode(string str) { const int NUM_BEGIN_UTF8 = 48; const int CAPITAL_BEGIN_UTF8 = 65; const int LOWER_BEGIN_UTF8 = 97; int charCode = -1; string encoded; stringstream out; for (int i = 0; str[i] != 0; i++) { charCode = (int)(unsigned char)str[i]; //エンコードする必要の無い文字の判定 if ((NUM_BEGIN_UTF8 <= charCode && charCode <= NUM_BEGIN_UTF8 + 9) || (CAPITAL_BEGIN_UTF8 <= charCode && charCode <= CAPITAL_BEGIN_UTF8 + 25) || (LOWER_BEGIN_UTF8 <= charCode && charCode <= LOWER_BEGIN_UTF8 + 25) || str[i] == '.' || str[i] == '_' || str[i] == '-' || str[i] == '~'){ out << str[i]; } else { out << '%' << hex << uppercase << charCode; } } encoded = out.str(); return encoded; } } namespace Twitter { namespace OAuth { static string CreateData(vector<string>const OAuth, METHOD method, int Start) { string query; for (int t = Start; t < OAuth.size(); t++) { if (t != Start)query += "&"; query += OAuth[t]; } return query; } static int split_url(const string url, vector<string>* OAuth) { int num = url.find_first_of('?'); OAuth->push_back(url.substr(0, num)); OAuth->push_back(url.substr(num + 1)); return 0; } static string sha1(const string Key, const string Data) { char* key = (char*)Key.c_str(); char* data = (char*)Data.c_str(); unsigned char res[SHA_DIGEST_LENGTH + 1]; size_t reslen; HMAC(EVP_sha1(), key, strlen(key), reinterpret_cast<const unsigned char*>(data), strlen(data), res, &reslen); return string(reinterpret_cast<char*>(res), reslen); } static int encode_base64(char* bufin, int len, char* bufout){ static unsigned char base64[] = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/="; unsigned char* pin = (unsigned char*)bufin; unsigned char* pout = (unsigned char*)bufout; for (int i = 0; i < len - 2; i += 3){ *pout++ = base64[pin[0] >> 2]; *pout++ = base64[0x3F & ((pin[0] << 4) | (pin[1] >> 4))]; *pout++ = base64[0x3F & ((pin[1] << 2) | (pin[2] >> 6))]; *pout++ = base64[0x3F & pin[2]]; pin += 3; } if (len % 3 == 1){ *pout++ = base64[pin[0] >> 2]; *pout++ = base64[0x3F & (pin[0] << 4)]; *pout++ = '='; *pout++ = '='; } else if (len % 3 == 2){ *pout++ = base64[pin[0] >> 2]; *pout++ = base64[0x3F & ((pin[0] << 4) | (pin[1] >> 4))]; *pout++ = base64[0x3F & (pin[1] << 2)]; *pout++ = '='; } *pout = '\0'; return pout - (unsigned char*)bufout; } static string CreateSignature(string ConsumerSecret, string AccessSecret, vector<string>const& OAuth, METHOD method, int Start = 1) { string str, key, data, methods; char out[256]; if (method == POST)methods = "POST"; else methods = "GET"; key = ConsumerSecret + "&" + AccessSecret; data = methods + "&" + CAIOS::REST::URL_encode(OAuth[0]) + "&" + CreateData(OAuth, method, Start); str = sha1(key, data); CAIOS::Twitter::OAuth::encode_base64((char*)str.c_str(), sizeof(str) - 1, out); return out; } static int IntOAuthParams(vector<string>* OAuth, METHOD method) { TwitterAPI_Keys key; auto CreateNonce = []() { static const char* chars = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789_"; const unsigned int max = 26 + 26 + 10 + 1; char tmp[50]; srand((unsigned int)time(0)); int len = 15 + rand() % 16; for (int i = 0; i < len; i++) { tmp[i] = chars[rand() % max]; } return std::string(tmp, len); }; string oauth_nonce = "oauth_nonce"; oauth_nonce += "="; oauth_nonce += CreateNonce(); OAuth->push_back(oauth_nonce); string oauth_timestamp = "oauth_timestamp"; oauth_timestamp += "="; oauth_timestamp += to_string((int)time(nullptr)); OAuth->push_back(oauth_timestamp); string oauth_token = "oauth_token"; oauth_token += "="; oauth_token += key.Accesstoken; OAuth->push_back(oauth_token); string oauth_consumer_key = "oauth_consumer_key"; oauth_consumer_key += "="; oauth_consumer_key += key.Consumer_Key; OAuth->push_back(oauth_consumer_key); string oauth_signature_method = "oauth_signature_method"; oauth_signature_method += "="; oauth_signature_method += "HMAC-SHA1"; OAuth->push_back(oauth_signature_method); string oauth_version = "oauth_version"; oauth_version += "="; oauth_version += "1.0"; OAuth->push_back(oauth_version); sort(OAuth->begin() + 1, OAuth->end()); string oauth_signature = "oauth_signature"; oauth_signature += "="; oauth_signature += CreateSignature(key.Consumer_Sec, key.Accesstoken_Aec, *OAuth, method); OAuth->push_back(oauth_signature); return 0; } static Request OAuthAuthentication(string url, METHOD method) { vector<string> OAuth; split_url(url, &OAuth); CAIOS::Twitter::OAuth::IntOAuthParams(&OAuth, method); Request req; if (method == POST) { req.url = OAuth[0]; req.post = CAIOS::Twitter::OAuth::CreateData(OAuth, method, 1); } else { req.url = OAuth[0]; req.post = CAIOS::Twitter::OAuth::CreateData(OAuth, method, 1); } return req; } } static string tweet(string message) { message = CAIOS::String::SJIS_to_UTF8(message); string url = TWITTER_URL; url += "?status=" + CAIOS::REST::URL_encode(message); Request req = OAuth::OAuthAuthentication(url, POST); return CAIOS::REST::POST(req); } } } ```