fourth commit

Author: andersoncgiusti

src/adapters/controllers/UserController.ts

@@ -0,0 +1,30 @@
+import { Application, Request, Response } from 'express'
+import { UserService } from '../../services/UserService'
+import { UserPresenter } from '../presenters/UserPresenter'
+
+export default (app: Application, userService: UserService) => {
+  app.get('/api/users/:id', async (req: Request, res: Response) => {
+    const { id } = req.params
+    try {
+      const user = await userService.getUserById(Number(id))
+      if (!user) {
+        return res.status(404).json({ error: 'User not found' })
+      }
+      res.json(UserPresenter.toResponse(user))
+    } catch (error) {
+      res.status(500).json({ error: 'Internal Server Error' })
+    }
+  })
+
+  app.get('/api/users', async (req: Request, res: Response) => {
+    try {
+      const users = await userService.getUsers()
+      if (!users || users.length === 0) {
+        return res.status(404).json({ error: 'No users found' })
+      }
+      res.json(UserPresenter.toResponseArray(users))
+    } catch (error) {
+      res.status(500).json({ error: 'Internal Server Error' })
+    }
+  })
+}

src/adapters/controllers/index.ts

@@ -1,16 +1,17 @@
 import { Application } from 'express'
 import { readdirSync } from 'fs'
 import { join } from 'path'
+import { IUserRepository } from '../repositories/UserRepository'
 
-export default (app: Application) => {
+export default (app: Application, userRepository: IUserRepository) => {
   const controllersPath = __dirname
 
   readdirSync(controllersPath)
     .filter((file) => file.endsWith('.ts') && file !== 'index.ts')
     .forEach(async (file) => {
       const controller = await import(join(controllersPath, file))
       if (typeof controller.default === 'function') {
-        controller.default(app)
+        controller.default(app, userRepository)
       }
     })
 }

src/adapters/presenters/UserPresenter.ts

@@ -0,0 +1,14 @@
+import { User } from '../../entities/User'
+
+export class UserPresenter {
+  static toResponse(user: User): User {
+    return {
+      id: user.id,
+      name: user.name
+    }
+  }
+
+  static toResponseArray(users: User[]): User[] {
+    return users.map((user) => this.toResponse(user))
+  }
+}

src/adapters/repositories/UserRepository.ts

@@ -0,0 +1,20 @@
+import { User } from '../../entities/User'
+
+const users: User[] = [
+  { id: 1, name: 'John Doe' },
+  { id: 2, name: 'Jane Smith' }
+]
+
+export interface IUserRepository {
+  getUsers(): User[]
+}
+
+export class UserRepository implements IUserRepository {
+  getUsers(): User[] {
+    return users
+  }
+
+  getUserById(userId: number): User | null {
+    return users.find((user) => user.id === userId) || null
+  }
+}

src/entities/User.ts

@@ -0,0 +1,4 @@
+export interface User {
+  id: number
+  name: string
+}

src/frameworks/express/server.ts

@@ -3,13 +3,13 @@ import cors from 'cors'
 import swaggerUi from 'swagger-ui-express'
 import specs from '../../swagger'
 import registerControllers from '../../adapters/controllers'
+import { UserRepository } from '../../adapters/repositories/UserRepository'
 
 const app: Application = express()
+const userRepository = new UserRepository()
 
 app.use(cors())
-
 app.use(express.json())
-
 app.use('/api-docs', swaggerUi.serve, swaggerUi.setup(specs))
 
 /**
@@ -38,6 +38,6 @@ app.get('/health/ping', (req: Request, res: Response) => {
   res.json({ success: true, message: 'Check OK' })
 })
 
-registerControllers(app)
+registerControllers(app, userRepository)
 
 export default app

src/services/UserService.ts

@@ -0,0 +1,16 @@
+import { User } from '../entities/User'
+import { GetUserUseCase } from '../useCases/getUser/GetUserUseCase'
+import { IGetUserRepository } from '../useCases/getUser/IGetUserRepository'
+
+export class UserService {
+  constructor(private readonly getUserRepository: IGetUserRepository) {}
+
+  async getUserById(userId: number): Promise<User | null> {
+    const getUserUseCase = new GetUserUseCase(this.getUserRepository)
+    return getUserUseCase.execute(userId)
+  }
+
+  async getUsers(): Promise<User[] | null> {
+    return this.getUserRepository.getUsers()
+  }
+}

src/useCases/createUser/CreateUserController.ts

@@ -0,0 +1,10 @@
+import { User } from '../../entities/User'
+import { IGetUserRepository } from './IGetUserRepository'
+
+export class GetUserController {
+  constructor(private readonly userRepository: IGetUserRepository) {}
+
+  async execute(): Promise<User[]> {
+    return this.userRepository.getUsers()
+  }
+}

src/useCases/getUser/GetUserController.ts

@@ -0,0 +1,27 @@
+import { Application, Request, Response } from 'express'
+import { UserRepository } from '../../adapters/repositories/UserRepository'
+import { UserPresenter } from '../../adapters/presenters/UserPresenter'
+
+export default (app: Application, userRepository: UserRepository) => {
+  app.get('/api/users/:id', async (req: Request, res: Response) => {
+    const { id } = req.params
+    try {
+      const user = await userRepository.getUserById(Number(id))
+      if (!user) {
+        return res.status(404).json({ error: 'User not found' })
+      }
+      res.json(UserPresenter.toResponse(user))
+    } catch (error) {
+      res.status(500).json({ error: 'Internal Server Error' })
+    }
+  })
+
+  app.get('/api/users', async (req: Request, res: Response) => {
+    try {
+      const users = userRepository.getUsers()
+      res.json(UserPresenter.toResponseArray(users))
+    } catch (error) {
+      res.status(500).json({ error: 'Internal Server Error' })
+    }
+  })
+}

src/useCases/getUser/GetUserUseCase.ts

@@ -0,0 +1,10 @@
+import { User } from '../../entities/User'
+import { IGetUserRepository } from './IGetUserRepository'
+
+export class GetUserUseCase {
+  constructor(private readonly userRepository: IGetUserRepository) {}
+
+  async execute(userId: number): Promise<User | null> {
+    return this.userRepository.getUserById(userId)
+  }
+}