Struct MockMessageSender 

pub struct MockMessageSender {
    pub logged_in: bool,
    pub session_info: SessionInfo,
    pub sent_messages: Vec<SentMessage>,
    pub next_error: Option<SteamError>,
    pub current_job_id: u64,
}

Mock message sender for testing.

Records all sent messages for inspection and verification in tests. Can be configured to simulate logged-in or logged-out state.

Example

let mut mock = MockMessageSender::new_logged_in(12345, 76561198012345678);

// Simulate sending a message
mock.send_message(EMsg::ClientChangeStatus, &body).await?;

// Verify the message was sent
assert_eq!(mock.sent_messages.len(), 1);
assert_eq!(mock.sent_messages[0].msg_type, EMsg::ClientChangeStatus);

// Decode the body for detailed verification
let sent_body: CMsgClientChangeStatus = mock.decode_last_message()?;
assert_eq!(sent_body.persona_state, Some(1));

Fields

logged_in: bool

Whether the mock is in “logged in” state.

session_info: SessionInfo

Session information.

sent_messages: Vec<SentMessage>

All messages sent through this mock.

next_error: Option<SteamError>

If set, next send will return this error.

current_job_id: u64

Current job ID source for simulation.

Implementations

impl MockMessageSender

pub fn new() -> Self

Create a new mock sender in logged-out state.

pub fn new_logged_in(session_id: i32, steam_id: u64) -> Self

Create a mock sender in logged-in state.

pub fn set_logged_in(&mut self, logged_in: bool)

Set whether this mock is “logged in”.

pub fn set_next_error(&mut self, error: SteamError)

Make the next send call return an error.

pub fn clear(&mut self)

Clear all recorded messages.

pub fn last_sent(&self) -> Option<&SentMessage>

Get the last sent message, if any.

pub fn decode_last_message<T: Message + Default>(&self) -> Result<T, SteamError>

Decode the body of the last sent message.

Useful for verifying the exact content of sent messages in tests.

pub fn messages_of_type(&self, msg_type: EMsg) -> Vec<&SentMessage>

Get messages of a specific type.

pub fn service_calls(&self) -> Vec<&SentMessage>

Get service method calls.

Trait Implementations

impl Debug for MockMessageSender

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for MockMessageSender

fn default() -> MockMessageSender

Returns the “default value” for a type.

impl MessageSender for MockMessageSender

fn is_logged_in(&self) -> bool

Check if currently logged in.

fn session_info(&self) -> SessionInfo

Get session info for building headers.

fn send_message<'life0, 'life1, 'async_trait, T>( &'life0 mut self, msg_type: EMsg, body: &'life1 T, ) -> Pin<Box<dyn Future<Output = Result<(), SteamError>> + Send + 'async_trait>>

where T: 'async_trait + Message + Send + Sync, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send a protobuf message.

fn send_service_method<'life0, 'life1, 'life2, 'async_trait, T>( &'life0 mut self, method: &'life1 str, body: &'life2 T, ) -> Pin<Box<dyn Future<Output = Result<(), SteamError>> + Send + 'async_trait>>

where T: 'async_trait + Message + Send + Sync, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Send a service method call (unified messages).