How to make sync requests

[paulocoutinhox]

Hi,

How i can make sync requests?

I want convert my sync code from Poco to Yasio:
https://github.com/nativium/nativium-modules/blob/main/custom/modules/http-client/implementation/cpp/nativium/net/http/SimpleHttpClientPlatformService.cpp

The main request method is here:
https://github.com/nativium/nativium-modules/blob/main/custom/modules/http-client/implementation/cpp/nativium/net/http/SimpleHttpClientPlatformService.cpp#L33-L154

Thanks.

[paulocoutinhox]

This is sufficient and correct? Can anyone check?

#include "nativium/net/http/HttpHeader.hpp"
#include "nativium/net/http/HttpMethod.hpp"
#include "nativium/net/http/HttpRequest.hpp"
#include "nativium/net/http/HttpRequestParam.hpp"
#include "nativium/net/http/HttpResponse.hpp"

#include "yasio/yasio.hpp"
#include "yasio/ibstream.hpp"
#include "yasio/obstream.hpp"

#include <iostream>
#include <map>
#include <sstream>
#include <string>

namespace nativium
{
namespace net
{
namespace http
{

using namespace nativium::net::http;

HttpResponse SimpleHttpClientPlatformService::doRequest(const HttpRequest &request)
{
    auto response = HttpResponse{0, "", "", {}, {}};
    
    yasio::inet::io_hostinfo info(request.url);
    yasio::inet::io_service service(info);

    yasio::inet::io_channel channel = service.open(0, yasio::inet::c_kind_tcp_client);

    service.set_option(yasio::inet::YOPT_C_LFBFD_PARAMS, 0, 65535, 10);
    
    service.start_service([&response, &request](yasio::inet::io_event *event)
    {
        switch (event->kind())
        {
        case yasio::inet::IOE_CONNECT:
            if (event->status() == 0) // Connection succeeded
            {
                yasio::inet::obstream obs;
                obs.write_v(fmt::format("{} {} HTTP/1.1\r\n", getMethodFromRequest(request), request.url));
                
                // Headers
                for (auto &header : request.headers)
                {
                    obs.write_v(fmt::format("{}: {}\r\n", header.name, header.value));
                }

                // Cookies
                std::string cookies;
                for (auto x = 0; x < request.cookies.size(); x++)
                {
                    if (x > 0)
                    {
                        cookies.append("; ");
                    }
                    cookies.append(request.cookies[x].name);
                    cookies.append("=");
                    cookies.append(request.cookies[x].value);
                }
                if (!cookies.empty())
                {
                    obs.write_v(fmt::format("Cookie: {}\r\n", cookies));
                }
                
                obs.write("\r\n"); // End of headers

                // Body
                if (request.params.size() > 0)
                {
                    std::string body;
                    for (auto &param : request.params)
                    {
                        if (!body.empty())
                            body += "&";
                        body += param.name + "=" + param.value;
                    }
                    obs.write(body.data(), body.size());
                }
                else
                {
                    obs.write(request.body.data(), request.body.size());
                }
                
                channel.write(std::move(obs.buffer()));
            }
            break;

        case yasio::inet::IOE_PACKET:
            {
                yasio::inet::ibstream_view ibs(event->packet());
                // Parse the HTTP response here. 
                // For simplicity, we're assuming it's just the body
                response.body = std::string(ibs.data(), ibs.length());
            }
            break;
        }
    });

    service.dispatch();
    return response;
}

std::string SimpleHttpClientPlatformService::getMethodFromRequest(const HttpRequest &request)
{
    switch (request.method)
    {
    case HttpMethod::METHOD_GET: return "GET";
    case HttpMethod::METHOD_POST: return "POST";
    case HttpMethod::METHOD_HEAD: return "HEAD";
    case HttpMethod::METHOD_PUT: return "PUT";
    case HttpMethod::METHOD_DELETE: return "DELETE";
    case HttpMethod::METHOD_PATCH: return "PATCH";
    case HttpMethod::METHOD_CONNECT: return "CONNECT";
    case HttpMethod::METHOD_OPTIONS: return "OPTIONS";
    case HttpMethod::METHOD_TRACE: return "TRACE";
    default: return "";
    }
}

} // namespace http
} // namespace net
} // namespace nativium

[halx99]

Refer to: https://github.com/yasio/yasio/blob/dev/extensions/yasio_http/HttpClient.cpp#L360