backbone-mail 0.4.1

//! Messaging Module
//!
//! Generated by metaphor-schema. Enhanced with runtime implementations.
//!
//! This module provides:
//! - Domain entities and repositories
//! - Application services
//! - HTTP and gRPC handlers
//! - Route configuration
//! - State machine enforcement
//! - Validation rules runtime
//! - RBAC middleware
//! - Trigger execution system
//! - Computed fields
//! - Workflow orchestrator

#![recursion_limit = "1024"]
#![allow(unused_imports)]

// Generated modules
pub mod domain;
pub mod infrastructure;
pub mod application;
pub mod presentation;
pub mod seeders;
pub mod exports;

// The module's extension (hand-written; ADR-0031).
#[path = "lib.ext.rs"]
mod lib_ext;
pub use lib_ext::*;
/// This crate's module and builder under fixed names, for the extension's `impl` blocks.
#[allow(dead_code)]
pub(crate) type ThisModule = MessagingModule;
#[allow(dead_code)]
pub(crate) type ThisModuleBuilder = MessagingModuleBuilder;

// Re-exports for convenience - Domain entities
pub use domain::entity::*;

// Re-exports - State Machine
pub use domain::state_machine::*;

// Re-exports - Infrastructure
pub use infrastructure::persistence::*;

// Re-exports - Application services
pub use application::service::MailActivityService;
pub use application::service::MailActivityTypeService;
pub use application::service::MailActivityPlanService;
pub use application::service::MailActivityPlanTemplateService;
pub use application::service::MailAliasDomainService;
pub use application::service::MailAliasService;
pub use application::service::MailAttachmentService;
pub use application::service::MailMessageAttachmentService;
pub use application::service::MailMessageStarService;
pub use application::service::MailMessageService;
pub use application::service::MailService;
pub use application::service::MailNotificationService;
pub use application::service::MailMessageSubtypeService;
pub use application::service::MailMessageReactionService;
pub use application::service::MailFollowersService;
pub use application::service::MailPresenceService;
pub use application::service::MailBlacklistService;
pub use application::service::MailTrackingValueService;
pub use application::service::DiscussChannelService;
pub use application::service::DiscussChannelMemberService;
pub use application::service::MailGuestService;
pub use application::service::MailServerService;
pub use application::service::FetchmailServerService;
pub use application::service::MailGatewayAllowedService;
pub use application::service::PhoneBlacklistService;
pub use application::service::MailMessageScheduleService;
pub use application::service::MailScheduledMessageService;
pub use application::service::SmsService;
pub use application::service::SmsTemplateService;
pub use application::service::SmsTrackerService;

// Re-exports - Validation
pub use application::validator::{ValidationError, ValidationResult};

use std::sync::Arc;
use axum::Router;
use sqlx::PgPool;

/// Messaging module configuration
///
/// Use the builder pattern to configure and register this module:
///
/// ```text
/// let messaging = MessagingModule::builder()
///     .with_database(pool.clone())
///     .build()?;
///
/// // Unguarded full CRUD (trusted/admin); compose a guarded router for production.
/// let router = messaging.all_crud_routes();
/// ```
pub struct MessagingModule {
    pub(crate) mail_activity_service: Arc<MailActivityService>,
    pub(crate) mail_activity_type_service: Arc<MailActivityTypeService>,
    pub(crate) mail_activity_plan_service: Arc<MailActivityPlanService>,
    pub(crate) mail_activity_plan_template_service: Arc<MailActivityPlanTemplateService>,
    pub(crate) mail_alias_domain_service: Arc<MailAliasDomainService>,
    pub(crate) mail_alias_service: Arc<MailAliasService>,
    pub(crate) mail_attachment_service: Arc<MailAttachmentService>,
    pub(crate) mail_message_attachment_service: Arc<MailMessageAttachmentService>,
    pub(crate) mail_message_star_service: Arc<MailMessageStarService>,
    pub(crate) mail_message_service: Arc<MailMessageService>,
    pub(crate) mail_service: Arc<MailService>,
    pub(crate) mail_notification_service: Arc<MailNotificationService>,
    pub(crate) mail_message_subtype_service: Arc<MailMessageSubtypeService>,
    pub(crate) mail_message_reaction_service: Arc<MailMessageReactionService>,
    pub(crate) mail_followers_service: Arc<MailFollowersService>,
    pub(crate) mail_presence_service: Arc<MailPresenceService>,
    pub(crate) mail_blacklist_service: Arc<MailBlacklistService>,
    pub(crate) mail_tracking_value_service: Arc<MailTrackingValueService>,
    pub(crate) discuss_channel_service: Arc<DiscussChannelService>,
    pub(crate) discuss_channel_member_service: Arc<DiscussChannelMemberService>,
    pub(crate) mail_guest_service: Arc<MailGuestService>,
    pub(crate) mail_server_service: Arc<MailServerService>,
    pub(crate) fetchmail_server_service: Arc<FetchmailServerService>,
    pub(crate) mail_gateway_allowed_service: Arc<MailGatewayAllowedService>,
    pub(crate) phone_blacklist_service: Arc<PhoneBlacklistService>,
    pub(crate) mail_message_schedule_service: Arc<MailMessageScheduleService>,
    pub(crate) mail_scheduled_message_service: Arc<MailScheduledMessageService>,
    pub(crate) sms_service: Arc<SmsService>,
    pub(crate) sms_template_service: Arc<SmsTemplateService>,
    pub(crate) sms_tracker_service: Arc<SmsTrackerService>,
    /// The module's extension state (`lib.ext.rs`); its fields read through `Deref`.
    pub(crate) ext: ModuleExt,
}

