Message handler for telemetry subsystem messages. More...

#include <telemetry_message_handler.hpp>

Inheritance diagram for telemetry_message_handler:

Collaboration diagram for telemetry_message_handler:

Public Member Functions
	telemetry_message_handler (database::context ctx, std::shared_ptr< comms::service::auth_session_service > sessions)
	Construct a telemetry message handler.

boost::asio::awaitable< std::expected< std::vector< std::byte >, ores::utility::serialization::error_code > >	handle_message (comms::messaging::message_type type, std::span< const std::byte > payload, const std::string &remote_address) override
	Handle a telemetry subsystem message.

Detailed Description

Message handler for telemetry subsystem messages.

Processes messages in the telemetry subsystem range (0x5000-0x5FFF). Handles:

submit_log_records_request (0x5000): Persists a batch of client log records
get_telemetry_logs_request (0x5010): Queries raw log entries with filters
get_telemetry_stats_request (0x5020): Queries aggregated statistics

The handler converts client log_record structures to persisted telemetry_log_entry structures, enriching them with session and account information from the auth_session_service.

Constructor & Destructor Documentation

◆ telemetry_message_handler()

telemetry_message_handler	(	database::context	ctx,
		std::shared_ptr< comms::service::auth_session_service >	sessions
	)

Construct a telemetry message handler.

Parameters

ctx	Database context for repository access
sessions	Shared auth session service for session/account lookup

Member Function Documentation

◆ handle_message()

boost::asio::awaitable< std::expected< std::vector< std::byte >, ores::utility::serialization::error_code > > handle_message	(	comms::messaging::message_type	type,
		std::span< const std::byte >	payload,
		const std::string &	remote_address
	)

overridevirtual

Handle a telemetry subsystem message.