backbone_bucket/infrastructure/persistence/
file_share_repository.rs1use anyhow::Result;
9use sqlx::PgPool;
10
11use crate::domain::entity::FileShare;
12
13pub const TABLE_NAME: &str = "bucket.file_shares";
15
16pub struct FileShareRepository(
21 backbone_orm::GenericCrudRepository<FileShare, backbone_orm::SoftDelete>,
22);
23
24impl std::ops::Deref for FileShareRepository {
25 type Target = backbone_orm::GenericCrudRepository<FileShare, backbone_orm::SoftDelete>;
26 fn deref(&self) -> &Self::Target { &self.0 }
27}
28
29impl FileShareRepository {
30 pub fn new(pool: PgPool) -> Self {
32 Self(backbone_orm::GenericCrudRepository::new(pool, TABLE_NAME))
33 }
34}
35
36impl FileShareRepository {
37 pub async fn find_by_token(&self, token: &str) -> Result<Option<FileShare>> {
39 self.find_by_text_field("token", token).await
40 }
41
42 pub async fn exists_by_token(&self, token: &str) -> Result<bool> {
44 self.exists_by_text_field("token", token).await
45 }
46
47}
48
49backbone_core::impl_crud_repository!(FileShareRepository, FileShare, soft_delete);