add post endpoint to insert documents

http-server/src/db/collections/logs.rs

@@ -31,3 +31,9 @@ pub async fn find(state: web::Data<Mutex<Client>>) -> Result<Vec<Log>> {
     }
     Ok(ret)
 }
+
+pub async fn insert(state: web::Data<Mutex<Client>>, log: Log) -> Result<()> {
+    let log_collection: Collection<Log> = get_collection(state, COLLECTION_NAME).await?;
+    log_collection.insert_one(log, None).await?;
+    Ok(())
+}

http-server/src/db/collections/notary.rs

@@ -32,3 +32,9 @@ pub async fn find(state: web::Data<Mutex<Client>>) -> Result<Vec<Notary>> {
     }
     Ok(ret)
 }
+
+pub async fn insert(state: web::Data<Mutex<Client>>, notary: Notary) -> Result<()> {
+    let notary_collection: Collection<Notary> = get_collection(state, COLLECTION_NAME).await?;
+    notary_collection.insert_one(notary, None).await?;
+    Ok(())
+}

http-server/src/db/collections/rkh.rs

@@ -30,3 +30,9 @@ pub async fn find(state: web::Data<Mutex<Client>>) -> Result<Vec<RootKeyHolder>>
     }
     Ok(ret)
 }
+
+pub async fn insert(state: web::Data<Mutex<Client>>, rkh: RootKeyHolder) -> Result<()> {
+    let rkh_collection: Collection<RootKeyHolder> = get_collection(state, COLLECTION_NAME).await?;
+    rkh_collection.insert_one(rkh, None).await?;
+    Ok(())
+}

http-server/src/router/logs.rs

@@ -1,17 +1,25 @@
 use crate::db;
-use actix_web::{get, http::header::ContentType, web, HttpResponse};
+use actix_web::{get, http::header::ContentType, web, HttpResponse, post};
 use mongodb::Client;
 use std::sync::Mutex;
 
 #[get("/logs")]
 pub async fn get(db_connection: web::Data<Mutex<Client>>) -> HttpResponse {
-    let items = match db::collections::logs::find(db_connection).await {
-        Ok(items) => items,
-        Err(_) => {
-            return HttpResponse::InternalServerError().finish();
-        }
-    };
-    return HttpResponse::Ok()
-        .content_type(ContentType::json())
-        .body(serde_json::to_string(&items).unwrap());
+    match db::collections::logs::find(db_connection).await {
+        Ok(i) => HttpResponse::Ok()
+            .content_type(ContentType::json())
+            .body(serde_json::to_string(&i).unwrap()),
+        Err(_) => HttpResponse::InternalServerError().finish(),
+    }
+}
+
+#[post("/logs")]
+pub async fn post(
+    db_connection: web::Data<Mutex<Client>>,
+    rkh: web::Json<db::collections::logs::Log>,
+) -> HttpResponse {
+    match db::collections::logs::insert(db_connection, rkh.into_inner()).await {
+        Ok(_) => HttpResponse::Ok().finish(),
+        Err(_) => HttpResponse::InternalServerError().finish(),
+    }
 }

http-server/src/router/notary.rs

@@ -1,17 +1,25 @@
 use crate::db;
-use actix_web::{get, http::header::ContentType, web, HttpResponse};
+use actix_web::{get, http::header::ContentType, web, HttpResponse, post};
 use mongodb::Client;
 use std::sync::Mutex;
 
 #[get("/notary")]
 pub async fn get(db_connection: web::Data<Mutex<Client>>) -> HttpResponse {
-    let items = match db::collections::notary::find(db_connection).await {
-        Ok(items) => items,
-        Err(_) => {
-            return HttpResponse::InternalServerError().finish();
-        }
-    };
-    return HttpResponse::Ok()
-        .content_type(ContentType::json())
-        .body(serde_json::to_string(&items).unwrap());
+    match db::collections::notary::find(db_connection).await {
+        Ok(i) => HttpResponse::Ok()
+            .content_type(ContentType::json())
+            .body(serde_json::to_string(&i).unwrap()),
+        Err(_) => HttpResponse::InternalServerError().finish(),
+    }
+}
+
+#[post("/notary")]
+pub async fn post(
+    db_connection: web::Data<Mutex<Client>>,
+    rkh: web::Json<db::collections::notary::Notary>,
+) -> HttpResponse {
+    match db::collections::notary::insert(db_connection, rkh.into_inner()).await {
+        Ok(_) => HttpResponse::Ok().finish(),
+        Err(_) => HttpResponse::InternalServerError().finish(),
+    }
 }

http-server/src/router/rkh.rs

@@ -1,17 +1,25 @@
 use crate::db;
-use actix_web::{get, http::header::ContentType, web, HttpResponse};
+use actix_web::{get, http::header::ContentType, web, HttpResponse, post};
 use mongodb::Client;
 use std::sync::Mutex;
 
 #[get("/rkh")]
 pub async fn get(db_connection: web::Data<Mutex<Client>>) -> HttpResponse {
-    let items = match db::collections::rkh::find(db_connection).await {
-        Ok(items) => items,
-        Err(_) => {
-            return HttpResponse::InternalServerError().finish();
-        }
-    };
-    return HttpResponse::Ok()
-        .content_type(ContentType::json())
-        .body(serde_json::to_string(&items).unwrap());
+    match db::collections::rkh::find(db_connection).await {
+        Ok(i) => HttpResponse::Ok()
+            .content_type(ContentType::json())
+            .body(serde_json::to_string(&i).unwrap()),
+        Err(_) => HttpResponse::InternalServerError().finish(),
+    }
+}
+
+#[post("/rkh")]
+pub async fn post(
+    db_connection: web::Data<Mutex<Client>>,
+    rkh: web::Json<db::collections::rkh::RootKeyHolder>,
+) -> HttpResponse {
+    match db::collections::rkh::insert(db_connection, rkh.into_inner()).await {
+        Ok(_) => HttpResponse::Ok().finish(),
+        Err(_) => HttpResponse::InternalServerError().finish(),
+    }
 }