Struct FileTransferManager 

pub struct FileTransferManager { /* private fields */ }

File transfer manager for chunking and reassembly.

Implementations

impl FileTransferManager

pub const MANUAL_SENDER: &'static str = "manual:ffi"

Pseudo-sender bound to assemblies fed through the manual process_file_chunk FFI path, which carries no wire sender. All manual chunks share this identity for sender binding and quota. The : is rejected by wire UserId validation, so no remote peer can ever claim this identity.

pub fn new() -> Self

Creates a new file transfer manager.

pub fn with_config(config: FileTransferConfig) -> Self

Creates a new file transfer manager with custom configuration.

max_total_buffered_bytes is clamped up to what a single max_file_size transfer charges (payload plus per-chunk overhead) — any lower value would make max_file_size unachievable.

pub fn chunk_file( &self, file_id: String, file_name: String, file_data: Vec<u8>, chunk_size_override: Option<usize>, ) -> Result<Vec<FileChunk>>

Chunks a file for sending.

Arguments

• file_id - Unique identifier for this file transfer
• file_name - Name of the file
• file_data - Complete file data
• chunk_size_override - If Some, uses this chunk size instead of the configured default. Allows callers to select a transport-appropriate chunk size.

Returns

Returns a vector of FileChunk ready to send. Fails if the file is empty or exceeds max_file_size, if the chunk size is zero, or if the chunking is so fine that the chunk count would exceed the receive-side total_chunks cap — Self::process_chunk on a receiver with the same max_file_size would silently drop every chunk of such a transfer.

pub fn process_chunk( &mut self, sender: &str, chunk: FileChunk, ) -> Result<FileProgress, ChunkRejection>

Processes a received file chunk from sender.

All wire-supplied fields (file_size, total_chunks, chunk_data, file_id) are bounded here before any assembly state is created, so a remote peer cannot force oversized allocations or unbounded bookkeeping. Assemblies are bound to the sender that started them, counted against global and per-sender caps, and the bytes buffered across all assemblies never exceed max_total_buffered_bytes.

Arguments

• sender - The authenticated (or wire-claimed) sender of the chunk
• chunk - The received file chunk

Returns

Returns Ok(FileProgress) with current progress, or the ChunkRejection explaining why the chunk was dropped.

pub fn is_complete(&self, file_id: &str) -> bool

Checks if a file transfer is complete.

pub fn finalize_file(&mut self, file_id: &str) -> Option<Vec<u8>>

Finalizes a file transfer and returns the complete file data.

Verifies the SHA256 checksum of the reassembled file before returning.

Arguments

• file_id - File identifier

Returns

Returns Some(Vec<u8>) if file is complete, its size matches the claimed file_size, and the checksum matches, None otherwise.

pub fn cleanup_stale_transfers( &mut self, max_age: Duration, ) -> Vec<StaleTransfer>

Removes stale/incomplete transfers that have not received any chunk updates within max_age, returning what was dropped so callers can surface the loss. Swept ids are tombstoned so straggler chunks cannot resurrect them; tombstones themselves expire by the same rule — no chunks for max_age — freeing the id for reuse.

pub fn get_progress(&self, file_id: &str) -> Option<FileProgress>

Gets the progress of an active file transfer.

pub fn cancel_transfer(&mut self, file_id: &str) -> bool

Cancels an active file transfer.

pub fn active_transfer_count(&self) -> usize

Gets the number of active file transfers.

Trait Implementations

impl Default for FileTransferManager

fn default() -> Self

Returns the “default value” for a type.