raisfast 0.2.19

The last backend you'll ever need. Rust-powered headless CMS with built-in blog, ecommerce, wallet, payment and 4 plugin engines.
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

//! Database backup Handler
//!
//! Performs a consistent SQLite backup by flushing the WAL and copying the database file.

use std::sync::Arc;

use crate::config::app::AppConfig;
use crate::errors::app_error::AppResult;
use crate::worker::{Job, JobHandler};

/// Database backup handler
pub struct DbBackupHandler {
    config: Arc<AppConfig>,
}

impl DbBackupHandler {
    /// Creates a new database backup handler
    #[must_use]
    pub fn new(config: Arc<AppConfig>) -> Self {
        Self { config }
    }
}

#[async_trait::async_trait]
impl JobHandler for DbBackupHandler {
    async fn handle(&self, job: &Job) -> AppResult<()> {
        match job {
            Job::Custom { job_type, .. } if job_type == "db_backup" => {}
            _ => return Ok(()),
        }

        let output_dir = format!("{}/backups", self.config.storage_root_dir);

        crate::db::backup::backup_database(&self.config, &output_dir, self.config.backup_retention)
            .await
            .map_err(crate::errors::app_error::AppError::Internal)?;

        tracing::info!("[db_backup] backup completed to {}", output_dir);
        Ok(())
    }
}