bindizr-service 0.1.0-beta.4

Application services for bindizr zone, record, token, and notification workflows
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49

use bindizr_core::dns::name::email_to_soa_mailbox;
use chrono::Utc;

use crate::{
    RepositoryTx,
    error::ServiceError,
    log_error,
    model::{zone::Zone, zone_snapshot::ZoneSnapshot},
    repository::RepositoryService,
};

/// Save a snapshot of the zone's SOA data for historical tracking.
pub async fn save_zone_snapshot_tx(
    tx: &mut RepositoryTx<'_>,
    zone: &Zone,
    serial: i32,
) -> Result<(), ServiceError> {
    RepositoryService::upsert_zone_snapshot_tx(
        tx,
        ZoneSnapshot {
            id: 0,
            zone_id: zone.id,
            serial,
            primary_ns: zone.primary_ns.clone(),
            admin_email: email_to_soa_mailbox(&zone.admin_email)
                .map_err(|e| ServiceError::BadRequest(e.to_string()))?,
            ttl: zone.ttl,
            refresh: zone.refresh,
            retry: zone.retry,
            expire: zone.expire,
            minimum_ttl: zone.minimum_ttl,
            created_at: Utc::now(),
        },
    )
    .await
    .map_err(|e| {
        log_error!("Failed to save SOA snapshot: {}", e);
        ServiceError::Internal("Failed to save SOA snapshot".to_string())
    })?;

    Ok(())
}

pub async fn get_by_serial(
    zone_id: i32,
    serial: i32,
) -> Result<Option<ZoneSnapshot>, ServiceError> {
    RepositoryService::get_zone_snapshot_by_serial(zone_id, serial).await
}