restServer.ts

import { IDatabase, IServer } from "../interfaces";
import express from "express";
import cors from "cors";
import morgan from "morgan";
import bodyParser from "body-parser";
import { AllProductsRequest, Order, OrderRequest, ProductRequest, UserPatchRequest, UserRequest } from "../types";

export default class RestServer implements IServer {

  db: IDatabase;
  server: any;

  constructor(db: IDatabase) {
    this.db = db;
    this.server = express();
  }

  start() {
    const port = 3000;
    this.server.use(cors());
    this.server.use(morgan("tiny"));
    this.server.use(bodyParser.json());

    this.server.get("/", (req: express.Request, res: express.Response) => res.send("Hello, World!"));

    this.server.get("/product/:productId", async (req: express.Request, res: express.Response) => {
      const { productId } = (req.params as ProductRequest);
      if (!productId) {
        res.status(400).send("No product id provided");
        return;
      }
      const product = await this.db.queryProductById(productId);
      res.send(product);
    }); // Gets a product by product id

    this.server.get("/randomproduct", async (req: express.Request, res: express.Response) => {
      const randProd = await this.db.queryRandomProduct();
      res.send(randProd);
    }); // I'm feeling lucky type

    this.server.get("/products", async (req: express.Request, res: express.Response) => {
      const { categoryId } = (req.query as AllProductsRequest);
      const products = await this.db.queryAllProducts(categoryId);
      res.send(products);
    }); // Gets all products, or by category

    this.server.get("/categories", async (req: express.Request, res: express.Response) => {
      const categories = await this.db.queryAllCategories();
      res.send(categories);
    }); // Gets all categories

    this.server.get("/allorders", async (req: express.Request, res: express.Response) => {
      const orders = await this.db.queryAllOrders();
      res.send(orders);
    }); // Gets all orders

    this.server.get("/orders", async (req: express.Request, res: express.Response) => {
      const { id } = (req.query as UserRequest);
      if (!id) {
        res.status(400).send("No user id provided");
        return;
      }
      const orders = await this.db.queryOrdersByUser(id);
      res.send(orders);
    }); // Gets all of a single user's orders

    this.server.get("/order/:id", async (req: express.Request, res: express.Response) => {
      const { id } = (req.params as OrderRequest);
      if (!id) {
        res.status(400).send("No order id provided");
        return;
      }
      const order = await this.db.queryOrderById(id);
      res.send(order);
    }); // Gets more details on a specific order by id

    this.server.get("/user/:id", async (req: express.Request, res: express.Response) => {
      const { id } = (req.params as UserRequest);
      if (!id) {
        res.status(400).send("No user id provided");
        return;
      }
      const user = await this.db.queryUserById(id);
      res.send(user);
    }); // Gets details on a specific user by username

    this.server.get("/users", async (_req: express.Request, res: express.Response) => {
      const users = await this.db.queryAllUsers();
      res.send(users);
    });// Gets all users

    this.server.post("/orders", async (req: express.Request, res: express.Response) => {
      const order = (req.body as Order);
      const response = await this.db.insertOrder(order);
      res.send(response);
    }); // Creates a new order

    this.server.patch("/user/:id", async (req: express.Request, res: express.Response) => {
      const updates = req.body;
      const userId = (req.params as UserRequest).id;
      const patch: UserPatchRequest = {
        ...updates,
        id: userId,
      }
      const response = await this.db.updateUser(patch);
      res.send(response);
    }); // Updates a user's email or password

    this.server.listen(port, () => {
      console.log(`REST server listening on port ${port}`);
    });
  }
}