Refactoring: Add product post method

1 files changed, 18 insertions, 1 deletions

diff --git a/src/db/product.rs b/src/db/product.rs
index 0fc8f05..5b58560 100644
--- a/src/db/product.rs
+++ b/src/db/product.rs
@@ -1,6 +1,7 @@
 use std::collections::HashMap;
+use std::time::SystemTime;
 
-use sqlx::SqlitePool;
+use sqlx::{Sqlite, SqlitePool, Transaction};
 
 use crate::error::AppError;
 
@@ -15,6 +16,22 @@ pub struct Product {
     pub updatedate: i64,
 }
 
+impl Product {
+    pub async fn post(tx: &mut Transaction<'static, Sqlite>, name: String, description: String) -> Result<Product, AppError> {
+        let now = SystemTime::now().duration_since(std::time::UNIX_EPOCH)?.as_millis() as i64;
+        let product = sqlx::query_as!(
+            Product, 
+            "INSERT INTO product (name, description, uploaddate, updatedate) VALUES ($1, $2, $3, $4) RETURNING id, name, description, uploaddate, updatedate", 
+            name, 
+            description,
+            now,
+            now)
+            .fetch_one(&mut **tx)
+            .await?;
+        Ok(product)
+    }
+}
+
 pub trait ProductMarker {
     fn product_id(&self) -> i64;
 }