http_session.cpp

Go to the documentation of this file.

// Copyright 2021 RobosoftAI Inc.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
 
/*****************************************************************************************************************
*
 
Author: Jacobus Lock
 
******************************************************************************************************************/
 
#include <http_client/http_session.hpp>
 
namespace cl_http
{
 
http_session::http_session(
  boost::asio::any_io_executor ioc, const std::function<void(const TResponse &)> response)
: onResponse{response}, resolver_{ioc}, stream_{ioc}
{
}
 
void http_session::setBody(const std::string & body) { req_.body() = body; }
 
void http_session::run(
  const std::string & host, const std::string & target, const boost::beast::http::verb http_method,
  const int & version)
{
  // Set up an HTTP request
  req_.version(version);
  req_.method(http_method);
  req_.target(target);
  req_.set(boost::beast::http::field::host, host);
  req_.set(boost::beast::http::field::user_agent, BOOST_BEAST_VERSION_STRING);
 
  // Look up the domain name
  resolver_.async_resolve(
    host.c_str(), kPort.c_str(),
    boost::beast::bind_front_handler(&http_session::on_resolve, shared_from_this()));
}
 
void http_session::on_resolve(
  boost::beast::error_code ec, boost::asio::ip::tcp::resolver::results_type results)
{
  if (ec) return fail(ec, "resolve");
 
  // Set a timeout on the operation
  stream_.expires_after(std::chrono::seconds(1));
 
  // Make the connection on the IP address we get from a lookup
  stream_.async_connect(
    results, boost::beast::bind_front_handler(&http_session::on_connect, shared_from_this()));
}
 
void http_session::fail(boost::beast::error_code ec, char const * what)
{
  std::cout << "Failure!..." << std::endl;
  std::cerr << what << ": " << ec.message() << "\n";
  res_.result(boost::beast::http::status::bad_request);
  res_.reason() = ec.message();
  onResponse(res_);
}
 
void http_session::on_connect(
  boost::beast::error_code ec, boost::asio::ip::tcp::resolver::results_type::endpoint_type)
{
  if (ec) return fail(ec, "connect");
 
  // Set a timeout on the operation
  stream_.expires_after(std::chrono::seconds(1));
 
  // Send the HTTP request to the remote host
  boost::beast::http::async_write(
    stream_, req_, boost::beast::bind_front_handler(&http_session::on_write, shared_from_this()));
}
 
void http_session::on_write(boost::beast::error_code ec, std::size_t bytes_transferred)
{
  boost::ignore_unused(bytes_transferred);
 
  if (ec) return fail(ec, "write");
 
  // Receive the HTTP response
  boost::beast::http::async_read(
    stream_, buffer_, res_,
    boost::beast::bind_front_handler(&http_session::on_read, shared_from_this()));
}
 
void http_session::on_read(boost::beast::error_code ec, std::size_t bytes_transferred)
{
  boost::ignore_unused(bytes_transferred);
 
  if (ec) return fail(ec, "read");
 
  // Gracefully close the socket
  stream_.socket().shutdown(boost::asio::ip::tcp::socket::shutdown_both, ec);
 
  // not_connected happens sometimes so don't bother reporting it.
  if (ec && ec != boost::beast::errc::not_connected) return fail(ec, "shutdown");
 
  // If we get here then the connection is closed gracefully
  onResponse(res_);
}
}  // namespace cl_http