src/server/gc_job.rs

   1 use std::sync::Arc;
   2 use anyhow::Error;
   3
   4 use crate::{
   5     server::WorkerTask,
   6     api2::types::*,
   7     server::jobstate::Job,
   8     backup::DataStore,
   9 };
  10
  11 /// Runs a garbage collection job.
  12 pub fn do_garbage_collection_job(
  13     mut job: Job,
  14     datastore: Arc<DataStore>,
  15     auth_id: &Authid,
  16     schedule: Option<String>,
  17     to_stdout: bool,
  18 ) -> Result<String, Error> {
  19
  20     let store = datastore.name().to_string();
  21
  22     let (email, notify) = crate::server::lookup_datastore_notify_settings(&store);
  23
  24     let worker_type = job.jobtype().to_string();
  25     let upid_str = WorkerTask::new_thread(
  26         &worker_type,
  27         Some(store.clone()),
  28         auth_id.clone(),
  29         to_stdout,
  30         move |worker| {
  31             job.start(&worker.upid().to_string())?;
  32
  33             worker.log(format!("starting garbage collection on store {}", store));
  34             if let Some(event_str) = schedule {
  35                 worker.log(format!("task triggered by schedule '{}'", event_str));
  36             }
  37
  38             let result = datastore.garbage_collection(&*worker, worker.upid());
  39
  40             let status = worker.create_state(&result);
  41
  42             match job.finish(status) {
  43                 Err(err) => eprintln!(
  44                     "could not finish job state for {}: {}",
  45                     job.jobtype().to_string(),
  46                     err
  47                 ),
  48                 Ok(_) => (),
  49             }
  50
  51             if let Some(email) = email {
  52                 let gc_status = datastore.last_gc_status();
  53                 if let Err(err) = crate::server::send_gc_status(&email, notify, &store, &gc_status, &result) {
  54                     eprintln!("send gc notification failed: {}", err);
  55                 }
  56             }
  57
  58             result
  59         }
  60     )?;
  61
  62     Ok(upid_str)
  63 }