impl std::ops::Deref for MessagingModule {
    type Target = ModuleExt;
    fn deref(&self) -> &Self::Target {
        &self.ext
    }
}

impl std::ops::DerefMut for MessagingModule {
    fn deref_mut(&mut self) -> &mut Self::Target {
        &mut self.ext
    }
}

/// What the extension's `build` hook receives from the generated build (ADR-0031).
#[allow(dead_code)]
pub(crate) struct ModuleParts<'a> {
    pub(crate) db_pool: &'a PgPool,
    pub(crate) mail_activity_service: &'a Arc<MailActivityService>,
    pub(crate) mail_activity_repository: &'a Arc<MailActivityRepository>,
    pub(crate) mail_activity_type_service: &'a Arc<MailActivityTypeService>,
    pub(crate) mail_activity_type_repository: &'a Arc<MailActivityTypeRepository>,
    pub(crate) mail_activity_plan_service: &'a Arc<MailActivityPlanService>,
    pub(crate) mail_activity_plan_repository: &'a Arc<MailActivityPlanRepository>,
    pub(crate) mail_activity_plan_template_service: &'a Arc<MailActivityPlanTemplateService>,
    pub(crate) mail_activity_plan_template_repository: &'a Arc<MailActivityPlanTemplateRepository>,
    pub(crate) mail_alias_domain_service: &'a Arc<MailAliasDomainService>,
    pub(crate) mail_alias_domain_repository: &'a Arc<MailAliasDomainRepository>,
    pub(crate) mail_alias_service: &'a Arc<MailAliasService>,
    pub(crate) mail_alias_repository: &'a Arc<MailAliasRepository>,
    pub(crate) mail_attachment_service: &'a Arc<MailAttachmentService>,
    pub(crate) mail_attachment_repository: &'a Arc<MailAttachmentRepository>,
    pub(crate) mail_message_attachment_service: &'a Arc<MailMessageAttachmentService>,
    pub(crate) mail_message_attachment_repository: &'a Arc<MailMessageAttachmentRepository>,
    pub(crate) mail_message_star_service: &'a Arc<MailMessageStarService>,
    pub(crate) mail_message_star_repository: &'a Arc<MailMessageStarRepository>,
    pub(crate) mail_message_service: &'a Arc<MailMessageService>,
    pub(crate) mail_message_repository: &'a Arc<MailMessageRepository>,
    pub(crate) mail_service: &'a Arc<MailService>,
    pub(crate) mail_repository: &'a Arc<MailRepository>,
    pub(crate) mail_notification_service: &'a Arc<MailNotificationService>,
    pub(crate) mail_notification_repository: &'a Arc<MailNotificationRepository>,
    pub(crate) mail_message_subtype_service: &'a Arc<MailMessageSubtypeService>,
    pub(crate) mail_message_subtype_repository: &'a Arc<MailMessageSubtypeRepository>,
    pub(crate) mail_message_reaction_service: &'a Arc<MailMessageReactionService>,
    pub(crate) mail_message_reaction_repository: &'a Arc<MailMessageReactionRepository>,
    pub(crate) mail_followers_service: &'a Arc<MailFollowersService>,
    pub(crate) mail_followers_repository: &'a Arc<MailFollowersRepository>,
    pub(crate) mail_presence_service: &'a Arc<MailPresenceService>,
    pub(crate) mail_presence_repository: &'a Arc<MailPresenceRepository>,
    pub(crate) mail_blacklist_service: &'a Arc<MailBlacklistService>,
    pub(crate) mail_blacklist_repository: &'a Arc<MailBlacklistRepository>,
    pub(crate) mail_tracking_value_service: &'a Arc<MailTrackingValueService>,
    pub(crate) mail_tracking_value_repository: &'a Arc<MailTrackingValueRepository>,
    pub(crate) discuss_channel_service: &'a Arc<DiscussChannelService>,
    pub(crate) discuss_channel_repository: &'a Arc<DiscussChannelRepository>,
    pub(crate) discuss_channel_member_service: &'a Arc<DiscussChannelMemberService>,
    pub(crate) discuss_channel_member_repository: &'a Arc<DiscussChannelMemberRepository>,
    pub(crate) mail_guest_service: &'a Arc<MailGuestService>,
    pub(crate) mail_guest_repository: &'a Arc<MailGuestRepository>,
    pub(crate) mail_server_service: &'a Arc<MailServerService>,
    pub(crate) mail_server_repository: &'a Arc<MailServerRepository>,
    pub(crate) fetchmail_server_service: &'a Arc<FetchmailServerService>,
    pub(crate) fetchmail_server_repository: &'a Arc<FetchmailServerRepository>,
    pub(crate) mail_gateway_allowed_service: &'a Arc<MailGatewayAllowedService>,
    pub(crate) mail_gateway_allowed_repository: &'a Arc<MailGatewayAllowedRepository>,
    pub(crate) phone_blacklist_service: &'a Arc<PhoneBlacklistService>,
    pub(crate) phone_blacklist_repository: &'a Arc<PhoneBlacklistRepository>,
    pub(crate) mail_message_schedule_service: &'a Arc<MailMessageScheduleService>,
    pub(crate) mail_message_schedule_repository: &'a Arc<MailMessageScheduleRepository>,
    pub(crate) mail_scheduled_message_service: &'a Arc<MailScheduledMessageService>,
    pub(crate) mail_scheduled_message_repository: &'a Arc<MailScheduledMessageRepository>,
    pub(crate) sms_service: &'a Arc<SmsService>,
    pub(crate) sms_repository: &'a Arc<SmsRepository>,
    pub(crate) sms_template_service: &'a Arc<SmsTemplateService>,
    pub(crate) sms_template_repository: &'a Arc<SmsTemplateRepository>,
    pub(crate) sms_tracker_service: &'a Arc<SmsTrackerService>,
    pub(crate) sms_tracker_repository: &'a Arc<SmsTrackerRepository>,
}

