UdpClient.h

#ifndef UDP_CLIENT_H
#define UDP_CLIENT_H

#define COMM_COUNT 5

#include "ICommClient.h"
#include <boost/asio.hpp>
#include <boost/system/error_code.hpp>

using boost::asio::ip::udp;
using boost::asio::ip::address;

// ReSharper disable once CppPolymorphicClassWithNonVirtualPublicDestructor
class UdpClient : public ICommClient  // NOLINT
{
public:
    UdpClient();
    // ReSharper disable once CppHidingFunction
    ~UdpClient();

    void Init(bool) override;
    void Send(std::string) override;
    void Send(int) override;
    boost::signals2::signal<void(double *, int)>* GetIncomer() override;
    boost::signals2::signal<void(std::string)>* GetStringIncomer() override;

private:
    boost::asio::io_service _ioServiceIn;
    std::shared_ptr<udp::socket> _socketIn;
    std::shared_ptr<udp::endpoint> _endpointIn;
    std::array<char, 1024> _bufferIn;

    boost::asio::io_service _ioServiceOut;
    std::shared_ptr<udp::socket> _socketOut;
    std::shared_ptr<udp::endpoint> _endpointOut;

    boost::signals2::signal<void(double *, int)> _incoming;
    boost::signals2::signal<void(std::string)> _stringIncoming;

    void StartReceive();
    void Receive(const boost::system::error_code& error, std::size_t bytesTransferred);

    union Command
    {
        char C[COMM_COUNT * 8];
        double D[COMM_COUNT];
    };

    union MFiflak
    {
        char C[4];
        int I;
    };
};

#endif //UDP_CLIENT_H