post shipments through HTTP

Author: mtanzim

warehouse-client/main.js

@@ -1,14 +1,36 @@
-const BASE_URL = "http://localhost:8082/";
+const BASE_URL = "http://localhost:8082";
 async function fetchData() {
   const res = await fetch(`${BASE_URL}/api/shipment`);
   const shipments = await res.json();
   return shipments;
 }
 
+async function shipCart(cartId) {
+  const res = await fetch(`${BASE_URL}/api/shipment`, {
+    method: "POST",
+    body: JSON.stringify({ cartId }),
+  });
+  if (res.status !== 200) {
+    throw new Error("Something went wrong!");
+  }
+}
+
 function generateBtnId(cartId) {
   return `btn-${cartId}`;
 }
 
+function generateBtnHandler(cartId) {
+  return async () => {
+    try {
+      await shipCart(cartId);
+      main();
+    } catch (err) {
+      console.log(err);
+      alert(err);
+    }
+  };
+}
+
 function renderData(rows) {
   document.getElementById("root").innerHTML = `<div class="grid-container">
 ${rows
@@ -19,11 +41,6 @@ ${rows
       paid,
     } = row;
 
-    // TODO: do this from the backend
-    if (shipped) {
-      return "";
-    }
-
     return `
       <div id=${cartId} class="grid-item">
         <h2><code>${cartId}</code>\t${paid ? "Paid" : "Pending"}</h2>
@@ -35,7 +52,7 @@ ${rows
         <ul>
         ${items
           .map(
-            ({ book, qty }) =>
+            ({ book, Qty: qty }) =>
               `<li>${book.title} - ${book.author} - ${qty}</li>`
           )
           .join("")}
@@ -48,17 +65,17 @@ ${rows
   })
   .join("")}
 </div>`;
+  return Promise.resolve();
 }
 
 function attachBtnHandlers(rows) {
-  const buttonIds = rows.map((row) => {
+  rows.forEach((row) => {
     const {
       cart: { cartId },
     } = row;
-    return generateBtnId(cartId);
-  });
-  buttonIds.forEach((btnId) => {
-    document.getElementById(btnId).onclick = () => alert(`${btnId} Clicked`);
+    const curBtnId = generateBtnId(cartId);
+    const curBtnHandler = generateBtnHandler(cartId);
+    document.getElementById(curBtnId).onclick = curBtnHandler;
   });
 }
 

warehouse-server/dto/shipment.go

@@ -0,0 +1,7 @@
+package dto
+
+import "go.mongodb.org/mongo-driver/bson/primitive"
+
+type PostShipment struct {
+	CartID primitive.ObjectID `bson:"_id,omitempty" json:"cartId"`
+}

warehouse-server/handler/warehouse.go

@@ -5,6 +5,7 @@ import (
 	"log"
 	"net/http"
 
+	localDTO "github.com/mtanzim/event-driven-bookstore/warehouse-server/dto"
 	service "github.com/mtanzim/event-driven-bookstore/warehouse-server/service"
 )
 
@@ -26,3 +27,20 @@ func (h ShipmentHandler) GetPendingShipments(w http.ResponseWriter, r *http.Requ
 	}
 	json.NewEncoder(w).Encode(pendingShipments)
 }
+
+func (h ShipmentHandler) PostPendingShipemt(w http.ResponseWriter, r *http.Request) {
+	w.Header().Set("Content-Type", "application/json")
+	var cart localDTO.PostShipment
+	if err := json.NewDecoder(r.Body).Decode(&cart); err != nil {
+		log.Println(err)
+		http.Error(w, "Cannot process shipment", http.StatusBadRequest)
+		return
+	}
+	postedShipment, err := h.service.PostPendingShipemt(&cart)
+	if err != nil {
+		log.Println(err)
+		http.Error(w, "Cannot update shipment", http.StatusInternalServerError)
+		return
+	}
+	json.NewEncoder(w).Encode(postedShipment)
+}

warehouse-server/main.go

@@ -54,6 +54,7 @@ func main() {
 	r := mux.NewRouter()
 	port := os.Getenv("REST_PORT")
 	r.HandleFunc("/api/shipment", shipmentHandler.GetPendingShipments).Methods(http.MethodGet, http.MethodOptions)
+	r.HandleFunc("/api/shipment", shipmentHandler.PostPendingShipemt).Methods(http.MethodPost, http.MethodOptions)
 	r.Use(loggingMiddleware)
 	// TODO: fix this
 	rWithCORS := cors.Default().Handler(r)

warehouse-server/service/shipment.go

@@ -3,10 +3,12 @@ package service
 import (
 	"context"
 	"encoding/json"
+	"errors"
 	"log"
 	"time"
 
 	dto "github.com/mtanzim/event-driven-bookstore/common-server/dto"
+	localDTO "github.com/mtanzim/event-driven-bookstore/warehouse-server/dto"
 	"go.mongodb.org/mongo-driver/bson"
 	"go.mongodb.org/mongo-driver/mongo"
 	"gopkg.in/confluentinc/confluent-kafka-go.v1/kafka"
@@ -26,7 +28,8 @@ func (s ShipmentService) GetPendingShipments() ([]dto.CartWarehouse, error) {
 	defer cancel()
 
 	var data []dto.CartWarehouse
-	cursor, err := s.collection.Find(ctx, bson.M{}, nil)
+	filter := bson.M{"shipped": false}
+	cursor, err := s.collection.Find(ctx, filter, nil)
 	if err != nil {
 		return nil, err
 
@@ -38,6 +41,25 @@ func (s ShipmentService) GetPendingShipments() ([]dto.CartWarehouse, error) {
 
 }
 
+func (s ShipmentService) PostPendingShipemt(cart *localDTO.PostShipment) (*localDTO.PostShipment, error) {
+	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
+	defer cancel()
+
+	filter := bson.M{"_id": cart.CartID}
+	update := bson.D{{"$set", bson.D{{"shipped", true}}}}
+
+	updateRes, updateErr := s.collection.UpdateOne(ctx, filter, update)
+	if updateErr != nil {
+		return nil, updateErr
+	}
+	if updateRes.ModifiedCount == 1 || updateRes.UpsertedCount == 1 {
+		log.Println("Successfully shipped cart:", cart.CartID)
+		return cart, nil
+	}
+	return nil, errors.New("Something went wrong.")
+
+}
+
 func (s ShipmentService) ConsumeMessages() {
 	// TODO: is this idiomatic :/
 	s.warehouseService.ConsumeMessages(s.processShipmentRequest)