impl MessagingModule {
    /// Create a new module builder
    pub fn builder() -> MessagingModuleBuilder {
        MessagingModuleBuilder::new()
    }

    /// Mount ALL generated CRUD endpoints (12 per entity) with NO domain
    /// validation — the fully **unguarded** surface. A well-formed request can
    /// create invalid rows or soft-delete a referenced master out from under its
    /// dependents. Prefer a guarded composition (read + validated writes) for any
    /// real deployment; use this only in trusted/admin/seeding contexts.
    pub fn all_crud_routes(&self) -> Router {
        use presentation::http::{
            create_mail_activity_routes,
            create_mail_activity_type_read_routes,
            create_mail_activity_plan_routes,
            create_mail_activity_plan_template_routes,
            create_mail_alias_domain_routes,
            create_mail_alias_routes,
            create_mail_attachment_routes,
            create_mail_message_attachment_routes,
            create_mail_message_star_routes,
            create_mail_message_read_routes,
            create_mail_read_routes,
            create_mail_notification_read_routes,
            create_mail_message_subtype_routes,
            create_mail_message_reaction_routes,
            create_mail_followers_routes,
            create_mail_presence_read_routes,
            create_mail_blacklist_routes,
            create_mail_tracking_value_routes,
            create_discuss_channel_read_routes,
            create_discuss_channel_member_routes,
            create_mail_guest_routes,
            create_mail_server_routes,
            create_fetchmail_server_read_routes,
            create_mail_gateway_allowed_routes,
            create_phone_blacklist_routes,
            create_mail_message_schedule_routes,
            create_mail_scheduled_message_routes,
            create_sms_read_routes,
            create_sms_template_routes,
            create_sms_tracker_read_routes,
        };

        Router::new()
            .merge(create_mail_activity_routes(self.mail_activity_service.clone()))
            // MailActivityType: hand_set lifecycle — the state field moves only through the
            // module's validated verbs; generic writes cannot reach it, so only the
            // read surface mounts here.
            .merge(create_mail_activity_type_read_routes(self.mail_activity_type_service.clone()))
            .merge(create_mail_activity_plan_routes(self.mail_activity_plan_service.clone()))
            .merge(create_mail_activity_plan_template_routes(self.mail_activity_plan_template_service.clone()))
            .merge(create_mail_alias_domain_routes(self.mail_alias_domain_service.clone()))
            .merge(create_mail_alias_routes(self.mail_alias_service.clone()))
            .merge(create_mail_attachment_routes(self.mail_attachment_service.clone()))
            .merge(create_mail_message_attachment_routes(self.mail_message_attachment_service.clone()))
            .merge(create_mail_message_star_routes(self.mail_message_star_service.clone()))
            // MailMessage: hand_set lifecycle — the state field moves only through the
            // module's validated verbs; generic writes cannot reach it, so only the
            // read surface mounts here.
            .merge(create_mail_message_read_routes(self.mail_message_service.clone()))
            // Mail: hand_set lifecycle — the state field moves only through the
            // module's validated verbs; generic writes cannot reach it, so only the
            // read surface mounts here.
            .merge(create_mail_read_routes(self.mail_service.clone()))
            // MailNotification: hand_set lifecycle — the state field moves only through the
            // module's validated verbs; generic writes cannot reach it, so only the
            // read surface mounts here.
            .merge(create_mail_notification_read_routes(self.mail_notification_service.clone()))
            .merge(create_mail_message_subtype_routes(self.mail_message_subtype_service.clone()))
            .merge(create_mail_message_reaction_routes(self.mail_message_reaction_service.clone()))
            .merge(create_mail_followers_routes(self.mail_followers_service.clone()))
            // MailPresence: hand_set lifecycle — the state field moves only through the
            // module's validated verbs; generic writes cannot reach it, so only the
            // read surface mounts here.
            .merge(create_mail_presence_read_routes(self.mail_presence_service.clone()))
            .merge(create_mail_blacklist_routes(self.mail_blacklist_service.clone()))
            .merge(create_mail_tracking_value_routes(self.mail_tracking_value_service.clone()))
            // DiscussChannel: hand_set lifecycle — the state field moves only through the
            // module's validated verbs; generic writes cannot reach it, so only the
            // read surface mounts here.
            .merge(create_discuss_channel_read_routes(self.discuss_channel_service.clone()))
            .merge(create_discuss_channel_member_routes(self.discuss_channel_member_service.clone()))
            .merge(create_mail_guest_routes(self.mail_guest_service.clone()))
            .merge(create_mail_server_routes(self.mail_server_service.clone()))
            // FetchmailServer: hand_set lifecycle — the state field moves only through the
            // module's validated verbs; generic writes cannot reach it, so only the
            // read surface mounts here.
            .merge(create_fetchmail_server_read_routes(self.fetchmail_server_service.clone()))
            .merge(create_mail_gateway_allowed_routes(self.mail_gateway_allowed_service.clone()))
            .merge(create_phone_blacklist_routes(self.phone_blacklist_service.clone()))
            .merge(create_mail_message_schedule_routes(self.mail_message_schedule_service.clone()))
            .merge(create_mail_scheduled_message_routes(self.mail_scheduled_message_service.clone()))
            // Sms: hand_set lifecycle — the state field moves only through the
            // module's validated verbs; generic writes cannot reach it, so only the
            // read surface mounts here.
            .merge(create_sms_read_routes(self.sms_service.clone()))
            .merge(create_sms_template_routes(self.sms_template_service.clone()))
            // SmsTracker: hand_set lifecycle — the state field moves only through the
            // module's validated verbs; generic writes cannot reach it, so only the
            // read surface mounts here.
            .merge(create_sms_tracker_read_routes(self.sms_tracker_service.clone()))
    }

