layers.hpp

Go to the documentation of this file.

 
#pragma once
 
#include "spsp/local_message.hpp"
 
namespace SPSP
{
    // Forward declaration
    template <typename TLocalLayer> class ILocalNode;
    template <typename TFarLayer> class IFarNode;
 
    template <typename TLocalMessage>
    class ILocalLayer
    {
        void* m_node = nullptr;
 
    public:
        using LocalAddrT = typename TLocalMessage::LocalAddrT;
        using LocalMessageT = TLocalMessage;
 
        void setNode(void* n)
        {
            m_node = n;
        }
 
        inline ILocalNode<ILocalLayer>* getNode() const
        {
            return static_cast<ILocalNode<ILocalLayer>*>(m_node);
        }
 
        inline bool nodeConnected() const
        {
            return m_node != nullptr;
        }
 
        virtual bool send(const TLocalMessage& msg) = 0;
    };
 
    class IFarLayer
    {
        void* m_node = nullptr;
 
    public:
        void setNode(void* n)
        {
            m_node = n;
        }
 
        inline IFarNode<IFarLayer>* getNode() const
        {
            return static_cast<IFarNode<IFarLayer>*>(m_node);
        }
 
        inline bool nodeConnected() const
        {
            return m_node != nullptr;
        }
 
        virtual bool publish(const std::string& src, const std::string& topic,
                             const std::string& payload) = 0;
 
        virtual bool subscribe(const std::string& topic) = 0;
 
        virtual bool unsubscribe(const std::string& topic) = 0;
    };
} // namespace SPSP