Client.cpp

/*
** Copyright (C) 2022 CERN
**
** This software is provided 'as-is', without any express or implied
** warranty.  In no event will the authors be held liable for any damages
** arising from the use of this software.
**
** Permission is granted to anyone to use this software for any purpose,
** including commercial applications, and to alter it and redistribute it
** freely, subject to the following restrictions:
**
** 1. The origin of this software must not be misrepresented; you must not
**    claim that you wrote the original software. If you use this software
**    in a product, an acknowledgment in the product documentation would be
**    appreciated but is not required.
** 2. Altered source versions must be plainly marked as such, and must not be
**    misrepresented as being the original software.
** 3. This notice may not be removed or altered from any source distribution.
**
** Created on: 2022-07-14T18:27:29
** Author: Sylvain Fargier <sylvain.fargier@cern.ch>
*/
 
#include "Client.hpp"
 
#include <oatpp/network/tcp/client/ConnectionProvider.hpp>
#include <oatpp/parser/json/mapping/ObjectMapper.hpp>
#include <oatpp/web/client/HttpRequestExecutor.hpp>
 
namespace smc {
namespace debug {
 
Client::Client(const oatpp::network::Address &address) :
    oatpp::web::client::ApiClient(
        oatpp::web::client::HttpRequestExecutor::createShared(
            oatpp::network::tcp::client::ConnectionProvider::createShared(
                address)),
        oatpp::parser::json::mapping::ObjectMapper::createShared())
{}
 
std::shared_ptr<oatpp::web::protocol::http::incoming::Response> Client::put(
    const std::string &path,
    const oatpp::Void &body,
    const std::unordered_map<oatpp::String, oatpp::String> &pathParams)
{
    oatpp::data::share::StringTemplate pathTemplate = parsePathTemplate(
        "put", oatpp::String(path));
    oatpp::web::client::ApiClient::Headers headers;
    std::unordered_map<oatpp::String, oatpp::String> queryParams;
    std::shared_ptr<oatpp::web::protocol::http::outgoing::Body> bodyVoid;
    if (bool(body))
    {
        bodyVoid = oatpp::web::protocol::http::outgoing::BufferBody::createShared(
            m_objectMapper->writeToString(body),
            m_objectMapper->getInfo().http_content_type);
    }
    return executeRequest("PUT", pathTemplate, headers, pathParams, queryParams,
                          bodyVoid);
}
 
std::shared_ptr<oatpp::web::protocol::http::incoming::Response> Client::post(
    const std::string &path,
    const oatpp::Void &body,
    const std::unordered_map<oatpp::String, oatpp::String> &pathParams)
{
    oatpp::data::share::StringTemplate pathTemplate = parsePathTemplate(
        "post", oatpp::String(path));
    oatpp::web::client::ApiClient::Headers headers;
    std::unordered_map<oatpp::String, oatpp::String> queryParams;
    std::shared_ptr<oatpp::web::protocol::http::outgoing::Body> bodyVoid;
    if (bool(body))
    {
        bodyVoid = oatpp::web::protocol::http::outgoing::BufferBody::createShared(
            m_objectMapper->writeToString(body),
            m_objectMapper->getInfo().http_content_type);
    }
    return executeRequest("POST", pathTemplate, headers, pathParams,
                          queryParams, bodyVoid);
}
 
std::shared_ptr<oatpp::web::protocol::http::incoming::Response> Client::get(
    const std::string &path,
    const std::unordered_map<oatpp::String, oatpp::String> &queryParams,
    const std::unordered_map<oatpp::String, oatpp::String> &pathParams)
{
    oatpp::data::share::StringTemplate pathTemplate = parsePathTemplate(
        "get", oatpp::String(path));
    oatpp::web::client::ApiClient::Headers headers;
    std::shared_ptr<oatpp::web::protocol::http::outgoing::Body> body;
    return executeRequest("GET", pathTemplate, headers, pathParams, queryParams,
                          body);
}
 
std::shared_ptr<oatpp::web::protocol::http::incoming::Response> Client::del(
    const std::string &path,
    const std::unordered_map<oatpp::String, oatpp::String> &queryParams,
    const std::unordered_map<oatpp::String, oatpp::String> &pathParams)
{
    oatpp::data::share::StringTemplate pathTemplate = parsePathTemplate(
        "delete", oatpp::String(path));
    oatpp::web::client::ApiClient::Headers headers;
    std::shared_ptr<oatpp::web::protocol::http::outgoing::Body> body;
    return executeRequest("DELETE", pathTemplate, headers, pathParams,
                          queryParams, body);
}
 
} // namespace debug
} // namespace smc