config

Cargo.lock

@@ -120,6 +120,9 @@ name = "camino"
 version = "1.0.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "cd065703998b183ed0b348a22555691373a9345a1431141e5778b48bb17e4703"
+dependencies = [
+ "serde",
+]
 
 [[package]]
 name = "cc"
@@ -218,6 +221,16 @@ dependencies = [
  "syn",
 ]
 
+[[package]]
+name = "directories-next"
+version = "1.0.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "8a28ccebc1239c5c57f0c55986e2ac03f49af0d0ca3dff29bfcad39d60a8be56"
+dependencies = [
+ "cfg-if",
+ "dirs-sys-next",
+]
+
 [[package]]
 name = "dirs-next"
 version = "2.0.0"
@@ -380,13 +393,16 @@ dependencies = [
  "bollard",
  "camino",
  "color-eyre",
+ "directories-next",
  "futures-util",
  "maplit",
  "min-id",
  "opener",
  "parse-display",
+ "serde",
  "termion",
  "tokio",
+ "toml",
 ]
 
 [[package]]
@@ -1117,6 +1133,15 @@ dependencies = [
  "tokio",
 ]
 
+[[package]]
+name = "toml"
+version = "0.5.8"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a31142970826733df8241ef35dc040ef98c679ab14d7c3e54d827099b3acecaa"
+dependencies = [
+ "serde",
+]
+
 [[package]]
 name = "tower-service"
 version = "0.3.1"

Cargo.toml

@@ -9,9 +9,12 @@ bollard = { version = "0.10", git = "https://github.com/icewind1991/bollard", br
 color-eyre = "0.5"
 min-id = "0.1"
 maplit = "1"
-camino = "1"
+camino = { version = "1", features = ["serde1"] }
 tokio = { version = "1" , features = ["fs", "macros"] }
 parse-display = "0.4"
 futures-util = "0.3"
 termion = "1"
 opener = "0.4"
+toml = "0.5"
+directories-next = "1"
+serde = "1"

README.md

@@ -0,0 +1,88 @@
+# Haze
+
+Hazy with a chance of clouds.
+
+## Setup
+
+### Requirements
+
+ - Docker
+
+### Config
+
+Create a file `~/.config/haze/haze.toml` with the following options:
+
+```toml
+sources_root = "/path/to/nextcloud/sources"
+work_dir = "/path/to/temp/folder" # optional, defaults to /tmp/haze
+```
+
+## Managing instances
+
+#### Start an instance
+
+```bash
+haze start [database]
+```
+
+Where database is one of `sqlite`, `mysql`, `mariadb` or `pgsql` with an option version (e.g. `pgsql:12`), defaults to `sqlite`.
+
+### List running instances
+
+```bash
+haze
+```
+
+or
+
+```bash
+haze list
+```
+
+#### Remove all running instances
+
+```bash
+haze clean
+```
+
+## Controlling running instances
+
+The following commands run against the most recently started instance and allow optionally providing a `match` to select a specific instance by it's name.
+
+#### Open an instance
+
+```bash
+haze [match] open
+```
+
+#### Open the database of an instance
+
+```bash
+haze [match] db
+```
+
+#### Execute a command on an instance
+
+```bash
+haze [match] exec [cmd]
+```
+
+If no `cmd` is specified it will launch `bash`
+
+#### Execute an occ command on an instance
+
+```bash
+haze [match] occ [cmd]
+```
+
+#### Show the logs of an instance
+
+```bash
+haze [match] logs
+```
+
+#### Stop an instance
+
+```bash
+haze [match] stop
+```

src/config.rs

@@ -1,6 +1,31 @@
 use camino::Utf8PathBuf;
+use color_eyre::{eyre::WrapErr, Report, Result};
+use directories_next::ProjectDirs;
+use serde::Deserialize;
+use std::fs::read;
 
+#[derive(Debug, Deserialize)]
 pub struct HazeConfig {
     pub sources_root: Utf8PathBuf,
+    #[serde(default = "default_work_dir")]
     pub work_dir: Utf8PathBuf,
 }
+
+fn default_work_dir() -> Utf8PathBuf {
+    "/tmp/haze".into()
+}
+
+impl HazeConfig {
+    pub fn load() -> Result<Self> {
+        let dirs = ProjectDirs::from("nl", "icewind", "haze").unwrap();
+        let file = dirs.config_dir().join("haze.toml");
+        if !file.exists() {
+            return Err(Report::msg(format!(
+                "Config file not setup: {}",
+                file.to_string_lossy()
+            )));
+        }
+        let content = read(&file).wrap_err("Failed to read config file")?;
+        toml::from_slice(&content).wrap_err("Failed to parse config file")
+    }
+}

src/main.rs

@@ -16,10 +16,7 @@ mod tty;
 async fn main() -> Result<()> {
     let mut docker =
         Docker::connect_with_local_defaults().wrap_err("Failed to connect to docker")?;
-    let config = HazeConfig {
-        sources_root: "/srv/http/owncloud".into(),
-        work_dir: "/tmp/haze".into(),
-    };
+    let config = HazeConfig::load().wrap_err("Failed to load config")?;
 
     let args = HazeArgs::parse(std::env::args())?;
 
@@ -66,18 +63,18 @@ async fn main() -> Result<()> {
             println!("http://{}", cloud.ip.unwrap());
         }
         HazeCommand::Stop => {
-            let cloud = get_by_filter(&mut docker, None, &config).await?;
+            let cloud = get_by_filter(&mut docker, args.id, &config).await?;
             cloud.destroy(&mut docker).await?;
         }
         HazeCommand::Logs => {
-            let cloud = get_by_filter(&mut docker, None, &config).await?;
+            let cloud = get_by_filter(&mut docker, args.id, &config).await?;
             let logs = cloud.logs(&mut docker).await?;
             for log in logs {
                 print!("{}", log);
             }
         }
         HazeCommand::Exec => {
-            let cloud = get_by_filter(&mut docker, None, &config).await?;
+            let cloud = get_by_filter(&mut docker, args.id, &config).await?;
             cloud
                 .exec(
                     &mut docker,
@@ -90,17 +87,17 @@ async fn main() -> Result<()> {
                 .await?;
         }
         HazeCommand::Occ => {
-            let cloud = get_by_filter(&mut docker, None, &config).await?;
+            let cloud = get_by_filter(&mut docker, args.id, &config).await?;
             let mut options = args.options;
             options.insert(0, "occ".to_string());
             cloud.exec(&mut docker, options).await?;
         }
         HazeCommand::Db => {
-            let cloud = get_by_filter(&mut docker, None, &config).await?;
+            let cloud = get_by_filter(&mut docker, args.id, &config).await?;
             cloud.db.exec(&mut docker, &cloud.id).await?;
         }
         HazeCommand::Open => {
-            let cloud = get_by_filter(&mut docker, None, &config).await?;
+            let cloud = get_by_filter(&mut docker, args.id, &config).await?;
             match cloud.ip {
                 Some(ip) => opener::open(format!("http://{}", ip))?,
                 None => eprintln!("{} is not running", cloud.id),