Struct CloudDecoder 

pub struct CloudDecoder { /* private fields */ }

IDUN Cloud WebSocket client for server-side EEG packet decoding.

Manages the full lifecycle: connect → start recording → subscribe to live insights → send raw packets → receive decoded data → end recording.

Implementations

impl CloudDecoder

pub fn new(api_token: String, device_id: String) -> Self

Create a new cloud decoder.

Arguments

• api_token — IDUN API token (or set IDUN_API_TOKEN env var)
• device_id — Guardian MAC address (format: "AA-BB-CC-DD-EE-FF")

pub fn from_env(device_id: String) -> Result<Self>

Create a cloud decoder from the IDUN_API_TOKEN environment variable.

Returns Err if the env var is not set.

pub async fn connect(&mut self) -> Result<()>

Connect to the IDUN Cloud WebSocket and start a recording session.

This method:

1. Opens the WebSocket connection with authentication
2. Spawns reader/writer tasks
3. Sends startNewRecording
4. Waits for the recording ID to be assigned
5. Subscribes to FILTERED_EEG live stream insights

pub async fn send_raw_packet( &mut self, raw_data: &[u8], device_ts: f64, sequence: u64, ) -> Result<()>

Send a raw BLE packet to the cloud for decoding.

The packet is base64-encoded and wrapped in a publishRawMeasurements message, matching the format used by the official Python SDK.

Returns Err if the WebSocket is not connected or the send fails.

pub fn try_recv_decoded(&mut self) -> Result<Option<CloudDecodedEeg>>

Try to receive the next decoded EEG event from the cloud.

Returns Ok(None) if no data is available yet (non-blocking). Returns Ok(Some(decoded)) with the cloud-decoded data. Returns Err if the channel is closed (cloud disconnected).

pub async fn recv_decoded(&mut self) -> Result<Option<CloudDecodedEeg>>

Receive the next decoded EEG event from the cloud (blocking).

Returns Ok(None) if the cloud disconnected.

pub async fn disconnect(&mut self) -> Result<()>

End the recording session and close the WebSocket.

pub fn is_connected(&self) -> bool

Check if the cloud session is active and ready to send/receive data.

pub fn recording_id(&self) -> Option<&str>

Get the current recording ID, if a session is active.