163 lines
2.9 KiB
C++
163 lines
2.9 KiB
C++
// The Construct
|
|
//
|
|
// Copyright (C) The Construct Developers, Authors & Contributors
|
|
// Copyright (C) 2016-2023 Jason Volk <jason@zemos.net>
|
|
//
|
|
// Permission to use, copy, modify, and/or distribute this software for any
|
|
// purpose with or without fee is hereby granted, provided that the above
|
|
// copyright notice and this permission notice is present in all copies. The
|
|
// full license for this software is available in the LICENSE file.
|
|
|
|
ircd::rest::request::request(const rfc3986::uri &uri,
|
|
opts opts)
|
|
{
|
|
if(!opts.remote)
|
|
opts.remote = net::hostport{uri};
|
|
|
|
const bool need_alloc
|
|
{
|
|
empty(opts.buf)
|
|
&& (empty(opts.sout.head) || empty(opts.sin.head))
|
|
};
|
|
|
|
const unique_mutable_buffer _buf
|
|
{
|
|
need_alloc? 16_KiB: 0_KiB
|
|
};
|
|
|
|
if(!empty(_buf))
|
|
opts.buf = _buf;
|
|
|
|
window_buffer window
|
|
{
|
|
opts.buf
|
|
};
|
|
|
|
if(empty(opts.sout.head))
|
|
{
|
|
assert(opts.remote);
|
|
assert(opts.method);
|
|
http::request
|
|
{
|
|
window,
|
|
host(opts.remote),
|
|
opts.method,
|
|
uri.resource(),
|
|
size(opts.content),
|
|
opts.content_type,
|
|
opts.headers
|
|
};
|
|
|
|
opts.sout.head = window.completed();
|
|
}
|
|
|
|
if(empty(opts.sout.content))
|
|
opts.sout.content = opts.content;
|
|
|
|
if(empty(opts.sin.head))
|
|
opts.sin.head = mutable_buffer{window};
|
|
|
|
// server::request will allocate dynamic content
|
|
opts.sin.content = mutable_buffer{};
|
|
|
|
assert(opts.remote);
|
|
server::request request
|
|
{
|
|
opts.remote,
|
|
std::move(opts.sout),
|
|
std::move(opts.sin),
|
|
&opts.sopts,
|
|
};
|
|
|
|
const auto code
|
|
{
|
|
request.get(opts.timeout)
|
|
};
|
|
|
|
if(opts.code)
|
|
*opts.code = code;
|
|
|
|
if(opts.out)
|
|
*opts.out = std::move(request.in.dynamic);
|
|
else
|
|
this->out = std::move(request.in.dynamic);
|
|
|
|
ret = request.in.content;
|
|
}
|
|
|
|
ircd::rest::request::request(const mutable_buffer &out,
|
|
const rfc3986::uri &uri,
|
|
opts opts)
|
|
{
|
|
if(!opts.remote)
|
|
opts.remote = net::hostport{uri};
|
|
|
|
const bool need_alloc
|
|
{
|
|
empty(opts.buf)
|
|
&& (empty(opts.sout.head) || empty(opts.sin.head))
|
|
};
|
|
|
|
const unique_mutable_buffer _buf
|
|
{
|
|
need_alloc? 16_KiB: 0_KiB
|
|
};
|
|
|
|
if(!empty(_buf))
|
|
opts.buf = _buf;
|
|
|
|
window_buffer window
|
|
{
|
|
opts.buf
|
|
};
|
|
|
|
if(empty(opts.sout.head))
|
|
{
|
|
assert(opts.remote);
|
|
assert(opts.method);
|
|
http::request
|
|
{
|
|
window,
|
|
host(opts.remote),
|
|
opts.method,
|
|
uri.resource(),
|
|
size(opts.content),
|
|
opts.content_type,
|
|
opts.headers
|
|
};
|
|
|
|
opts.sout.head = window.completed();
|
|
}
|
|
|
|
if(empty(opts.sout.content))
|
|
opts.sout.content = opts.content;
|
|
|
|
if(empty(opts.sin.head))
|
|
opts.sin.head = mutable_buffer{window};
|
|
|
|
if(empty(opts.sin.content))
|
|
opts.sin.content = out;
|
|
|
|
if(empty(opts.sin.content))
|
|
opts.sin.content = opts.sin.head;
|
|
|
|
assert(opts.remote);
|
|
server::request request
|
|
{
|
|
opts.remote,
|
|
std::move(opts.sout),
|
|
std::move(opts.sin),
|
|
&opts.sopts,
|
|
};
|
|
|
|
const auto code
|
|
{
|
|
request.get(opts.timeout)
|
|
};
|
|
|
|
if(opts.code)
|
|
*opts.code = code;
|
|
|
|
ret = request.in.content;
|
|
}
|