    /// Deprecated alias for [`Self::all_crud_routes`]. `routes()` reads like
    /// "the routes" but mounts UNVALIDATED generic CRUD on every entity — a naive
    /// mount exposes unguarded writes. Compose a guarded router (read + validated
    /// writes) for production, or call `all_crud_routes()` to opt into the full
    /// unguarded surface explicitly.
    #[deprecated(note = "mounts unvalidated generic CRUD; prefer readonly_routes() + validated writes, or all_crud_routes() for the full/unguarded surface")]
    pub fn routes(&self) -> Router {
        self.all_crud_routes()
    }

    /// Read-only routes for every entity (GET endpoints only) — the safe base.
    ///
    /// Generic mutation can't reach here, so this surface cannot bypass a
    /// validated write service's invariants. Use this as the production base and
    /// merge validated write routes (or a write service's HTTP layer) onto it.
    pub fn readonly_routes(&self) -> Router {
        use presentation::http::{
            create_mail_activity_read_routes,
            create_mail_activity_type_read_routes,
            create_mail_activity_plan_read_routes,
            create_mail_activity_plan_template_read_routes,
            create_mail_alias_domain_read_routes,
            create_mail_alias_read_routes,
            create_mail_attachment_read_routes,
            create_mail_message_attachment_read_routes,
            create_mail_message_star_read_routes,
            create_mail_message_read_routes,
            create_mail_read_routes,
            create_mail_notification_read_routes,
            create_mail_message_subtype_read_routes,
            create_mail_message_reaction_read_routes,
            create_mail_followers_read_routes,
            create_mail_presence_read_routes,
            create_mail_blacklist_read_routes,
            create_mail_tracking_value_read_routes,
            create_discuss_channel_read_routes,
            create_discuss_channel_member_read_routes,
            create_mail_guest_read_routes,
            create_mail_server_read_routes,
            create_fetchmail_server_read_routes,
            create_mail_gateway_allowed_read_routes,
            create_phone_blacklist_read_routes,
            create_mail_message_schedule_read_routes,
            create_mail_scheduled_message_read_routes,
            create_sms_read_routes,
            create_sms_template_read_routes,
            create_sms_tracker_read_routes,
        };

        Router::new()
            .merge(create_mail_activity_read_routes(self.mail_activity_service.clone()))
            .merge(create_mail_activity_type_read_routes(self.mail_activity_type_service.clone()))
            .merge(create_mail_activity_plan_read_routes(self.mail_activity_plan_service.clone()))
            .merge(create_mail_activity_plan_template_read_routes(self.mail_activity_plan_template_service.clone()))
            .merge(create_mail_alias_domain_read_routes(self.mail_alias_domain_service.clone()))
            .merge(create_mail_alias_read_routes(self.mail_alias_service.clone()))
            .merge(create_mail_attachment_read_routes(self.mail_attachment_service.clone()))
            .merge(create_mail_message_attachment_read_routes(self.mail_message_attachment_service.clone()))
            .merge(create_mail_message_star_read_routes(self.mail_message_star_service.clone()))
            .merge(create_mail_message_read_routes(self.mail_message_service.clone()))
            .merge(create_mail_read_routes(self.mail_service.clone()))
            .merge(create_mail_notification_read_routes(self.mail_notification_service.clone()))
            .merge(create_mail_message_subtype_read_routes(self.mail_message_subtype_service.clone()))
            .merge(create_mail_message_reaction_read_routes(self.mail_message_reaction_service.clone()))
            .merge(create_mail_followers_read_routes(self.mail_followers_service.clone()))
            .merge(create_mail_presence_read_routes(self.mail_presence_service.clone()))
            .merge(create_mail_blacklist_read_routes(self.mail_blacklist_service.clone()))
            .merge(create_mail_tracking_value_read_routes(self.mail_tracking_value_service.clone()))
            .merge(create_discuss_channel_read_routes(self.discuss_channel_service.clone()))
            .merge(create_discuss_channel_member_read_routes(self.discuss_channel_member_service.clone()))
            .merge(create_mail_guest_read_routes(self.mail_guest_service.clone()))
            .merge(create_mail_server_read_routes(self.mail_server_service.clone()))
            .merge(create_fetchmail_server_read_routes(self.fetchmail_server_service.clone()))
            .merge(create_mail_gateway_allowed_read_routes(self.mail_gateway_allowed_service.clone()))
            .merge(create_phone_blacklist_read_routes(self.phone_blacklist_service.clone()))
            .merge(create_mail_message_schedule_read_routes(self.mail_message_schedule_service.clone()))
            .merge(create_mail_scheduled_message_read_routes(self.mail_scheduled_message_service.clone()))
            .merge(create_sms_read_routes(self.sms_service.clone()))
            .merge(create_sms_template_read_routes(self.sms_template_service.clone()))
            .merge(create_sms_tracker_read_routes(self.sms_tracker_service.clone()))
    }

