From 9036469324912eae3eed8cb8645f91f1a68c5857 Mon Sep 17 00:00:00 2001
From: Bryan Newbold <bnewbold@robocracy.org>
Date: Tue, 15 May 2018 20:53:56 -0700
Subject: progress on inserts

Using a huge sql_query() to do raw multi-table inserts for now.
---
 rust/README.md              |  4 +++
 rust/src/api_server.rs      | 73 +++++++++++++++++++++++++++------------------
 rust/src/bin/fatcat-iron.rs |  2 +-
 rust/src/database_models.rs |  6 ++--
 4 files changed, 51 insertions(+), 34 deletions(-)

(limited to 'rust')

diff --git a/rust/README.md b/rust/README.md
index 8d9084c3..f539e4fb 100644
--- a/rust/README.md
+++ b/rust/README.md
@@ -12,3 +12,7 @@ Things!
 Debugging SQL errors:
 
     psql fatcat_rs < migrations/2018-05-12-001226_init/up.sql
+
+Creating entities:
+
+    http --json post localhost:9411/v0/container name=asdf issn=1234-5678
diff --git a/rust/src/api_server.rs b/rust/src/api_server.rs
index b8ec3abd..81232728 100644
--- a/rust/src/api_server.rs
+++ b/rust/src/api_server.rs
@@ -11,6 +11,7 @@ use database_schema::{container_rev, container_ident, container_edit,
 };
 use uuid;
 use diesel::prelude::*;
+use diesel::{self, insert_into};
 use futures::{self, Future};
 use fatcat_api::models;
 use fatcat_api::models::*;
@@ -35,33 +36,18 @@ impl Api for Server {
     ) -> Box<Future<Item = ContainerIdGetResponse, Error = ApiError> + Send> {
         let conn = self.db_pool.get().expect("db_pool error");
         let id = uuid::Uuid::parse_str(&id).unwrap();
-        let (ident, rev): (ContainerIdentRow, Option<ContainerRevRow>) = container_ident::table
+        let (ident, rev): (ContainerIdentRow, ContainerRevRow) = container_ident::table
             .find(id)
-            .left_outer_join(container_rev::table)
+            .inner_join(container_rev::table)
             .first(&conn)
             .expect("error loading container");
-/*
-        let (ident, rev): (ContainerIdentRow, Option<ContainerRevRow>) = container_ident::table
-            .left_join(container_rev::table)
-            .filter(container_ident::id.equals(id))
-            .first(&conn)
-            .expect("error loading container");
-*/
-/*
-        let c: ContainerIdentRow = container_ident::table
-            .find(id)
-            .first(&conn)
-            .expect("error loading container");
-        //let c: i64 = container_rev::table.count().first(&conn).expect("DB Error");
-        println!("container count: {:?}", c);
-*/ 
 
         let entity = ContainerEntity {
-            issn: None,
-            publisher: Some("Hello!".into()),
-            parent: None,
-            name: None,
-            state: None,
+            issn: rev.issn,
+            publisher: rev.publisher,
+            parent: None, // TODO
+            name: Some(rev.name), // TODO: not optional
+            state: None, // TODO:
             ident: Some(ident.id.to_string()),
             revision: ident.rev_id.map(|v| v as isize),
             redirect: ident.redirect_id.map(|u| u.to_string()),
@@ -91,13 +77,42 @@ impl Api for Server {
         body: Option<models::ContainerEntity>,
         context: &Context,
     ) -> Box<Future<Item = ContainerPostResponse, Error = ApiError> + Send> {
-        let context = context.clone();
-        println!(
-            "container_post({:?}) - X-Span-ID: {:?}",
-            body,
-            context.x_span_id.unwrap_or(String::from("<none>")).clone()
-        );
-        Box::new(futures::failed("Generic failure".into()))
+        println!("{:?}", body);
+        let body = body.expect("missing body"); // TODO: required parameter
+        //let editgroup_id: i64 = body.editgroup.expect("need editgroup_id") as i64; // TODO: or find/create
+        let editgroup_id = 1;
+        let conn = self.db_pool.get().expect("db_pool error");
+
+        let name = body.name.unwrap();
+        let issn = body.issn.unwrap();
+        println!("name={} issn={}", name, issn);
+
+        let edit: Vec<ContainerEditRow> = diesel::sql_query(
+            "WITH rev AS ( INSERT INTO container_rev (name, issn)
+                        VALUES ($1, $2)
+                        RETURNING id ),
+                ident AS ( INSERT INTO container_ident (rev_id)
+                            VALUES ((SELECT rev.id FROM rev))
+                            RETURNING id )
+            INSERT INTO container_edit (editgroup_id, ident_id, rev_id) VALUES
+                ($3, (SELECT ident.id FROM ident), (SELECT rev.id FROM rev))
+            RETURNING *")
+            .bind::<diesel::sql_types::Text, _>(name)
+            .bind::<diesel::sql_types::Text, _>(issn)
+            .bind::<diesel::sql_types::BigInt, _>(editgroup_id)
+            .load(&conn)
+            .unwrap();
+        let edit = &edit[0];
+
+        let entity_edit = EntityEdit {
+            editgroup_id: Some(edit.editgroup_id as isize),
+            revision: Some(edit.rev_id.unwrap() as isize),
+            ident: Some(edit.ident_id.to_string()),
+            id: Some(edit.id as isize),
+        };
+        Box::new(futures::done(Ok(
+            ContainerPostResponse::Created(entity_edit),
+        )))
     }
 
     fn creator_id_get(
diff --git a/rust/src/bin/fatcat-iron.rs b/rust/src/bin/fatcat-iron.rs
index 6e8c3765..05a8e1a5 100644
--- a/rust/src/bin/fatcat-iron.rs
+++ b/rust/src/bin/fatcat-iron.rs
@@ -59,7 +59,7 @@ fn main() {
     } else {
         // Using HTTP
         Iron::new(chain)
-            .http("localhost:8080")
+            .http("localhost:9411")
             .expect("Failed to start HTTP server");
     }
 }
diff --git a/rust/src/database_models.rs b/rust/src/database_models.rs
index 6c899ccf..e95e5980 100644
--- a/rust/src/database_models.rs
+++ b/rust/src/database_models.rs
@@ -1,9 +1,7 @@
 
 use chrono;
-use serde_json;
+//use serde_json;
 use uuid::Uuid;
-//use diesel::prelude::*;
-
 use database_schema::*;
 
 // Ugh. I thought the whole point was to *not* do this, but:
@@ -13,7 +11,7 @@ use database_schema::*;
 macro_rules! entity_structs {
     ($edit_table:expr, $edit_struct:ident, $ident_table:expr, $ident_struct:ident) => (
 
-        #[derive(Debug, Queryable, Identifiable, Associations, AsChangeset)]
+        #[derive(Debug, Queryable, Identifiable, Associations, AsChangeset, QueryableByName)]
         #[table_name = $edit_table]
         pub struct $edit_struct {
             pub id: i64,
-- 
cgit v1.2.3