userd 0.2.0

A user daemon, managing services and regular running of jobs, in user space.
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

use futures::{StreamExt, stream::FuturesUnordered};

use crate::prelude::*;

pub(crate) struct Task {
    triggers: Vec<triggers::TriggerBox>,
    activity: Activity,
}

impl Task {
    pub(crate) fn new(config: config::Task) -> Result<Self> {
        Ok(Self {
            triggers: triggers::build_triggers(config.triggers)?,
            activity: Activity::new(config.name.clone(), config.command)?,
        })
    }
    pub(crate) async fn start(self) {
        utils::log_error("task: start activity", self.activity.start_activity().await);
        loop {
            let mut futs = self
                .triggers
                .iter()
                .map(|t| tokio::spawn(t.wait_for()))
                .collect::<FuturesUnordered<_>>();
            let result = futs.next().await;
            if let Some(Err(e)) = result {
                log::error!("An error occured in a trigger: {}", e);
            } else {
                utils::log_error("task: start activity", self.activity.start_activity().await);
            }
        }
    }
}