GWMessageContext.h

#pragma once

#include <Poco/SharedPtr.h>

#include "core/Result.h"
#include "gwmessage/GWRequest.h"
#include "gwmessage/GWResponse.h"
#include "gwmessage/GWResponseWithAck.h"
#include "gwmessage/GWSensorDataExport.h"
#include "model/GlobalID.h"
#include "util/LambdaTimerTask.h"

namespace BeeeOn {

enum GWMessagePriority {
        DEFAULT_PRIO = 0,
        DATA_PRIO = 10,
        REQUEST_PRIO = 20,
        RESPONSEWITHACK_PRIO = 30,
        RESPONSE_PRIO = 40,
};

class GWMessageContext {
public:
        typedef Poco::SharedPtr<GWMessageContext> Ptr;

        GWMessageContext(GWMessagePriority priority);

        virtual ~GWMessageContext();

        GWMessage::Ptr message();
        void setMessage(GWMessage::Ptr msg);

        int priority() const;

        GlobalID id() const;

protected:
        int m_priority;
        GWMessage::Ptr m_message;
};

class GWTimedContext : public GWMessageContext {
public:
        typedef Poco::SharedPtr<GWTimedContext> Ptr;

        GWTimedContext(GWMessagePriority priority);

        LambdaTimerTask::Ptr missingResponseTask();
        void setMissingResponseTask(LambdaTimerTask::Ptr task);

private:
        LambdaTimerTask::Ptr m_missingResponseTask;
};

class GWRequestContext : public GWTimedContext {
public:
        typedef Poco::SharedPtr<GWRequestContext> Ptr;

        GWRequestContext();
        GWRequestContext(GWRequest::Ptr request, Result::Ptr result);

        Result::Ptr result();
        void setResult(Result::Ptr result);
private:
        Result::Ptr m_result;
};

class GWResponseContext : public GWMessageContext {
public:
        typedef Poco::SharedPtr<GWResponseContext> Ptr;

        GWResponseContext();
        GWResponseContext(GWResponse::Ptr response);
};

class GWResponseWithAckContext : public GWTimedContext {
public:
        typedef Poco::SharedPtr<GWResponseWithAckContext> Ptr;

        GWResponseWithAckContext(GWResponse::Status status);

        GWResponse::Status status();
        void setStatus(GWResponse::Status);

private:
        GWResponse::Status m_status;
};

class GWSensorDataExportContext : public GWTimedContext {
public:
        typedef Poco::SharedPtr<GWSensorDataExportContext> Ptr;

        GWSensorDataExportContext();
};

class ContextPriorityComparator {
public:
        bool operator()(const GWMessageContext::Ptr a, const GWMessageContext::Ptr b);
};

}