feature: 뉴스레터 수신 거부 API 추가

Author: ooheunda

src/controllers/__test__/user.controller.test.ts

@@ -405,4 +405,44 @@ describe('UserController', () => {
       expect(mockResponse.redirect).not.toHaveBeenCalled();
     });
   });
+
+  describe('unsubscribeNewsletter', () => {
+    beforeEach(() => {
+      mockRequest.query = {};
+      mockResponse.redirect = jest.fn().mockReturnThis();
+    });
+
+    it('이메일이 없으면 BadRequestError를 던져야 한다', async () => {
+      mockRequest.query = {};
+
+      await userController.unsubscribeNewsletter(
+        mockRequest as Request,
+        mockResponse as Response,
+        nextFunction
+      );
+
+      expect(nextFunction).toHaveBeenCalledWith(
+        expect.objectContaining({
+          message: '이메일이 필요합니다.',
+        })
+      );
+      expect(mockResponse.redirect).not.toHaveBeenCalled();
+    });
+
+    it('구독 해제 완료시 메인 페이지로 리다이렉트해야 한다', async () => {
+      const email = 'test@example.com';
+      mockRequest.query = { email };
+      mockUserService.unsubscribeNewsletter.mockResolvedValue(undefined);
+
+      await userController.unsubscribeNewsletter(
+        mockRequest as Request,
+        mockResponse as Response,
+        nextFunction
+      );
+
+      expect(mockUserService.unsubscribeNewsletter).toHaveBeenCalledWith(email);
+      expect(mockResponse.redirect).toHaveBeenCalledWith('/main');
+      expect(nextFunction).not.toHaveBeenCalled();
+    });
+  });
 });

src/controllers/user.controller.ts

@@ -5,6 +5,7 @@ import { QRLoginTokenResponseDto } from '@/types/dto/responses/qrResponse.type';
 import { UserService } from '@/services/user.service';
 import { QRTokenExpiredError, QRTokenInvalidError } from '@/exception/token.exception';
 import { fetchVelogApi } from '@/modules/velog/velog.api';
+import { BadRequestError } from '@/exception';
 
 type Token10 = string & { __lengthBrand: 10 };
 
@@ -169,4 +170,19 @@ export class UserController {
       next(error);
     }
   };
+
+  unsubscribeNewsletter: RequestHandler = async (req: Request, res: Response<EmptyResponseDto>, next: NextFunction) => {
+    try { 
+      const email = req.query.email as string;
+      if (!email) {
+        throw new BadRequestError('이메일이 필요합니다.');
+      }
+
+      await this.userService.unsubscribeNewsletter(email);
+      res.redirect('/main');
+    } catch (error) {
+      logger.error(`뉴스레터 구독 해제 실패: [email: ${req.query.email}]`, error);
+      next(error);
+    }
+  };
 }

src/repositories/user.repository.ts

@@ -7,7 +7,7 @@ import { DBError } from '@/exception';
 export class UserRepository {
   constructor(private readonly pool: Pool) {}
 
-  async findByUserId(id: number): Promise<User> {
+  async findByUserId(id: number): Promise<User | null> {
     try {
       const user = await this.pool.query('SELECT * FROM "users_user" WHERE id = $1', [id]);
       return user.rows[0] || null;
@@ -17,7 +17,7 @@ export class UserRepository {
     }
   }
 
-  async findByUserVelogUUID(uuid: string): Promise<User> {
+  async findByUserVelogUUID(uuid: string): Promise<User | null> {
     try {
       const user = await this.pool.query('SELECT * FROM "users_user" WHERE velog_uuid = $1', [uuid]);
       return user.rows[0] || null;
@@ -27,6 +27,16 @@ export class UserRepository {
     }
   }
 
+  async findByUserEmail(email: string): Promise<User | null> {
+    try {
+      const user = await this.pool.query('SELECT * FROM "users_user" WHERE email = $1', [email]);
+      return user.rows[0] || null;
+    } catch (error) {
+      logger.error('Email로 유저를 조회 중 오류 : ', error);
+      throw new DBError('유저 조회 중 문제가 발생했습니다.');
+    }
+  }
+
   async findSampleUser(): Promise<User> {
     try {
       const query = `
@@ -152,4 +162,14 @@ export class UserRepository {
       throw new DBError('QR 코드 사용 처리 중 문제가 발생했습니다.');
     }
   }
+
+  async unsubscribeNewsletter(id: number): Promise<void> {
+    try {
+      const query = `UPDATE "users_user" SET newsletter_subscribed = false WHERE id = $1`;
+      await this.pool.query(query, [id]);
+    } catch (error) {
+      logger.error('User Repo unsubscribeNewsletter Error : ', error);
+      throw new DBError('뉴스레터 구독 해제 중 문제가 발생했습니다.');
+    }
+  }
 }

src/routes/user.router.ts

@@ -151,4 +151,25 @@ router.post('/qr-login', authMiddleware.verify, userController.createToken);
  */
 router.get('/qr-login', userController.getToken);
 
+/**
+ * @swagger
+ * /newsletter-unsubscribe:
+ *   get:
+ *     tags: 
+ *       - User
+ *     summary: 뉴스레터 구독 해제 (메일에서 바로 접근)
+ *     parameters:
+ *       - in: query
+ *         name: email
+ *         required: true
+ *         schema:
+ *           type: string
+ *         description: 구독을 해제할 이메일
+ *     responses:
+ *       302:
+ *         description: 뉴스레터 구독 해제 성공 후 메인 페이지로 리디렉션
+ */
+router.get('/newsletter-unsubscribe', userController.unsubscribeNewsletter);
+
+
 export default router;

src/services/user.service.ts

@@ -170,4 +170,19 @@ export class UserService {
     );
     return { decryptedAccessToken, decryptedRefreshToken };
   }
+
+  async unsubscribeNewsletter(email: string) {
+    try {
+      const user = await this.userRepo.findByUserEmail(email);
+      if (!user) {
+        logger.error(`유저를 찾을 수 없습니다. [email: ${email}]`);
+        return; // 일반적인 실패시 리디렉션
+      }
+
+      await this.userRepo.unsubscribeNewsletter(user.id);
+    } catch (error) {
+      logger.error('User Service unsubscribeNewsletter Error : ', error);
+      throw error;
+    }
+  }
 }