artnetreceiver.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
 
 // Local Includes
#include "artnetlistener.h"
#include "artnetevent.h"
 
// External Includes
#include <nap/device.h>
#include <rtti/factory.h>
#include <asio/io_service.hpp>
#include <thread>
#include <mutex>
#include <queue>
#include <memory>
#include <cstdint>
 
namespace nap
{
    // Forward Declares
    class ArtNetService;
 
    class NAPAPI ArtNetReceiver : public Device
    {
        RTTI_ENABLE(Device)
 
    public:
 
        // Default constructor
        ArtNetReceiver() = default;
 
        // Constructor used by factory
        ArtNetReceiver(ArtNetService & service);
 
        virtual bool start(utility::ErrorState& errorState) override;
 
        virtual void stop() override;
 
        void addEvent(ArtNetEventPtr event);
 
        void consumeEvents(std::queue<ArtNetEventPtr>& outEvents);
 
        std::string mIpAddress = "";    
        uint16 mPort = 6454;            
 
    private:
        friend class ArtNetService;
 
        // Art-Net service that consumes the events
        ArtNetService* mService = nullptr;
 
        // The ASIO I/O service
        asio::io_service mIOService;
 
        // The thread used for running the I/O service
        std::thread mRunThread;
 
        // The UDP socket server used for receiving Art-Net
        std::unique_ptr<ArtNetListener> mListener = nullptr;
 
        // Queue that holds all the consumed events
        std::queue<ArtNetEventPtr> mEvents;
 
        // Mutex associated with setting / getting events
        std::mutex mEventMutex;
    };
 
    using ArtNetReceiverCreator = rtti::ObjectCreator<ArtNetReceiver, ArtNetService>;
}