CamManager.h

Go to the documentation of this file.

#ifndef CAM_MANAGER_H
#define CAM_MANAGER_H

#include <RocServer.h>
#include <RocLogger.h>
#include <Extractor.h>
#include <StorageManager.h>

#include <list>

#include <mutex>

class CamManager : public RocServer {
public:
    CamManager(zmq::context_t & _ctx,
               const std::string & _brokerEndpoint,
               const std::string & _serviceName,
               const PubSubEndpoint & _cameraSource,
               StorageManager & _storageManager
              );
    ~CamManager();
    Json::Value addExtractor(const std::string & name, const Json::Value & arguments);
    Json::Value listExtractors();
    Json::Value removeExtractor(const std::string & name, const std::string & identifier);
private:
    Json::Value call(const std::string & name, const Json::Value & arguments);
    
    PubSubEndpoint cameraSource;
    std::list<Extractor *> extractors;
    std::mutex extractorsMutex;
    
    RocLogger logger;
    StorageManager * storageManager;
};

#endif /* CAM_MANAGER_H */