Added source code files

Author: Manoj85

src/app.ts

@@ -0,0 +1,32 @@
+import express from "express";
+import { env } from "config/env";
+import Controller from "interfaces/controller.interface";
+
+class App {
+  private app: express.Application;
+
+  constructor(controllers: Controller[]) {
+    this.app = express();
+
+    this.initializeMiddlewares();
+    this.initializeControllers(controllers);
+  }
+
+  private initializeMiddlewares() {
+    this.app.use(express.json());
+  }
+
+  private initializeControllers(controllers: Controller[]) {
+    controllers.forEach((controller) => {
+      this.app.use("/api/v1", controller.router);
+    });
+  }
+
+  public listen() {
+    this.app.listen(env.PORT, () => {
+      console.log(`App listening on the port ${env.PORT}`);
+    });
+  }
+}
+
+export default App;

src/config/database.ts

@@ -0,0 +1,13 @@
+import { Pool } from "pg";
+import { env } from "./env";
+
+const pool = new Pool({
+  host: env.POSTGRES_HOST,
+  user: env.POSTGRES_USER,
+  password: env.POSTGRES_PASSWORD,
+  database: env.POSTGRES_DB,
+  port: env.POSTGRES_PORT,
+  idleTimeoutMillis: 30000,
+});
+
+export default pool;

src/config/env.ts

@@ -0,0 +1,14 @@
+import { config } from "dotenv";
+import { cleanEnv, port, str } from "envalid";
+
+config();
+
+export const env = cleanEnv(process.env, {
+  POSTGRES_USER: str(),
+  POSTGRES_PASSWORD: str(),
+  POSTGRES_HOST: str(),
+  POSTGRES_PORT: port({ default: 5432 }),
+  POSTGRES_DB: str(),
+
+  PORT: port({ default: 5000 }),
+});

src/interfaces/controller.interface.ts

@@ -0,0 +1,8 @@
+import { Router } from "express";
+
+interface Controller {
+  path: string;
+  router: Router;
+}
+
+export default Controller;

src/server.ts

@@ -0,0 +1,5 @@
+import App from "./app";
+import UsersController from "users/users.controller";
+
+const app = new App([new UsersController()]);
+app.listen();

src/users/users.controller.ts

@@ -0,0 +1,50 @@
+import pool from "config/database";
+import { Router, Request, Response, NextFunction } from "express";
+
+class UsersController {
+  public path = "/users";
+  public router = Router();
+
+  constructor() {
+    this.initializeRoutes();
+  }
+
+  public initializeRoutes() {
+    this.router.get(this.path, this.getUsers);
+    this.router.post(this.path, this.createUser);
+  }
+
+  private createUser = async (
+    request: Request,
+    response: Response,
+    next: NextFunction
+  ) => {
+    const { username, email } = request.body;
+    try {
+      const insertUser =
+        "INSERT INTO users (username, email) VALUES ($1, $2) RETURNING *";
+      const result = await pool.query(insertUser, [username, email]);
+
+      const createdUser = result.rows[0];
+      return response.json(createdUser);
+    } catch (err) {
+      next(err);
+    }
+  };
+
+  private getUsers = async (
+    _: Request,
+    response: Response,
+    next: NextFunction
+  ) => {
+    try {
+      const result = await pool.query("SELECT id, username, email FROM users");
+      const users = result.rows;
+      return response.json(users);
+    } catch (err) {
+      next(err);
+    }
+  };
+}
+
+export default UsersController;