blob: 2488135ab44e8b412083b8b968f537cf0c52fec3 [file] [log] [blame]
#pragma once
#include "common/instance_id.hpp"
#include "common/utils.hpp"
#include <err.h>
#include <libpldm/base.h>
#include <libpldm/bios.h>
#include <libpldm/fru.h>
#include <libpldm/platform.h>
#include <sys/socket.h>
#include <sys/un.h>
#include <unistd.h>
#include <CLI/CLI.hpp>
#include <nlohmann/json.hpp>
#include <cstring>
#include <iomanip>
#include <iostream>
#include <utility>
namespace pldmtool
{
namespace helper
{
constexpr uint8_t PLDM_ENTITY_ID = 8;
constexpr uint8_t MCTP_MSG_TYPE_PLDM = 1;
using ordered_json = nlohmann::ordered_json;
/** @brief print the input message if pldmverbose is enabled
*
* @param[in] pldmVerbose - verbosity flag - true/false
* @param[in] msg - message to print
* @param[in] data - data to print
*
* @return - None
*/
template <class T>
void Logger(bool pldmverbose, const char* msg, const T& data)
{
if (pldmverbose)
{
std::stringstream s;
s << data;
std::cout << msg << s.str() << std::endl;
}
}
/** @brief Display in JSON format.
*
* @param[in] data - data to print in json
*
* @return - None
*/
static inline void DisplayInJson(const ordered_json& data)
{
std::cout << data.dump(4) << std::endl;
}
/** @brief MCTP socket read/recieve
*
* @param[in] requestMsg - Request message to compare against loopback
* message recieved from mctp socket
* @param[out] responseMsg - Response buffer recieved from mctp socket
* @param[in] pldmVerbose - verbosity flag - true/false
*
* @return - 0 on success.
* -1 or -errno on failure.
*/
int mctpSockSendRecv(const std::vector<uint8_t>& requestMsg,
std::vector<uint8_t>& responseMsg, bool pldmVerbose);
class CommandInterface
{
public:
explicit CommandInterface(const char* type, const char* name,
CLI::App* app) :
pldmType(type),
commandName(name), mctp_eid(PLDM_ENTITY_ID), pldmVerbose(false),
instanceId(0)
{
app->add_option("-m,--mctp_eid", mctp_eid, "MCTP endpoint ID");
app->add_flag("-v, --verbose", pldmVerbose);
app->callback([&]() { exec(); });
}
virtual ~CommandInterface() = default;
virtual std::pair<int, std::vector<uint8_t>> createRequestMsg() = 0;
virtual void parseResponseMsg(struct pldm_msg* responsePtr,
size_t payloadLength) = 0;
virtual void exec();
int pldmSendRecv(std::vector<uint8_t>& requestMsg,
std::vector<uint8_t>& responseMsg);
/**
* @brief get MCTP endpoint ID
*
* @return uint8_t - MCTP endpoint ID
*/
inline uint8_t getMCTPEID()
{
return mctp_eid;
}
/**
* @brief get PLDM type
*
* @return pldm type
*/
inline std::string getPLDMType()
{
return pldmType;
}
/**
* @brief get command name
*
* @return the command name
*/
inline std::string getCommandName()
{
return commandName;
}
private:
const std::string pldmType;
const std::string commandName;
uint8_t mctp_eid;
bool pldmVerbose;
protected:
uint8_t instanceId;
pldm::InstanceIdDb instanceIdDb;
};
} // namespace helper
} // namespace pldmtool