GWSCommandSender.h

#pragma once

#include <Poco/Timespan.h>

#include "core/CommandSender.h"
#include "gwmessage/GWDeviceAcceptRequest.h"
#include "gwmessage/GWListenRequest.h"
#include "gwmessage/GWSearchRequest.h"
#include "gwmessage/GWSetValueRequest.h"
#include "gwmessage/GWUnpairRequest.h"
#include "loop/StoppableRunnable.h"
#include "loop/StopControl.h"
#include "server/GWSConnector.h"
#include "server/GWSListener.h"
#include "util/Loggable.h"

namespace BeeeOn {

class GWSCommandSender :
        public StoppableRunnable,
        public GWSListener,
        public CommandSender,
        Loggable {
public:
        GWSCommandSender();

        void setConnector(GWSConnector::Ptr connector);
        void setUnpairDuration(const Poco::Timespan &duration);

        void run() override;
        void stop() override;

        void onRequest(GWRequest::Ptr request) override;

protected:
        void handleDeviceAccept(GWDeviceAcceptRequest::Ptr request);
        void handleListen(GWListenRequest::Ptr request);
        void handleSearch(GWSearchRequest::Ptr request);
        void handleSetValue(GWSetValueRequest::Ptr request);
        void handleUnpair(GWUnpairRequest::Ptr request);
        void dispatch(Command::Ptr command, GWRequest::Ptr request);

        class RequestAnswer : public Answer {
        public:
                typedef Poco::AutoPtr<RequestAnswer> Ptr;

                RequestAnswer(AnswerQueue &queue, GWRequest::Ptr request);

                GWRequest::Ptr request() const;

        private:
                GWRequest::Ptr m_request;
        };

        void respond(RequestAnswer::Ptr answer, bool failed);

private:
        Poco::Timespan m_unpairDuration;
        GWSConnector::Ptr m_connector;
        StopControl m_stopControl;
};

}