taolib.testing.file_storage.repository.upload_repo

上传会话 Repository。

提供上传会话的数据访问操作。

Classes

UploadSessionRepository

上传会话 Repository。

Module Contents

class taolib.testing.file_storage.repository.upload_repo.UploadSessionRepository(collection)

Bases: taolib.testing._base.repository.AsyncRepository[taolib.testing.file_storage.models.upload.UploadSessionDocument]

上传会话 Repository。

async find_active_by_user(user_id: str) → list[taolib.testing.file_storage.models.upload.UploadSessionDocument]

查找用户的活跃上传会话。

async find_expired_sessions(before: datetime.datetime) → list[taolib.testing.file_storage.models.upload.UploadSessionDocument]

查找已过期的上传会话。

async update_status(session_id: str, status: taolib.testing.file_storage.models.enums.UploadStatus) → taolib.testing.file_storage.models.upload.UploadSessionDocument | None

更新上传状态。

async add_uploaded_chunk(session_id: str, chunk_index: int, bytes_count: int) → taolib.testing.file_storage.models.upload.UploadSessionDocument | None

添加已上传分片记录。

async create_indexes() → None

创建索引。