},
},
server::{
+ lookup_user_email,
jobstate::{
Job,
JobState,
UPID_SCHEMA,
JOB_ID_SCHEMA,
MediaPoolConfig,
+ Userid,
},
server::WorkerTask,
task::TaskState,
let pool = MediaPool::with_config(status_path, &pool_config, changer_name)?;
- let mut pool_writer = PoolWriter::new(pool, &setup.drive, worker)?;
+ let notify_user = setup.notify_user.as_ref().unwrap_or_else(|| &Userid::root_userid());
+ let email = lookup_user_email(notify_user);
+
+ let mut pool_writer = PoolWriter::new(pool, &setup.drive, worker, email)?;
let mut group_list = BackupInfo::list_backup_groups(&datastore.base_path())?;
DRIVE_NAME_SCHEMA,
UPID_SCHEMA,
Authid,
+ Userid,
},
config::{
self,
DynamicIndexReader,
FixedIndexReader,
},
- server::WorkerTask,
+ server::{
+ lookup_user_email,
+ WorkerTask,
+ },
tape::{
TAPE_STATUS_DIR,
TapeRead,
description: "Media set UUID.",
type: String,
},
+ "notify-user": {
+ type: Userid,
+ optional: true,
+ },
},
},
returns: {
store: String,
drive: String,
media_set: String,
+ notify_user: Option<Userid>,
rpcenv: &mut dyn RpcEnvironment,
) -> Result<Value, Error> {
&drive,
&datastore,
&auth_id,
+ ¬ify_user,
)?;
}
drive_name: &str,
datastore: &DataStore,
authid: &Authid,
+ notify_user: &Option<Userid>,
) -> Result<(), Error> {
let media_set_uuid = match media_id.media_set_label {
Some(ref set) => &set.uuid,
};
- let (mut drive, info) = request_and_load_media(worker, &drive_config, &drive_name, &media_id.label)?;
+ let email = notify_user
+ .as_ref()
+ .and_then(|userid| lookup_user_email(userid))
+ .or_else(|| lookup_user_email(&authid.clone().into()));
+
+ let (mut drive, info) = request_and_load_media(worker, &drive_config, &drive_name, &media_id.label, &email)?;
match info.media_set_label {
None => {
}
/// Lookup users email address
-fn lookup_user_email(userid: &Userid) -> Option<String> {
+pub fn lookup_user_email(userid: &Userid) -> Option<String> {
use crate::config::user::{self, User};
config: &SectionConfigData,
drive: &str,
label: &MediaLabel,
+ notify_email: &Option<String>,
) -> Result<(
Box<dyn TapeDriver>,
MediaId,
return Ok((handle, media_id));
}
-
- let to = "root@localhost"; // fixme
-
let mut last_media_uuid = None;
let mut last_error = None;
if tried {
if let Some(reason) = failure_reason {
task_log!(worker, "Please insert media '{}' into drive '{}'", label_text, drive);
- send_load_media_email(drive, &label_text, to, Some(reason))?;
+ if let Some(to) = notify_email {
+ send_load_media_email(drive, &label_text, to, Some(reason))?;
+ }
}
failure_reason = None;
drive_name: String,
status: Option<PoolWriterState>,
media_set_catalog: MediaSetCatalog,
+ notify_email: Option<String>,
}
impl PoolWriter {
- pub fn new(mut pool: MediaPool, drive_name: &str, worker: &WorkerTask) -> Result<Self, Error> {
+ pub fn new(mut pool: MediaPool, drive_name: &str, worker: &WorkerTask, notify_email: Option<String>) -> Result<Self, Error> {
let current_time = proxmox::tools::time::epoch_i64();
drive_name: drive_name.to_string(),
status: None,
media_set_catalog,
+ notify_email,
})
}
let (drive_config, _digest) = crate::config::drive::config()?;
let (mut drive, old_media_id) =
- request_and_load_media(worker, &drive_config, &self.drive_name, media.label())?;
+ request_and_load_media(worker, &drive_config, &self.drive_name, media.label(), &self.notify_email)?;
// test for critical tape alert flags
if let Ok(alert_flags) = drive.tape_alert_flags() {