AbstractGWSConnector.h

#pragma once

#include <queue>

#include <Poco/Event.h>
#include <Poco/Mutex.h>

#include "gwmessage/GWMessage.h"
#include "server/GWSConnector.h"
#include "server/GWSPriorityAssigner.h"
#include "util/Loggable.h"

namespace BeeeOn {

class AbstractGWSConnector :
        public GWSConnector,
        protected Loggable {
public:
        AbstractGWSConnector();

        void setOutputsCount(int count);
        void setPriorityAssigner(GWSPriorityAssigner::Ptr assigner);

        void setupQueues();

        void send(const GWMessage::Ptr message) override;

protected:
        size_t selectOutput() const;

        void updateOutputs(size_t i);

        bool outputValid(size_t i) const;

        GWMessage::Ptr peekOutput(size_t i) const;

        void popOutput(size_t i);

protected:
        Poco::Event m_outputsUpdated;
        mutable Poco::Mutex m_outputLock;

private:
        unsigned int m_outputsCount;
        std::vector<std::queue<GWMessage::Ptr>> m_outputs;
        std::vector<size_t> m_outputsStatus;
        GWSPriorityAssigner::Ptr m_priorityAssigner;
};

}