Method HandleActionsPacket

Src/Core/Profiler.cpp:30–66

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

////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
void FSecure::C3::Core::Profiler::HandleActionsPacket(ByteView actionsPacket)
{
	std::scoped_lock lock(m_AccessMutex);

	try
	{
		auto actions = json::parse(std::string{ actionsPacket });
		auto jActions = actions.find("Command");
		if (jActions == actions.end())
			throw std::runtime_error{ "Command object is missing" };

		(*jActions)["ByteForm"] = base64::encode(TranslateCommand(*jActions));

		// Helper lambda that read particular element from actions JSON.
		auto ReadJsonElement = [&actions](std::string_view elementName)
		{
			auto element = actions.find(elementName);
			if (element != actions.end())
				return element;

			throw std::runtime_error{ std::string{ elementName } +" is not specified." };
		};

		// Parse AgentId.
		if (auto relayAgentId = ReadJsonElement("relayAgentId"); relayAgentId->is_null())
			m_Gateway->ParseAndRunCommand(actions);
		else if (auto agent = m_Gateway->m_Agents.Find(relayAgentId->get<std::string>()))
			agent->ParseAndRunCommand(actions);
		else
			throw std::runtime_error{ "Unknown AgentId." };
	}
	catch (std::exception& exception)
	{
		if (auto gateway = m_Gateway->m_Gateway.lock())
			gateway->Log({ "Caught an exception while parsing Action. "s + exception.what(), FSecure::C3::LogMessage::Severity::Error});
	}
}

////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
FSecure::C3::Core::Profiler::Profile FSecure::C3::Core::Profiler::Get()