oscreceiver.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 <nap/device.h>
#include <rtti/factory.h>
#include <utility/dllexport.h>
#include <thread>
#include <queue>
 
// Local Includes
#include "oscpacketlistener.h"
#include "oscreceivingsocket.h"
#include "oscevent.h"
 
// Forward Declares
namespace nap
{
    class OSCService;
}
 
namespace nap
{
    class NAPAPI OSCReceiver : public Device
    {
        friend class OSCService;
        RTTI_ENABLE(Device)
    public:
        // Constructor used by factory
        OSCReceiver(OSCService& service);
 
        virtual bool start(utility::ErrorState& errorState) override;
 
        virtual void stop() override;
 
    public:
        int mPort = 7000;               
        bool mDebugOutput = false;      
        bool mAllowPortReuse = false;   
 
        void addEvent(OSCEventPtr event);
 
    private:
        // Runs in the background
        void eventThread(int port);
 
        void consumeEvents(std::queue<OSCEventPtr>& outEvents);
 
        // The socket used for receiving messages
        std::unique_ptr<OSCReceivingSocket> mSocket = nullptr;
 
        // Queue that holds all the consumed events
        std::queue<OSCEventPtr> mEvents;
 
        // Mutex associated with setting / getting events
        std::mutex  mEventMutex;
 
        // The listener used for handling messages
        std::unique_ptr<OSCPacketListener>  mListener = nullptr;
 
        // OSC service that manages all the osc receivers / senders
        OSCService* mService = nullptr;
 
        // The thread that receives and converts the messages
        std::thread mEventThread;
    };
 
    // Object creator used for constructing the the OSC receiver
    using OSCReceiverObjectCreator = rtti::ObjectCreator<OSCReceiver, OSCService>;
}