consensus_service_impl.hpp

Go to the documentation of this file.

#ifndef IROHA_YAC_SERVICE_IMPL_HPP
#define IROHA_YAC_SERVICE_IMPL_HPP

#include "yac.grpc.pb.h"

#include <memory>

#include "consensus/yac/vote_message.hpp"
#include "logger/logger_fwd.hpp"

namespace iroha::consensus::yac {
  class ServiceImpl : public proto::Yac::Service {
   public:
    using Service = proto::Yac;

    ServiceImpl(logger::LoggerPtr log,
                std::function<void(std::vector<VoteMessage>)> callback);

    grpc::Status SendState(::grpc::ServerContext *context,
                           const ::iroha::consensus::yac::proto::State *request,
                           ::google::protobuf::Empty *response) override;

   private:
    std::function<void(std::vector<VoteMessage>)> callback_;

    logger::LoggerPtr log_;
  };
}  // namespace iroha::consensus::yac

#endif  // IROHA_YAC_SERVICE_IMPL_HPP