koprogo_api/application/ports/
unit_repository.rs

1use crate::application::dto::{PageRequest, UnitFilters};
2use crate::domain::entities::Unit;
3use async_trait::async_trait;
4use uuid::Uuid;
5
6#[async_trait]
7pub trait UnitRepository: Send + Sync {
8    async fn create(&self, unit: &Unit) -> Result<Unit, String>;
9    async fn find_by_id(&self, id: Uuid) -> Result<Option<Unit>, String>;
10    async fn find_by_building(&self, building_id: Uuid) -> Result<Vec<Unit>, String>;
11    async fn find_by_owner(&self, owner_id: Uuid) -> Result<Vec<Unit>, String>;
12
13    /// Find all units with pagination and filters
14    /// Returns tuple of (units, total_count)
15    async fn find_all_paginated(
16        &self,
17        page_request: &PageRequest,
18        filters: &UnitFilters,
19    ) -> Result<(Vec<Unit>, i64), String>;
20
21    async fn update(&self, unit: &Unit) -> Result<Unit, String>;
22    async fn delete(&self, id: Uuid) -> Result<bool, String>;
23}

koprogo_api/application/ports/unit_repository.rs

koprogo_api/application/ports/
unit_repository.rs