modify: QRLoginToken 라우터, 서비스, 레포 User쪽으로 합치기

Author: Jihyun3478

src/controllers/qr.controller.ts

@@ -1,7 +1,13 @@
 import { NextFunction, Request, Response, RequestHandler, CookieOptions } from 'express';
 import logger from '@/configs/logger.config';
 import { EmptyResponseDto, LoginResponseDto, UserWithTokenDto } from '@/types';
+import { QRLoginTokenResponseDto } from '@/types/dto/responses/qrResponse.type';
 import { UserService } from '@/services/user.service';
+import { InvalidTokenError, TokenExpiredError } from '@/exception/token.exception';
+import { NotFoundError } from '@/exception';
+
+type Token32 = string & { __lengthBrand: 10 };
+
 export class UserController {
   constructor(private userService: UserService) { }
 
@@ -102,4 +108,64 @@ export class UserController {
 
     res.status(200).json(response);
   };
+
+  createToken: RequestHandler = async (
+    req: Request,
+    res: Response<QRLoginTokenResponseDto>,
+    next: NextFunction,
+  ) => {
+    try {
+      const user = req.user;
+      const ip = req.ip ?? '';
+      const userAgent = req.headers['user-agent'] || '';
+
+      const token = await this.userService.create(user.id, ip, userAgent);
+      const typedToken = token as Token32;
+
+      const response = new QRLoginTokenResponseDto(
+        true,
+        'QR 토큰 생성 완료',
+        { token: typedToken },
+        null
+      );
+      res.status(200).json(response);
+    } catch (error) {
+      logger.error('QR 토큰 생성 실패:', error);
+      next(error);
+    }
+  };
+
+  getToken: RequestHandler = async (req: Request, res: Response, next: NextFunction) => {
+    try {
+      const token = req.query.token as string;
+      if (!token) {
+        throw new InvalidTokenError('토큰이 필요합니다.');
+      }
+
+      const found = await this.userService.useToken(token);
+      if (!found) {
+        throw new TokenExpiredError();
+      }
+
+      const user = await this.userService.findByVelogUUID(found.user.toString());
+      if (!user) throw new NotFoundError('유저를 찾을 수 없습니다.');
+
+      const { decryptedAccessToken, decryptedRefreshToken } = this.userService.getDecryptedTokens(  
+        user.group_id,  
+        user.access_token,  
+        user.refresh_token  
+      );
+
+      res.clearCookie('access_token', this.cookieOption());
+      res.clearCookie('refresh_token', this.cookieOption());
+
+      res.cookie('access_token', decryptedAccessToken, this.cookieOption());
+      res.cookie('refresh_token', decryptedRefreshToken, this.cookieOption());
+
+      res.redirect('/main');
+    } catch (error) {
+      logger.error('QR 토큰 로그인 처리 실패', error);
+      next(error);
+    }
+  };
 }

src/controllers/user.controller.ts

@@ -1,7 +1,7 @@
 import dotenv from 'dotenv';
 import { Pool } from 'pg';
 import pg from 'pg';
-import { QRLoginTokenRepository } from '@/repositories/qr.repository';
+import { UserRepository } from '@/repositories/user.repository';
 import { generateRandomToken } from '@/utils/generateRandomToken.util';
 import logger from '@/configs/logger.config';
 
@@ -10,7 +10,7 @@ jest.setTimeout(30000);
 
 describe('QRLoginTokenRepository 통합 테스트', () => {
   let testPool: Pool;
-  let repo: QRLoginTokenRepository;
+  let repo: UserRepository;
 
   const TEST_DATA = {
     USER_ID: 1,
@@ -39,7 +39,7 @@ describe('QRLoginTokenRepository 통합 테스트', () => {
     await testPool.query('SELECT 1');
     logger.info('테스트 DB 연결 성공');
 
-    repo = new QRLoginTokenRepository(testPool);
+    repo = new UserRepository(testPool);
   });
 
   afterAll(async () => {

src/repositories/__test__/qr.repo.integration.test.ts

@@ -1,4 +1,4 @@
-import { QRLoginTokenRepository } from '@/repositories/qr.repository';
+import { UserRepository } from '@/repositories/user.repository';
 import { DBError } from '@/exception';
 import { Pool } from 'pg';
 
@@ -7,10 +7,10 @@ const mockPool: Partial<Pool> = {
 };
 
 describe('QRLoginTokenRepository', () => {
-  let repo: QRLoginTokenRepository;
+  let repo: UserRepository;
 
   beforeEach(() => {
-    repo = new QRLoginTokenRepository(mockPool as Pool);
+    repo = new UserRepository(mockPool as Pool);
   });
 
   afterEach(() => {

src/repositories/__test__/qr.repo.test.ts

@@ -1,10 +1,11 @@
 import { Pool } from 'pg';
 import logger from '@/configs/logger.config';
 import { User } from '@/types';
+import { QRLoginToken } from "@/types/models/QRLoginToken.type";
 import { DBError } from '@/exception';
 
 export class UserRepository {
-  constructor(private readonly pool: Pool) { }
+  constructor(private readonly pool: Pool) {}
 
   async findByUserVelogUUID(uuid: string): Promise<User> {
     try {
@@ -91,4 +92,44 @@ export class UserRepository {
       throw new DBError('유저 생성 중 문제가 발생했습니다.');
     }
   }
+
+  async createQRLoginToken(token: string, userId: number, ip: string, userAgent: string): Promise<void> {
+    try {
+      const query = `
+            INSERT INTO users_qrlogintoken (token, user_id, created_at, expires_at, is_used, ip_address, user_agent)
+            VALUES ($1, $2, NOW(), NOW() + INTERVAL '5 minutes', false, $3, $4);
+        `;
+      await this.pool.query(query, [token, userId, ip, userAgent]);
+    } catch (error) {
+      logger.error('QRLoginToken Repo Create Error : ', error);
+      throw new DBError('QR 코드 토큰 생성 중 문제가 발생했습니다.');
+    }
+  }
+
+  async findQRLoginToken(token: string): Promise<QRLoginToken | null> {
+    try {
+      const query = `
+            SELECT *
+            FROM users_qrlogintoken
+            WHERE token = $1 AND is_used = false AND expires_at > NOW();
+        `;
+      const result = await this.pool.query(query, [token]);
+      return result.rows[0] ?? null;
+    } catch (error) {
+      logger.error('QRLoginToken Repo find QR Code Error : ', error);
+      throw new DBError('QR 코드 토큰 조회 중 문제가 발생했습니다.');
+    }
+  }
+
+  async markTokenUsed(token: string): Promise<void> {
+    try {
+      const query = `
+        UPDATE users_qrlogintoken SET is_used = true WHERE token = $1;
+      `;
+      await this.pool.query(query, [token]);
+    } catch (error) {
+      logger.error('QRLoginToken Repo mark as used Error : ', error);
+      throw new DBError('QR 코드 사용 처리 중 문제가 발생했습니다.');
+    }
+  }
 }

src/repositories/qr.repository.ts

@@ -2,7 +2,6 @@ import express, { Router } from 'express';
 import UserRouter from './user.router';
 import PostRouter from './post.router';
 import NotiRouter from './noti.router';
-import QrRouter from './qr.router';
 import LeaderboardRouter from './leaderboard.router';
 
 const router: Router = express.Router();
@@ -14,7 +13,6 @@ router.use('/ping', (req, res) => {
 router.use('/', UserRouter);
 router.use('/', PostRouter);
 router.use('/', NotiRouter);
-router.use('/', QrRouter);
 router.use('/', LeaderboardRouter);
 
 export default router;