chore: remove database folder of gitignore

docker-compose.yml

@@ -34,7 +34,6 @@ services:
       context: .
       target: development
       dockerfile: Dockerfile
-    restart: always
     volumes:
       - './src/:/usr/app/src/'
       - './assets/:/usr/app/assets/'

package.json

@@ -28,7 +28,7 @@
     "typescript": "~5.1"
   },
   "scripts": {
-    "dev": "yarn --env-file=.env nodemon",
+    "dev": "yarn --env-file=.env nodemon --legacy-watch",
     "docker:up": "docker compose --env-file .env up -d --build --force-recreate app_dev",
     "docker:migrate": "docker compose --env-file .env exec app_dev yarn prisma migrate reset",
     "start": "node build/src/main.js",

prisma/seed.ts

@@ -9,14 +9,17 @@ import {
 } from '@/modules/beer/application/event/created-beer'
 import { FindCategoryHandlerImpl } from '@/modules/beer/application/query/find-category'
 import { CreateBeerSqlRepository } from '@/modules/beer/infra/repository/sql/create-beer'
+import { mongoService } from '@/modules/core/database/nosql/mongo-service'
+import { BeerModel } from '@/modules/core/database/nosql/schema'
+import { env } from '@/modules/core/env'
 import { eventBus } from '@/modules/core/event-bus'
 import { PrismaClient } from '@prisma/client'
 import { randomUUID } from 'crypto'
 const prisma = new PrismaClient()
 
 console.log('Seeding...')
 
-const eventHandler = new CreatedBeerHandlerImpl()
+const eventHandler = new CreatedBeerHandlerImpl(BeerModel)
 
 eventBus.subscribe(CreatedBeerEvent, (event) => eventHandler.execute(event))
 
@@ -84,8 +87,14 @@ async function saveBeer() {
 }
 
 async function main() {
+	await mongoService.connect(env.MONGO_URL)
+	await mongoService.dropCollection('beers')
 	await saveBeer()
 	console.log('Seeding finished!')
+
+	setTimeout(() => {
+		process.exit(0)
+	}, 1000)
 }
 
 main()

src/index.ts

@@ -2,10 +2,11 @@ import 'module-alias/register'
 
 import { beerRouter } from './modules/beer/router'
 import { app } from './modules/core/api/http/express'
-import { connect } from './modules/core/db/nosql/connection'
+import { mongoService } from './modules/core/database/nosql/mongo-service'
+import { env } from './modules/core/env'
 import { orderRouter } from './modules/order/router'
 
-connect()
+mongoService.connect(env.MONGO_URL)
 
 app.use('/beer', beerRouter)
 

src/modules/beer/application/event/created-beer.ts

@@ -1,10 +1,11 @@
-import { BeerModel } from '@/modules/core/db/nosql/schema'
+import { BeerModel } from '@/modules/core/database/nosql/schema'
 import { BaseEvent } from '@/modules/core/event-bus'
 
 type Data = {
 	id: string
 	name: string
 	description: string
+	price: number
 	imageUrl: string
 	abv: number
 	ibu: number
@@ -33,6 +34,8 @@ export interface CreatedBeerHandler {
 }
 
 export class CreatedBeerHandlerImpl implements CreatedBeerHandler {
+	constructor(private readonly beerModel: typeof BeerModel) {}
+
 	count = 0
 	async execute(event: CreatedBeerEvent): Promise<void> {
 		const { data } = event
@@ -41,7 +44,7 @@ export class CreatedBeerHandlerImpl implements CreatedBeerHandler {
 
 		console.log('CreatedBeerHandlerImpl', ++this.count)
 
-		const beer = new BeerModel(data)
+		const beer = new this.beerModel(data)
 
 		await beer.save()
 	}

src/modules/beer/application/query/find-beer.ts

@@ -1,4 +1,4 @@
-import { BeerModel } from '@/modules/core/db/nosql/schema'
+import { BeerModel } from '@/modules/core/database/nosql/schema'
 import { NotFoundError } from '@/modules/core/errors/not-found'
 
 export class FindBeerQuery {

src/modules/beer/application/query/list-beer.ts

@@ -1,4 +1,4 @@
-import { BeerModel } from '@/modules/core/db/nosql/schema'
+import { BeerModel } from '@/modules/core/database/nosql/schema'
 import { Pagination } from '../../../core/querying/pagination'
 
 export class ListBeerQuery {

src/modules/beer/domain/aggregate/beer.ts

@@ -52,6 +52,7 @@ export class Beer {
 			id: this.id,
 			name: this.name,
 			description: this.description,
+			price: this.price,
 			imageUrl: this.imageUrl,
 			abv: this.abv.getValue(),
 			ibu: this.ibu.getValue(),

src/modules/beer/presentation/controller/__test__/list-beer.spec.ts

@@ -27,6 +27,8 @@ describe('ListBeerControllerImpl', () => {
 				page: 1,
 				limit: 10,
 			},
+			body: undefined,
+			params: undefined,
 		}
 
 		const response = {
@@ -89,6 +91,8 @@ describe('ListBeerControllerImpl', () => {
 			query: {
 				page: -10,
 			},
+			body: undefined,
+			params: undefined,
 		}
 
 		const result = await sut.execute(request)

src/modules/beer/router.ts

@@ -1,5 +1,5 @@
 import { Request, Response, Router } from 'express'
-import { BeerModel } from '../core/db/nosql/schema'
+import { BeerModel } from '../core/database/nosql/schema'
 import { FindBeerHandlerImpl } from './application/query/find-beer'
 import { ListBeerHandlerImpl } from './application/query/list-beer'
 import { FindBeerControllerImpl } from './presentation/controller/find-beer'

src/modules/core/database/nosql/mongo-service.ts

@@ -0,0 +1,28 @@
+import mongoose, { Collection } from 'mongoose'
+
+export class MongoService {
+	client: mongoose.Mongoose
+
+	async connect(uri: string): Promise<void> {
+		this.client = await mongoose.connect(uri, {})
+	}
+
+	async disconnect(): Promise<void> {
+		await this.client.disconnect()
+	}
+
+	async isConnected() {
+		const state = this.client.connection.readyState
+		return state === 1
+	}
+
+	getCollection(name: string): Collection {
+		return this.client.connection.collection(name)
+	}
+
+	dropCollection(name: string): Promise<void> {
+		return this.client.connection.dropCollection(name)
+	}
+}
+
+export const mongoService = new MongoService()

src/modules/core/database/nosql/protocols/no-sql-service.ts

@@ -0,0 +1,17 @@
+export interface NoSqlService {
+	connect(): Promise<void>
+	disconnect(): Promise<void>
+	isConnected(): Promise<boolean>
+	getCollection(name: string): Promise<Collection>
+}
+
+export interface Collection {
+	insertOne(data: any): Promise<any>
+	insertMany(data: any[]): Promise<any>
+	findOne(data: any): Promise<any>
+	findMany(data: any): Promise<any>
+	updateOne(data: any): Promise<any>
+	updateMany(data: any): Promise<any>
+	deleteOne(data: any): Promise<any>
+	deleteMany(data: any): Promise<any>
+}

src/modules/core/database/nosql/schema.ts

@@ -0,0 +1,76 @@
+import mongoose, { Schema } from 'mongoose'
+
+const beerSchema = new Schema({
+	id: {
+		type: String,
+		unique: true,
+		required: true,
+	},
+	name: {
+		type: String,
+		required: true,
+	},
+	description: {
+		type: String,
+		required: true,
+	},
+	imageUrl: {
+		type: String,
+		required: true,
+	},
+	price: {
+		type: Number,
+		required: true,
+	},
+	abv: {
+		type: Number,
+		required: true,
+	},
+	ibu: {
+		type: Number,
+		required: true,
+	},
+	ebc: {
+		type: Number,
+		required: true,
+	},
+	category: {
+		type: {
+			id: {
+				type: String,
+				required: true,
+			},
+			name: {
+				type: String,
+				required: true,
+			},
+			createdAt: {
+				type: Date,
+				required: true,
+			},
+			updatedAt: {
+				type: Date,
+				required: true,
+			},
+		},
+		required: true,
+	},
+	foodPairing: {
+		type: [String],
+		required: true,
+	},
+	brewersTips: {
+		type: String,
+		required: true,
+	},
+	createdAt: {
+		type: Date,
+		required: true,
+	},
+	updatedAt: {
+		type: Date,
+		required: true,
+	},
+})
+
+export const BeerModel = mongoose.model('Beer', beerSchema)

src/modules/core/database/sql/prisma-client.ts

@@ -0,0 +1,3 @@
+import { PrismaClient } from '@prisma/client'
+
+export const prismaClient = new PrismaClient()

src/modules/order/router.ts

@@ -1,6 +1,6 @@
 import { Request, Router } from 'express'
 import { FindBeerSqlRepository } from '../beer/infra/repository/sql/find-beer'
-import { prismaClient } from '../core/db/sql/prisma-client'
+import { prismaClient } from '../core/database/sql/prisma-client'
 import { CreateOrderHandlerImpl } from './application/command/create-order'
 import { CreateOrderSqlRepository } from './infra/repository/sql/create-order'
 import { CreateOrderControllerImpl } from './presentation/controller/create-order'