dunedaq::restcmd::RestEndpoint Class Reference

#include <RestEndpoint.hpp>

Public Member Functions
	RestEndpoint (const std::string &, int port, std::function< void(const cmdobj_t &, cmdlib::cmd::CommandReply)> callback) noexcept
void	init (size_t threads)
void	start ()
void	stop ()
void	shutdown ()
void	handleResponseCommand (const cmdobj_t &cmd, cmdlib::cmd::CommandReply &meta)
uint16_t	getPort () const
std::shared_ptr< Pistache::Http::Client >	getHttpClient () const

Private Member Functions
void	createRouting ()
void	createDescription ()
void	handle_route_command (const Pistache::Rest::Request &, Pistache::Http::ResponseWriter response)

Private Attributes
Pistache::Port	port_
Pistache::Address	address_
std::shared_ptr< Pistache::Http::Endpoint >	http_endpoint_
Pistache::Rest::Description	description_
Pistache::Rest::Router	router_
Pistache::Http::Mime::MediaType	accepted_mime_
std::shared_ptr< Pistache::Http::Client >	http_client_
Pistache::Http::Client::Options	http_client_options_
std::vector< Pistache::Async::Promise< Pistache::Http::Response > >	http_client_responses_
std::function< void(const cmdobj_t &, cmdlib::cmd::CommandReply)>	command_callback_
std::thread	server_thread_

Detailed Description

Definition at line 39 of file RestEndpoint.hpp.

Constructor & Destructor Documentation

RestEndpoint()

dunedaq::restcmd::RestEndpoint::RestEndpoint ( const std::string & , int port, std::function< void(const cmdobj_t &, cmdlib::cmd::CommandReply)> callback )

inlineexplicitnoexcept

Definition at line 41 of file RestEndpoint.hpp.

    : port_{ static_cast<uint16_t>(port) }
    , address_{ Pistache::Ipv4::any(), port_ }
    , http_endpoint_{ std::make_shared<Pistache::Http::Endpoint>( address_ ) }
    , description_{ "DUNE DAQ cmdlib API", "0.1" }
    , accepted_mime_{ MIME(Application, Json) }
    , http_client_{ std::make_shared<Pistache::Http::Client>() }
    , command_callback_{ callback }
  { }

Member Function Documentation

createDescription()

void dunedaq::restcmd::RestEndpoint::createDescription ( )

private

createRouting()

void RestEndpoint::createRouting ( )

private

Definition at line 54 of file RestEndpoint.cpp.

{
  using namespace Rest;
  Routes::Post(router_, "/command", Routes::bind(&RestEndpoint::handle_route_command, this));
}

getHttpClient()

std::shared_ptr< Pistache::Http::Client > dunedaq::restcmd::RestEndpoint::getHttpClient ( ) const

inline

Definition at line 62 of file RestEndpoint.hpp.

                                                          {
    return http_client_;
  }

getPort()

uint16_t dunedaq::restcmd::RestEndpoint::getPort ( ) const

inline

Definition at line 59 of file RestEndpoint.hpp.

                           {
    return static_cast<uint16_t>(port_);
  }

handle_route_command()

void RestEndpoint::handle_route_command ( const Pistache::Rest::Request & , Pistache::Http::ResponseWriter response )

private

Definition at line 78 of file RestEndpoint.cpp.

{
  dunedaq::cmdlib::cmd::CommandReply meta;
  auto addr = request.address();
  auto headers = request.headers();
  auto ct = headers.get<Http::Header::ContentType>();
  if ( ct->mime() != accepted_mime_ ) {
    auto res = response.send(Http::Code::Not_Acceptable, "Not a JSON command!\n");
  } else {
    auto ansport = headers.getRaw("X-Answer-Port"); // RS: FIXME reply using headers
    auto anshost = headers.tryGetRaw("X-Answer-Host"); // RS: FIXME reply using headers
    meta.data["ans-port"] = ansport.value();
    meta.data["ans-host"] = ( !anshost.isEmpty() ? anshost.get().value() : addr.host() );
    command_callback_(nlohmann::json::parse(request.body()), meta); // RS: FIXME parse errors
    auto res = response.send(Http::Code::Accepted, "Command received\n");
  }
}

handleResponseCommand()

void RestEndpoint::handleResponseCommand	(	const cmdobj_t &	cmd,
		cmdlib::cmd::CommandReply &	meta )

Definition at line 96 of file RestEndpoint.cpp.

