2020-10-28 11:58:15 +00:00
|
|
|
use anyhow::{format_err, Error};
|
2020-10-28 06:58:07 +00:00
|
|
|
|
|
|
|
use crate::{
|
|
|
|
server::WorkerTask,
|
|
|
|
api2::types::*,
|
|
|
|
server::jobstate::Job,
|
|
|
|
config::verify::VerificationJobConfig,
|
|
|
|
backup::{
|
|
|
|
DataStore,
|
|
|
|
BackupInfo,
|
2020-10-28 11:58:15 +00:00
|
|
|
verify_all_backups,
|
2020-10-28 06:58:07 +00:00
|
|
|
},
|
|
|
|
task_log,
|
|
|
|
};
|
|
|
|
|
|
|
|
/// Runs a verification job.
|
|
|
|
pub fn do_verification_job(
|
|
|
|
mut job: Job,
|
|
|
|
verification_job: VerificationJobConfig,
|
|
|
|
userid: &Userid,
|
|
|
|
schedule: Option<String>,
|
|
|
|
) -> Result<String, Error> {
|
2020-10-28 11:58:15 +00:00
|
|
|
|
2020-10-28 06:58:07 +00:00
|
|
|
let datastore = DataStore::lookup_datastore(&verification_job.store)?;
|
|
|
|
|
2020-10-28 11:58:15 +00:00
|
|
|
let datastore2 = datastore.clone();
|
2020-10-28 06:58:07 +00:00
|
|
|
|
2020-10-28 11:58:15 +00:00
|
|
|
let outdated_after = verification_job.outdated_after.clone();
|
|
|
|
let ignore_verified = verification_job.ignore_verified.unwrap_or(true);
|
|
|
|
|
|
|
|
let filter = move |backup_info: &BackupInfo| {
|
|
|
|
if !ignore_verified {
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
let manifest = match datastore2.load_manifest(&backup_info.backup_dir) {
|
|
|
|
Ok((manifest, _)) => manifest,
|
2020-10-28 12:56:49 +00:00
|
|
|
Err(_) => return true,
|
2020-10-28 11:58:15 +00:00
|
|
|
};
|
|
|
|
|
|
|
|
let raw_verify_state = manifest.unprotected["verify_state"].clone();
|
|
|
|
let last_state = match serde_json::from_value::<SnapshotVerifyState>(raw_verify_state) {
|
|
|
|
Ok(last_state) => last_state,
|
|
|
|
Err(_) => return true,
|
|
|
|
};
|
2020-10-28 06:58:07 +00:00
|
|
|
|
2020-10-28 11:58:15 +00:00
|
|
|
let now = proxmox::tools::time::epoch_i64();
|
|
|
|
let days_since_last_verify = (now - last_state.upid.starttime) / 86400;
|
|
|
|
|
|
|
|
outdated_after
|
|
|
|
.map(|v| days_since_last_verify > v)
|
|
|
|
.unwrap_or(true)
|
|
|
|
};
|
2020-10-28 06:58:07 +00:00
|
|
|
|
2020-10-27 12:36:56 +00:00
|
|
|
let email = crate::server::lookup_user_email(userid);
|
|
|
|
|
2020-10-28 06:58:07 +00:00
|
|
|
let job_id = job.jobname().to_string();
|
|
|
|
let worker_type = job.jobtype().to_string();
|
|
|
|
let upid_str = WorkerTask::new_thread(
|
|
|
|
&worker_type,
|
|
|
|
Some(job.jobname().to_string()),
|
|
|
|
userid.clone(),
|
|
|
|
false,
|
|
|
|
move |worker| {
|
|
|
|
job.start(&worker.upid().to_string())?;
|
|
|
|
|
|
|
|
task_log!(worker,"Starting datastore verify job '{}'", job_id);
|
|
|
|
if let Some(event_str) = schedule {
|
|
|
|
task_log!(worker,"task triggered by schedule '{}'", event_str);
|
|
|
|
}
|
|
|
|
|
2020-10-28 11:58:15 +00:00
|
|
|
let result = verify_all_backups(datastore, worker.clone(), worker.upid(), &filter);
|
|
|
|
let job_result = match result {
|
|
|
|
Ok(ref errors) if errors.is_empty() => Ok(()),
|
|
|
|
Ok(_) => Err(format_err!("verification failed - please check the log for details")),
|
|
|
|
Err(_) => Err(format_err!("verification failed - job aborted")),
|
|
|
|
};
|
2020-10-28 06:58:07 +00:00
|
|
|
|
2020-10-28 11:58:15 +00:00
|
|
|
let status = worker.create_state(&job_result);
|
2020-10-28 06:58:07 +00:00
|
|
|
|
|
|
|
match job.finish(status) {
|
|
|
|
Err(err) => eprintln!(
|
|
|
|
"could not finish job state for {}: {}",
|
|
|
|
job.jobtype().to_string(),
|
|
|
|
err
|
|
|
|
),
|
|
|
|
Ok(_) => (),
|
|
|
|
}
|
|
|
|
|
2020-10-27 12:36:56 +00:00
|
|
|
if let Some(email) = email {
|
|
|
|
if let Err(err) = crate::server::send_verify_status(&email, verification_job, &result) {
|
|
|
|
eprintln!("send verify notification failed: {}", err);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-10-28 11:58:15 +00:00
|
|
|
job_result
|
2020-10-28 06:58:07 +00:00
|
|
|
},
|
|
|
|
)?;
|
|
|
|
Ok(upid_str)
|
|
|
|
}
|