/* This file is part of mastodonpp. * Copyright © 2020 tastytea * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU Affero General Public License as published by * the Free Software Foundation, version 3. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU Affero General Public License for more details. * * You should have received a copy of the GNU Affero General Public License * along with this program. If not, see . */ #include "curl_wrapper.hpp" #include "exceptions.hpp" #include "log.hpp" #include namespace mastodonpp { using std::uint8_t; using std::uint16_t; CURLWrapper::CURLWrapper() : _curl_buffer_error{} { curl_global_init(CURL_GLOBAL_ALL); // NOLINT(hicpp-signed-bitwise) _connection = curl_easy_init(); setup_curl(); } CURLWrapper::~CURLWrapper() noexcept { curl_easy_cleanup(_connection); curl_global_cleanup(); } answer_type CURLWrapper::make_request(const http_method &method, const string_view &uri) { debuglog << "Making request to: " << uri << '\n'; CURLcode code; switch (method) { case http_method::GET: { // NOLINTNEXTLINE(cppcoreguidelines-pro-type-vararg) code = curl_easy_setopt(_connection, CURLOPT_HTTPGET, 1L); break; } case http_method::POST: { // NOLINTNEXTLINE(cppcoreguidelines-pro-type-vararg) code = curl_easy_setopt(_connection, CURLOPT_POST, 1L); break; } } if (code != CURLE_OK) { throw CURLException{code, "Failed to set HTTP method", _curl_buffer_error}; } // NOLINTNEXTLINE(cppcoreguidelines-pro-type-vararg) code = curl_easy_setopt(_connection, CURLOPT_URL, uri.data()); if (code != CURLE_OK) { throw CURLException{code, "Failed to set URI", _curl_buffer_error}; } answer_type answer; code = curl_easy_perform(_connection); if (code == CURLE_OK) { long http_status; // NOLINT(google-runtime-int) // NOLINTNEXTLINE(cppcoreguidelines-pro-type-vararg) curl_easy_getinfo(_connection, CURLINFO_RESPONSE_CODE, &http_status); answer.http_status = static_cast(http_status); debuglog << "HTTP status code: " << http_status << '\n'; answer.headers = _curl_buffer_headers; answer.body = _curl_buffer_body; } else { answer.curl_error_code = static_cast(code); answer.error_message = _curl_buffer_error; debuglog << "libcurl error: " << code << '\n'; debuglog << _curl_buffer_error << '\n'; } return answer; } int CURLWrapper::writer(char *data, size_t size, size_t nmemb, string *writerData) { if(writerData == nullptr) { return 0; } writerData->append(data, size*nmemb); return static_cast(size * nmemb); } void CURLWrapper::setup_curl() { if (_connection == nullptr) { throw CURLException{CURLE_FAILED_INIT, "Failed to initialize curl."}; } // NOLINTNEXTLINE(cppcoreguidelines-pro-type-vararg) CURLcode code{curl_easy_setopt(_connection, CURLOPT_ERRORBUFFER, _curl_buffer_error)}; if (code != CURLE_OK) { throw CURLException{code, "Failed to set error buffer."}; } // NOLINTNEXTLINE(cppcoreguidelines-pro-type-vararg) code = curl_easy_setopt(_connection, CURLOPT_WRITEFUNCTION, writer); if (code != CURLE_OK) { throw CURLException{code, "Failed to set writer", _curl_buffer_error}; } // NOLINTNEXTLINE(cppcoreguidelines-pro-type-vararg) code = curl_easy_setopt(_connection, CURLOPT_HEADERDATA, &_curl_buffer_headers); if (code != CURLE_OK) { throw CURLException{code, "Failed to set header data", _curl_buffer_error}; } // NOLINTNEXTLINE(cppcoreguidelines-pro-type-vararg) code = curl_easy_setopt(_connection, CURLOPT_WRITEDATA, &_curl_buffer_body); if (code != CURLE_OK) { throw CURLException{code, "Failed to set write data", _curl_buffer_error}; } } } // namespace mastodonpp