Add Repo Service Route

database/data.json

@@ -0,0 +1 @@
+[{"id":10,"name":"Batman","age":"50","power":"rich"},{"id":2,"name":"Chapolin"}]

package.json

@@ -6,7 +6,7 @@
   "type": "module",
   "scripts": {
     "start": "node src/index.js",
-    "test": "echo \"Error: no test specified\" && exit 1"
+    "test": "node --test tests/"
   },
   "keywords": [],
   "author": "",

src/entities/hero.js

@@ -0,0 +1,10 @@
+import { randomUUID } from "node:crypto";
+
+export default class Hero {
+    constructor({ name, age, power }) {
+        this.id = randomUUID()
+        this.name = name
+        this.age = age
+        this.power = power
+    }
+}

src/factories/heroFactory.js

@@ -0,0 +1,21 @@
+import HeroRepository from "../repositories/heroRepository.js"
+import HeroService from "../services/heroService.js"
+
+const generateInstance = ({
+    filePath
+}) => {
+    //hero goeas all db connections
+    const heroRepository = new HeroRepository({
+        file: filePath
+    })
+
+    const heroService = new HeroService({
+        heroRepository
+    })
+
+    return heroService
+}
+
+export {
+    generateInstance
+}

src/handler.js

@@ -1,13 +1,31 @@
-import path from 'node:path'
-import { parse } from 'node:url'
+import {
+    join,
+    dirname
+} from 'node:path'
+
+import { parse, fileURLToPath } from 'node:url'
+import { generateInstance } from './factories/heroFactory.js'
+import { routes } from './routes/heroRoute.js'
 import { DEFAULT_HEADER } from './utils/utils.js'
 
+const currentDir = dirname(
+    fileURLToPath(
+        import.meta.url
+    )
+)
+
+const filePath = join(currentDir, './database', 'data.json')
+
+const heroService = generateInstance({
+    filePath
+})
+
+const heroRoutes = routes({
+    heroService
+})
 
 const allRoutes = {
-    '/heroes:get': async (req, res) => {
-        res.write('GET')
-        res.end()
-    },
+    ...heroRoutes,
     //404 Routes
     default: (req, res) => {
         res.writeHead(404, DEFAULT_HEADER)

src/repositories/heroRepository.js

@@ -0,0 +1,45 @@
+import { readFile, writeFile } from "node:fs/promises"
+
+export default class HeroRepository {
+    constructor({
+        file
+    }) {
+        this.file = file
+    }
+
+    async #currentiFileContent() {
+        return JSON.parse(await readFile(this.file))
+    }
+
+    find() {
+        return this.#currentiFileContent()
+    }
+
+    async create(data) {
+        const currentFile = await this.#currentiFileContent()
+        currentFile.push(data)
+
+        await writeFile(
+            this.file,
+            JSON.stringify(currentFile)
+        )
+
+        return data.id
+    }
+}
+/*
+const heroRepository = new HeroRepository({
+    file: 'database/data.json'
+})
+
+console.log(
+    await heroRepository.create({
+        id: 2,
+        name: 'Chapolin'
+    })
+)
+
+console.log(
+    await heroRepository.find()
+)
+*/

src/routes/heroRoute.js

@@ -0,0 +1,32 @@
+import { once } from "node:events";
+import Hero from "../entities/hero.js";
+import { DEFAULT_HEADER } from "../utils/utils.js";
+
+const routes = ({
+    heroService
+}) => ({
+    '/heroes:get': async (req, res) => {
+        res.write('GET')
+        res.end()
+    },
+
+    '/heroes:post': async (req, res) => {
+        const data = await once(req, 'data');
+        const item = JSON.parse(data)
+
+        const hero = new Hero(item)
+
+        const id = await heroService.create(hero)
+
+        res.writeHead(201, DEFAULT_HEADER)
+        res.write(JSON.stringify({
+            id,
+            success: 'User created with success',
+        }))
+        return res.end()
+    },
+})
+
+export {
+    routes
+}

src/services/heroService.js

@@ -0,0 +1,15 @@
+export default class HeroService {
+    constructor({
+        heroRepository
+    }) {
+        this.heroRepository = heroRepository
+    }
+
+    find() {
+        return this.heroRepository.find()
+    }
+
+    create(data) {
+        return this.heroRepository.create(data)
+    }
+}

tests/integration/hero.test.js

@@ -0,0 +1,51 @@
+import test from 'node:test'
+import assert from 'node:assert'
+import { promisify } from 'node:util'
+
+
+test('Hero Integration Test Suite', async (t) => {
+    const testPort = 9009
+
+    process.env.PORT = testPort
+    const { server } = await import('../../src/index.js')
+
+    const testServerAddress = `http://localhost:${testPort}/heroes`
+
+    await t.test('it should create a hero', async (t) => {
+        const data = {
+            "name": "Batman",
+            "age": "50",
+            "power": "rich"
+        }
+
+        const request = await fetch(testServerAddress, {
+            method: 'POST',
+            body: JSON.stringify(data)
+        })
+
+
+        assert.deepStrictEqual(
+            request.headers.get('content-type'),
+            'application/json'
+        )
+
+        assert.strictEqual(request.status, 201)
+
+        const result = await request.json()
+
+        assert.deepStrictEqual(
+            result.success,
+            'User created with success',
+            'it should return a valid text message'
+        )
+
+        assert.ok(
+            result.id.length > 30,
+            'id should be a valid uuid'
+        )
+    })
+
+    //Promisify convert callback to promise
+    await promisify(server.close.bind(server))
+
+})