axis_relayio_manager.h

// Copyright 2018-present Network Optix, Inc. Licensed under MPL 2.0: www.mozilla.org/MPL/2.0/

#pragma once

#include <list>
#include <map>
#include <set>

#include <QtCore/QAtomicInt>
#include <QtCore/QMutex>
#include <QtCore/QObject>
#include <QtCore/QWaitCondition>
#include <QtNetwork/QNetworkReply>

#include <camera/camera_plugin.h>
#include <plugins/plugin_tools.h>

class AxisCameraManager;


class AxisRelayIOManager
:
    public QObject,
    public nxcip::CameraRelayIOManager
{
    Q_OBJECT

public:
    AxisRelayIOManager(
        AxisCameraManager* cameraManager,
        unsigned int inputPortCount,
        unsigned int outputPortCount );
    virtual ~AxisRelayIOManager();

    virtual void* queryInterface( const nxpl::NX_GUID& interfaceID ) override;
    virtual int addRef() const override;
    virtual int releaseRef() const override;

    virtual int getRelayOutputList( char** idList, int* idNum ) const override;
    virtual int getInputPortList( char** idList, int* idNum ) const override;
    virtual int setRelayOutputState(
        const char* outputID,
        int activate,
        unsigned int autoResetTimeoutMS ) override;
    virtual int startInputPortMonitoring() override;
    virtual void stopInputPortMonitoring() override;
    virtual void registerEventHandler( nxcip::CameraInputEventHandler* handler ) override;
    virtual void unregisterEventHandler( nxcip::CameraInputEventHandler* handler ) override;
    virtual void getLastErrorString( char* errorString ) const override;

private:
    using  PortMonitoringSlotPtr = void(AxisRelayIOManager::*)(int);

    struct AsyncCallContext
    {
        AsyncCallContext()
        :
            done( false ),
            resultCode( 0 )
        {
        }

        bool done;
        int resultCode;
    };

    enum MultipartedParsingState
    {
        waitingDelimiter,
        readingHeaders,
        readingData
    };

    nxpt::CommonRefManager m_refManager;
    AxisCameraManager* m_cameraManager;
    unsigned int m_inputPortCount;
    unsigned int m_outputPortCount;
    std::map<QString, unsigned int> m_inputPortNameToIndex;
    std::map<QString, unsigned int> m_outputPortNameToIndex;
    std::list<nxcip::CameraInputEventHandler*> m_eventHandlers;
    mutable QMutex m_mutex;
    std::map<unsigned int, QNetworkReply*> m_inputPortHttpMonitor;
    QWaitCondition m_cond;
    QAtomicInt m_asyncCallCounter;
    std::map<int, AsyncCallContext> m_awaitedAsyncCallIDs;
    MultipartedParsingState m_multipartedParsingState;

    void copyPortList(
        char** idList,
        int* idNum,
        const std::map<QString, unsigned int>& portNameToIndex ) const;
    void callSlotFromOwningThread( PortMonitoringSlotPtr slotPtr, int* const resultCode = NULL );
    void readAxisRelayPortNotification( const QByteArray& line );

private:
    void startInputPortMonitoringPriv( int asyncCallID );
    void stopInputPortMonitoringPriv( int asyncCallID );
    void onMonitorDataAvailable();
    void onConnectionFinished( QNetworkReply* reply );
};