threaded_proto_udp_sender.hpp

#pragma once
 
#include <boost/asio.hpp>
#include <boost/bind.hpp>
#include <optional>
#include <string>
 
#include "software/networking/udp/threaded_udp_sender.h"
 
template <class SendProto>
class ThreadedProtoUdpSender : private ThreadedUdpSender
{
   public:
    ThreadedProtoUdpSender(const std::string& ip_address, unsigned short port,
                           const std::string& interface, bool multicast);
 
    std::string getInterface() const;
 
    std::string getIpAddress() const;
 
    void sendProto(const SendProto& message, bool async = false);
 
 
   private:
    std::string data_buffer;
};
 
template <class SendProto>
ThreadedProtoUdpSender<SendProto>::ThreadedProtoUdpSender(const std::string& ip_address,
                                                          unsigned short port,
                                                          const std::string& interface,
                                                          bool multicast)
    : ThreadedUdpSender(ip_address, port, interface, multicast)
{
}
 
template <class SendProto>
std::string ThreadedProtoUdpSender<SendProto>::getInterface() const
{
    return ThreadedUdpSender::getInterface();
}
 
template <class SendProto>
std::string ThreadedProtoUdpSender<SendProto>::getIpAddress() const
{
    return ThreadedUdpSender::getIpAddress();
}
 
template <class SendProto>
void ThreadedProtoUdpSender<SendProto>::sendProto(const SendProto& message, bool async)
{
    message.SerializeToString(&data_buffer);
    sendString(data_buffer, async);
}