threaded_proto_unix_sender.hpp

#pragma once
 
#include <boost/asio.hpp>
#include <boost/bind.hpp>
#include <string>
 
#include "software/networking/unix/threaded_unix_sender.h"
 
template <class SendProto>
class ThreadedProtoUnixSender : private ThreadedUnixSender
{
   public:
    ThreadedProtoUnixSender(const std::string& unix_path,
                            const std::shared_ptr<ProtoLogger>& proto_logger = nullptr)
        : ThreadedUnixSender(unix_path), proto_logger(proto_logger)
    {
    }
 
    void sendProto(const SendProto& message);
 
   private:
    std::string data_buffer;
 
    std::shared_ptr<ProtoLogger> proto_logger;
};
 
template <class SendProtoT>
void ThreadedProtoUnixSender<SendProtoT>::sendProto(const SendProtoT& message)
{
    message.SerializeToString(&data_buffer);
    sendString(data_buffer);
 
    if (proto_logger)
    {
        proto_logger->saveSerializedProto<SendProtoT>(data_buffer);
    }
}