Struct PresenceTestClient 

pub struct PresenceTestClient { /* private fields */ }

Presence-aware test client wrapper.

Provides convenient methods for presence operations during E2E testing. Each client maintains its own gRPC connection and client ID.

Implementations

impl PresenceTestClient

pub fn new(client: GrpcClient, display_name: &str) -> Self

Create a new presence test client (not yet joined).

Call join() to register with the presence service.

pub async fn join(&mut self) -> Result<JoinResponse, String>

Join the presence session.

Registers this client with the server and receives an assigned client ID. Returns the full join response including peer list.

pub async fn leave(&mut self) -> Result<(), String>

Leave the presence session.

Unregisters this client from the server. Safe to call multiple times.

pub fn client_id(&self) -> u64

Get client ID (panics if not joined).

Panics

Panics if join() has not been called or if the client has left.

pub const fn is_joined(&self) -> bool

Check if this client has joined.

pub fn display_name(&self) -> &str

Get this client’s display name.

pub async fn update_cursor( &mut self, _line: u64, _col: u64, ) -> Result<(), String>

Update cursor position.

Note: This is now a no-op (Phase 14, #471). Cursor tracking moved to CursorMoved notifications with client_id. This method is preserved for test compatibility but does nothing.

pub async fn update_buffer(&mut self, buffer_id: u64) -> Result<(), String>

Update buffer ID.

pub async fn update_mode(&mut self, mode: &str) -> Result<(), String>

Update mode.

pub async fn follow(&mut self, target_id: u64) -> Result<(), String>

Set follow mode (sync mode = 1).

pub async fn present(&mut self) -> Result<(), String>

Set present mode (sync mode = 2).

pub async fn independent(&mut self) -> Result<(), String>

Set independent mode (sync mode = 0).

pub async fn peers(&mut self) -> Result<Vec<ClientPresence>, String>

Get all peers (excludes self).

pub async fn all_clients(&mut self) -> Result<Vec<ClientPresence>, String>

Get all clients including self.

pub fn grpc(&mut self) -> &mut GrpcClient

Access underlying gRPC client for other operations (e.g., send_keys).

pub async fn send_keys(&mut self, keys: &str) -> Result<(), String>

Send keys using this client’s ID for per-client mode routing.

Per-client state (#471): Per-client input routing

Keys are processed using this client’s per-client mode stack, enabling multi-client mode isolation.

pub async fn get_mode(&mut self) -> Result<GetModeResponse, String>

Get the current mode for this client.

Per-client state (#471): Per-client mode isolation

Returns the mode from this client’s per-client mode stack.

pub async fn get_cursor(&mut self) -> Result<(u64, u64), String>

Get cursor position for this client.

Per-client state (#471): Per-client cursor isolation

Returns the cursor from this client’s per-client editing state.

pub async fn get_buffer(&mut self) -> Result<String, String>

Get buffer content.

Returns the content of the active buffer.