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

//! Queries for FileComment 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::FileComment;
use crate::infrastructure::persistence::{FileCommentRepository, PaginationParams, PaginatedResult, FileCommentFilter};
use super::QueryHandler;

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

/// Query trait for FileComment 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 FileCommentQuery: Send + Sync {
    type Output;
    async fn execute(&self) -> Result<Self::Output>;
}

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

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

/// Handler for GetFileCommentByIdQuery
pub struct GetFileCommentByIdHandler<R: FileCommentRepository> {
    repository: std::sync::Arc<R>,
}

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

#[async_trait]
impl<R: FileCommentRepository + 'static> QueryHandler<GetFileCommentByIdQuery> for GetFileCommentByIdHandler<R> {
    type Output = Option<FileComment>;

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

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

/// Query to list file_comment entities with pagination
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct ListFileCommentQuery {
    pub page: u32,
    pub per_page: u32,
    pub filter_file_id: Option<Uuid>,
    pub filter_user_id: Option<Uuid>,
    pub filter_parent_id: Option<Uuid>,
    pub filter_content: Option<String>,
    pub filter_resolved: Option<bool>,
    pub filter_resolved_by: Option<Uuid>,
    pub filter_status: Option<CommentStatus>,
}

impl Default for ListFileCommentQuery {
    fn default() -> Self {
        Self {
            page: 1,
            per_page: 20,
            filter_file_id: None,
            filter_user_id: None,
            filter_parent_id: None,
            filter_content: None,
            filter_resolved: None,
            filter_resolved_by: None,
            filter_status: None,
        }
    }
}

/// Handler for ListFileCommentQuery
pub struct ListFileCommentHandler<R: FileCommentRepository> {
    repository: std::sync::Arc<R>,
}

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

#[async_trait]
impl<R: FileCommentRepository + 'static> QueryHandler<ListFileCommentQuery> for ListFileCommentHandler<R> {
    type Output = PaginatedResult<FileComment>;

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

        // Build filter from query parameters
        let filters = FileCommentFilter {
            file_id: query.filter_file_id.clone(),
            user_id: query.filter_user_id.clone(),
            parent_id: query.filter_parent_id.clone(),
            content: query.filter_content.clone(),
            resolved: query.filter_resolved.clone(),
            resolved_by: query.filter_resolved_by.clone(),
            status: query.filter_status.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 GetActiveFileCommentQuery;
// <<< CUSTOM QUERIES END >>>