udp_client.h

#ifndef UDP_CLIENT_H
#define UDP_CLIENT_H
 
#include <sys/socket.h>
#include <arpa/inet.h>
#include <array>
#include "./network_socket.h"
 
namespace AsyncBsdSocketLib
{
    class UdpClient : public NetworkSocket
    {
    private:
        std::string mNicIpAddress;
        std::string mMulticastIpAddress;
        bool mIsMulticast;
        bool mShareAddress;
 
    public:
        UdpClient() = delete;
 
        UdpClient(std::string ipAddress, uint16_t port);
 
        UdpClient(
            std::string ipAddress,
            uint16_t port,
            std::string nicIpAddress,
            std::string multicastIpAddress,
            bool shareAddress = true);
 
        int Connection() const noexcept override;
 
        bool TrySetup() noexcept override;
 
        template <std::size_t N>
        ssize_t Send(
            const std::array<uint8_t, N> &buffer,
            std::string ipAddress,
            uint16_t port) const noexcept
        {
            // No flag for sending
            const int _flags = 0;
 
            struct sockaddr_in _destinationAddress;
            _destinationAddress.sin_addr.s_addr = inet_addr(ipAddress.c_str());
            _destinationAddress.sin_family = AF_INET;
            _destinationAddress.sin_port = htons(port);
 
            ssize_t _result =
                sendto(
                    FileDescriptor,
                    buffer.data(),
                    N,
                    _flags,
                    (struct sockaddr *)&_destinationAddress,
                    sizeof(_destinationAddress));
 
            return _result;
        }
 
        template <std::size_t N>
        ssize_t Receive(
            std::array<uint8_t, N> &buffer,
            std::string &ipAddress,
            uint16_t &port) const noexcept
        {
            // No flag for receiving
            const int _flags = 0;
 
            struct sockaddr_in _sourceAddress;
            socklen_t _sourceAddressLength = sizeof(_sourceAddress);
 
            ssize_t _result =
                recvfrom(
                    FileDescriptor,
                    buffer.data(),
                    N,
                    _flags,
                    (struct sockaddr *)&_sourceAddress,
                    &_sourceAddressLength);
 
            // Convert IP address
            char _ipAddress[INET_ADDRSTRLEN];
            inet_ntop(AF_INET, &(_sourceAddress.sin_addr), _ipAddress, INET_ADDRSTRLEN);
            ipAddress = std::string(_ipAddress);
 
            // Convert port number
            port = htons(_sourceAddress.sin_port);
 
            return _result;
        }
    };
}
 
#endif