WM5 | AHMADZAY BAHADORY | MODULE DATABASE | E-COMMERCE-API | WEEK 4

E-Commerce-API/.babelrc

@@ -0,0 +1,3 @@
+{
+  "presets": ["@babel/preset-env"]
+}

E-Commerce-API/app.js

@@ -1,8 +1,153 @@
-const express = require("express");
+import express from "express";
+import bodyParser from "body-parser";
+import "dotenv/config";
+import pg from "pg";
+
 const app = express();
-// Your code to run the server should go here
-// Don't hardcode your DB password in the code or upload it to GitHub! Never ever do this ever.
-// Use environment variables instead:
-// https://www.codementor.io/@parthibakumarmurugesan/what-is-env-how-to-set-up-and-run-a-env-file-in-node-1pnyxw9yxj
+const port = process.env.SERVER_PORT;
+app.use(bodyParser.json());
+
+const { Pool } = pg;
+const db = new Pool({
+  connectionString: process.env.DATABASE_URL,
+});
+
+app.get("/products", async (req, res) => {
+  try {
+    const result = await db.query(
+      "SELECT pro.product_name, sup.supplier_name, pa.unit_price FROM products pro JOIN suppliers sup ON pro.id = sup.id JOIN product_availability pa ON pa.supp_id = sup.id"
+    );
+
+    res.send(result.rows);
+  } catch (error) {
+    console.error(error);
+    res.status(500).json({ error: "Internal server error" });
+  }
+});
+
+// //get by name
+app.get("/products/:name", (req, res) => {
+  let productName = req.params.name;
+  productName = productName.replace(/-/g, " ");
+  db.query(
+    "SELECT pro.product_name, sup.supplier_name, pa.unit_price FROM products pro JOIN suppliers sup ON pro.id = sup.id JOIN product_availability pa ON pa.supp_id = sup.id WHERE lower(pro.product_name) LIKE $1 || '%'",
+    [productName.toLowerCase()]
+  ).then((result) => res.json(result.rows));
+});
+
+// //get customers by id
+app.get("/customers/:id", function (req, res) {
+  const custId = parseInt(req.params.id);
+  db.query("SELECT * FROM customers WHERE id = $1", [custId])
+    .then((result) => {
+      res.status(200).json(result.rows);
+    })
+    .catch((error) => {
+      console.log(error);
+      res.status(500).json({
+        error: {
+          message: "internal server error",
+          type: "database error",
+        },
+      });
+    });
+});
+
+// //post customers
+app.post("/customers", (req, res) => {
+  const name = req.body.name;
+  const address = req.body.address;
+  const city = req.body.city;
+  const country = req.body.country;
+  const query = `INSERT INTO customers(name, address, city, country)VALUES($1,$2,$3,$4)`;
+  db.query(query, [name, address, city, country])
+    .then(() => {
+      res
+        .status(201)
+        .send({ message: "created a new customer was successfully !" });
+    })
+    .catch((error) => {
+      console.log(error);
+      res.status(500).json({
+        error: {
+          message: "internal server error",
+          type: "database error",
+        },
+      });
+    });
+});
+
+// //post product
+app.post("/products", (req, res) => {
+  const productName = req.body.product_name;
+  const query = `INSERT INTO products(product_name)VALUES($1)`;
+  db.query(query, [productName])
+    .then(() => {
+      res
+        .status(201)
+        .send({ message: "created a new product was successfully !" });
+    })
+    .catch((error) => {
+      console.log(error);
+      res.status(500).json({
+        error: {
+          message: "internal server error",
+          type: "database error",
+        },
+      });
+    });
+});
+
+//post
+//to be continue for nex
+app.post("/availability", (req, res) => {
+  // Extracting data from request body
+  const { prod_id, unit_price, supp_id } = req.body;
+
+  // Checking if unit_price is a positive integer
+  if (!Number.isInteger(unit_price) || unit_price <= 0) {
+    return res.status(400).json({
+      error: {
+        message: "Unit price must be a positive integer.",
+        type: "validation error",
+      },
+    });
+  }
+
+  // Checking if supp_id is provided
+  if (!supp_id) {
+    return res.status(400).json({
+      error: {
+        message: "Supplier ID is required.",
+        type: "validation error",
+      },
+    });
+  }
+
+  // Inserting into the database
+  const query =
+    "INSERT INTO product_availability(prod_id,unit_price, supp_id) VALUES($1, $2,$3)";
+  db.query(query, [prod_id, unit_price, supp_id])
+    .then(() => {
+      res.status(201).json({
+        message: "New product availability was successfully created!",
+      });
+    })
+    .catch((error) => {
+      console.error(error);
+      res.status(500).json({
+        error: {
+          message: "Internal server error.",
+          type: "database error",
+        },
+      });
+    });
+});
+
+if (process.env.NODE_ENV !== "test") {
+  app.listen(port, () => {
+    console.log(`server listening on port ${port} !`);
+  });
+}
 
-module.exports = app;
+export default app;

E-Commerce-API/customers.spec.js

@@ -0,0 +1,34 @@
+import request from "supertest";
+import app from "../E-Commerce-API/app";
+
+describe("GET /customers/:id", () => {
+  it("should load a single customer by their ID", async () => {
+    const customerId = 3;
+    const response = await request(app).get(`/customers/${customerId}`);
+    expect(response.status).toBe(200);
+    expect(response.body) === expect.any(Array);
+    response.body.forEach((product) => {
+      expect(product).toEqual(
+        expect.objectContaining({
+          id: expect.any(Number),
+        })
+      );
+    });
+  });
+});
+
+describe("post /customers", () => {
+  it("should create a new customer with name, address, city, and country", async () => {
+    const customerData = {
+      name: "marcus",
+      address: "solihull 12",
+      city: "shirley",
+      country: "UK",
+    };
+    const response = await request(app).post(`/customers`).send(customerData);
+    expect(response.status).toBe(201);
+    expect(response.body).toEqual({
+      message: "created a new customer was successfully !",
+    });
+  });
+});