backbone_bucket/infrastructure/persistence/
user_quota_repository.rs

1//! Repository for UserQuota entities
2//!
3//! Generated by metaphor-schema. Do not edit manually.
4//!
5//! Thin newtype over `backbone_orm::GenericCrudRepository<UserQuota, backbone_orm::SoftDelete>`.
6//! All standard CRUD methods are available via `Deref`.
7
8use anyhow::Result;
9use sqlx::PgPool;
10use uuid::Uuid;
11
12use crate::domain::entity::UserQuota;
13
14/// Table name for UserQuota entities
15pub const TABLE_NAME: &str = "bucket.user_quotas";
16
17/// Repository for UserQuota entities.
18///
19/// All standard CRUD, soft-delete, pagination, and bulk methods are
20/// provided automatically via `Deref` to `backbone_orm::GenericCrudRepository`.
21pub struct UserQuotaRepository(
22    backbone_orm::GenericCrudRepository<UserQuota, backbone_orm::SoftDelete>,
23);
24
25impl std::ops::Deref for UserQuotaRepository {
26    type Target = backbone_orm::GenericCrudRepository<UserQuota, backbone_orm::SoftDelete>;
27    fn deref(&self) -> &Self::Target { &self.0 }
28}
29
30impl UserQuotaRepository {
31    /// Create a new repository instance.
32    pub fn new(pool: PgPool) -> Self {
33        Self(backbone_orm::GenericCrudRepository::new(pool, TABLE_NAME))
34    }
35}
36
37impl UserQuotaRepository {
38    /// Find user_quota by user_id (excludes soft-deleted)
39    pub async fn find_by_user_id(&self, user_id: uuid::Uuid) -> Result<Option<UserQuota>> {
40        self.find_by_uuid_field("user_id", user_id).await
41    }
42
43    /// Check if user_quota exists by user_id (excludes soft-deleted)
44    pub async fn exists_by_user_id(&self, user_id: uuid::Uuid) -> Result<bool> {
45        self.exists_by_uuid_field("user_id", user_id).await
46    }
47
48}
49
50backbone_core::impl_crud_repository!(UserQuotaRepository, UserQuota, soft_delete);

backbone_bucket/infrastructure/persistence/user_quota_repository.rs

backbone_bucket/infrastructure/persistence/
user_quota_repository.rs