7 files changed, 138 insertions, 1 deletions

diff --git a/src/handlers/cart_items.rs b/src/handlers/cart_items.rs
new file mode 100644
index 0000000..62cab75
--- /dev/null
+++ b/src/handlers/cart_items.rs
@@ -0,0 +1,111 @@
+use crate::models::{AddCartItem, CartItem, Customer, Product};
+use crate::schema::product::dsl as prod;
+use crate::schema::{cart_items::dsl::*, customer::dsl::*};
+use crate::TPool;
+
+use actix_identity::Identity;
+use actix_web::{web, HttpResponse, Responder};
+use diesel::prelude::*;
+use log::{error, info};
+use serde::Deserialize;
+
+#[derive(Deserialize, Debug)]
+pub struct AddToCart {
+    product_id: i32,
+}
+
+pub async fn add_to_cart(
+    cookie: Identity,
+    item_details: web::Json<AddToCart>,
+    pool: web::Data<TPool>,
+) -> impl Responder {
+    info!("Add to cart hit: {:?}", item_details.product_id);
+    let conn = pool.get().unwrap();
+    if let Some(uname) = cookie.identity() {
+        let selected_user = customer
+            .filter(username.eq(&uname))
+            .limit(1)
+            .first::<Customer>(&conn)
+            .expect("Couldn't connect to DB");
+        let new_cart_item = AddCartItem {
+            cart_id: selected_user.id,
+            product_id: item_details.product_id,
+        };
+        diesel::insert_into(cart_items)
+            .values(new_cart_item)
+            .execute(&conn)
+            .expect("Coundn't connect to DB");
+        HttpResponse::Ok().body("Inserted successfully!")
+    } else {
+        error!("Unauthorized add to cart action!");
+        return HttpResponse::Unauthorized()
+            .body("Need to be logged in to add to cart!");
+    }
+}
+
+#[derive(Deserialize, Debug)]
+pub struct RemoveFromCart {
+    product_id: i32,
+}
+
+pub async fn remove_from_cart(
+    cookie: Identity,
+    item_details: web::Json<RemoveFromCart>,
+    pool: web::Data<TPool>,
+) -> impl Responder {
+    info!("Remove from cart hit: {:?}", item_details.product_id);
+    let conn = pool.get().unwrap();
+    if let Some(uname) = cookie.identity() {
+        let selected_user = customer
+            .filter(username.eq(&uname))
+            .limit(1)
+            .first::<Customer>(&conn)
+            .expect("Couldn't connect to DB");
+
+        diesel::delete(
+            cart_items
+                .filter(cart_id.eq(selected_user.id))
+                .filter(product_id.eq(item_details.product_id)),
+        )
+        .execute(&conn)
+        .expect("Coundn't connect to DB");
+        HttpResponse::Ok().body("Removed successfully!")
+    } else {
+        error!("Unauthorized add to cart action!");
+        return HttpResponse::Unauthorized()
+            .body("Need to be logged in to add to cart!");
+    }
+}
+
+pub async fn get_user_cart_items(
+    cookie: Identity,
+    pool: web::Data<TPool>,
+) -> impl Responder {
+    let conn = pool.get().unwrap();
+    if let Some(uname) = cookie.identity() {
+        let selected_user = customer
+            .filter(username.eq(&uname))
+            .limit(1)
+            .first::<Customer>(&conn)
+            .expect("Couldn't connect to DB");
+        let user_cart_items = cart_items
+            .filter(cart_id.eq(selected_user.id))
+            .load::<CartItem>(&conn)
+            .expect("Couldn't connect to DB");
+        let cart_products = user_cart_items
+            .into_iter()
+            .map(|item| {
+                prod::product
+                    .filter(prod::id.eq(item.product_id))
+                    .limit(1)
+                    .first::<Product>(&conn)
+                    .expect("Couldn't connect to db")
+            })
+            .collect::<Vec<_>>();
+        return HttpResponse::Ok()
+            .body(serde_json::to_string(&cart_products).unwrap());
+    } else {
+        return HttpResponse::Unauthorized()
+            .body("Need to be logged in to add to cart!");
+    }
+}
diff --git a/tests/json_data/chair.json b/tests/product/chair.json
index bb13c8b..bb13c8b 100644
--- a/tests/json_data/chair.json
+++ b/tests/product/chair.json
diff --git a/tests/json_data/dumb_sofa.json b/tests/product/dumb_sofa.json
index 2b09a58..2b09a58 100644
--- a/tests/json_data/dumb_sofa.json
+++ b/tests/product/dumb_sofa.json
diff --git a/tests/json_data/smart_sofa.json b/tests/product/smart_sofa.json
index 5d7f7d4..5d7f7d4 100644
--- a/tests/json_data/smart_sofa.json
+++ b/tests/product/smart_sofa.json
diff --git a/tests/requests.txt b/tests/requests.txt
new file mode 100644
index 0000000..7e38905
--- /dev/null
+++ b/tests/requests.txt
@@ -0,0 +1,17 @@
+http POST :7878/user/login username=akshay password=password
+
+http POST :7878/user/login username=akshay password=nigga
+
+http POST :7878/user/change_password Cookie:user-login=mKT3PRPSKJp/AdsfPCXg3GICmQW2wViUwUKPpsXKp+70ug== old_password=nigga new_password=nigga
+
+http :7878/user/change_password username=akshay password=password
+
+http :7878/product/catalog
+
+http :7878/product/1
+
+http POST :7878/cart/add Cookie:user-login=mKT3PRPSKJp/AdsfPCXg3GICmQW2wViUwUKPpsXKp+70ug== product_id:=1
+
+http :7878/cart/items Cookie:user-login=mKT3PRPSKJp/AdsfPCXg3GICmQW2wViUwUKPpsXKp+70ug==
+
+http POST :7878/cart/remove Cookie: product_id:=1
diff --git a/tests/users/add_akshay.json b/tests/users/add_akshay.json
new file mode 100644
index 0000000..1d6c405
--- /dev/null
+++ b/tests/users/add_akshay.json
@@ -0,0 +1,8 @@
+
+{
+    "username": "Akshay",
+    "password": "akshay",
+    "phone_number": "123454234",
+    "email_id": "[email protected]",
+    "address": "Rv College of Engineering, Mysuru Road, 560087, Near Metro station"
+}
diff --git a/tests/json_data/add_user.json b/tests/users/add_user.json
index c7b2c15..1f481e9 100644
--- a/tests/json_data/add_user.json
+++ b/tests/users/add_user.json
@@ -2,5 +2,6 @@
     "username": "Ramu Kaka",
     "password": "ramu123",
     "phone_number": "123454234",
-    "email_id": "[email protected]"
+    "email_id": "[email protected]",
+    "address": "RA-602, Purva Riviera"
 }