backbone_core/

macros.rs

//! Code-generation macros for backbone-schema generated repositories.
//!
//! These macros centralise the boilerplate `CrudRepository<E>` trait impl so
//! the generator can emit a single line instead of ~125 lines per entity.
//!
//! # Usage (in generated repository files)
//!
//! ```rust,ignore
//! // Entities that use JSONB-based soft delete (metadata.deleted_at):
//! backbone_core::impl_crud_repository!(UserRepository, User, soft_delete);
//!
//! // Entities that use hard deletes only:
//! backbone_core::impl_crud_repository!(RoleRepository, Role, no_soft_delete);
//! ```

/// Report an `?include=` hydration failure.
///
/// Hydration runs after the main query and only shapes the response, so it does
/// not fail the request — but it used to return an empty expansion SILENTLY,
/// which read as "no related rows": every expanded relation rendered as `null`
/// and the underlying wiring bug was invisible. Logging at error level keeps
/// the response stable while making the failure diagnosable from service logs.
pub fn log_include_hydration_failure(table: &str, error: &str) {
    tracing::error!(
        relation_table = table,
        error = error,
        "include hydration failed; relation expanded as null"
    );
}

/// Implement `backbone_core::CrudRepository<E>` for a generated repository struct.
///
/// This macro removes ~125 lines of boilerplate per entity by centralising the
/// `anyhow::Result → RepositoryError` mapping that is otherwise copy-pasted
/// identically for every entity.
///
/// # Method mapping — `soft_delete` variant
///
/// | CrudRepository method         | Inherent struct method called       |
/// |-------------------------------|-------------------------------------|
/// | `create`                      | `create(&entity)`                   |
/// | `find_by_id`                  | `find_by_id(id)`                    |
/// | `find_by_id_including_deleted`| `find_deleted_by_id(id)`            |
/// | `update`                      | `update(&id, &entity)`              |
/// | `update_changed`              | `update_changed(&id, &before, &after)` |
/// | `soft_delete`                 | `soft_delete(id)`                   |
/// | `restore`                     | `restore(id)`                       |
/// | `hard_delete`                 | `permanent_delete(id)`              |
/// | `list`                        | `list_paginated(pagination)`        |
/// | `list_deleted`                | `list_deleted(pagination)`          |
/// | `list_deleted_filtered`       | `list_deleted_filtered(pagination, filters)` |
/// | `count`                       | `count_active()`                    |
/// | `count_deleted`               | `count_deleted()`                   |
/// | `bulk_create`                 | `bulk_create(&entities)` (one transaction) |
/// | `bulk_update_changed`         | `bulk_update_changed(&pairs)` (one transaction) |
/// | `empty_trash`                 | `empty_trash()`                     |
///
/// # Method mapping — `no_soft_delete` variant
///
/// | CrudRepository method         | Inherent struct method called       |
/// |-------------------------------|-------------------------------------|
/// | `find_by_id_including_deleted`| `find_by_id(id)` (same as normal)   |
/// | `soft_delete`                 | `delete(id)`                        |
/// | `restore`                     | `find_by_id(id)` (no-op restore)    |
/// | `hard_delete`                 | `delete(id)`                        |
/// | `list_deleted`                | `Ok((vec![], 0))`                   |
/// | `count`                       | `count()`                           |
/// | `count_deleted`               | `Ok(0)`                             |
/// | `empty_trash`                 | `Ok(0)`                             |
#[macro_export]
macro_rules! impl_crud_repository {
    // ── Soft-delete variant ────────────────────────────────────────────────────
    //
    // For entities that store deleted_at inside the metadata JSONB column.
    // The generated struct exposes: soft_delete, restore, permanent_delete,
    // list_deleted, find_deleted_by_id, count_active, count_deleted, empty_trash.
    ($repo:ty, $entity:ty, soft_delete) => {
        #[async_trait::async_trait]
        impl backbone_core::CrudRepository<$entity> for $repo {
            async fn fetch_related_json(
                &self,
                table: &str,
                ids: &[String],
            ) -> Vec<serde_json::Value> {
                match backbone_orm::fetch_by_ids_as_json(
                    (&**self).pool(),
                    (&**self).table_name(),
                    table,
                    ids,
                )
                .await
                {
                    Ok(rows) => rows,
                    Err(err) => {
                        backbone_core::log_include_hydration_failure(table, &err.to_string());
                        Vec::new()
                    }
                }
            }

            async fn reference_visible(
                &self,
                table: &str,
                column: &str,
                value: &serde_json::Value,
            ) -> Result<Option<bool>, backbone_core::RepositoryError> {
                backbone_orm::reference_visible(
                    (&**self).pool(),
                    (&**self).table_name(),
                    table,
                    column,
                    value,
                )
                .await
                .map_err(backbone_core::RepositoryError::from_source)
            }

            // ── NOTE on method resolution ─────────────────────────────────────
            // This repo is a newtype wrapping `GenericCrudRepository<E, SoftDelete>`
            // and implements `Deref` to it.  Inside a trait impl, unqualified `self.foo()`
            // resolves to the *trait* method (recursive) when both the trait and the
            // inner type have a method with the same name.  We use `(&**self).foo()`
            // to force resolution through the `Deref` target's inherent methods.

            async fn create(
                &self,
                entity: $entity,
            ) -> Result<$entity, backbone_core::RepositoryError> {
                (&**self).create(&entity)
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn find_by_id(
                &self,
                id: &str,
            ) -> Result<Option<$entity>, backbone_core::RepositoryError> {
                (&**self).find_by_id(id)
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn find_by_id_including_deleted(
                &self,
                id: &str,
            ) -> Result<Option<$entity>, backbone_core::RepositoryError> {
                (&**self).find_deleted_by_id(id)
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn update(
                &self,
                entity: $entity,
            ) -> Result<$entity, backbone_core::RepositoryError> {
                let id = backbone_core::PersistentEntity::entity_id(&entity);
                (&**self).update(&id, &entity)
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
                    .and_then(|opt| opt.ok_or(backbone_core::RepositoryError::NotFound))
            }

            async fn update_changed(
                &self,
                before: &$entity,
                after: $entity,
            ) -> Result<Option<$entity>, backbone_core::RepositoryError> {
                let id = backbone_core::PersistentEntity::entity_id(&after);
                (&**self)
                    .update_changed(&id, before, &after)
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn soft_delete(
                &self,
                id: &str,
            ) -> Result<bool, backbone_core::RepositoryError> {
                (&**self).soft_delete(id)
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn restore(
                &self,
                id: &str,
            ) -> Result<Option<$entity>, backbone_core::RepositoryError> {
                (&**self).restore(id)
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn hard_delete(
                &self,
                id: &str,
            ) -> Result<bool, backbone_core::RepositoryError> {
                (&**self).permanent_delete(id)
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn list(
                &self,
                page: u32,
                limit: u32,
            ) -> Result<(Vec<$entity>, u64), backbone_core::RepositoryError> {
                let pagination =
                    backbone_orm::repository::PaginationParams::new(page, limit);
                (&**self).list_paginated(pagination)
                    .await
                    .map(|r| (r.data, r.pagination.total))
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn list_filtered(
                &self,
                page: u32,
                limit: u32,
                filters: std::collections::HashMap<String, String>,
            ) -> Result<(Vec<$entity>, u64), backbone_core::RepositoryError> {
                let pagination =
                    backbone_orm::repository::PaginationParams::new(page, limit);
                (&**self).list_paginated_filtered(pagination, Some(&filters))
                    .await
                    .map(|r| (r.data, r.pagination.total))
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn list_filtered_with_info(
                &self,
                page: u32,
                limit: u32,
                filters: std::collections::HashMap<String, String>,
            ) -> Result<
                (Vec<$entity>, backbone_orm::repository::PaginationInfo),
                backbone_core::RepositoryError,
            > {
                let pagination =
                    backbone_orm::repository::PaginationParams::new(page, limit);
                (&**self)
                    .list_paginated_filtered(pagination, Some(&filters))
                    .await
                    .map(|r| (r.data, r.pagination))
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            fn table_name(&self) -> Option<&str> {
                Some((&**self).table_name())
            }

            async fn aggregate_filtered(
                &self,
                spec: &backbone_orm::repository::AggregateSpec,
                filters: std::collections::HashMap<String, String>,
            ) -> Result<backbone_orm::repository::AggregateResult, backbone_core::RepositoryError> {
                (&**self).aggregate_filtered(spec, Some(&filters))
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn list_deleted(
                &self,
                page: u32,
                limit: u32,
            ) -> Result<(Vec<$entity>, u64), backbone_core::RepositoryError> {
                let pagination =
                    backbone_orm::repository::PaginationParams::new(page, limit);
                (&**self).list_deleted(pagination)
                    .await
                    .map(|r| (r.data, r.pagination.total))
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn list_deleted_filtered(
                &self,
                page: u32,
                limit: u32,
                filters: std::collections::HashMap<String, String>,
            ) -> Result<(Vec<$entity>, u64), backbone_core::RepositoryError> {
                let pagination =
                    backbone_orm::repository::PaginationParams::new(page, limit);
                (&**self).list_deleted_filtered(pagination, Some(&filters))
                    .await
                    .map(|r| (r.data, r.pagination.total))
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn count(&self) -> Result<u64, backbone_core::RepositoryError> {
                (&**self).count_active()
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn count_deleted(&self) -> Result<u64, backbone_core::RepositoryError> {
                (&**self).count_deleted()
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn bulk_create(
                &self,
                entities: Vec<$entity>,
            ) -> Result<Vec<$entity>, backbone_core::RepositoryError> {
                // One transaction: every row or none, the failed row named by its index.
                (&**self).bulk_create(&entities)
                    .await
                    .map_err(backbone_core::RepositoryError::from_batch_source)
            }

            async fn empty_trash(&self) -> Result<u64, backbone_core::RepositoryError> {
                (&**self).empty_trash()
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            // ── Atomic batch operations (single-transaction, all-or-nothing) ──

            async fn bulk_soft_delete(
                &self,
                ids: &[String],
            ) -> Result<u64, backbone_core::RepositoryError> {
                (&**self).bulk_soft_delete(ids)
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn bulk_restore(
                &self,
                ids: &[String],
            ) -> Result<Vec<$entity>, backbone_core::RepositoryError> {
                (&**self).bulk_restore(ids)
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn bulk_hard_delete(
                &self,
                ids: &[String],
            ) -> Result<u64, backbone_core::RepositoryError> {
                (&**self).bulk_permanent_delete(ids)
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn restore_all(&self) -> Result<Vec<$entity>, backbone_core::RepositoryError> {
                (&**self).restore_all()
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn bulk_update(
                &self,
                entities: Vec<$entity>,
            ) -> Result<Vec<$entity>, backbone_core::RepositoryError> {
                (&**self).bulk_update(&entities)
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn bulk_update_changed(
                &self,
                pairs: Vec<($entity, $entity)>,
            ) -> Result<Vec<$entity>, backbone_core::RepositoryError> {
                (&**self).bulk_update_changed(&pairs)
                    .await
                    .map_err(backbone_core::RepositoryError::from_batch_source)
            }
        }
    };

    // ── No-soft-delete variant ─────────────────────────────────────────────────
    //
    // For entities that use hard deletes only (no soft_delete, restore, trash).
    // Soft-delete-related trait methods return sensible no-op results.
    ($repo:ty, $entity:ty, no_soft_delete) => {
        #[async_trait::async_trait]
        impl backbone_core::CrudRepository<$entity> for $repo {
            async fn fetch_related_json(
                &self,
                table: &str,
                ids: &[String],
            ) -> Vec<serde_json::Value> {
                match backbone_orm::fetch_by_ids_as_json(
                    (&**self).pool(),
                    (&**self).table_name(),
                    table,
                    ids,
                )
                .await
                {
                    Ok(rows) => rows,
                    Err(err) => {
                        backbone_core::log_include_hydration_failure(table, &err.to_string());
                        Vec::new()
                    }
                }
            }

            async fn reference_visible(
                &self,
                table: &str,
                column: &str,
                value: &serde_json::Value,
            ) -> Result<Option<bool>, backbone_core::RepositoryError> {
                backbone_orm::reference_visible(
                    (&**self).pool(),
                    (&**self).table_name(),
                    table,
                    column,
                    value,
                )
                .await
                .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn create(
                &self,
                entity: $entity,
            ) -> Result<$entity, backbone_core::RepositoryError> {
                (&**self).create(&entity)
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn find_by_id(
                &self,
                id: &str,
            ) -> Result<Option<$entity>, backbone_core::RepositoryError> {
                (&**self).find_by_id(id)
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn find_by_id_including_deleted(
                &self,
                id: &str,
            ) -> Result<Option<$entity>, backbone_core::RepositoryError> {
                // No soft delete: "including deleted" == normal lookup
                (&**self).find_by_id(id)
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn update(
                &self,
                entity: $entity,
            ) -> Result<$entity, backbone_core::RepositoryError> {
                let id = backbone_core::PersistentEntity::entity_id(&entity);
                (&**self).update(&id, &entity)
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
                    .and_then(|opt| opt.ok_or(backbone_core::RepositoryError::NotFound))
            }

            async fn update_changed(
                &self,
                before: &$entity,
                after: $entity,
            ) -> Result<Option<$entity>, backbone_core::RepositoryError> {
                let id = backbone_core::PersistentEntity::entity_id(&after);
                (&**self)
                    .update_changed(&id, before, &after)
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn soft_delete(
                &self,
                id: &str,
            ) -> Result<bool, backbone_core::RepositoryError> {
                // No soft delete: fall back to hard delete
                (&**self).delete(id)
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn restore(
                &self,
                id: &str,
            ) -> Result<Option<$entity>, backbone_core::RepositoryError> {
                // No soft delete: "restore" is a no-op, return the current row
                (&**self).find_by_id(id)
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn hard_delete(
                &self,
                id: &str,
            ) -> Result<bool, backbone_core::RepositoryError> {
                (&**self).delete(id)
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn list(
                &self,
                page: u32,
                limit: u32,
            ) -> Result<(Vec<$entity>, u64), backbone_core::RepositoryError> {
                let pagination =
                    backbone_orm::repository::PaginationParams::new(page, limit);
                (&**self).list_paginated(pagination)
                    .await
                    .map(|r| (r.data, r.pagination.total))
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn list_filtered(
                &self,
                page: u32,
                limit: u32,
                filters: std::collections::HashMap<String, String>,
            ) -> Result<(Vec<$entity>, u64), backbone_core::RepositoryError> {
                let pagination =
                    backbone_orm::repository::PaginationParams::new(page, limit);
                (&**self).list_paginated_filtered(pagination, Some(&filters))
                    .await
                    .map(|r| (r.data, r.pagination.total))
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn list_filtered_with_info(
                &self,
                page: u32,
                limit: u32,
                filters: std::collections::HashMap<String, String>,
            ) -> Result<
                (Vec<$entity>, backbone_orm::repository::PaginationInfo),
                backbone_core::RepositoryError,
            > {
                let pagination =
                    backbone_orm::repository::PaginationParams::new(page, limit);
                (&**self)
                    .list_paginated_filtered(pagination, Some(&filters))
                    .await
                    .map(|r| (r.data, r.pagination))
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            fn table_name(&self) -> Option<&str> {
                Some((&**self).table_name())
            }

            async fn aggregate_filtered(
                &self,
                spec: &backbone_orm::repository::AggregateSpec,
                filters: std::collections::HashMap<String, String>,
            ) -> Result<backbone_orm::repository::AggregateResult, backbone_core::RepositoryError> {
                (&**self).aggregate_filtered(spec, Some(&filters))
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn list_deleted(
                &self,
                _page: u32,
                _limit: u32,
            ) -> Result<(Vec<$entity>, u64), backbone_core::RepositoryError> {
                // No soft delete: trash is always empty
                Ok((vec![], 0))
            }

            async fn list_deleted_filtered(
                &self,
                _page: u32,
                _limit: u32,
                _filters: std::collections::HashMap<String, String>,
            ) -> Result<(Vec<$entity>, u64), backbone_core::RepositoryError> {
                // No soft delete: trash is always empty
                Ok((vec![], 0))
            }

            async fn count(&self) -> Result<u64, backbone_core::RepositoryError> {
                (&**self).count()
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn count_deleted(&self) -> Result<u64, backbone_core::RepositoryError> {
                Ok(0)
            }

            async fn bulk_create(
                &self,
                entities: Vec<$entity>,
            ) -> Result<Vec<$entity>, backbone_core::RepositoryError> {
                // One transaction: every row or none, the failed row named by its index.
                (&**self).bulk_create(&entities)
                    .await
                    .map_err(backbone_core::RepositoryError::from_batch_source)
            }

            async fn empty_trash(&self) -> Result<u64, backbone_core::RepositoryError> {
                Ok(0)
            }

            // ── Atomic batch operations ───────────────────────────────────────

            async fn bulk_soft_delete(
                &self,
                ids: &[String],
            ) -> Result<u64, backbone_core::RepositoryError> {
                // No soft delete: fall back to hard delete
                (&**self).bulk_delete(ids)
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn bulk_restore(
                &self,
                _ids: &[String],
            ) -> Result<Vec<$entity>, backbone_core::RepositoryError> {
                // No soft delete: nothing is ever in trash to restore
                Ok(Vec::new())
            }

            async fn bulk_hard_delete(
                &self,
                ids: &[String],
            ) -> Result<u64, backbone_core::RepositoryError> {
                (&**self).bulk_delete(ids)
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn restore_all(&self) -> Result<Vec<$entity>, backbone_core::RepositoryError> {
                // No soft delete: trash is always empty
                Ok(Vec::new())
            }

            async fn bulk_update(
                &self,
                entities: Vec<$entity>,
            ) -> Result<Vec<$entity>, backbone_core::RepositoryError> {
                (&**self).bulk_update(&entities)
                    .await
                    .map_err(backbone_core::RepositoryError::from_source)
            }

            async fn bulk_update_changed(
                &self,
                pairs: Vec<($entity, $entity)>,
            ) -> Result<Vec<$entity>, backbone_core::RepositoryError> {
                (&**self).bulk_update_changed(&pairs)
                    .await
                    .map_err(backbone_core::RepositoryError::from_batch_source)
            }
        }
    };
}