someip_sd_agent.h

#ifndef SOMEIP_SD_AGENT_H
#define SOMEIP_SD_AGENT_H
 
#include <future>
#include "../../helper/finite_state_machine.h"
#include "../../helper/network_layer.h"
#include "./someip_sd_message.h"
 
namespace ara
{
    namespace com
    {
        namespace someip
        {
            namespace sd
            {
                template <typename T>
                class SomeIpSdAgent
                {
                protected:
                    helper::FiniteStateMachine<T> StateMachine;
 
                    std::future<void> Future;
 
                    helper::NetworkLayer<SomeIpSdMessage> *CommunicationLayer;
 
                    virtual void StartAgent(T state) = 0;
 
                    virtual void StopAgent() = 0;
 
                public:
                    SomeIpSdAgent(
                        helper::NetworkLayer<SomeIpSdMessage> *networkLayer) : CommunicationLayer{networkLayer}
                    {
                    }
 
                    void Start()
                    {
                        // Valid future means the timer is not expired yet.
                        if (Future.valid())
                        {
                            throw std::logic_error(
                                "The state has been already activated.");
                        }
                        else
                        {
                            T _state = GetState();
                            StartAgent(_state);
                        }
                    }
 
                    T GetState() const noexcept
                    {
                        return StateMachine.GetState();
                    }
 
                    void Join()
                    {
                        // If the future is valid, block unitl its result becomes avialable after the timer expiration.
                        if (Future.valid())
                        {
                            Future.get();
                        }
                    }
 
                    void Stop()
                    {
                        StopAgent();
                    }
 
                    virtual ~SomeIpSdAgent() noexcept = default;
                };
            }
        }
    }
}
 
#endif