{
  dunedaq::cmdlib::cmd::Command command = cmd.get<dunedaq::cmdlib::cmd::Command>();
  std::ostringstream addrstr;
  addrstr << meta.data["ans-host"].get<std::string>() << ":" << meta.data["ans-port"].get<std::string>() << "/response";
  meta.data["cmdid"] = command.id;
  TLOG() << "Sending POST request to " << addrstr.str();
 
  nlohmann::json body_json;
  dunedaq::cmdlib::cmd::to_json(body_json, meta);
  auto response = http_client_->post(addrstr.str()).body(body_json.dump()).send();
  response.then(
    [&](Http::Response response) {
      TLOG() << "Response code = " << response.code();
    },
    [&](std::exception_ptr exc) {
      // handle response failure
      try{
        std::rethrow_exception(exc);
      }
      catch (const std::exception &e) {
        TLOG() << "Exception thrown by Http::Client::post() call: \"" << e.what() << "\"; errno = " << errno;
      }
    }
  );
  http_client_responses_.push_back(std::move(response));
}

init()

void RestEndpoint::init

(

size_t

threads

)

Definition at line 20 of file RestEndpoint.cpp.

{
  auto opts = Http::Endpoint::options()
    .threads(static_cast<int>(threads))
    .maxRequestSize(15728640) // 15MB
    .maxResponseSize(1048576) // 1MB
    .flags(Pistache::Tcp::Options::ReuseAddr)
    .flags(Pistache::Tcp::Options::ReusePort);
 
  http_endpoint_->init(opts);
  createRouting();
  http_client_options_ = Http::Client::options().threads(static_cast<int>(threads));
  http_client_->init(http_client_options_);
}

shutdown()

void RestEndpoint::shutdown

(

)

Definition at line 47 of file RestEndpoint.cpp.

{
  http_endpoint_->shutdown();
  //server_thread_.join();
  http_client_->shutdown();
}

start()

void RestEndpoint::start

(

)

Definition at line 35 of file RestEndpoint.cpp.

{
  http_endpoint_->setHandler(router_.handler());
  http_endpoint_->serveThreaded();
  port_ = http_endpoint_->getPort();
  TLOG() << "REST server started on port " << port_;
}

stop()

void dunedaq::restcmd::RestEndpoint::stop

(

)

Member Data Documentation

accepted_mime_

Pistache::Http::Mime::MediaType dunedaq::restcmd::RestEndpoint::accepted_mime_

private

Definition at line 80 of file RestEndpoint.hpp.

address_

Pistache::Address dunedaq::restcmd::RestEndpoint::address_

private

Definition at line 76 of file RestEndpoint.hpp.

command_callback_

std::function<void(const cmdobj_t&, cmdlib::cmd::CommandReply)> dunedaq::restcmd::RestEndpoint::command_callback_

private

Definition at line 88 of file RestEndpoint.hpp.

description_

Pistache::Rest::Description dunedaq::restcmd::RestEndpoint::description_

private

Definition at line 78 of file RestEndpoint.hpp.

http_client_

std::shared_ptr<Pistache::Http::Client> dunedaq::restcmd::RestEndpoint::http_client_

private

Definition at line 83 of file RestEndpoint.hpp.

http_client_options_

Pistache::Http::Client::Options dunedaq::restcmd::RestEndpoint::http_client_options_

private

Definition at line 84 of file RestEndpoint.hpp.

http_client_responses_

std::vector<Pistache::Async::Promise<Pistache::Http::Response> > dunedaq::restcmd::RestEndpoint::http_client_responses_

private

Definition at line 85 of file RestEndpoint.hpp.

http_endpoint_

std::shared_ptr<Pistache::Http::Endpoint> dunedaq::restcmd::RestEndpoint::http_endpoint_

private

Definition at line 77 of file RestEndpoint.hpp.

port_

Pistache::Port dunedaq::restcmd::RestEndpoint::port_

private

Definition at line 75 of file RestEndpoint.hpp.

router_

Pistache::Rest::Router dunedaq::restcmd::RestEndpoint::router_

private

Definition at line 79 of file RestEndpoint.hpp.

server_thread_

std::thread dunedaq::restcmd::RestEndpoint::server_thread_

private

Definition at line 91 of file RestEndpoint.hpp.

---

The documentation for this class was generated from the following files:

• /github/workspace/dunedaq/sourcecode/restcmd/include/restcmd/RestEndpoint.hpp
• /github/workspace/dunedaq/sourcecode/restcmd/src/RestEndpoint.cpp