execution_server.h

#ifndef EXECUTION_SERVER_H
#define EXECUTION_SERVER_H
 
#include <map>
#include <mutex>
#include <string>
#include "./execution_client.h"
#include "../com/someip/rpc/rpc_server.h"
 
namespace ara
{
    namespace exec
    {
        class ExecutionServer
        {
        private:
            const uint16_t cService{1};
            const uint16_t cMethodId{1};
 
            std::mutex mMutex;
            com::someip::rpc::RpcServer *const mRpcServer;
            std::map<std::string, ExecutionState> mExecutionStates;
 
            static void injectErrorCode(
                std::vector<uint8_t> &payload, ExecErrc errorCode);
 
            bool handleExecutionStateReport(
                const std::vector<uint8_t> &rpcRequestPayload,
                std::vector<uint8_t> &rpcResponsePayload);
 
        public:
            explicit ExecutionServer(
                com::someip::rpc::RpcServer *rpcServer);
 
            bool TryGetExecutionState(
                std::string id, ExecutionState &state);
        };
    }
}
 
#endif