CscMJPGStreamer.h

Go to the documentation of this file.

#ifndef MJPG_STREAMER_H
#define MJPG_STREAMER_H
 
#include "CscCommon.h"
#include "HttpServer.h"
 
using std::weak_ptr;
 
namespace conscience_core::mjpg_streamer {
 
class CSC_DLL_IMPORTEXPORT UnauthorizedStreamAccessException : public exception {
public:
    UnauthorizedStreamAccessException(const string &errorMessage) noexcept : errorMessage(errorMessage) {}
    ~UnauthorizedStreamAccessException() noexcept override = default;
    const char *what() const noexcept override {
        return errorMessage.c_str();
    }
 
private:
    const string errorMessage;
};
 
class CSC_DLL_IMPORTEXPORT CscMJPGStreamer : public FrameSourceProvider {
public:
    static CscMJPGStreamer *&lastInstance();
 
    CscMJPGStreamer(unsigned short port);
    virtual ~CscMJPGStreamer();
 
    FrameSourceId registerFrameSource(const FrameSourceData &frameSourceData);
 
    ptr<FrameSource> getFrameSource(const string &accessToken) override;
    void releaseFrameSource(const FrameSourceId &sourceUid);
 
    string createAccess(const FrameSourceId &sourceUid);
 
private:
    unique_ptr<CscLogger> logger = nullptr;
    ptr<HttpServer> httpServer = nullptr;
 
    mutex frameSourcesMutex;
    map<FrameSourceId, ptr<FrameSource>> frameSources;
 
    FrameSourceId checkAccessToken(const string &accessToken);
 
    const string tokenAESKey;
    const string tokenAESInitVector;
 
    void decodeToken(const string &accessTokenEncryptedB64, unsigned long long &outTimestampMillis, string &outSourceUid);
};
 
}
 
#endif