FrameSource.h

Go to the documentation of this file.

#ifndef MJPG_STREAMER_FrameSource_H
#define MJPG_STREAMER_FrameSource_H
 
#include "CscCommon.h"
#include "CaptureEngine/CscCaptureEngine.h"
#include "ArtificialIntelligence/CscEntityReflexion.h"
#include "ArtificialIntelligence/CscEntityReflexions.h"
#include <condition_variable>
 
using namespace conscience_core::media_capture;
using namespace conscience_core::ai;
 
namespace conscience_core::mjpg_streamer {
 
typedef string FrameSourceId;
 
enum FrameSourceQuality {
    High, Medium, Low
};
 
enum FrameSourceType {
    FrameSourceType_CaptureEngine = 100
};
 
class CSC_DLL_IMPORTEXPORT FrameSourceData {
public:
    int frameSourceType;
    
    map<string, string> additionalParameters;
    
    FrameSourceData(int frameSourceType, const map<string, string> &additionalParameters);
    
    bool equals(const FrameSourceData &other) const;
    bool operator== (const FrameSourceData &other) const;
};
 
class CSC_DLL_IMPORTEXPORT FrameSource {
public:
    const FrameSourceId uid;
    
    FrameSourceQuality quality;
    
    system_clock::time_point lastGrabTime = system_clock::now();
    
    mutex frameDataLock;
    std::condition_variable  frameDataLockCondition;
    mutex stateMutex;
    
    /* global JPG frame, this is more or less the "database" */
    unsigned char *buf = nullptr;
    int size = -1;
    
    FrameSource(const FrameSourceData &frameSourceData, FrameSourceQuality quality = FrameSourceQuality::Medium);
    
    void start();
    void stop();
    
    bool isStopped();
    const FrameSourceData frameSourceData;
    
protected:
    virtual optional<cv::Mat> grab() = 0;
    unique_ptr<CscLogger> logger = CscLogger::getForCategory("MJPGStreamer_FrameSource");
    
private:
    bool stopped = true;
};
 
#define FRAME_SOURCE_PARAM_CAPTURE_ENGINE_ENTITY_SERIAL_NUMBER "entitySerialNumber"
#define FRAME_SOURCE_PARAM_CAPTURE_ENGINE_VIDEO_SOURCE_ID "videoSourceId"
#define FRAME_SOURCE_PARAM_CAPTURE_ENGINE_AI_PROCESSED_FRAMES "aiProcessedFrames"
 
class CSC_DLL_IMPORTEXPORT CaptureEngineFrameSource : public FrameSource {
public:
    CaptureEngineFrameSource(const FrameSourceData &frameSourceData);
protected:
    const string entitySerialNumber;
    const bool aiProcessedFrames;
    
    virtual optional<Mat> grab() override;
    
    ptr<CscEntityReflexion> reflexion = nullptr;
    CscCaptureEngine *captureEngine = nullptr;
};
class CSC_DLL_IMPORTEXPORT FrameSourceProvider {
public:
    virtual ptr<FrameSource> getFrameSource(const string &accessToken) = 0;
};
 
 
}
 
#endif