feat: added cults

api/src/cult.rs

@@ -0,0 +1,29 @@
+extern crate postgres;
+use postgres::{Connection, TlsMode};
+use std::env;
+
+pub fn get_cult_all(vec: &mut Vec<crate::Cult>) {
+    let pg_connection_string = env::var("DATABASE_URI").expect("need a db uri");
+    println!("Connecting to {}", pg_connection_string);
+    let conn = Connection::connect(&pg_connection_string[..], TlsMode::None) .unwrap();
+    println!("Connection is fine");
+    for row in &conn.query("SELECT id, name FROM cults", &[]).unwrap() {
+        let cult = crate::Cult {
+            id: row.get(0),
+            name: row.get(1)
+        };
+        vec.push(cult);
+    }
+}
+
+pub fn get_cult_by_id(vec: &mut Vec<crate::Cult>, id: i32) {
+    let pg_connection_string = env::var("DATABASE_URI").expect("need a db uri");
+    let conn = Connection::connect(&pg_connection_string[..], TlsMode::None) .unwrap();
+    for row in &conn.query("SELECT id, name FROM cults WHERE id = $1", &[&id]).unwrap() {
+        let cult = crate::Cult {
+            id: row.get(0),
+            name: row.get(1)
+        };
+        vec.push(cult);
+    }
+}

api/src/main.rs

@@ -2,7 +2,26 @@ use actix_web::{web, App, HttpServer, Responder};
 use serde::Serialize;
 
 mod person;
+mod cult;
 
+#[derive(Serialize)]
+pub struct Cult {
+    pub id: i32,
+    pub name: String
+}
+
+fn get_cult_list() -> impl Responder {
+    let mut vec:Vec<Cult> = Vec::new();
+    cult::get_cult_all(&mut vec);
+    web::Json(vec)
+}
+
+fn get_cult(info: web::Path<i32>) -> impl Responder {
+    let mut vec:Vec<Cult> = Vec::new();
+    cult::get_cult_by_id(&mut vec, info.into_inner());
+    web::Json(vec)
+}
+
 #[derive(Serialize)]
 pub struct Person {
     pub person_id: i32,
@@ -36,6 +55,10 @@ fn main() {
                 .route(web::get().to(get_person)))
                 // .route(web::delete().to(delete_person))
                 // .route(web::put().to(update_person)))
+            .service(web::resource("/cults/{cult_id}")
+                .route(web::get().to(get_cult)))
+            .service(web::resource("/cults")
+                .route(web::get().to(get_cult_list)))
             .service(web::resource("/persons")
                 .route(web::get().to(get_person_list)))
                 // .route(web::post().to(create_person)))

database/create_cults.sql

@@ -0,0 +1,10 @@
+CREATE TABLE cults
+(
+	id serial NOT NULL,
+	name VARCHAR(100)
+);
+
+-- ALTER TABLE CULTS owner TO jayylmao;
+
+INSERT INTO cults (name) 
+        VALUES ('Church of the Latter day dudes');

docker-compose.yml

@@ -2,7 +2,7 @@ version: "2.3"
 services:
   api:
     build:
-      context: ./readspacer-api
+      context: ./api
       dockerfile: Dockerfile
     ports:
       - "8000:8000"