websocketinterface.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 "websocketevent.h"
 
// External Includes
#include <nap/resource.h>
#include <queue>
#include <mutex>
 
namespace nap
{
    class WebSocketService;
 
    class NAPAPI WebSocketInterface : public Resource
    {
        friend class WebSocketService;
        RTTI_ENABLE(Resource)
    public:
        WebSocketInterface(WebSocketService& service);
 
        // Destructor
        virtual ~WebSocketInterface();
 
        virtual bool init(utility::ErrorState& errorState) override;
 
        template<typename T>
        T& as();
 
        template<typename T>
        const T& as() const;
 
    protected:
        void addEvent(WebSocketEventPtr newEvent);
 
        // Queue that holds all the consumed events
        std::queue<WebSocketEventPtr> mEvents;
 
        // Mutex associated with setting / getting events
        std::mutex  mEventMutex;
 
        // Handle to the web socket service
        WebSocketService* mService = nullptr;
 
    private:
        void consumeEvents(std::queue<WebSocketEventPtr>& outEvents);
 
        // If the interface registered on init
        bool mRegistered = false;
    };
 
    
    // Template definitions
 
    template<typename T>
    const T& nap::WebSocketInterface::as() const
    {
        const T* return_p = nullptr;
        if (this->get_type().is_derived_from<T>())
            return_p = reinterpret_cast<const T*>(this);
        assert(return_p != nullptr);
        return *return_p;
    }
 
 
    template<typename T>
    T& nap::WebSocketInterface::as()
    {
        T* cast_interface = rtti_cast<T>(this);
        assert(cast_interface != nullptr);
        return *cast_interface;
    }
 
}