Method HandleMessage

Src/Core/GateRelay.cpp:487–531

///////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
nlohmann::json FSecure::C3::Core::GateRelay::HandleMessage(nlohmann::json const& message)
{
	auto messageType = message.at("MessageType").get<std::string>();
	auto sequenceNumber = message.value("SequenceNumber", 0ul);
	auto const& messageData = message.at("MessageData");

	json commandResponse;
	std::optional<std::string> error;
	try
	{
		if (messageType == "Action")
		{
			m_Profiler->HandleActionsPacket(ByteView{ messageData.dump() });
			return {};
		}
		else if (messageType == "NewBuild")
		{
			commandResponse = m_Profiler->HandleNewBuildMessage(messageData);
		}
		else if (messageType == "Error")
		{
			Log({ "Controller error: " + messageData.at("Message").get<std::string>(), LogMessage::Severity::Error });
		}
	}
	catch (std::exception& e)
	{
		Log({"HandleMessage failed: Seq: "s + std::to_string(sequenceNumber) + ". Reason: " + e.what(), LogMessage::Severity::Warning});
		error = e.what();
	}

	if (sequenceNumber == 0)
		return {};

	json fullResponse
	{
		{"MessageType", messageType},
		{"SequenceNumber", sequenceNumber},
		{"MessageData", commandResponse },
	};

	if (error)
		fullResponse["Error"] = *error;

	return fullResponse;
}

////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
void FSecure::C3::Core::GateRelay::CloseDevicesAndConnectors()