Struct SessionFileStore 

pub struct SessionFileStore { /* private fields */ }

Protected immutable file storage shared by inbound and outbound transports.

Display names live only in metadata; payloads always use an internal filename.

Implementations

impl SessionFileStore

pub fn new(state_dir: &Path) -> Self

Creates a store below the gateway’s already protected state directory.

pub async fn begin_upload( &self, session_id: &str, name: String, size: u64, media_type: String, ) -> Result<PendingSessionFileWrite>

Starts one connection-owned user upload.

pub async fn publish_artifact( &self, session_id: &str, name: String, media_type: String, bytes: &[u8], ) -> Result<SessionFileReference>

Publishes one immutable agent artifact.

pub async fn list_uploads( &self, session_id: &str, ) -> Result<Vec<SessionFileReference>>

Lists completed user uploads for one session.

pub async fn list_artifacts( &self, session_id: &str, ) -> Result<Vec<SessionFileReference>>

Lists completed agent artifacts for one session.

pub async fn delete_session(&self, session_id: &str) -> Result<()>

Permanently removes every upload and artifact owned by one idle session.

pub async fn read_chunk( &self, session_id: &str, file_id: &str, offset: u64, max_bytes: usize, ) -> Result<SessionFileChunk>

Reads one bounded byte range from either kind of stored session file.

pub async fn read_upload_all( &self, session_id: &str, expected: &SessionFileReference, ) -> Result<(SessionFileReference, Vec<u8>)>

Reads and validates one complete user upload for model input.

pub async fn verify_upload( &self, session_id: &str, expected: &SessionFileReference, ) -> Result<()>

Verifies that a frontend reference names the exact user upload.

Trait Implementations

impl Clone for SessionFileStore

fn clone(&self) -> SessionFileStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.