mirror of
https://github.com/mudita/MuditaOS.git
synced 2026-04-23 16:40:22 -04:00
d5174215eb
Fix wrong "count" key word in contacts, and add test for variables in device info endpoint. Disabled test jira: 5906 - test_calendar_events.py 5907 - test_connection_security.py 5908 - test_dom_dump.py 5909 - test_usb_echo.py
67 lines
1.8 KiB
C++
67 lines
1.8 KiB
C++
// 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/Context.hpp>
|
|
#include <endpoints/EndpointFactory.hpp>
|
|
|
|
#include <FreeRTOS.h>
|
|
#include <log/log.hpp>
|
|
|
|
#include <bits/exception.h>
|
|
#include <cinttypes>
|
|
#include <memory>
|
|
|
|
namespace sys
|
|
{
|
|
class Service;
|
|
} // namespace sys
|
|
|
|
using namespace parserFSM;
|
|
|
|
xQueueHandle MessageHandler::sendQueue;
|
|
|
|
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: %" PRIu32 "\nbody: %s\n",
|
|
static_cast<int>(context->getMethod()),
|
|
static_cast<int>(context->getEndpoint()),
|
|
context->getUuid(),
|
|
context->getBody().dump().c_str());
|
|
|
|
auto handler = endpointFactory->create(*context, OwnerServicePtr);
|
|
|
|
if (handler != nullptr) {
|
|
handler->handle(*context);
|
|
}
|
|
else {
|
|
LOG_ERROR("No way to handle!");
|
|
}
|
|
}
|
|
|
|
void MessageHandler::putToSendQueue(const std::string &msg)
|
|
{
|
|
if (uxQueueSpacesAvailable(sendQueue) != 0) {
|
|
auto responseString = new std::string(msg);
|
|
LOG_DEBUG("%s", responseString->c_str());
|
|
xQueueSend(sendQueue, &responseString, portMAX_DELAY);
|
|
}
|
|
}
|