- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 -58 -59 -60 -61 -62 -63 -64 -65 -66 -67 -68 -69 -70 -71 -72 -73 -74 -75 -76 -77 -78 -79 -80 -81 -82 -83 -84 -85 -86 -87 -88 -89 -90 -91 -92 -93 -94 -95 -96 -97 -98 -99 -100 -101 -102 -103 -104 | - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | const RegisterUserCommand = require('../../application/auth/commands/RegisterUserCommand'); -const LoginUserCommand = require('../../application/auth/commands/LoginUserCommand'); - -/** - * Auth Controller - * Authentication endpoints using CQRS Commands with cookie-based JWT - */ -class AuthController { - constructor(registerUserCommandHandler, loginUserCommandHandler, jwtService) { - this.registerUserCommandHandler = registerUserCommandHandler; - this.loginUserCommandHandler = loginUserCommandHandler; - this.jwtService = jwtService; - } - - /** - * POST /api/auth/register - User regisztráció - */ - async register(req, res) { - try { - const { name, email, password } = req.body; - - const command = new RegisterUserCommand(name, email, password); - const result = await this.registerUserCommandHandler.handle(command); - - // Set JWT token in httpOnly cookie - res.cookie( - this.jwtService.getCookieName(), - result.token, - this.jwtService.getCookieOptions() - ); - - res.status(201).json({ - message: 'User registered successfully', - data: { - user: result.user - } - }); - } catch (error) { - // Validációs hibák -> 400 - const status = error.message.includes('required') || - error.message.includes('already exists') || - error.message.includes('Invalid') || - error.message.includes('must be') ? 400 : 500; - - res.status(status).json({ error: error.message }); - } - } - - /** - * POST /api/auth/login - User bejelentkezés - */ - async login(req, res) { - try { - const { email, password } = req.body; - - const command = new LoginUserCommand(email, password); - const result = await this.loginUserCommandHandler.handle(command); - - // Set JWT token in httpOnly cookie - res.cookie( - this.jwtService.getCookieName(), - result.token, - this.jwtService.getCookieOptions() - ); - - res.status(200).json({ - message: 'Login successful', - data: { - user: result.user - } - }); - } catch (error) { - // Validációs vagy auth hibák -> 401 - const status = error.message.includes('Invalid') || - error.message.includes('required') ? 401 : 500; - - res.status(status).json({ error: error.message }); - } - } - - /** - * POST /api/auth/logout - User kijelentkezés - */ - async logout(req, res) { - try { - // Clear the auth cookie - res.clearCookie(this.jwtService.getCookieName(), { - httpOnly: true, - secure: process.env.NODE_ENV === 'production', - sameSite: 'strict', - path: '/' - }); - - res.status(200).json({ - message: 'Logout successful' - }); - } catch (error) { - res.status(500).json({ error: error.message }); - } - } -} - -module.exports = AuthController; - |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 -58 -59 -60 -61 -62 -63 -64 -65 -66 -67 -68 -69 -70 -71 -72 -73 -74 -75 -76 -77 -78 -79 -80 -81 -82 -83 -84 -85 -86 -87 -88 -89 -90 -91 -92 -93 -94 -95 -96 -97 -98 -99 -100 -101 -102 -103 -104 -105 | - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | const GetMeQuery = require('../../application/user/queries/GetMeQuery'); -const GetAllUsersQuery = require('../../application/user/queries/GetAllUsersQuery'); -const GetUserByIdQuery = require('../../application/user/queries/GetUserByIdQuery'); -const UpdateUserProfileCommand = require('../../application/user/commands/UpdateUserProfileCommand'); - -/** - * User Controller - * User-related endpoints using CQRS pattern (protected by JWT) - */ -class UserController { - constructor(getMeQueryHandler, getAllUsersQueryHandler, getUserByIdQueryHandler, updateUserProfileCommandHandler) { - this.getMeQueryHandler = getMeQueryHandler; - this.getAllUsersQueryHandler = getAllUsersQueryHandler; - this.getUserByIdQueryHandler = getUserByIdQueryHandler; - this.updateUserProfileCommandHandler = updateUserProfileCommandHandler; - } - - /** - * GET /api/users/me - Bejelentkezett user adatai (protected) - */ - async getMe(req, res) { - try { - // req.user-t az authMiddleware tölti ki a JWT-ből - const userId = req.user.userId; - - const query = new GetMeQuery(userId); - const user = await this.getMeQueryHandler.handle(query); - - res.status(200).json({ - message: 'User retrieved successfully', - data: user - }); - } catch (error) { - const status = error.message.includes('not found') ? 404 : 500; - res.status(status).json({ error: error.message }); - } - } - - /** - * GET /api/users - Összes user lekérése (protected) - */ - async getAll(req, res) { - try { - const query = new GetAllUsersQuery(); - const users = await this.getAllUsersQueryHandler.handle(query); - - res.status(200).json({ - message: 'Users retrieved successfully', - data: users, - count: users.length - }); - } catch (error) { - res.status(500).json({ error: error.message }); - } - } - - /** - * GET /api/users/:id - User lekérése ID alapján (protected) - */ - async getById(req, res) { - try { - const { id } = req.params; - const userId = parseInt(id); - - if (isNaN(userId)) { - return res.status(400).json({ error: 'Invalid user ID' }); - } - - const query = new GetUserByIdQuery(userId); - const user = await this.getUserByIdQueryHandler.handle(query); - - res.status(200).json({ - message: 'User retrieved successfully', - data: user - }); - } catch (error) { - const status = error.message.includes('not found') ? 404 : 500; - res.status(status).json({ error: error.message }); - } - } - - /** - * PUT /api/users/me - User profil frissítése (protected) - */ - async updateMe(req, res) { - try { - const userId = req.user.userId; - const { name } = req.body; - - const command = new UpdateUserProfileCommand(userId, name); - const user = await this.updateUserProfileCommandHandler.handle(command); - - res.status(200).json({ - message: 'Profile updated successfully', - data: user - }); - } catch (error) { - const status = error.message.includes('required') ? 400 : 500; - res.status(status).json({ error: error.message }); - } - } -} - -module.exports = UserController; - |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| AuthController.js | -
-
- |
- 0% | -0/26 | -0% | -0/10 | -0% | -0/4 | -0% | -0/26 | -
| UserController.js | -
-
- |
- 0% | -0/39 | -0% | -0/8 | -0% | -0/5 | -0% | -0/39 | -
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 | - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | const JwtService = require('../../application/services/JwtService'); - -const jwtService = new JwtService(); - -/** - * Authentication Middleware - JWT token ellenőrzés (Cookie-based) - * - * Ezt a middleware-t használd protected route-okon! - * - * Példa használat: - * router.get('/me', authMiddleware, userController.getMe); - */ -function authMiddleware(req, res, next) { - try { - // 1. Token kinyerése cookieból - const token = jwtService.extractTokenFromCookies(req.cookies); - - if (!token) { - return res.status(401).json({ - error: 'Authentication required', - message: 'No token provided in cookies' - }); - } - - // 2. Token verifikálása - const decoded = jwtService.verifyToken(token); - - // 3. User adatok elhelyezése req.user-ben (controller-ek használhatják) - req.user = { - userId: decoded.userId, - email: decoded.email - }; - - // 4. Folytatás - next(); - } catch (error) { - return res.status(401).json({ - error: 'Authentication failed', - message: error.message - }); - } -} - -module.exports = authMiddleware; - |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 | - - - - - - - - - - - - - - - - - - - - - - | const cors = require('cors'); - -// Engedélyezett origin-ek whitelist (környezeti változóból) -const allowedOrigins = process.env.ALLOWED_ORIGINS?.split(',') || ['http://localhost:3000']; - -const corsOptions = { - origin: function (origin, callback) { - // TODO 1: Ha nincs origin (pl. Postman, curl, backend-backend hívás), engedélyezd - // Tipp: if (!origin) return callback(null, true); - - // TODO 2: Ha az origin benne van az allowedOrigins-ban, engedélyezd - // Tipp: if (allowedOrigins.includes(origin)) return callback(null, true); - - // TODO 3: Egyébként tiltsd le CORS hibával - // Tipp: callback(new Error('Not allowed by CORS')); - }, - credentials: true, // Cookie/Auth header engedélyezése - methods: ['GET', 'POST', 'PUT', 'DELETE', 'OPTIONS'], - allowedHeaders: ['Content-Type', 'Authorization'] -}; - -module.exports = cors(corsOptions); - |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| authMiddleware.js | -
-
- |
- 0% | -0/11 | -0% | -0/2 | -0% | -0/1 | -0% | -0/11 | -
| corsMiddleware.js | -
-
- |
- 0% | -0/4 | -0% | -0/2 | -0% | -0/1 | -0% | -0/4 | -
| scopeMiddleware.js | -
-
- |
- 0% | -0/2 | -100% | -0/0 | -0% | -0/2 | -0% | -0/2 | -
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 | - - - - - - - - - - - - - - - - - - | /** - * Request szintű DI scope létrehozása - * Middleware ami minden kéréshez új DI scope-ot készít - */ -function scopeMiddleware(container) { - return (req, res, next) => { - // TODO 1: Hozz létre request-specifikus scope-ot - // Tipp: const scope = container.createScope(); - - // TODO 2: Tárold el a scope-ot req.scope alatt - // Tipp: req.scope = scope; - - // TODO 3: Hívd meg a next()-et - // Tipp: next(); - }; -} - -module.exports = scopeMiddleware; - |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 | - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | const express = require('express'); - -/** - * Auth Routes - * Public endpoints (nincs JWT védelem) - * - * @param {Container} container - DI Container - */ -function createAuthRoutes(container) { - const router = express.Router(); - - // AuthController lekérése a DI Container-ből - const authController = container.resolve('AuthController'); - - /** - * POST /api/auth/register - User regisztráció - * Body: { name, email, password } - * Response: { user, token } - */ - router.post('/register', (req, res) => authController.register(req, res)); - - /** - * POST /api/auth/login - User bejelentkezés - * Body: { email, password } - * Response: { user, token } - */ - router.post('/login', (req, res) => authController.login(req, res)); - - /** - * POST /api/auth/logout - User kijelentkezés - * Clears the authentication cookie - */ - router.post('/logout', (req, res) => authController.logout(req, res)); - - /** - * OPTIONS /api/auth/* - CORS preflight - */ - router.options('*', (req, res) => res.sendStatus(204)); - - return router; -} - -module.exports = createAuthRoutes; - |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| authRoutes.js | -
-
- |
- 0% | -0/13 | -100% | -0/0 | -0% | -0/5 | -0% | -0/9 | -
| userRoutes.js | -
-
- |
- 0% | -0/16 | -100% | -0/0 | -0% | -0/6 | -0% | -0/11 | -
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 | - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | const express = require('express'); -const authMiddleware = require('../middlewares/authMiddleware'); - -/** - * User Routes - * Protected endpoints (JWT authentication required) - * - * @param {Container} container - DI Container - */ -function createUserRoutes(container) { - const router = express.Router(); - - // UserController lekérése a DI Container-ből - const userController = container.resolve('UserController'); - - /** - * GET /api/users/me - Bejelentkezett user adatai - * Headers: Authorization: Bearer <token> - */ - router.get('/me', authMiddleware, (req, res) => userController.getMe(req, res)); - - /** - * PUT /api/users/me - User profil frissítése - * Headers: Authorization: Bearer <token> - * Body: { name } - */ - router.put('/me', authMiddleware, (req, res) => userController.updateMe(req, res)); - - /** - * GET /api/users - Összes user lekérése (protected) - * Headers: Authorization: Bearer <token> - */ - router.get('/', authMiddleware, (req, res) => userController.getAll(req, res)); - - /** - * GET /api/users/:id - User lekérése ID alapján (protected) - * Headers: Authorization: Bearer <token> - */ - router.get('/:id', authMiddleware, (req, res) => userController.getById(req, res)); - - /** - * OPTIONS /api/users/* - CORS preflight - */ - router.options('*', (req, res) => res.sendStatus(204)); - - return router; -} - -module.exports = createUserRoutes; - |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 | - - - - - - - - - - - - | /**
- * Login User Command
- * Command object for user login
- */
-class LoginUserCommand {
- constructor(email, password) {
- this.email = email;
- this.password = password;
- }
-}
-
-module.exports = LoginUserCommand;
- |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 -58 -59 -60 -61 | - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | const bcrypt = require('bcryptjs'); -const JwtService = require('../../services/JwtService'); - -const jwtService = new JwtService(); - -/** - * Login User Command Handler - * Handles user login authentication - */ -class LoginUserCommandHandler { - constructor(prisma) { - this.prisma = prisma; - } - - /** - * Execute login command - * @param {LoginUserCommand} command - * @returns {Promise<Object>} { user, token } - */ - async handle(command) { - const { email, password } = command; - - // Validáció - if (!email || !password) { - throw new Error('Email and password are required'); - } - - // User keresése email alapján - const user = await this.prisma.user.findUnique({ - where: { email } - }); - - if (!user) { - throw new Error('Invalid email or password'); - } - - // Jelszó ellenőrzése - const isPasswordValid = await bcrypt.compare(password, user.password); - - if (!isPasswordValid) { - throw new Error('Invalid email or password'); - } - - // JWT token generálása - const token = jwtService.generateToken({ - userId: user.id, - email: user.email - }); - - // Jelszót ne adjuk vissza - const { password: _, ...userWithoutPassword } = user; - - return { - user: userWithoutPassword, - token - }; - } -} - -module.exports = LoginUserCommandHandler; - |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 | - - - - - - - - - - - - - | /**
- * Register User Command
- * Command object for user registration
- */
-class RegisterUserCommand {
- constructor(name, email, password) {
- this.name = name;
- this.email = email;
- this.password = password;
- }
-}
-
-module.exports = RegisterUserCommand;
- |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 -58 -59 -60 -61 -62 -63 -64 -65 -66 -67 -68 -69 -70 -71 -72 -73 -74 -75 -76 -77 -78 -79 -80 -81 -82 -83 -84 | - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | const bcrypt = require('bcryptjs'); -const JwtService = require('../../services/JwtService'); - -const jwtService = new JwtService(); - -/** - * Register User Command Handler - * Handles user registration business logic - */ -class RegisterUserCommandHandler { - constructor(prisma, emailService) { - this.prisma = prisma; - this.emailService = emailService; - } - - /** - * Execute user registration command - * @param {RegisterUserCommand} command - * @returns {Promise<Object>} { user, token } - */ - async handle(command) { - const { name, email, password } = command; - - // Validáció - if (!name || !email || !password) { - throw new Error('Name, email and password are required'); - } - - if (password.length < 6) { - throw new Error('Password must be at least 6 characters long'); - } - - // Email formátum ellenőrzés - const emailRegex = /^[^\s@]+@[^\s@]+\.[^\s@]+$/; - if (!emailRegex.test(email)) { - throw new Error('Invalid email format'); - } - - // Ellenőrizzük, hogy létezik-e már a user - const existingUser = await this.prisma.user.findUnique({ - where: { email } - }); - - if (existingUser) { - throw new Error('User with this email already exists'); - } - - // Jelszó hashelése (bcrypt) - const hashedPassword = await bcrypt.hash(password, 10); - - // User létrehozása - const user = await this.prisma.user.create({ - data: { - name, - email, - password: hashedPassword - } - }); - - // Welcome email küldése (async, nem várunk rá) - if (this.emailService) { - this.emailService.sendWelcomeEmail(email, name).catch(err => { - console.error('❌ Failed to send welcome email:', err.message); - }); - } - - // JWT token generálása - const token = jwtService.generateToken({ - userId: user.id, - email: user.email - }); - - // Jelszót ne adjuk vissza a response-ban - const { password: _, ...userWithoutPassword } = user; - - return { - user: userWithoutPassword, - token - }; - } -} - -module.exports = RegisterUserCommandHandler; - |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| LoginUserCommand.js | -
-
- |
- 0% | -0/3 | -100% | -0/0 | -0% | -0/1 | -0% | -0/3 | -
| LoginUserCommandHandler.js | -
-
- |
- 0% | -0/17 | -0% | -0/8 | -0% | -0/2 | -0% | -0/17 | -
| RegisterUserCommand.js | -
-
- |
- 0% | -0/4 | -100% | -0/0 | -0% | -0/1 | -0% | -0/4 | -
| RegisterUserCommandHandler.js | -
-
- |
- 0% | -0/25 | -0% | -0/13 | -0% | -0/3 | -0% | -0/25 | -
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 -58 | - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -1x - | /**
- * Dependency Injection Container
- * Supports singleton, transient, and scoped lifetimes
- */
-class Container {
- constructor() {
- // TODO 1: Inicializáld a services Map-et (singleton instance-ok tárolása)
- // TODO 2: Inicializáld a factories Map-et (factory függvények tárolása)
- // TODO 3: Inicializáld a lifetimes Map-et (lifecycle típusok tárolása)
-
- // Példa inicializálás:
- // this.services = new Map();
- // this.factories = new Map();
- // this.lifetimes = new Map();
- }
-
- register(name, factory, lifetime = 'singleton') {
- // TODO 4: Tárold el a factory függvényt (this.factories.set(name, factory))
- // TODO 5: Tárold el a lifetime típust (this.lifetimes.set(name, lifetime))
- // TODO 6: Ha a lifetime === 'singleton', azonnal példányosítsd:
- // - Hívd meg a factory-t: const instance = factory();
- // - Tárold el: this.services.set(name, instance);
- }
-
- resolve(name, scope = null) {
- // TODO 7: Ha a service regisztrálva van mint 'scoped' ÉS van scope paraméter:
- // - Ellenőrizd: if (scope && scope.has(name)) return scope.get(name);
- // - Ha nincs még a scope-ban, példányosítsd és tárold:
- // const instance = this.factories.get(name)();
- // scope.set(name, instance);
- // return instance;
-
- // TODO 8: Ha singleton, add vissza a services-ből:
- // if (this.lifetimes.get(name) === 'singleton') {
- // return this.services.get(name);
- // }
-
- // TODO 9: Ha transient, minden alkalommal hívj egy új factory-t:
- // if (this.lifetimes.get(name) === 'transient') {
- // return this.factories.get(name)();
- // }
-
- // TODO 10: Ha nem regisztrált a service, dobj hibát:
- // throw new Error(`Service '${name}' is not registered`);
- }
-
- createScope() {
- // TODO 11: Hozz létre egy új Map-et az scoped instance-oknak
- // TODO 12: Térj vissza egy objektummal ami tartalmaz egy resolve metódust:
- // const scopeMap = new Map();
- // return {
- // resolve: (name) => this.resolve(name, scopeMap)
- // };
- }
-}
-
-module.exports = Container;
- |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 | - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | /**
- * Email Service
- * Nodemailer + Handlebars template based email sending
- *
- * TODO: Implement by students
- */
-class EmailService {
- constructor() {
- // TODO 1: Hozz létre Nodemailer transportot Ethereal tesztelő SMTP-vel
- // this.transporter = nodemailer.createTransport({
- // host: 'smtp.ethereal.email',
- // port: 587,
- // secure: false, // TLS
- // auth: {
- // user: process.env.ETHEREAL_USER || 'your-test-email@ethereal.email',
- // pass: process.env.ETHEREAL_PASS || 'your-test-password'
- // }
- // });
-
- console.log('📧 EmailService initialized');
- }
-
- async sendWelcomeEmail(userEmail, userName) {
- // TODO 2-6: Implement email sending with Handlebars template
- // For now, just log to console
- console.log(`📧 Would send welcome email to ${userEmail} (${userName})`);
- return true;
- }
-}
-
-module.exports = EmailService;
- |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 -58 -59 -60 -61 -62 -63 -64 -65 -66 -67 -68 -69 -70 -71 -72 -73 -74 -75 -76 -77 -78 -79 -80 -81 -82 -83 -84 -85 -86 -87 -88 -89 -90 -91 -92 -93 -94 -95 -96 -97 -98 -99 -100 -101 -102 -103 -104 -105 -106 -107 -108 -109 -110 -111 -112 -113 -114 -115 | - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | const jwt = require('jsonwebtoken'); - -/** - * JWT Service - * Handles JWT token generation, verification, and cookie management - */ -class JwtService { - constructor() { - this.secret = process.env.JWT_SECRET || 'default-secret-change-me'; - this.expiresIn = process.env.JWT_EXPIRES_IN || '1h'; - this.cookieName = 'auth_token'; - } - - /** - * Generate JWT token - * @param {Object} payload - { userId, email } - * @returns {string} JWT token - */ - generateToken(payload) { - return jwt.sign(payload, this.secret, { expiresIn: this.expiresIn }); - } - - /** - * Verify JWT token - * @param {string} token - JWT token - * @returns {Object} Decoded payload - */ - verifyToken(token) { - try { - return jwt.verify(token, this.secret); - } catch (error) { - throw new Error('Invalid or expired token'); - } - } - - /** - * Extract token from Authorization header (Bearer token) - * @param {string} authHeader - Authorization header value - * @returns {string|null} Token or null - */ - extractTokenFromHeader(authHeader) { - if (!authHeader) { - return null; - } - - const parts = authHeader.split(' '); - - if (parts.length !== 2 || parts[0] !== 'Bearer') { - return null; - } - - return parts[1]; - } - - /** - * Extract token from cookies - * @param {Object} cookies - Request cookies object - * @returns {string|null} Token or null - */ - extractTokenFromCookies(cookies) { - if (!cookies || !cookies[this.cookieName]) { - return null; - } - - return cookies[this.cookieName]; - } - - /** - * Get cookie options for setting JWT cookie - * @returns {Object} Cookie options - */ - getCookieOptions() { - const isProduction = process.env.NODE_ENV === 'production'; - - return { - httpOnly: true, // Prevents XSS attacks - secure: isProduction, // HTTPS only in production - sameSite: 'strict', // CSRF protection - maxAge: this._getMaxAge(), - path: '/' - }; - } - - /** - * Get cookie max age in milliseconds - * @private - * @returns {number} - */ - _getMaxAge() { - // Parse JWT_EXPIRES_IN (e.g., "1h", "7d") - const expiresIn = this.expiresIn; - - if (expiresIn.endsWith('h')) { - return parseInt(expiresIn) * 60 * 60 * 1000; - } else if (expiresIn.endsWith('d')) { - return parseInt(expiresIn) * 24 * 60 * 60 * 1000; - } else if (expiresIn.endsWith('m')) { - return parseInt(expiresIn) * 60 * 1000; - } - - // Default: 1 hour - return 60 * 60 * 1000; - } - - /** - * Get cookie name - * @returns {string} - */ - getCookieName() { - return this.cookieName; - } -} - -module.exports = JwtService; - |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| Container.js | -
-
- |
- 100% | -1/1 | -100% | -2/2 | -100% | -4/4 | -100% | -1/1 | -
| EmailService.js | -
-
- |
- 0% | -0/4 | -100% | -0/0 | -0% | -0/2 | -0% | -0/4 | -
| JwtService.js | -
-
- |
- 0% | -0/29 | -0% | -0/20 | -0% | -0/8 | -0% | -0/29 | -
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 | - - - - - - - - - - - - | /**
- * Update User Profile Command
- * Command object for updating user profile
- */
-class UpdateUserProfileCommand {
- constructor(userId, name) {
- this.userId = userId;
- this.name = name;
- }
-}
-
-module.exports = UpdateUserProfileCommand;
- |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 | - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | /**
- * Update User Profile Command Handler
- * Handles user profile update logic
- */
-class UpdateUserProfileCommandHandler {
- constructor(prisma) {
- this.prisma = prisma;
- }
-
- /**
- * Execute update profile command
- * @param {UpdateUserProfileCommand} command
- * @returns {Promise<Object>} Updated user data
- */
- async handle(command) {
- const { userId, name } = command;
-
- if (!name) {
- throw new Error('Name is required');
- }
-
- const user = await this.prisma.user.update({
- where: { id: userId },
- data: { name }
- });
-
- const { password, ...userWithoutPassword } = user;
- return userWithoutPassword;
- }
-}
-
-module.exports = UpdateUserProfileCommandHandler;
- |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| UpdateUserProfileCommand.js | -
-
- |
- 0% | -0/3 | -100% | -0/0 | -0% | -0/1 | -0% | -0/3 | -
| UpdateUserProfileCommandHandler.js | -
-
- |
- 0% | -0/8 | -0% | -0/2 | -0% | -0/2 | -0% | -0/8 | -
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 | - - - - - - - - - - - | /**
- * Get All Users Query
- * Query object for retrieving all users
- */
-class GetAllUsersQuery {
- constructor() {
- // No parameters needed for getting all users
- }
-}
-
-module.exports = GetAllUsersQuery;
- |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 | - - - - - - - - - - - - - - - - - - - - - - - - - | /**
- * Get All Users Query Handler
- * Handles retrieval of all users
- */
-class GetAllUsersQueryHandler {
- constructor(prisma) {
- this.prisma = prisma;
- }
-
- /**
- * Execute get all users query
- * @param {GetAllUsersQuery} query
- * @returns {Promise<Array>} List of users without passwords
- */
- async handle(query) {
- const users = await this.prisma.user.findMany({
- orderBy: { createdAt: 'desc' }
- });
-
- // Remove passwords from all users
- return users.map(({ password, ...user }) => user);
- }
-}
-
-module.exports = GetAllUsersQueryHandler;
- |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 | - - - - - - - - - - - | /**
- * Get Me Query
- * Query object for getting current authenticated user
- */
-class GetMeQuery {
- constructor(userId) {
- this.userId = userId;
- }
-}
-
-module.exports = GetMeQuery;
- |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 | - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | /**
- * Get Me Query Handler
- * Handles retrieval of current authenticated user
- */
-class GetMeQueryHandler {
- constructor(prisma) {
- this.prisma = prisma;
- }
-
- /**
- * Execute get me query
- * @param {GetMeQuery} query
- * @returns {Promise<Object>} User data without password
- */
- async handle(query) {
- const { userId } = query;
-
- const user = await this.prisma.user.findUnique({
- where: { id: userId }
- });
-
- if (!user) {
- throw new Error('User not found');
- }
-
- const { password, ...userWithoutPassword } = user;
- return userWithoutPassword;
- }
-}
-
-module.exports = GetMeQueryHandler;
- |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 | - - - - - - - - - - - | /**
- * Get User By ID Query
- * Query object for retrieving a user by ID
- */
-class GetUserByIdQuery {
- constructor(userId) {
- this.userId = userId;
- }
-}
-
-module.exports = GetUserByIdQuery;
- |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 | - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | /**
- * Get User By ID Query Handler
- * Handles retrieval of a specific user by ID
- */
-class GetUserByIdQueryHandler {
- constructor(prisma) {
- this.prisma = prisma;
- }
-
- /**
- * Execute get user by ID query
- * @param {GetUserByIdQuery} query
- * @returns {Promise<Object>} User data without password
- */
- async handle(query) {
- const { userId } = query;
-
- if (!userId || isNaN(userId)) {
- throw new Error('Valid user ID is required');
- }
-
- const user = await this.prisma.user.findUnique({
- where: { id: parseInt(userId) }
- });
-
- if (!user) {
- throw new Error('User not found');
- }
-
- const { password, ...userWithoutPassword } = user;
- return userWithoutPassword;
- }
-}
-
-module.exports = GetUserByIdQueryHandler;
- |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| GetAllUsersQuery.js | -
-
- |
- 0% | -0/1 | -100% | -0/0 | -0% | -0/1 | -0% | -0/1 | -
| GetAllUsersQueryHandler.js | -
-
- |
- 0% | -0/5 | -100% | -0/0 | -0% | -0/3 | -0% | -0/4 | -
| GetMeQuery.js | -
-
- |
- 0% | -0/2 | -100% | -0/0 | -0% | -0/1 | -0% | -0/2 | -
| GetMeQueryHandler.js | -
-
- |
- 0% | -0/8 | -0% | -0/2 | -0% | -0/2 | -0% | -0/8 | -
| GetUserByIdQuery.js | -
-
- |
- 0% | -0/2 | -100% | -0/0 | -0% | -0/1 | -0% | -0/2 | -
| GetUserByIdQueryHandler.js | -
-
- |
- 0% | -0/10 | -0% | -0/6 | -0% | -0/2 | -0% | -0/10 | -
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 -58 -59 -60 -61 | - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | /**
- * User Repository Interface
- * Defines contract for user data access
- */
-class IUserRepository {
- /**
- * Find user by ID
- * @param {number} id
- * @returns {Promise<User|null>}
- */
- async findById(id) {
- throw new Error('Method findById() must be implemented');
- }
-
- /**
- * Find user by email
- * @param {string} email
- * @returns {Promise<User|null>}
- */
- async findByEmail(email) {
- throw new Error('Method findByEmail() must be implemented');
- }
-
- /**
- * Find all users
- * @returns {Promise<User[]>}
- */
- async findAll() {
- throw new Error('Method findAll() must be implemented');
- }
-
- /**
- * Create new user
- * @param {User} user
- * @returns {Promise<User>}
- */
- async create(user) {
- throw new Error('Method create() must be implemented');
- }
-
- /**
- * Update existing user
- * @param {User} user
- * @returns {Promise<User>}
- */
- async update(user) {
- throw new Error('Method update() must be implemented');
- }
-
- /**
- * Delete user by ID
- * @param {number} id
- * @returns {Promise<boolean>}
- */
- async delete(id) {
- throw new Error('Method delete() must be implemented');
- }
-}
-
-module.exports = IUserRepository;
- |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| IUserRepository.js | -
-
- |
- 0% | -0/7 | -100% | -0/0 | -0% | -0/6 | -0% | -0/7 | -
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 -58 -59 -60 -61 -62 -63 -64 -65 -66 -67 -68 -69 -70 -71 -72 -73 -74 -75 -76 -77 | - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | /**
- * User Domain Model
- * Pure domain entity with business logic validation
- */
-class User {
- constructor(id, name, email, password, createdAt, updatedAt) {
- this.id = id;
- this.name = name;
- this.email = email;
- this.password = password;
- this.createdAt = createdAt;
- this.updatedAt = updatedAt;
- }
-
- /**
- * Factory method to create a new User
- * @param {Object} data - { name, email, password }
- * @returns {User}
- */
- static create(data) {
- const { name, email, password } = data;
-
- // Validation
- if (!name || name.trim().length === 0) {
- throw new Error('User name is required');
- }
-
- if (!email || !User.isValidEmail(email)) {
- throw new Error('Valid email is required');
- }
-
- if (!password || password.length < 6) {
- throw new Error('Password must be at least 6 characters long');
- }
-
- return new User(null, name.trim(), email.toLowerCase(), password, new Date(), new Date());
- }
-
- /**
- * Email validation
- * @param {string} email
- * @returns {boolean}
- */
- static isValidEmail(email) {
- const emailRegex = /^[^\s@]+@[^\s@]+\.[^\s@]+$/;
- return emailRegex.test(email);
- }
-
- /**
- * Update user name
- * @param {string} newName
- */
- updateName(newName) {
- if (!newName || newName.trim().length === 0) {
- throw new Error('User name is required');
- }
- this.name = newName.trim();
- this.updatedAt = new Date();
- }
-
- /**
- * Get user without sensitive data
- * @returns {Object}
- */
- toPublicJSON() {
- return {
- id: this.id,
- name: this.name,
- email: this.email,
- createdAt: this.createdAt,
- updatedAt: this.updatedAt
- };
- }
-}
-
-module.exports = User;
- |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| User.js | -
-
- |
- 0% | -0/22 | -0% | -0/16 | -0% | -0/5 | -0% | -0/22 | -
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| api/controllers | -
-
- |
- 0% | -0/65 | -0% | -0/18 | -0% | -0/9 | -0% | -0/65 | -
| api/middlewares | -
-
- |
- 0% | -0/17 | -0% | -0/4 | -0% | -0/4 | -0% | -0/17 | -
| api/routers | -
-
- |
- 0% | -0/29 | -100% | -0/0 | -0% | -0/11 | -0% | -0/20 | -
| application/auth/commands | -
-
- |
- 0% | -0/49 | -0% | -0/21 | -0% | -0/7 | -0% | -0/49 | -
| application/services | -
-
- |
- 2.94% | -1/34 | -9.09% | -2/22 | -28.57% | -4/14 | -2.94% | -1/34 | -
| application/user/commands | -
-
- |
- 0% | -0/11 | -0% | -0/2 | -0% | -0/3 | -0% | -0/11 | -
| application/user/queries | -
-
- |
- 0% | -0/28 | -0% | -0/8 | -0% | -0/10 | -0% | -0/27 | -
| domain/irepositories | -
-
- |
- 0% | -0/7 | -100% | -0/0 | -0% | -0/6 | -0% | -0/7 | -
| domain/models | -
-
- |
- 0% | -0/22 | -0% | -0/16 | -0% | -0/5 | -0% | -0/22 | -
| infrastructure/db | -
-
- |
- 0% | -0/25 | -0% | -0/8 | -0% | -0/5 | -0% | -0/25 | -
| infrastructure/repositories | -
-
- |
- 0% | -0/25 | -0% | -0/4 | -0% | -0/9 | -0% | -0/24 | -
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 -58 -59 -60 -61 -62 -63 -64 -65 -66 -67 -68 -69 -70 -71 -72 -73 -74 -75 | - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | const { PrismaClient } = require('@prisma/client');
-
-/**
- * Database Connection Wrapper
- * Manages Prisma Client lifecycle
- */
-class DatabaseConnection {
- constructor() {
- this.prisma = null;
- }
-
- /**
- * Initialize Prisma Client
- */
- async connect() {
- if (this.prisma) {
- console.log('⚠️ Prisma Client already connected');
- return;
- }
-
- try {
- this.prisma = new PrismaClient({
- log: process.env.NODE_ENV === 'development' ? ['query', 'error', 'warn'] : ['error'],
- });
-
- await this.prisma.$connect();
- console.log('✅ Prisma connected to PostgreSQL');
- } catch (error) {
- console.error('❌ Failed to connect to database:', error);
- throw error;
- }
- }
-
- /**
- * Get Prisma Client instance
- * @returns {PrismaClient}
- */
- getClient() {
- if (!this.prisma) {
- throw new Error('Database not connected. Call connect() first.');
- }
- return this.prisma;
- }
-
- /**
- * Close database connection
- */
- async disconnect() {
- if (this.prisma) {
- await this.prisma.$disconnect();
- console.log('🛑 Prisma disconnected');
- this.prisma = null;
- }
- }
-
- /**
- * Health check
- * @returns {Promise<boolean>}
- */
- async healthCheck() {
- try {
- await this.prisma.$queryRaw`SELECT 1`;
- return true;
- } catch (error) {
- console.error('❌ Database health check failed:', error);
- return false;
- }
- }
-}
-
-// Singleton instance
-const databaseConnection = new DatabaseConnection();
-
-module.exports = databaseConnection;
- |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| DatabaseConnection.js | -
-
- |
- 0% | -0/25 | -0% | -0/8 | -0% | -0/5 | -0% | -0/25 | -
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 -58 -59 -60 -61 -62 -63 -64 -65 -66 -67 -68 -69 -70 -71 -72 -73 -74 -75 -76 -77 -78 -79 -80 -81 -82 -83 -84 -85 -86 -87 -88 -89 -90 -91 -92 -93 -94 -95 -96 -97 -98 -99 -100 -101 -102 -103 -104 -105 -106 -107 -108 -109 -110 -111 -112 -113 -114 -115 -116 -117 -118 -119 -120 -121 -122 -123 -124 -125 -126 -127 -128 -129 -130 -131 | - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - | const IUserRepository = require('../../domain/irepositories/IUserRepository'); -const User = require('../../domain/models/User'); - -/** - * User Repository Implementation - * Prisma-based data access for User entity - */ -class UserRepository extends IUserRepository { - constructor(prisma) { - super(); - this.prisma = prisma; - } - - /** - * Find user by ID - * @param {number} id - * @returns {Promise<User|null>} - */ - async findById(id) { - const userData = await this.prisma.user.findUnique({ - where: { id: parseInt(id) } - }); - - if (!userData) { - return null; - } - - return this._toDomain(userData); - } - - /** - * Find user by email - * @param {string} email - * @returns {Promise<User|null>} - */ - async findByEmail(email) { - const userData = await this.prisma.user.findUnique({ - where: { email: email.toLowerCase() } - }); - - if (!userData) { - return null; - } - - return this._toDomain(userData); - } - - /** - * Find all users - * @returns {Promise<User[]>} - */ - async findAll() { - const usersData = await this.prisma.user.findMany({ - orderBy: { createdAt: 'desc' } - }); - - return usersData.map(userData => this._toDomain(userData)); - } - - /** - * Create new user - * @param {User} user - * @returns {Promise<User>} - */ - async create(user) { - const userData = await this.prisma.user.create({ - data: { - name: user.name, - email: user.email, - password: user.password - } - }); - - return this._toDomain(userData); - } - - /** - * Update existing user - * @param {User} user - * @returns {Promise<User>} - */ - async update(user) { - const userData = await this.prisma.user.update({ - where: { id: user.id }, - data: { - name: user.name, - email: user.email, - password: user.password, - updatedAt: new Date() - } - }); - - return this._toDomain(userData); - } - - /** - * Delete user by ID - * @param {number} id - * @returns {Promise<boolean>} - */ - async delete(id) { - try { - await this.prisma.user.delete({ - where: { id: parseInt(id) } - }); - return true; - } catch (error) { - return false; - } - } - - /** - * Convert Prisma data to Domain model - * @private - * @param {Object} userData - Prisma user data - * @returns {User} - */ - _toDomain(userData) { - return new User( - userData.id, - userData.name, - userData.email, - userData.password, - userData.createdAt, - userData.updatedAt - ); - } -} - -module.exports = UserRepository; - |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| UserRepository.js | -
-
- |
- 0% | -0/25 | -0% | -0/4 | -0% | -0/9 | -0% | -0/24 | -