use anyhow::Result;
use sqlx::PgPool;
use uuid::Uuid;
use crate::domain::entity::MailAttachment;
pub const TABLE_NAME: &str = "messaging.mail_attachments";
pub struct MailAttachmentRepository(
backbone_orm::GenericCrudRepository<MailAttachment, backbone_orm::SoftDelete>,
);
impl std::ops::Deref for MailAttachmentRepository {
type Target = backbone_orm::GenericCrudRepository<MailAttachment, backbone_orm::SoftDelete>;
fn deref(&self) -> &Self::Target { &self.0 }
}
impl MailAttachmentRepository {
pub fn new(pool: PgPool) -> Self {
Self(backbone_orm::GenericCrudRepository::new(pool, TABLE_NAME))
}
}
impl MailAttachmentRepository {
pub async fn find_by_access_token(&self, access_token: uuid::Uuid) -> Result<Option<MailAttachment>> {
self.find_by_uuid_field("access_token", access_token).await
}
pub async fn exists_by_access_token(&self, access_token: uuid::Uuid) -> Result<bool> {
self.exists_by_uuid_field("access_token", access_token).await
}
}
backbone_core::impl_crud_repository!(MailAttachmentRepository, MailAttachment, soft_delete);