atros 0.1.0

Automation for the Rest of Us
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
68

use std::io::{stdout, Write};

use colored::Colorize;

use crate::{
    cache::{CacheFile, CachedTask},
    step::{Step, Task},
    system_pacman::PackageManager,
};

use super::{run_install, run_shell, tools::println_std, System};

pub fn run(
    step: &Step,
    system: &System,
    package_manager: &PackageManager,
    file_cache: &mut CacheFile,
) -> anyhow::Result<()> {
    stdout().write_all(format!("{} Step: {}\n", "┌──".bright_black(), step.title).as_bytes())?;

    if let Some(desc) = &step.description {
        println_std(format!("Description: {desc}"))?;
    }

    for (idx, task) in step.tasks.iter().enumerate() {
        println_std(format!("\n{} Task No: {}", "├─>".bright_black(), idx + 1))?;

        let task_system = match task {
            Task::Install(task) => &task.system,
            Task::Shell(task) => &task.system,
        };

        if let Some(sys) = task_system {
            if system != sys {
                println_std(format!(
                    "Warning: This task is defined for {sys:#?}, Skipping..."
                ))?;
                continue;
            }
        }

        let task_cache = match file_cache.tasks.get_mut(idx) {
            Some(task) => task,
            None => {
                file_cache.tasks.push(CachedTask {
                    failed: true,
                    command: "".to_string(),
                });

                file_cache
                    .tasks
                    .get_mut(idx)
                    .expect("An error occured while unwrapping task cache")
            }
        };

        match task {
            Task::Install(task) => {
                run_install::run(task, package_manager, task_cache)?;
            }
            Task::Shell(task) => {
                run_shell::run(task, task_cache)?;
            }
        }
    }

    Ok(())
}