state_server.h

#ifndef STATE_SERVER_H
#define STATE_SERVER_H
 
#include <atomic>
#include <map>
#include <mutex>
#include <set>
#include "../com/someip/rpc/rpc_server.h"
#include "../sm/trigger.h"
#include "./exec_exception.h"
 
namespace ara
{
    namespace exec
    {
        class StateServer
        {
        private:
            const uint16_t cServiceId{3};
            const uint16_t cSetStateId{1};
            const uint16_t cStateTransitionId{2};
 
            com::someip::rpc::RpcServer *const mRpcServer;
            const std::set<std::pair<std::string, std::string>> mFunctionGroupStates;
            std::map<std::string, sm::Trigger<std::string> *> mNotifiers;
            std::map<std::string, std::string> mCurrentStates;
            std::atomic_bool mInitialized;
            std::mutex mMutex;
 
            void injectErrorCode(
                std::vector<uint8_t> &payload, ExecErrc errorCode);
 
            void notify(std::string functionGroup, std::string state);
 
            bool handleSetState(
                const std::vector<uint8_t> &rpcRequestPayload,
                std::vector<uint8_t> &rpcResponsePayload);
 
            bool handleStateTransition(
                const std::vector<uint8_t> &rpcRequestPayload,
                std::vector<uint8_t> &rpcResponsePayload);
 
        public:
            StateServer(
                com::someip::rpc::RpcServer *rpcServer,
                std::set<std::pair<std::string, std::string>> &&functionGroupStates,
                std::map<std::string, std::string> &&initialStates);
 
            bool TryGetState(
                std::string functionGroup, std::string &state);
 
            void SetNotifier(
                std::string functionGroup, std::function<void()> callback);
 
            bool Initialized() const noexcept;
 
            ~StateServer();
        };
    }
}
 
#endif