Thomas API Express Database

src/routers/base.controller.js

@@ -0,0 +1,71 @@
+const db = require('../../db')
+
+class BaseController {
+    constructor(tableName) {
+        this.tableName = tableName
+    }
+
+    async getAll(req, res, next) {
+        try {
+            const response = await db.query(
+                `
+                SELECT * FROM ${this.tableName}
+                `
+            )
+            const items = response.rows
+
+            res.json({ [this.tableName]: items })
+        } catch (err) {
+            next(new Error(`Could not get ${this.tableName}: `, err))
+        }
+    }
+
+    async getById(req, res, next) {
+        const id = parseInt(req.params.id)
+
+        try {
+            const response = await db.query(
+                `
+                SELECT * FROM ${this.tableName} WHERE id = $1
+                `,
+                [id]
+            )
+            const [item] = response.rows
+
+            res.json({ [this.tableName.slice(0, -1)]: item })
+        } catch (err) {
+            next(
+                new Error(
+                    `Could not get item from ${this.tableName} with id ${id}:`,
+                    err
+                )
+            )
+        }
+    }
+
+    async delete(req, res, next) {
+        const id = parseInt(req.params.id)
+
+        try {
+            const response = await db.query(
+                `
+                DELETE FROM ${this.tableName} WHERE id = $1
+                returning *
+                `,
+                [id]
+            )
+            const [item] = response.rows
+
+            res.status(201).json({ [this.tableName.slice(0, -1)]: item })
+        } catch (err) {
+            next(
+                new Error(
+                    `Could not delete ${this.tableName} with id ${id}:`,
+                    err
+                )
+            )
+        }
+    }
+}
+
+module.exports = BaseController

src/routers/books.controller.js

@@ -0,0 +1,50 @@
+const db = require('../../db')
+const BaseController = require('./base.controller')
+
+class BooksController extends BaseController {
+    constructor() {
+        super('books')
+    }
+
+    async addBook(req, res, next) {
+        const { title, type, author, topic, publication_date, pages } = req.body
+
+        try {
+            const response = await db.query(
+                `
+                INSERT INTO books (title, type, author, topic, publication_date, pages)
+                VALUES ($1, $2, $3, $4, $5, $6)
+                returning *
+                `,
+                [title, type, author, topic, publication_date, pages]
+            )
+            const [book] = response.rows
+
+            res.status(201).json({ book: book })
+        } catch (err) {
+            next(new Error('Could not add book: ', err))
+        }
+    }
+
+    async updateBook(req, res, next) {
+        const { title, type, author, topic, publication_date, pages } = req.body
+
+        try {
+            const response = await db.query(
+                `
+                INSERT INTO books (title, type, author, topic, publication_date, pages)
+                VALUES ($1, $2, $3, $4, $5, $6)
+                returning *
+                `,
+                [title, type, author, topic, publication_date, pages]
+            )
+            const [book] = response.rows
+
+            res.status(201).json({ book: book })
+        } catch (err) {
+            next(new Error('Could not add book: ', err))
+        }
+    }
+}
+
+module.exports = BooksController

src/routers/books.js

@@ -1,9 +1,13 @@
 const express = require('express')
 const router = express.Router()
-const db = require("../../db");
 
-router.get('/', async (req, res) => {
+const BooksController = require('./books.controller')
+const booksController = new BooksController()
 
-})
+router.post('/', booksController.addBook.bind(booksController))
+router.get('/', booksController.getAll.bind(booksController))
+router.get('/:id', booksController.getById.bind(booksController))
+router.put('/:id', booksController.updateBook.bind(booksController))
+router.delete('/:id', booksController.delete.bind(booksController))
 
 module.exports = router

src/routers/pets.controller.js

@@ -0,0 +1,52 @@
+const db = require('../../db')
+const BaseController = require('./base.controller')
+
+class PetsController extends BaseController {
+    constructor() {
+        super('pets')
+    }
+
+    async addPet(req, res, next) {
+        const { name, age, type, breed, has_microchip } = req.body
+
+        try {
+            const response = await db.query(
+                `
+                INSERT INTO pets (name, age, type, breed, has_microchip)
+                VALUES ($1, $2, $3, $4, $5)
+                returning *
+                `,
+                [name, age, type, breed, has_microchip]
+            )
+            const [pet] = response.rows
+
+            res.status(201).json({ pet: pet })
+        } catch (err) {
+            next(new Error('Could not add pet: ', err))
+        }
+    }
+
+    async updatePet(req, res, next) {
+        const id = parseInt(req.params.id)
+        const { name, age, type, breed, has_microchip } = req.body
+
+        try {
+            const response = await db.query(
+                `
+                UPDATE pets
+                SET name = $1, age = $2, type = $3, breed = $4, has_microchip = $5
+                WHERE id = $6
+                returning *
+                `,
+                [name, age, type, breed, has_microchip, id]
+            )
+            const [pet] = response.rows
+
+            res.status(201).json({ pet })
+        } catch (err) {
+            next(new Error(`Could not update pet with id ${id}: `, err))
+        }
+    }
+}
+
+module.exports = PetsController

src/routers/pets.js

@@ -0,0 +1,13 @@
+const express = require('express')
+const router = express.Router()
+
+const PetsController = require('./pets.controller')
+const petsController = new PetsController()
+
+router.post('/', petsController.addPet.bind(petsController))
+router.get('/', petsController.getAll.bind(petsController))
+router.get('/:id', petsController.getById.bind(petsController))
+router.put('/:id', petsController.updatePet.bind(petsController))
+router.delete('/:id', petsController.delete.bind(petsController))
+
+module.exports = router

src/server.js

@@ -1,16 +1,18 @@
-const express = require("express");
-const morgan = require("morgan");
-const cors = require("cors");
+const express = require('express')
+const morgan = require('morgan')
+const cors = require('cors')
 
-const app = express();
+const app = express()
 
-app.use(morgan("dev"));
-app.use(cors());
-app.use(express.json());
+app.use(morgan('dev'))
+app.use(cors())
+app.use(express.json())
 
 //TODO: Implement books and pets APIs using Express Modular Routers
 const booksRouter = require('./routers/books.js')
+const petsRouter = require('./routers/pets.js')
 
 app.use('/books', booksRouter)
+app.use('/pets', petsRouter)
 
 module.exports = app