requestor.hpp

Go to the documentation of this file.

#ifndef OCF_OCM_SERVERCTL_REQUESTOR_HPP_
#define OCF_OCM_SERVERCTL_REQUESTOR_HPP_

#include <iostream>
#include <unordered_map>
#include <vector>

#include <boost/asio/io_service.hpp>
#include <boost/program_options.hpp>

#include <OcmServerIf.hpp>
#include <rad/logger.hpp>

struct CommonArgs {
    unsigned timeout;
    std::string req_addr;
    std::string pub_addr;

    CommonArgs() = default;
    CommonArgs(CommonArgs const&) = delete;
    CommonArgs& operator=(CommonArgs const&) = delete;
};

struct Requestor {
    explicit Requestor(CommonArgs& args);
    virtual ~Requestor() {
    }
    virtual std::string Synopsis();
    virtual void AddOptions(boost::program_options::options_description& descr);
    virtual void Handle(::ocmServerIf::CommandsSync& client,
                        boost::program_options::variables_map& vm,
                        std::vector<std::string>& opts) = 0;

  protected:
    CommonArgs& m_args;
};

struct PingRequestor : Requestor {
    using Requestor::Requestor;
    void Handle(::ocmServerIf::CommandsSync& client,
                boost::program_options::variables_map& vm,
                std::vector<std::string>& opts) override;
};

struct StateRequestor : Requestor {
    using Requestor::Requestor;
    void Handle(::ocmServerIf::CommandsSync& client,
                boost::program_options::variables_map& vm,
                std::vector<std::string>& opts) override;
};

#endif  // #ifndef OCF_OCM_SERVERCTL_REQUESTOR_HPP_