    /// The generated state-machine verbs (`POST /<entities>/:id/transitions/<verb>`) of the
    /// entities whose machines declare `verbs: generated`: the only way their states move,
    /// since a generic write changing a state field is a rule break.
    pub fn transition_routes(&self) -> Router {
        Router::new()
            .merge(presentation::http::mail_activity_type_handler::create_mail_activity_type_transition_routes(self.mail_activity_type_service.clone()))
    }

}

/// Builder for MessagingModule
pub struct MessagingModuleBuilder {
    db_pool: Option<PgPool>,
    /// The builder's extension state (`lib.ext.rs`); its fields read through `Deref`.
    ext: ModuleBuilderExt,
}

impl std::ops::Deref for MessagingModuleBuilder {
    type Target = ModuleBuilderExt;
    fn deref(&self) -> &Self::Target {
        &self.ext
    }
}

impl std::ops::DerefMut for MessagingModuleBuilder {
    fn deref_mut(&mut self) -> &mut Self::Target {
        &mut self.ext
    }
}

impl MessagingModuleBuilder {
    /// Create a new builder
    pub fn new() -> Self {
        Self {
            db_pool: None,
            ext: Default::default(),
        }
    }

    /// Set the database connection pool
    pub fn with_database(mut self, pool: PgPool) -> Self {
        self.db_pool = Some(pool);
        self
    }


