MessageDispatcher.h

gehe zur Dokumentation dieser Datei

 
#pragma once
 
#include "context/AuthContext.h"
#include "context/WorkflowContext.h"
#include "messages/MsgContext.h"
#include "messages/MsgHandler.h"
 
#include <QJsonDocument>
#include <QString>
 
#include <functional>
#include <initializer_list>
 
class test_Message;
 
namespace governikus
{
 
class MessageDispatcher
{
    private:
        friend class ::test_Message;
 
        MsgDispatcherContext mContext;
 
        MsgHandler createForStateChange(MsgType pStateType);
        MsgHandler createForCommand(const QJsonObject& pObj);
 
        MsgHandler cancel();
        MsgHandler accept();
        MsgHandler interrupt();
        MsgHandler handleCurrentState(MsgCmdType pCmdType, std::initializer_list<MsgType> pMsgType, const std::function<MsgHandler()>& pFunc) const;
        MsgHandler handleInternalOnly(MsgCmdType pCmdType, const std::function<MsgHandler()>& pFunc) const;
 
    public:
        class Msg final
        {
            friend class MessageDispatcher;
            const MsgType mType;
            const QByteArray mData;
 
            Msg(const MsgHandler& pHandler);
 
            public:
                operator QByteArray() const;
                operator MsgType() const;
        };
 
        MessageDispatcher();
 
        QByteArray init(const QSharedPointer<WorkflowContext>& pWorkflowContext);
        QByteArray finish();
        void reset();
        Msg processCommand(const QByteArray& pMsg);
        QByteArray processStateChange(const QString& pState);
 
        [[nodiscard]] QByteArray createMsgReader(const ReaderInfo& pInfo) const;
};
 
char* toString(const MessageDispatcher::Msg& pMsg);
 
} // namespace governikus