From 1dc484b1c901da11451b50f66c80fc723a28ed7b Mon Sep 17 00:00:00 2001
From: eraden <adrian.wozniak@ita-prog.pl>
Date: Tue, 15 Nov 2022 20:53:02 +0100
Subject: [PATCH] Create variant

---
 crates/channels/src/stocks/product_variant.rs |  2 +-
 .../src/actions/product_variant.rs            | 50 +++++++++++++++++--
 2 files changed, 47 insertions(+), 5 deletions(-)

diff --git a/crates/channels/src/stocks/product_variant.rs b/crates/channels/src/stocks/product_variant.rs
index e9a0ff3..91a16ea 100644
--- a/crates/channels/src/stocks/product_variant.rs
+++ b/crates/channels/src/stocks/product_variant.rs
@@ -6,7 +6,7 @@ pub mod create_product_variant {
     #[derive(Debug, serde::Serialize, serde::Deserialize)]
     pub struct Input {
         pub product_id: ProductId,
-        pub name: ProductName,
+        pub name: ProductVariantName,
         pub short_description: ProductShortDesc,
         pub long_description: ProductLongDesc,
         pub price: Price,
diff --git a/crates/stock_manager/src/actions/product_variant.rs b/crates/stock_manager/src/actions/product_variant.rs
index c0caf6b..7476a20 100644
--- a/crates/stock_manager/src/actions/product_variant.rs
+++ b/crates/stock_manager/src/actions/product_variant.rs
@@ -1,16 +1,58 @@
-use channels::stocks::{create_product_variant, delete_product_variant, update_product_variant};
+use channels::stocks::{
+    create_product_variant, delete_product_variant, update_product_variant, Error,
+};
 use channels::AsyncClient;
 use config::SharedAppConfig;
+use db_utils::PgT;
 
+use crate::begin_t;
 use crate::db::Database;
 
 pub async fn create_product_variant(
-    _input: create_product_variant::Input,
-    _db: Database,
+    input: create_product_variant::Input,
+    db: Database,
     _mqtt: AsyncClient,
     _config: SharedAppConfig,
 ) -> create_product_variant::Output {
-    todo!()
+    let mut t = begin_t!(db, Error::InternalServerError);
+    match inner_create_product_variant(input, &mut t).await {
+        Ok(res) => {
+            if let Err(e) = t.commit().await {
+                tracing::error!("{}", e);
+                return Err(Error::InternalServerError);
+            }
+            Ok(res)
+        }
+        Err(e) => {
+            t.rollback().await.map_err(|e| {
+                tracing::error!("{}", e);
+                Error::InternalServerError
+            })?;
+            Err(e)
+        }
+    }
+}
+
+async fn inner_create_product_variant(
+    input: create_product_variant::Input,
+    t: &mut PgT<'_>,
+) -> create_product_variant::Output {
+    let dbm = crate::db::CreateProductVariant {
+        product_id: input.product_id,
+        name: input.name,
+        short_description: input.short_description,
+        long_description: input.long_description,
+        price: input.price,
+    };
+    match dbm.run(t).await {
+        Ok(variant) => Ok(create_product_variant::Details {
+            product_variant: variant,
+        }),
+        Err(e) => {
+            tracing::error!("{}", e);
+            Err(Error::CreateProductVariant(input.product_id))
+        }
+    }
 }
 
 pub async fn update_product_variant(