Struct MultipartUploadService 

pub struct MultipartUploadService { /* private fields */ }

Implementations

impl MultipartUploadService

pub fn new( session_repo: Arc<UploadSessionRepository>, bucket_repo: Arc<BucketRepository>, quota_repo: Arc<UserQuotaRepository>, ) -> Self

pub async fn initiate( &self, bucket_id: Uuid, user_id: Uuid, path: &str, filename: &str, mime_type: Option<&str>, file_size: i64, chunk_size: Option<i32>, ) -> ServiceResult<UploadSession>

pub async fn authorize_part( &self, session_id: Uuid, user_id: Uuid, part_number: i32, part_bytes: i64, ) -> ServiceResult<()>

Check that a part may be written before its bytes are stored: the session is the caller’s, live, expecting this part number, the part not already recorded, and its size within the session’s chunk size.

pub async fn record_part( &self, session_id: Uuid, user_id: Uuid, part_number: i32, ) -> ServiceResult<UploadSession>

pub async fn complete( &self, session_id: Uuid, user_id: Uuid, ) -> ServiceResult<UploadSession>

pub async fn check_capacity( &self, user_id: Uuid, bytes: i64, ) -> ServiceResult<()>

Check (without mutating) whether user_id has capacity for bytes more. Returns Ok(()) when there is no quota row (no limit configured) or when used_bytes + bytes <= limit_bytes.

Called by the single-shot upload handler before writing to storage. The resumable flow calls into Self::complete which performs the same check.

pub async fn record_completed_usage( &self, user_id: Uuid, bytes: i64, ) -> ServiceResult<()>

Record post-upload usage on the user’s quota row. Best-effort: when no quota row exists this is a no-op. Call AFTER the storage put and DB row commit succeed.

pub async fn abort(&self, session_id: Uuid, user_id: Uuid) -> ServiceResult<()>

pub async fn mark_failed(&self, session_id: Uuid) -> ServiceResult<()>

Fail a session whose completion was refused after it began (its parts did not assemble to the declared size), so it does not stay completing forever.

pub async fn mark_completed(&self, session_id: Uuid) -> ServiceResult<()>

pub async fn cleanup_expired(&self) -> ServiceResult<u64>

pub async fn list_active( &self, _user_id: Uuid, _bucket_id: Uuid, ) -> ServiceResult<Vec<UploadSession>>