Struct PresignedUploadTask

pub struct PresignedUploadTask {

    pub id: PresignedUploadTaskId,
    pub status: PresignedTaskStatus,
    pub name: String,
    pub mime: String,
    pub size: i32,
    pub document_box: DocumentBoxScopeRaw,
    pub folder_id: FolderId,
    pub file_key: String,
    pub created_at: DateTime<Utc>,
    pub expires_at: DateTime<Utc>,
    pub created_by: Option<UserId>,
    pub parent_id: Option<FileId>,
    pub processing_config: Option<Json<Value>>,
}

Task storing the details for a presigned upload task

Fields

id: PresignedUploadTaskId

ID of the upload task

status: PresignedTaskStatus

File created from the outcome of this task

name: String

Name of the file being uploaded

mime: String

Mime type of the file being uploaded

size: i32

Expected size in bytes of the file

document_box: DocumentBoxScopeRaw

ID of the document box the folder belongs to

folder_id: FolderId

Target folder to store the file in

file_key: String

S3 key where the file should be stored

created_at: DateTime<Utc>

Creation timestamp of the upload task

expires_at: DateTime<Utc>

Timestamp of when the presigned URL will expire (Used as the date for background cleanup, to ensure that all files)

created_by: Option<UserId>

User who created the file

parent_id: Option<FileId>

Optional file to make the parent of this file

processing_config: Option<Json<Value>>

Config that can be used when processing for additional configuration to how the file is processed

Implementations

impl PresignedUploadTask

pub async fn create( db: impl DbExecutor<'_>, create: CreatePresignedUploadTask, ) -> DbResult<PresignedUploadTask>

Create a new presigned upload task

pub async fn set_status( &mut self, db: impl DbExecutor<'_>, status: PresignedTaskStatus, ) -> DbResult<()>

pub async fn find( db: impl DbExecutor<'_>, scope: &DocumentBoxScopeRaw, task_id: PresignedUploadTaskId, ) -> DbResult<Option<PresignedUploadTask>>

Find a specific presigned upload task

pub async fn find_expired( db: impl DbExecutor<'_>, current_date: DateTime<Utc>, ) -> DbResult<Vec<PresignedUploadTask>>

Finds all presigned uploads that have expired based on the current date

pub async fn find_by_file_key( db: impl DbExecutor<'_>, file_key: &str, ) -> DbResult<Option<PresignedUploadTask>>

Find a specific presigned upload task

pub async fn delete( db: impl DbExecutor<'_>, task_id: PresignedUploadTaskId, ) -> DbResult<()>

Delete a specific presigned upload task

Trait Implementations

impl Debug for PresignedUploadTask

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'a, R: Row> FromRow<'a, R> for PresignedUploadTask

where &'a str: ColumnIndex<R>, PresignedUploadTaskId: Decode<'a, R::Database> + Type<R::Database>, Json<PresignedTaskStatus>: Decode<'a, R::Database> + Type<R::Database>, String: Decode<'a, R::Database> + Type<R::Database>, i32: Decode<'a, R::Database> + Type<R::Database>, DocumentBoxScopeRaw: Decode<'a, R::Database> + Type<R::Database>, FolderId: Decode<'a, R::Database> + Type<R::Database>, DateTime<Utc>: Decode<'a, R::Database> + Type<R::Database>, Option<UserId>: Decode<'a, R::Database> + Type<R::Database>, Option<FileId>: Decode<'a, R::Database> + Type<R::Database>, Option<Json<Value>>: Decode<'a, R::Database> + Type<R::Database>,

fn from_row(__row: &'a R) -> Result<Self>

impl Serialize for PresignedUploadTask

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.