oscsender.h

/* This Source Code Form is subject to the terms of the Mozilla Public
 * License, v. 2.0. If a copy of the MPL was not distributed with this
 * file, You can obtain one at https://mozilla.org/MPL/2.0/. */
 
#pragma once
 
// External Includes
#include <ip/UdpSocket.h>
#include <nap/resource.h>
#include <rtti/factory.h>
#include <queue>
#include <nap/device.h>
 
// Local Includes
#include "oscevent.h"
 
// Forward declares
class UdpTransmitSocket;
namespace nap
{
    class OSCService;
}
namespace osc
{
    class OutboundPacketStream;
}
 
 
namespace nap 
{
    class NAPAPI OSCSender : public Device
    {
        friend class OSCService;
        RTTI_ENABLE(Device)
    public:
        OSCSender() = default;
 
        // Constructor used by factory
        OSCSender(OSCService& service);
 
        std::string mIPAddress = "127.0.0.1";   
        int mPort = 8000;                       
        int mBufferScale = 2;                   
        bool mAllowFailure = false;             
 
 
        virtual bool start(utility::ErrorState& errorState) override;
 
        virtual void stop() override;
 
        bool send(const OSCEvent& oscEvent);
 
        void addEvent(OSCEventPtr oscEvent);
 
        void sendQueuedEvents();
 
    private:
        // Socket used for sending messages
        std::unique_ptr<UdpTransmitSocket> mSocket = nullptr;
 
        void writeToPacket(const OSCEvent& oscEvent, osc::OutboundPacketStream& outPacket);
 
        // Queue that holds all the events to be send over as a bundle
        std::queue<OSCEventPtr> mEventQueue;
        
        // The number of bytes represented by the values in the event queue
        std::size_t mEventQueueDataSize;
 
        // Vector that holds osc data to be send over
        std::vector<char> mBuffer;
    };
}