From a9adeb2d8abf33dd59ba181bb7777ee3ddb75755 Mon Sep 17 00:00:00 2001
From: "R. Tyler Croy" <rtyler@brokenco.de>
Date: Wed, 3 Mar 2021 10:20:15 -0800
Subject: [PATCH] Map the project and system configuration defined in the demo
 directory

---
 Cargo.lock                  |   1 +
 crates/models/Cargo.toml    |   1 +
 crates/models/src/config.rs | 167 ++++++++++++++++++++++++++++++++++++
 crates/models/src/lib.rs    |   1 +
 4 files changed, 170 insertions(+)
 create mode 100644 crates/models/src/config.rs

diff --git a/Cargo.lock b/Cargo.lock
index f1e1f15..fea714c 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -1670,6 +1670,7 @@ version = "0.1.0"
 dependencies = [
  "serde 1.0.123",
  "serde_json",
+ "serde_yaml",
  "uuid",
 ]
 
diff --git a/crates/models/Cargo.toml b/crates/models/Cargo.toml
index 3d7a7f8..468196f 100644
--- a/crates/models/Cargo.toml
+++ b/crates/models/Cargo.toml
@@ -7,4 +7,5 @@ edition = "2018"
 [dependencies]
 serde = {version = "~1.0.117", features = ["rc", "derive"]}
 serde_json = "~1.0.59"
+serde_yaml = "~0.8.17"
 uuid = { version = "~0.8.1", features = ["v4", "serde"]}
diff --git a/crates/models/src/config.rs b/crates/models/src/config.rs
new file mode 100644
index 0000000..222c45d
--- /dev/null
+++ b/crates/models/src/config.rs
@@ -0,0 +1,167 @@
+/*
+ * The config module is responsible for deserializing common configuration stored in
+ * PREFIX/etc/otto
+ */
+
+use serde::{Deserialize, Serialize};
+use std::collections::HashMap;
+use std::path::PathBuf;
+
+/**
+ * Struct representing the main configuration file for Otto, e.g. PREFIX/etc/otto/otto.yml
+ *
+ * ```rust
+ * use otto_models::config::Otto;
+ * let yaml = r#"
+ * ---
+ * services:
+ *   dashboard:
+ *     host: 'localhost'
+ *     port: 7670
+ *         "#;
+ * let otto: Otto = serde_yaml::from_str(&yaml).expect("Failed to deserialize");
+ * assert_eq!(otto.services.len(), 1);
+ * ```
+ */
+#[derive(Clone, Debug, Deserialize, Serialize)]
+pub struct Otto {
+    pub services: HashMap<String, Service>,
+}
+
+/**
+ * Service definition within the main otto configuration
+ *
+ * All fields are currently required to be present in the configuration
+ */
+#[derive(Clone, Debug, Deserialize, Serialize)]
+pub struct Service {
+    pub host: String,
+    pub port: u64,
+}
+
+/** Project definition for Otto.
+ *
+ * This struct maps the configuration for the yaml files typically expected to be found inside of
+ * PREFIX/etc/otto/projects.d/
+ *
+ */
+#[derive(Clone, Debug, Deserialize, Serialize)]
+pub struct Project {
+    pub title: String,
+    pub description: String,
+    pub source: SourceMap,
+    #[serde(default = "default_pipeline")]
+    pub pipeline: Pipeline,
+}
+
+#[derive(Clone, Debug, Deserialize, Serialize)]
+pub struct SourceMap {
+    pub url: String,
+    #[serde(default = "default_refspec")]
+    pub refspec: String,
+}
+
+/**
+ * The default refspec is *, so matching all refs
+ */
+fn default_refspec() -> String {
+    String::from("*")
+}
+
+/**
+ * The default pipeline configuration for a project will also point to the local ./Ottofile
+ */
+fn default_pipeline() -> Pipeline {
+    Pipeline {
+        path: Some(PathBuf::from("./Ottofile")),
+        inline: None,
+    }
+}
+
+#[derive(Clone, Debug, Deserialize, Serialize)]
+pub struct Pipeline {
+    pub path: Option<PathBuf>,
+    pub inline: Option<String>,
+}
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    #[test]
+    fn deser_otto_yml() {
+        let yaml = r#"
+---
+services:
+  dashboard:
+    host: 'localhost'
+    port: 7670
+        "#;
+        let otto: Otto = serde_yaml::from_str(&yaml).expect("Failed to deserialize");
+        assert!(otto.services.contains_key("dashboard"));
+        let dashboard = otto.services.get("dashboard").unwrap();
+        assert_eq!(dashboard.port, 7670);
+    }
+
+    #[test]
+    fn deser_project_yml() {
+        let yaml = r#"
+---
+title: 'Hello World'
+description: |
+  The Hello World project exists as a simple demonstrate loading a project into Otto
+source:
+  url: 'https://github.com/rtyler/hello-gem.git'
+"#;
+        let project: Project = serde_yaml::from_str(&yaml).expect("Failed to deser project");
+        assert_eq!(project.title, "Hello World");
+        assert_eq!(project.source.refspec, "*");
+    }
+
+    #[test]
+    fn test_default_refspec() {
+        assert_eq!(default_refspec(), "*");
+    }
+
+    #[test]
+    fn test_default_pipeline() {
+        let pipeline = default_pipeline();
+        assert!(pipeline.path.is_some());
+        let path = pipeline.path.unwrap();
+        assert_eq!(path, PathBuf::from("./Ottofile"));
+    }
+
+    /*
+     * This is a failure, a declared pipeline: must have contents
+     */
+    #[test]
+    fn deser_project_w_empty_pipeline() {
+        let yaml = r#"
+---
+title: 'Hello World'
+description: |
+  The Hello World project exists as a simple demonstrate loading a project into Otto
+source:
+  url: 'https://github.com/rtyler/hello-gem.git'
+pipeline:
+"#;
+        let rc = serde_yaml::from_str::<Project>(&yaml);
+        assert!(rc.is_err(), "An empty pipeline: is an error condition");
+    }
+
+    #[test]
+    fn deser_project_w_inline_pipeline() {
+        let yaml = r#"
+---
+title: 'Hello World'
+description: |
+  The Hello World project exists as a simple demonstrate loading a project into Otto
+source:
+  url: 'https://github.com/rtyler/hello-gem.git'
+pipeline:
+  inline: 'this is just a buffer not a real pipeline'
+"#;
+        let project: Project = serde_yaml::from_str(&yaml).expect("Failed to deser project");
+        assert!(project.pipeline.inline.is_some());
+    }
+}
diff --git a/crates/models/src/lib.rs b/crates/models/src/lib.rs
index b9e7d86..3a57bb0 100644
--- a/crates/models/src/lib.rs
+++ b/crates/models/src/lib.rs
@@ -3,6 +3,7 @@ use std::collections::HashMap;
 use uuid::Uuid;
 
 pub use serde_json::Value;
+pub mod config;
 pub mod osp;
 
 /**