add resource_controller! macro

Cargo.toml

@@ -10,6 +10,7 @@ serde_json = "1.0"
 diesel = { version = "1.3.2", features = ["postgres", "chrono", "uuid"] }
 chrono = { version = "0.4", features = ["serde"] }
 uuid = { version = "0.6", features = ["serde", "v4"] }
+mashup = "0.1"
 
 [dev-dependencies]
 diesel_migrations = { version = "1.3.0", features = ["postgres"] }

src/controller.rs

@@ -36,5 +36,70 @@ where
 
     fn get_all(&self, by: Expr<Self::DBTable>) -> Result<Vec<Self::ModelWithId>, Error>;
 
-    fn update(&self, model: &Self::Model, by: Expr<Self::DBTable>) -> Result<Self::ModelWithId, Error>;
+    fn update(
+        &self,
+        model: &Self::Model,
+        by: Expr<Self::DBTable>,
+    ) -> Result<Self::ModelWithId, Error>;
+}
+
+macro_rules! resource_controller {
+    ($model:ident) => {
+
+        mashup! {
+            controller["controller"] = $model Controller;
+            modelWithId["modelWithId"] = $model WithId;
+        }
+
+        controller! {
+            pub struct "controller";
+
+            modelWithId! {
+                impl ResourceWithId for "controller" {
+                    type ModelWithId = "modelWithId";
+                }
+            }
+
+            impl Resource for "controller" {
+                type Model = $model;
+            }
+
+            impl ResourceTable for "controller" {
+                type DBTable = table;
+            }
+
+            impl ResourceSql for "controller" {
+                type SQLType = SqlType;
+            }
+
+            use crate::db::establish_connection as connection;
+
+            impl ResourceController for "controller" {
+                fn create(&self, model: &Self::Model) -> Result<Self::ModelWithId, Error> {
+                    Ok(insert_into(table)
+                       .values(model)
+                       .get_result(&connection())?)
+                }
+
+                fn get_one(&self, by: Expr<table>) -> Result<Self::ModelWithId, Error> {
+                    Ok(table
+                       .filter(by)
+                       .get_result::<Self::ModelWithId>(&connection())?)
+                }
+
+                fn get_all(&self, by: Expr<table>) -> Result<Vec<Self::ModelWithId>, Error> {
+                    Ok(table
+                       .filter(by)
+                       .get_results::<Self::ModelWithId>(&connection())?)
+                }
+
+                fn update(&self, model: &Self::Model, by: Expr<table>) -> Result<Self::ModelWithId, Error> {
+                    Ok(update(table)
+                       .filter(by)
+                       .set(model)
+                       .get_result::<Self::ModelWithId>(&connection())?)
+                }
+            }
+        }
+    }
 }

src/lib.rs

@@ -1,2 +1,2 @@
-mod controller;
-
+#[macro_use]
+pub mod controller;