stream.h

Go to the documentation of this file.

 
#pragma once
 
#include <functional>
#include <memory>
 
#include <flyby/payload/component/component.h>
#include <flyby/payload/component/camera.h>
 
namespace flyby {
 
    class StreamInterface : public Component {
    public:
        friend class ComponentHandler;
 
        virtual void register_camera(std::shared_ptr<CameraInterface> camera) = 0;
 
        virtual void start_stream(unsigned int endpoint_idx, std::function<void(std::string)> set_alive_callback) = 0;
 
        [[nodiscard]] virtual unsigned int get_active_camera_idx() = 0;
 
        virtual void set_active_camera(unsigned int camera_idx) = 0;
 
        [[nodiscard]] virtual unsigned int get_endpoint_idx() const = 0;
 
        [[nodiscard]] virtual const std::vector<std::shared_ptr<const CameraInterface>>& get_cameras_const() const = 0;
 
    protected:
        using Component::Component;
 
    private:
        virtual void set_endpoint_idx(unsigned int endpoint_idx) = 0;
        virtual void set_active_camera_idx(unsigned int camera_idx) = 0;
        virtual std::shared_ptr<CameraInterface> get_active_camera() = 0;
        virtual std::vector<std::shared_ptr<CameraInterface>>& get_cameras() = 0;
    };
 
    class Stream : public StreamInterface {
    public:
        explicit Stream(const std::string& name);
 
        Stream(std::string name, unsigned int endpoint_idx, std::string uuid);
 
        ~Stream() override;
 
        void register_camera(std::shared_ptr<CameraInterface> camera) final;
 
        void start_stream(unsigned int endpoint_idx, std::function<void(std::string)> set_alive_callback) override;
 
        void set_active_camera(unsigned int camera_idx) override;
 
        [[nodiscard]] unsigned int get_endpoint_idx() const final;
 
        [[nodiscard]] const std::vector<std::shared_ptr<const CameraInterface>>& get_cameras_const() const final;
 
    private:
        void set_endpoint_idx(unsigned int endpoint_idx) final;
        std::shared_ptr<CameraInterface> get_active_camera() final;
        unsigned int get_active_camera_idx() final;
        void set_active_camera_idx(unsigned int camera_idx) final;
        std::vector<std::shared_ptr<CameraInterface>>& get_cameras() final;
 
        unsigned int m_endpoint_idx;
        unsigned int m_active_camera_idx;
        std::vector<std::shared_ptr<CameraInterface>> m_cameras;
    };
 
}