surrealcs_kernel/logging/messages/actors_client/
reader.rs

1//! Defines the logging of transaction messages sent to the client reader.
2use crate::logging::messages::connections::ping::PingJourney;
3use crate::logging::messages::transactions::base::TransactionJourney;
4use crate::messages::server::interface::ServerMessage;
5use crate::messages::server::wrapper::WrappedServerMessage;
6
7const TARGET: &str = "surrealcs::kernel::client::reader";
8
9/// Logs a transaction message that the client reader has received.
10///
11/// # Arguments
12/// * `message`: the transaction message that the client reader has received
13pub fn log_client_reader_message(message: &WrappedServerMessage) {
14	// Log ping messages separately
15	if let ServerMessage::Ping(_) = &message.message {
16		tracing::trace!(target: TARGET, connection_id = %message.connection_id, "{}", PingJourney::RecievedByClientReader.as_str());
17	}
18	// Log other transaction messages
19	let tx_pointer = TransactionJourney::RecievedByClientReader;
20	let log = tx_pointer.from_wrapped_server_message(message);
21	if let Some(log) = log {
22		tracing::trace!(target: TARGET, "{log}");
23	}
24}