backbone-bucket 0.3.0

Bucket Bounded Context: File Storage Module for Backbone Framework
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147

//! Queries for UploadSession aggregate
//!
//! Generated by backbone-schema. Do not edit manually.
//!
//! CQRS Queries represent requests for data without side effects.

use async_trait::async_trait;
use anyhow::Result;
use serde::{Deserialize, Serialize};

use crate::domain::entity::UploadSession;
use crate::infrastructure::persistence::{UploadSessionRepository, PaginationParams, PaginatedResult, UploadSessionFilter};
use super::QueryHandler;

// ============================================================================
// QUERY TRAIT (DEPRECATED)
// ============================================================================

/// Query trait for UploadSession operations
///
/// **DEPRECATED**: Use the generic `QueryHandler<Q>` trait from `mod.rs` instead.
/// This trait is kept for backwards compatibility.
#[deprecated(since = "0.2.0", note = "Use QueryHandler<Q> trait instead")]
#[async_trait]
pub trait UploadSessionQuery: Send + Sync {
    type Output;
    async fn execute(&self) -> Result<Self::Output>;
}

// ============================================================================
// GET BY ID QUERY
// ============================================================================

/// Query to get a upload_session by ID
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct GetUploadSessionByIdQuery {
    pub id: String,
}

/// Handler for GetUploadSessionByIdQuery
pub struct GetUploadSessionByIdHandler<R: UploadSessionRepository> {
    repository: std::sync::Arc<R>,
}

impl<R: UploadSessionRepository> GetUploadSessionByIdHandler<R> {
    pub fn new(repository: std::sync::Arc<R>) -> Self {
        Self { repository }
    }
}

#[async_trait]
impl<R: UploadSessionRepository + 'static> QueryHandler<GetUploadSessionByIdQuery> for GetUploadSessionByIdHandler<R> {
    type Output = Option<UploadSession>;

    async fn handle(&self, query: GetUploadSessionByIdQuery) -> Result<Self::Output> {
        self.repository.find_by_id(&query.id).await
    }
}

// ============================================================================
// LIST QUERY
// ============================================================================

/// Query to list upload_session entities with pagination
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct ListUploadSessionQuery {
    pub page: u32,
    pub per_page: u32,
    pub filter_bucket_id: Option<Uuid>,
    pub filter_user_id: Option<Uuid>,
    pub filter_path: Option<String>,
    pub filter_filename: Option<String>,
    pub filter_mime_type: Option<String>,
    pub filter_file_size: Option<i64>,
    pub filter_status: Option<UploadStatus>,
    pub filter_storage_backend: Option<StorageBackend>,
}

impl Default for ListUploadSessionQuery {
    fn default() -> Self {
        Self {
            page: 1,
            per_page: 20,
            filter_bucket_id: None,
            filter_user_id: None,
            filter_path: None,
            filter_filename: None,
            filter_mime_type: None,
            filter_file_size: None,
            filter_status: None,
            filter_storage_backend: None,
        }
    }
}

/// Handler for ListUploadSessionQuery
pub struct ListUploadSessionHandler<R: UploadSessionRepository> {
    repository: std::sync::Arc<R>,
}

impl<R: UploadSessionRepository> ListUploadSessionHandler<R> {
    pub fn new(repository: std::sync::Arc<R>) -> Self {
        Self { repository }
    }
}

#[async_trait]
impl<R: UploadSessionRepository + 'static> QueryHandler<ListUploadSessionQuery> for ListUploadSessionHandler<R> {
    type Output = PaginatedResult<UploadSession>;

    async fn handle(&self, query: ListUploadSessionQuery) -> Result<Self::Output> {
        let params = PaginationParams::new(query.page, query.per_page);

        // Build filter from query parameters
        let filters = UploadSessionFilter {
            bucket_id: query.filter_bucket_id.clone(),
            user_id: query.filter_user_id.clone(),
            path: query.filter_path.clone(),
            filename: query.filter_filename.clone(),
            mime_type: query.filter_mime_type.clone(),
            file_size: query.filter_file_size.clone(),
            status: query.filter_status.clone(),
            storage_backend: query.filter_storage_backend.clone(),
            ..Default::default()
        };

        // Use list_with_filters if any filters are set
        if filters.has_filters() {
            self.repository.list_with_filters(params, filters).await
        } else {
            self.repository.list(params).await
        }
    }
}

// ============================================================================
// CUSTOM QUERIES
// ============================================================================
// <<< CUSTOM QUERIES START >>>

// <<< CUSTOM QUERIES START >>>
// Add your custom queries here
// Example:
//
// #[derive(Debug, Clone, Serialize, Deserialize)]
// pub struct GetActiveUploadSessionQuery;
// <<< CUSTOM QUERIES END >>>