~aleteoryx/muditaos

ref: 3e7b94dc05844c2aee890a683aec193b7e80494d muditaos/module-services/service-desktop/parser/MessageHandler.cpp -rw-r--r-- 1.4 KiB
3e7b94dc — Alek Rudnik [EGD-8137] Fix system pre closure procedure 4 years ago
                                                                                
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
// Copyright (c) 2017-2021, Mudita Sp. z.o.o. All rights reserved.
// For licensing, see https://github.com/mudita/MuditaOS/LICENSE.md

#include "MessageHandler.hpp"

#include <endpoints/EndpointFactory.hpp>

#include <log/log.hpp>

#include <memory>

namespace sdesktop::endpoints
{

    MessageHandler::MessageHandler(sys::Service *OwnerService, std::unique_ptr<EndpointFactory> endpointFactory)
        : OwnerServicePtr(OwnerService), endpointFactory(std::move(endpointFactory))
    {}

    void MessageHandler::parseMessage(const std::string &msg)
    {
        try {
            messageJson = json11::Json::parse(msg, JsonErrorMsg);
        }
        catch (const std::exception &e) {
            LOG_ERROR("Cannot create MessageHandler! err:%s", e.what());
        }
    }

    void MessageHandler::processMessage()
    {
        auto context = ContextFactory::create(messageJson);

        LOG_DEBUG("[MsgHandler]\nmethod: %d\nendpoint: %d\nuuid: %d\n",
                  static_cast<int>(context->getMethod()),
                  static_cast<int>(context->getEndpoint()),
                  context->getUuid());

        auto handler = endpointFactory->create(*context, OwnerServicePtr);

        if (handler != nullptr) {
            handler->handle(*context);
        }
        else {
            LOG_ERROR("No way to handle!");
        }
    }

} // namespace sdesktop::endpoints