runtasktic 1.2.1

Command-line task management tool for execution of regular long sequential or parallel tasks.
Documentation 
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
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67

use crate::config::Config;
use crate::fst::dot::*;
use crate::fst::*;
use anyhow::{Context, Result};
use clap::Parser;
use std::fs;
use std::io::Cursor;
use std::path::PathBuf;

#[derive(Parser, Debug)]
pub struct Dot {
  /// Path of the configuration file to visualize.
  #[structopt()]
  config: PathBuf,
  /// Path for the image. `dot` command is required.
  #[structopt()]
  image: PathBuf,
}

impl Dot {
  pub fn exec(&self) -> Result<()> {
    ensure!(
      self.config.exists(),
      "The config file {} does not exists",
      self.config.display()
    );
    self.run()
  }

  fn run(&self) -> Result<()> {
    let yaml = fs::read_to_string(self.config.as_path())
      .with_context(|| anyhow!("Can't read the config file: {}", self.config.display()))?;

    let mut config = Config::from_str(yaml.as_str())
      .with_context(|| anyhow!("Can't read the config file {}", self.config.display()))?;

    let mut graph = TaskFst::new();
    for task in config.tasks_values_mut() {
      task.set_state(graph.add_state(task.id()));
    }

    for task in config.tasks().values() {
      if task.depends_on().len() == 0 {
        graph.add_start_state(task.state());
      } else {
        for prev in task.depends_on().iter() {
          let err_msg = format!("{} depends on {} but does not exists", task.id(), prev);
          let prev_state = config.tasks().get(prev).ok_or(anyhow!(err_msg))?.state();
          graph.add_arc(prev_state, task.state());
        }
      }
    }

    ensure!(
      !graph.is_cyclic(),
      "Can't execute your configuration. There is a deadlock in your tasks !"
    );

    let mut buf: Vec<u8> = vec![];
    dot_write_file(&graph, &mut buf).with_context(|| "Can't create dot file")?;

    dot_write_png(&mut Cursor::new(buf), &self.image)
      .with_context(|| "Can't save graph as png file")?;

    Ok(())
  }
}