surrealcs_kernel/logging/messages/actors_server/
reader.rs

1//! Defines the logging of transaction messages sent to the server 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
7/// Logs a transaction message that the server reader has received.
8///
9/// # Arguments
10/// * `message`: the transaction message that the server reader has received
11pub fn log_server_reader_message(message: &WrappedServerMessage) {
12	if let ServerMessage::Ping(_) = &message.message {
13		tracing::trace!("{}", PingJourney::RecievedByServerReader.to_log(&message.connection_id));
14	}
15
16	let tx_pointer = TransactionJourney::RecievedByServerReader;
17	let log = tx_pointer.from_wrapped_server_message(message);
18	if log.is_some() {
19		tracing::trace!("{}", log.unwrap());
20	}
21}