http_node_client.h

Go to the documentation of this file.

// Copyright (c) Microsoft Corporation. All rights reserved.
// Licensed under the Apache 2.0 License.
#pragma once
 
#include "node/node_client.h"
 
#include <chrono>
 
namespace ccf
{
  class HTTPNodeClient : public NodeClient
  {
  public:
    HTTPNodeClient(
      std::shared_ptr<ccf::RPCMap> rpc_map,
      ccf::crypto::KeyPairPtr node_sign_kp,
      const ccf::crypto::Pem& self_signed_node_cert_,
      const std::optional<ccf::crypto::Pem>& endorsed_node_cert_) :
      NodeClient(
        rpc_map, node_sign_kp, self_signed_node_cert_, endorsed_node_cert_)
    {}
 
    virtual ~HTTPNodeClient() {}
 
    virtual bool make_request(::http::Request& request) override
    {
      const auto& node_cert = endorsed_node_cert.has_value() ?
        endorsed_node_cert.value() :
        self_signed_node_cert;
 
      std::vector<uint8_t> packed = request.build_request();
 
      auto node_session = std::make_shared<ccf::SessionContext>(
        ccf::InvalidSessionId, node_cert.raw());
      auto ctx = ccf::make_rpc_context(node_session, packed);
 
      std::shared_ptr<ccf::RpcHandler> search =
        ::http::fetch_rpc_handler(ctx, rpc_map);
 
      search->process(ctx);
 
      auto rs = ctx->get_response_status();
 
      if (rs != HTTP_STATUS_OK)
      {
        auto ser_res = ctx->serialise_response();
        std::string str((char*)ser_res.data(), ser_res.size());
        LOG_DEBUG_FMT("Request failed: {}", str);
      }
 
      return rs == HTTP_STATUS_OK;
    }
  };
}