testing/spsp/espnow_adapter.hpp

Go to the documentation of this file.

 
#pragma once
 
#include <string>
#include <unordered_set>
 
#include "spsp/espnow_adapter_if.hpp"
#include "spsp/espnow_types.hpp"
 
namespace SPSP::LocalLayers::ESPNOW
{
    class Adapter : public IAdapter
    {
        AdapterRecvCb m_recvCb = nullptr;
        AdapterSendCb m_sendCb = nullptr;
        std::unordered_set<LocalAddrT> m_peers;
 
    public:
        void setRecvCb(AdapterRecvCb cb) noexcept
        {
            m_recvCb = cb;
        }
 
        AdapterRecvCb getRecvCb() const noexcept
        {
            return m_recvCb;
        }
 
        void setSendCb(AdapterSendCb cb) noexcept
        {
            m_sendCb = cb;
        }
 
        AdapterSendCb getSendCb() const noexcept
        {
            return m_sendCb;
        }
 
        virtual void send(const LocalAddrT& dst, const std::string& data) const
        {
            std::thread t(this->getSendCb(), dst, true);
            t.detach();
        }
 
        void addPeer(const LocalAddrT& peer)
        {
            m_peers.insert(peer);
        }
 
        void removePeer(const LocalAddrT& peer)
        {
            if (!m_peers.erase(peer)) {
                throw AdapterError("Can't remove non-existing peer");
            }
        }
    };
} // namespace SPSP::LocalLayers::ESPNOW