    /// Build the module with configured dependencies
    pub fn build(self) -> anyhow::Result<MessagingModule> {
        let db_pool = self.db_pool
            .ok_or_else(|| anyhow::anyhow!("Database pool not configured"))?;

        // MailActivity service
        let mail_activity_repository = Arc::new(MailActivityRepository::new(db_pool.clone()));
        let mail_activity_service = Arc::new(MailActivityService::with_repository(mail_activity_repository.clone()));

        // MailActivityType service
        let mail_activity_type_repository = Arc::new(MailActivityTypeRepository::new(db_pool.clone()));
        let mail_activity_type_service = Arc::new(MailActivityTypeService::with_repository(mail_activity_type_repository.clone()).with_guard(Arc::new(crate::application::service::MailActivityTypeRowRules)));

        // MailActivityPlan service
        let mail_activity_plan_repository = Arc::new(MailActivityPlanRepository::new(db_pool.clone()));
        let mail_activity_plan_service = Arc::new(MailActivityPlanService::with_repository(mail_activity_plan_repository.clone()));

        // MailActivityPlanTemplate service
        let mail_activity_plan_template_repository = Arc::new(MailActivityPlanTemplateRepository::new(db_pool.clone()));
        let mail_activity_plan_template_service = Arc::new(MailActivityPlanTemplateService::with_repository(mail_activity_plan_template_repository.clone()));

        // MailAliasDomain service
        let mail_alias_domain_repository = Arc::new(MailAliasDomainRepository::new(db_pool.clone()));
        let mail_alias_domain_service = Arc::new(MailAliasDomainService::with_repository(mail_alias_domain_repository.clone()));

        // MailAlias service
        let mail_alias_repository = Arc::new(MailAliasRepository::new(db_pool.clone()));
        let mail_alias_service = Arc::new(MailAliasService::with_repository(mail_alias_repository.clone()));

        // MailAttachment service
        let mail_attachment_repository = Arc::new(MailAttachmentRepository::new(db_pool.clone()));
        let mail_attachment_service = Arc::new(MailAttachmentService::with_repository(mail_attachment_repository.clone()));

        // MailMessageAttachment service
        let mail_message_attachment_repository = Arc::new(MailMessageAttachmentRepository::new(db_pool.clone()));
        let mail_message_attachment_service = Arc::new(MailMessageAttachmentService::with_repository(mail_message_attachment_repository.clone()));

        // MailMessageStar service
        let mail_message_star_repository = Arc::new(MailMessageStarRepository::new(db_pool.clone()));
        let mail_message_star_service = Arc::new(MailMessageStarService::with_repository(mail_message_star_repository.clone()));

        // MailMessage service
        let mail_message_repository = Arc::new(MailMessageRepository::new(db_pool.clone()));
        let mail_message_service = Arc::new(MailMessageService::with_repository(mail_message_repository.clone()));

        // Mail service
        let mail_repository = Arc::new(MailRepository::new(db_pool.clone()));
        let mail_service = Arc::new(MailService::with_repository(mail_repository.clone()).with_guard(Arc::new(crate::application::service::MailRowRules)));

        // MailNotification service
        let mail_notification_repository = Arc::new(MailNotificationRepository::new(db_pool.clone()));
        let mail_notification_service = Arc::new(MailNotificationService::with_repository(mail_notification_repository.clone()).with_guard(Arc::new(crate::application::service::MailNotificationRowRules)));

        // MailMessageSubtype service
        let mail_message_subtype_repository = Arc::new(MailMessageSubtypeRepository::new(db_pool.clone()));
        let mail_message_subtype_service = Arc::new(MailMessageSubtypeService::with_repository(mail_message_subtype_repository.clone()));

        // MailMessageReaction service
        let mail_message_reaction_repository = Arc::new(MailMessageReactionRepository::new(db_pool.clone()));
        let mail_message_reaction_service = Arc::new(MailMessageReactionService::with_repository(mail_message_reaction_repository.clone()));

        // MailFollowers service
        let mail_followers_repository = Arc::new(MailFollowersRepository::new(db_pool.clone()));
        let mail_followers_service = Arc::new(MailFollowersService::with_repository(mail_followers_repository.clone()));

        // MailPresence service
        let mail_presence_repository = Arc::new(MailPresenceRepository::new(db_pool.clone()));
        let mail_presence_service = Arc::new(MailPresenceService::with_repository(mail_presence_repository.clone()).with_guard(Arc::new(crate::application::service::MailPresenceRowRules)));

        // MailBlacklist service
        let mail_blacklist_repository = Arc::new(MailBlacklistRepository::new(db_pool.clone()));
        let mail_blacklist_service = Arc::new(MailBlacklistService::with_repository(mail_blacklist_repository.clone()));

        // MailTrackingValue service
        let mail_tracking_value_repository = Arc::new(MailTrackingValueRepository::new(db_pool.clone()));
        let mail_tracking_value_service = Arc::new(MailTrackingValueService::with_repository(mail_tracking_value_repository.clone()));

        // DiscussChannel service
        let discuss_channel_repository = Arc::new(DiscussChannelRepository::new(db_pool.clone()));
        let discuss_channel_service = Arc::new(DiscussChannelService::with_repository(discuss_channel_repository.clone()));

        // DiscussChannelMember service
        let discuss_channel_member_repository = Arc::new(DiscussChannelMemberRepository::new(db_pool.clone()));
        let discuss_channel_member_service = Arc::new(DiscussChannelMemberService::with_repository(discuss_channel_member_repository.clone()));

        // MailGuest service
        let mail_guest_repository = Arc::new(MailGuestRepository::new(db_pool.clone()));
        let mail_guest_service = Arc::new(MailGuestService::with_repository(mail_guest_repository.clone()));

        // MailServer service
        let mail_server_repository = Arc::new(MailServerRepository::new(db_pool.clone()));
        let mail_server_service = Arc::new(MailServerService::with_repository(mail_server_repository.clone()));

        // FetchmailServer service
        let fetchmail_server_repository = Arc::new(FetchmailServerRepository::new(db_pool.clone()));
        let fetchmail_server_service = Arc::new(FetchmailServerService::with_repository(fetchmail_server_repository.clone()));

        // MailGatewayAllowed service
        let mail_gateway_allowed_repository = Arc::new(MailGatewayAllowedRepository::new(db_pool.clone()));
        let mail_gateway_allowed_service = Arc::new(MailGatewayAllowedService::with_repository(mail_gateway_allowed_repository.clone()));

        // PhoneBlacklist service
        let phone_blacklist_repository = Arc::new(PhoneBlacklistRepository::new(db_pool.clone()));
        let phone_blacklist_service = Arc::new(PhoneBlacklistService::with_repository(phone_blacklist_repository.clone()));

        // MailMessageSchedule service
        let mail_message_schedule_repository = Arc::new(MailMessageScheduleRepository::new(db_pool.clone()));
        let mail_message_schedule_service = Arc::new(MailMessageScheduleService::with_repository(mail_message_schedule_repository.clone()));

        // MailScheduledMessage service
        let mail_scheduled_message_repository = Arc::new(MailScheduledMessageRepository::new(db_pool.clone()));
        let mail_scheduled_message_service = Arc::new(MailScheduledMessageService::with_repository(mail_scheduled_message_repository.clone()));

        // Sms service
        let sms_repository = Arc::new(SmsRepository::new(db_pool.clone()));
        let sms_service = Arc::new(SmsService::with_repository(sms_repository.clone()).with_guard(Arc::new(crate::application::service::SmsRowRules)));

        // SmsTemplate service
        let sms_template_repository = Arc::new(SmsTemplateRepository::new(db_pool.clone()));
        let sms_template_service = Arc::new(SmsTemplateService::with_repository(sms_template_repository.clone()));

        // SmsTracker service
        let sms_tracker_repository = Arc::new(SmsTrackerRepository::new(db_pool.clone()));
        let sms_tracker_service = Arc::new(SmsTrackerService::with_repository(sms_tracker_repository.clone()));


        // The extension builds its own state from what the generated build made.
        let ext = self.ext.build(&ModuleParts {
            db_pool: &db_pool,
            mail_activity_service: &mail_activity_service,
            mail_activity_repository: &mail_activity_repository,
            mail_activity_type_service: &mail_activity_type_service,
            mail_activity_type_repository: &mail_activity_type_repository,
            mail_activity_plan_service: &mail_activity_plan_service,
            mail_activity_plan_repository: &mail_activity_plan_repository,
            mail_activity_plan_template_service: &mail_activity_plan_template_service,
            mail_activity_plan_template_repository: &mail_activity_plan_template_repository,
            mail_alias_domain_service: &mail_alias_domain_service,
            mail_alias_domain_repository: &mail_alias_domain_repository,
            mail_alias_service: &mail_alias_service,
            mail_alias_repository: &mail_alias_repository,
            mail_attachment_service: &mail_attachment_service,
            mail_attachment_repository: &mail_attachment_repository,
            mail_message_attachment_service: &mail_message_attachment_service,
            mail_message_attachment_repository: &mail_message_attachment_repository,
            mail_message_star_service: &mail_message_star_service,
            mail_message_star_repository: &mail_message_star_repository,
            mail_message_service: &mail_message_service,
            mail_message_repository: &mail_message_repository,
            mail_service: &mail_service,
            mail_repository: &mail_repository,
            mail_notification_service: &mail_notification_service,
            mail_notification_repository: &mail_notification_repository,
            mail_message_subtype_service: &mail_message_subtype_service,
            mail_message_subtype_repository: &mail_message_subtype_repository,
            mail_message_reaction_service: &mail_message_reaction_service,
            mail_message_reaction_repository: &mail_message_reaction_repository,
            mail_followers_service: &mail_followers_service,
            mail_followers_repository: &mail_followers_repository,
            mail_presence_service: &mail_presence_service,
            mail_presence_repository: &mail_presence_repository,
            mail_blacklist_service: &mail_blacklist_service,
            mail_blacklist_repository: &mail_blacklist_repository,
            mail_tracking_value_service: &mail_tracking_value_service,
            mail_tracking_value_repository: &mail_tracking_value_repository,
            discuss_channel_service: &discuss_channel_service,
            discuss_channel_repository: &discuss_channel_repository,
            discuss_channel_member_service: &discuss_channel_member_service,
            discuss_channel_member_repository: &discuss_channel_member_repository,
            mail_guest_service: &mail_guest_service,
            mail_guest_repository: &mail_guest_repository,
            mail_server_service: &mail_server_service,
            mail_server_repository: &mail_server_repository,
            fetchmail_server_service: &fetchmail_server_service,
            fetchmail_server_repository: &fetchmail_server_repository,
            mail_gateway_allowed_service: &mail_gateway_allowed_service,
            mail_gateway_allowed_repository: &mail_gateway_allowed_repository,
            phone_blacklist_service: &phone_blacklist_service,
            phone_blacklist_repository: &phone_blacklist_repository,
            mail_message_schedule_service: &mail_message_schedule_service,
            mail_message_schedule_repository: &mail_message_schedule_repository,
            mail_scheduled_message_service: &mail_scheduled_message_service,
            mail_scheduled_message_repository: &mail_scheduled_message_repository,
            sms_service: &sms_service,
            sms_repository: &sms_repository,
            sms_template_service: &sms_template_service,
            sms_template_repository: &sms_template_repository,
            sms_tracker_service: &sms_tracker_service,
            sms_tracker_repository: &sms_tracker_repository,
        })?;

        Ok(MessagingModule {
            mail_activity_service,
            mail_activity_type_service,
            mail_activity_plan_service,
            mail_activity_plan_template_service,
            mail_alias_domain_service,
            mail_alias_service,
            mail_attachment_service,
            mail_message_attachment_service,
            mail_message_star_service,
            mail_message_service,
            mail_service,
            mail_notification_service,
            mail_message_subtype_service,
            mail_message_reaction_service,
            mail_followers_service,
            mail_presence_service,
            mail_blacklist_service,
            mail_tracking_value_service,
            discuss_channel_service,
            discuss_channel_member_service,
            mail_guest_service,
            mail_server_service,
            fetchmail_server_service,
            mail_gateway_allowed_service,
            phone_blacklist_service,
            mail_message_schedule_service,
            mail_scheduled_message_service,
            sms_service,
            sms_template_service,
            sms_tracker_service,
            ext,
        })
    }
}

impl Default for MessagingModuleBuilder {
    fn default() -> Self {
        Self::new()
    }
}

// This directory's extension (hand-written; ADR-0031).
include!("mod.ext.rs");