flows

src/flow.rs

@@ -0,0 +1,43 @@
+use std::collections::HashMap;
+
+use mongod::{assert_reference_of, Reference, Validate};
+
+pub struct FlowInfo {
+    pub name: String,
+    pub depends: HashMap<String, i64>,
+    pub next: Option<String>,
+    pub produces: Option<Vec<String>>,
+}
+
+use mongod::{
+    derive::{Model, Referencable},
+    Model, Referencable, ToAPI,
+};
+use mongodb::bson::doc;
+use serde::{Deserialize, Serialize};
+use serde_json::json;
+
+/// A production flow
+#[derive(Debug, Clone, Serialize, Deserialize, Model, Referencable)]
+pub struct Flow {
+    /// ID
+    pub _id: String,
+    /// Tiemstamp when the flow was started
+    pub started: i64,
+    /// Timestamp when the flow was ended
+    pub ended: i64,
+    /// Kind of flow; ID of the describing JSON
+    pub kind: String,
+    /// The flow succedding this one
+    pub next: Option<Reference>,
+}
+
+impl Validate for Flow {
+    async fn validate(&self) -> Result<(), String> {
+        if let Some(next) = &self.next {
+            assert_reference_of!(next, Flow);
+        }
+
+        Ok(())
+    }
+}

src/item.rs

@@ -11,8 +11,6 @@ use serde_json::json;
 use crate::transaction::Transaction;
 use crate::variant::Variant;
 
-// todo : api key auth
-
 // ITEM
 // VARIANTS
 // QUANTIZATION

src/main.rs

@@ -8,10 +8,10 @@ use rocket::{http::Method, launch};
 
 mod config;
 mod db;
+mod flow;
 mod item;
 mod json_store;
 mod location;
-mod process;
 mod routes;
 mod transaction;
 mod variant;

src/process.rs

@@ -1,8 +0,0 @@
-use std::collections::HashMap;
-
-pub struct ProcessInfo {
-    pub name: String,
-    pub depends: HashMap<String, i64>,
-    pub next: Option<String>,
-    pub produces: Option<Vec<String>>,
-}

src/routes/mod.rs

@@ -30,7 +30,7 @@ impl<'r> FromRequest<'r> for Token {
     type Error = ();
 
     async fn from_request(request: &'r Request<'_>) -> rocket::request::Outcome<Self, Self::Error> {
-        match request.headers().get_one("token") {
+        match request.headers().get_one("Token") {
             Some(key) => Outcome::Success(Token(key.to_string())),
             None => Outcome::Error((Status::Unauthorized, ())),
         }