add products

Author: mateogalic112

package.json

@@ -28,6 +28,7 @@
     "zod": "^3.23.8"
   },
   "devDependencies": {
+    "@faker-js/faker": "^9.3.0",
     "@types/bcrypt": "^5.0.2",
     "@types/cookie-parser": "^1.4.7",
     "@types/cors": "^2.8.17",

src/db/seed.ts

@@ -1,14 +1,21 @@
 import pool from "config/database";
 import bcrypt from "bcrypt";
 import { initializeDatabase } from "./setup";
+import { RegisterPayload } from "auth/auth.validation";
+import { CreateProductPayload } from "products/products.validation";
+import { faker } from "@faker-js/faker";
 
-const seedData = [
-  {
-    username: "Mateo",
-    email: "[email protected]",
-    password: "123456"
-  }
-];
+const users: RegisterPayload[] = Array.from({ length: 2 }, () => ({
+  username: faker.internet.displayName(),
+  email: faker.internet.email(),
+  password: "123456"
+}));
+
+const products: CreateProductPayload[] = Array.from({ length: 2 }, () => ({
+  name: faker.commerce.productName(),
+  description: faker.commerce.productDescription(),
+  price: +faker.commerce.price({ min: 100, max: 10000, dec: 0 })
+}));
 
 export async function seedDatabase() {
   await initializeDatabase();
@@ -19,15 +26,24 @@ export async function seedDatabase() {
 
     // Clear the users table
     await client.query("TRUNCATE TABLE users RESTART IDENTITY CASCADE");
+    await client.query("TRUNCATE TABLE products RESTART IDENTITY CASCADE");
 
-    for (const { username, email, password } of seedData) {
+    for (const { username, email, password } of users) {
       const hashedPassword = await bcrypt.hash(password, 10);
       await client.query(`INSERT INTO users (username, email, password) VALUES ($1, $2, $3)`, [
         username,
         email,
         hashedPassword
       ]);
     }
+
+    for (const { name, description, price } of products) {
+      await client.query(`INSERT INTO products (name, description, price) VALUES ($1, $2, $3)`, [
+        name,
+        description,
+        price
+      ]);
+    }
     await client.query("COMMIT");
   } catch (error) {
     await client.query("ROLLBACK");

src/db/setup.ts

@@ -11,6 +11,18 @@ async function createTables() {
           updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
           );
       `);
+
+  // Price is in cents to avoid floating point arithmetic issues
+  await pool.query(`
+        CREATE TABLE IF NOT EXISTS products (
+          id SERIAL PRIMARY KEY,
+          name VARCHAR(100),
+          description TEXT,
+          price INT,
+          created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+          updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+          );
+    `);
 }
 
 // Run the table creation and seeding process

src/interfaces/db.interface.ts

@@ -0,0 +1,5 @@
+export interface DBModel {
+  id: number;
+  created_at: Date;
+  updated_at: Date;
+}

src/products/products.controller.ts

@@ -0,0 +1,21 @@
+import { Controller } from "interfaces/controller.interface";
+import { ProductService } from "./products.service";
+import { Request, Response } from "express";
+
+export class ProductController extends Controller {
+  private productService = new ProductService();
+
+  constructor() {
+    super("/products");
+    this.initializeRoutes();
+  }
+
+  protected initializeRoutes() {
+    this.router.get(`${this.path}`, this.getProducts);
+  }
+
+  private getProducts = async (_request: Request, response: Response) => {
+    const products = await this.productService.getProducts();
+    response.json({ data: products });
+  };
+}

src/products/products.model.ts

@@ -0,0 +1,4 @@
+import { CreateProductPayload } from "./products.validation";
+import { DBModel } from "interfaces/db.interface";
+
+export interface Product extends DBModel, CreateProductPayload {}

src/products/products.repository.ts

@@ -0,0 +1,9 @@
+import pool from "config/database";
+import { Product } from "./products.model";
+
+export class ProductRepository {
+  public async getProducts() {
+    const result = await pool.query<Product[]>("SELECT id, name, description, price FROM products");
+    return result.rows;
+  }
+}

src/products/products.service.ts

@@ -0,0 +1,9 @@
+import { ProductRepository } from "./products.repository";
+
+export class ProductService {
+  private productRepository = new ProductRepository();
+
+  public async getProducts() {
+    return this.productRepository.getProducts();
+  }
+}

src/products/products.validation.ts

@@ -0,0 +1,11 @@
+import { z } from "zod";
+
+export const createProductSchema = z.object({
+  body: z.object({
+    name: z.string().min(3),
+    description: z.string().min(10),
+    price: z.number().int().positive()
+  })
+});
+
+export type CreateProductPayload = z.infer<typeof createProductSchema>["body"];

src/server.ts

@@ -1,6 +1,7 @@
 import { AuthController } from "auth/auth.controller";
 import App from "./app";
 import UsersController from "users/users.controller";
+import { ProductController } from "products/products.controller";
 
-const app = new App([new AuthController(), new UsersController()]);
+const app = new App([new AuthController(), new ProductController(), new UsersController()]);
 app.listen();

src/users/users.controller.ts

@@ -12,6 +12,7 @@ class UsersController extends Controller {
     this.router.get(this.path, this.getUsers);
   }
 
+  // TODO: For testing purposes only. Remove this in production.
   private getUsers = async (_: Request, response: Response, next: NextFunction) => {
     try {
       const result = await pool.query("SELECT id, username, email FROM users");

src/users/users.model.ts

@@ -1,6 +1,4 @@
 import { RegisterPayload } from "auth/auth.validation";
+import { DBModel } from "interfaces/db.interface";
 
-export interface User extends RegisterPayload {
-  id: number;
-  created_at: Date;
-}
+export interface User extends DBModel, RegisterPayload {}

yarn.lock

@@ -180,6 +180,11 @@
   dependencies:
     levn "^0.4.1"
 
+"@faker-js/faker@^9.3.0":
+  version "9.3.0"
+  resolved "https://registry.yarnpkg.com/@faker-js/faker/-/faker-9.3.0.tgz#ef398dab34c67faaa0e348318c905eae3564fa58"
+  integrity sha512-r0tJ3ZOkMd9xsu3VRfqlFR6cz0V/jFYRswAIpC+m/DIfAUXq7g8N7wTAlhSANySXYGKzGryfDXwtwsY8TxEIDw==
+
 "@humanfs/core@^0.19.0":
   version "0.19.0"
   resolved "https://registry.yarnpkg.com/@humanfs/core/-/core-0.19.0.tgz#08db7a8c73bb07673d9ebd925f2dad746411fcec"