MuditaOS/module-services/service-desktop/parser/ParserFSM.hpp

// Copyright (c) 2017-2024, Mudita Sp. z.o.o. All rights reserved.
// For licensing, see https://github.com/mudita/MuditaOS/LICENSE.md

#pragma once

#include "MessageHandler.hpp"

#include <Timers/TimerHandle.hpp>

#include <json11.hpp>
#include <string>

namespace sdesktop::endpoints
{
    enum class State
    {
        NoMsg,
        ReceivedPartialHeader,
        ReceivedPartialPayload,
    };

    class StateMachine
    {
      public:
        explicit StateMachine(sys::Service *ownerServicePtr);
        void processMessage(std::string &&msg);
        [[nodiscard]] auto getCurrentState() const noexcept -> State
        {
            return state;
        };

        void setState(const State newState) noexcept
        {
            state = newState;
        }

        void setMessageHandler(std::unique_ptr<MessageHandler> handler);

      private:
        std::string receivedMsg;
        State state = State::NoMsg;
        std::string payload;
        std::string header;
        unsigned long payloadLength = 0;
        std::unique_ptr<MessageHandler> messageHandler;
        sys::TimerHandle parserTimer;

        void parseHeader();
        void resetParser();
        void restartTimer();
        void parsePartialHeader();
        void parseNewMessage();
        void parsePartialMessage();
        void parsePayload();
    };
} // namespace sdesktop::endpoints