rpc_client.h

#ifndef RPC_CLIENT_H
#define RPC_CLIENT_H
 
#include <functional>
#include <map>
#include <stdint.h>
#include <vector>
#include "./someip_rpc_message.h"
 
namespace ara
{
    namespace com
    {
        namespace someip
        {
            namespace rpc
            {
                class RpcClient
                {
                public:
                    using HandlerType = std::function<void(const SomeIpRpcMessage &)>;
 
                private:
                    const uint8_t mProtocolVersion;
                    const uint8_t mInterfaceVersion;
                    std::map<uint32_t, uint16_t> mSessionIds;
                    std::map<uint32_t, HandlerType> mHandlers;
 
                protected:
                    RpcClient(
                        uint8_t protocolVersion,
                        uint8_t interfaceVersion) noexcept;
 
                    void InvokeHandler(const std::vector<uint8_t> &payload) const;
 
                    virtual void Send(const std::vector<uint8_t> &payload) = 0;
 
                public:
                    void SetHandler(
                        uint16_t serviceId, uint16_t methodId, HandlerType handler);
 
                    void Send(
                        uint16_t serviceId,
                        uint16_t methodId,
                        uint16_t clientId,
                        const std::vector<uint8_t> &rpcPayload);
 
                    virtual ~RpcClient() noexcept = default;
                };
            }
        }
    }
}
 
#endif