WIP tasks

devenv.nix

@@ -1,5 +1,7 @@
 { inputs, pkgs, lib, config, ... }: {
   env.DEVENV_NIX = inputs.nix.packages.${pkgs.stdenv.system}.nix;
+  env.RUST_LOG = "devenv=debug";
+  env.RUST_LOG_SPAN_EVENTS = "full";
 
   packages = [
     pkgs.cairo
@@ -208,6 +210,10 @@ EOF
     '';
   };
 
+
+  tasks.sleep.exec = "sleep 10";
+  tasks.sleep.depends = [ "enterShell" ];
+
   pre-commit.hooks = {
     nixpkgs-fmt.enable = true;
     #shellcheck.enable = true;

devenv/Cargo.toml

@@ -7,15 +7,18 @@ license.workspace = true
 
 [dependencies]
 ansiterm.workspace = true
+assert_matches = "1.5.0"
 clap.workspace = true
 cli-table.workspace = true
+crossterm = "0.28.1"
 dotlock.workspace = true
 fs2.workspace = true
 hex.workspace = true
 include_dir.workspace = true
 indoc.workspace = true
 miette.workspace = true
 nix.workspace = true
+petgraph = "0.6.5"
 regex.workspace = true
 reqwest.workspace = true
 schemars.workspace = true
@@ -25,6 +28,14 @@ serde_json.workspace = true
 serde_yaml.workspace = true
 sha2.workspace = true
 tempdir.workspace = true
+tempfile = "3.12.0"
+test-log = { version = "0.2.16", features = ["trace"] }
+thiserror = "1.0.63"
+tokio = { version = "1.39.3", features = [
+    "process",
+    "macros",
+    "rt-multi-thread",
+] }
 tracing.workspace = true
 which.workspace = true
 whoami.workspace = true

devenv/src/cli.rs

@@ -165,6 +165,12 @@ pub(crate) enum Commands {
         command: ProcessesCommand,
     },
 
+    #[command(about = "Run tasks. https://devenv.sh/tasks/")]
+    Tasks {
+        #[command(subcommand)]
+        command: TasksCommand,
+    },
+
     #[command(about = "Run tests. http://devenv.sh/tests/", alias = "ci")]
     Test {
         #[arg(short, long, help = "Don't override .devenv to a temporary directory.")]
@@ -241,6 +247,13 @@ pub(crate) enum ProcessesCommand {
     // TODO: Status/Attach
 }
 
+#[derive(Subcommand, Clone)]
+#[clap(about = "Run tasks. https://devenv.sh/tasks/")]
+pub(crate) enum TasksCommand {
+    #[command(about = "Run tasks.")]
+    Run { tasks: Vec<String> },
+}
+
 #[derive(Subcommand, Clone)]
 #[clap(
     about = "Build, copy, or run a container. https://devenv.sh/containers/",

devenv/src/devenv.rs

@@ -1,4 +1,4 @@
-use super::{cli, command, config, log};
+use super::{cli, command, config, log, tasks};
 use clap::crate_version;
 use cli_table::Table;
 use cli_table::{print_stderr, WithTitle};
@@ -566,6 +566,41 @@ impl Devenv {
         Ok(self.has_processes.unwrap())
     }
 
+    pub async fn tasks_run(&mut self, roots: Vec<String>) -> Result<()> {
+        if roots.is_empty() {
+            bail!("No tasks specified.");
+        }
+        let config = {
+            let _logprogress = self.log_progress.with_newline("Evaluating tasks");
+            self.run_nix(
+                "nix",
+                &[
+                    "build",
+                    ".#devenv.task.config",
+                    "--no-link",
+                    "--print-out-paths",
+                ],
+                &command::Options::default(),
+            )?
+        };
+        // parse tasks config
+        let config_content =
+            std::fs::read_to_string(String::from_utf8_lossy(&config.stdout).trim())
+                .expect("Failed to read config file");
+        let tasks: Vec<tasks::TaskConfig> =
+            serde_json::from_str(&config_content).expect("Failed to parse tasks config");
+        // run tasks
+        let config = tasks::Config { roots, tasks };
+        let mut tui = tasks::TasksUi::new(config).await?;
+        let tasks_status = tui.run().await?;
+
+        if tasks_status.failed > 0 || tasks_status.dependency_failed > 0 {
+            Err(miette::bail!("Some tasks failed"))
+        } else {
+            Ok(())
+        }
+    }
+
     pub fn test(&mut self) -> Result<()> {
         self.assemble(true)?;
 

devenv/src/lib.rs

@@ -1,8 +1,11 @@
+#[macro_use]
+extern crate assert_matches;
 mod cli;
 pub mod command;
 pub mod config;
 mod devenv;
 pub mod log;
+pub mod tasks;
 
 pub use cli::{default_system, GlobalOptions};
 pub use devenv::{Devenv, DevenvOptions};

devenv/src/main.rs

@@ -3,13 +3,15 @@ mod command;
 mod config;
 mod devenv;
 mod log;
+mod tasks;
 
 use clap::{crate_version, Parser};
-use cli::{Cli, Commands, ContainerCommand, InputsCommand, ProcessesCommand};
+use cli::{Cli, Commands, ContainerCommand, InputsCommand, ProcessesCommand, TasksCommand};
 use devenv::Devenv;
 use miette::Result;
 
-fn main() -> Result<()> {
+#[tokio::main]
+async fn main() -> Result<()> {
     let cli = Cli::parse();
 
     let level = if cli.global_options.verbose {
@@ -126,6 +128,9 @@ fn main() -> Result<()> {
             }
             ProcessesCommand::Down {} => devenv.down(),
         },
+        Commands::Tasks { command } => match command {
+            TasksCommand::Run { tasks } => devenv.tasks_run(tasks).await,
+        },
         Commands::Inputs { command } => match command {
             InputsCommand::Add { name, url, follows } => devenv.inputs_add(&name, &url, &follows),
         },