🐛 fix: redis에 캐싱된 최신 피드가 삭제되지 않는 버그 수정

rss-notifier/src/db-access.ts

@@ -4,6 +4,7 @@ import * as dotenv from "dotenv";
 import * as mysql from "mysql2/promise";
 import Redis from "ioredis";
 import * as process from "node:process";
+import { PoolConnection } from "mysql2/promise";
 
 dotenv.config({
   path: process.env.NODE_ENV === "production" ? "rss-notifier/.env" : ".env",
@@ -34,12 +35,12 @@ export const createRedisClient = async () => {
   });
 };
 
-export const executeQuery = async (query: string, params: any[] = []) => {
-  let connection;
+export const executeQuery = async <T>(query: string, params: any[] = []) => {
+  let connection: PoolConnection;
   try {
     connection = await pool.getConnection();
     const [rows] = await connection.query(query, params);
-    return rows;
+    return rows as T[];
   } catch (err) {
     logger.error("쿼리 " + query + " 실행 중 오류 발생:", err);
     throw err;
@@ -58,15 +59,15 @@ export const selectAllRss = async (): Promise<RssObj[]> => {
 
 export const insertFeeds = async (resultData: FeedDetail[]) => {
   let successCount = 0;
-  let lastFeedId;
+  let lastFeedId: number;
   const query = `
         INSERT INTO feed (blog_id, created_at, title, path, thumbnail)
         VALUES (?, ?, ?, ?, ?)
     `;
   for (const feed of resultData) {
     try {
       lastFeedId = (
-        await executeQuery(query, [
+        await executeQuery<FeedDetail>(query, [
           feed.blogId,
           feed.pubDate,
           feed.title,
@@ -81,23 +82,36 @@ export const insertFeeds = async (resultData: FeedDetail[]) => {
   }
 
   logger.info(
-    `${successCount}개의 피드 데이터가 성공적으로 데이터베이스에 삽입되었습니다.`
+    `${successCount}개의 피드 데이터가 성공적으로 데이터베이스에 삽입되었습니다.`,
   );
   lastFeedId = lastFeedId - successCount + 1;
   return lastFeedId;
 };
 
-export const deleteRecentFeedStartId = async () => {
+export const deleteRecentFeed = async () => {
   const redis = await createRedisClient();
   try {
-    const keys = await redis.keys(redisConstant.FEED_RECENT_ALL_KEY);
-    if (keys.length > 0) {
-      await redis.del(...keys);
+    const keysToDelete = [];
+    let cursor = "0";
+    do {
+      const [newCursor, keys] = await redis.scan(
+        cursor,
+        "MATCH",
+        redisConstant.FEED_RECENT_ALL_KEY,
+        "COUNT",
+        "100",
+      );
+      keysToDelete.push(...keys);
+      cursor = newCursor;
+    } while (cursor !== "0");
+
+    if (keysToDelete.length > 0) {
+      await redis.del(...keysToDelete);
     }
     await redis.set(redisConstant.FEED_RECENT_KEY, "false");
   } catch (error) {
     logger.error(
-      `Redis의 feed:recent:*를 삭제하는 도중 에러가 발생했습니다. 에러 내용: ${error}`
+      `Redis의 feed:recent:*를 삭제하는 도중 에러가 발생했습니다. 에러 내용: ${error}`,
     );
   } finally {
     if (redis) await redis.quit();
@@ -120,7 +134,7 @@ export const setRecentFeedList = async (startId: number) => {
                    FROM feed f
                    JOIN rss_accept r ON f.blog_id = r.id
                    WHERE f.id >= ${startId}`;
-    const resultList = await executeQuery(query);
+    const resultList = await executeQuery<RssObj>(query);
     const pipeLine = redis.pipeline();
     for (const feed of resultList) {
       pipeLine.hset(`feed:recent:${feed.id}`, feed);
@@ -129,7 +143,7 @@ export const setRecentFeedList = async (startId: number) => {
     await pipeLine.exec();
   } catch (error) {
     logger.error(
-      `Redis의 feed:recent:*를 저장하는 도중 에러가 발생했습니다. 에러 내용: ${error}`
+      `Redis의 feed:recent:*를 저장하는 도중 에러가 발생했습니다. 에러 내용: ${error}`,
     );
   } finally {
     if (redis) await redis.quit();

rss-notifier/src/rss-notifier.ts

@@ -3,8 +3,8 @@ import "dotenv/config";
 import {
   selectAllRss,
   insertFeeds,
-  deleteRecentFeedStartId,
   setRecentFeedList,
+  deleteRecentFeed,
 } from "./db-access.js";
 import { RssObj, FeedDetail, RawFeed } from "./types.js";
 import { XMLParser } from "fast-xml-parser";
@@ -57,7 +57,7 @@ const fetchRss = async (rssUrl: string): Promise<RawFeed[]> => {
 
 const findNewFeeds = async (
   rssObj: RssObj,
-  now: number
+  now: number,
 ): Promise<FeedDetail[]> => {
   try {
     const TIME_INTERVAL = process.env.TIME_INTERVAL
@@ -84,13 +84,13 @@ const findNewFeeds = async (
           link: decodeURIComponent(feed.link),
           imageUrl: imageUrl,
         };
-      })
+      }),
     );
 
     return detailedFeeds;
   } catch (err) {
     logger.warn(
-      `[${rssObj.rssUrl}] 에서 데이터 조회 중 오류 발생으로 인한 스킵 처리. 오류 내용 : ${err}`
+      `[${rssObj.rssUrl}] 에서 데이터 조회 중 오류 발생으로 인한 스킵 처리. 오류 내용 : ${err}`,
     );
     return [];
   }
@@ -123,10 +123,10 @@ export const performTask = async () => {
   const newFeeds = await Promise.all(
     rssObjects.map(async (rssObj) => {
       logger.info(
-        `[${++idx}번째 rss [${rssObj.rssUrl}] 에서 데이터 조회하는 중...`
+        `[${++idx}번째 rss [${rssObj.rssUrl}] 에서 데이터 조회하는 중...`,
       );
       return await findNewFeeds(rssObj, currentTime.setSeconds(0, 0));
-    })
+    }),
   );
 
   const result = newFeeds.flat().sort((currentFeed, nextFeed) => {
@@ -135,9 +135,9 @@ export const performTask = async () => {
     return dateCurrent.getTime() - dateNext.getTime();
   });
 
+  await deleteRecentFeed();
   if (result.length === 0) {
     logger.info("새로운 피드가 없습니다.");
-    await deleteRecentFeedStartId();
     return;
   }
 

server/src/feed/api-docs/readFeedList.api-docs.ts

@@ -0,0 +1,88 @@
+import { applyDecorators } from '@nestjs/common';
+import {
+  ApiBadRequestResponse,
+  ApiOkResponse,
+  ApiOperation,
+  ApiQuery,
+} from '@nestjs/swagger';
+
+export function ApiReadFeedList() {
+  return applyDecorators(
+    ApiOperation({
+      summary: `메인 화면 게시글 조회 API`,
+    }),
+    ApiQuery({
+      name: 'lastId',
+      required: false,
+      type: Number,
+      description: '마지막으로 받은 피드의 ID',
+      example: 10,
+    }),
+    ApiQuery({
+      name: 'limit',
+      required: false,
+      type: Number,
+      description: '한 번에 가져올 피드 수',
+      example: 5,
+      default: 12,
+    }),
+    ApiOkResponse({
+      description: 'Ok',
+      schema: {
+        properties: {
+          message: {
+            type: 'string',
+          },
+          data: {
+            type: 'object',
+            properties: {
+              result: {
+                type: 'array',
+                items: {
+                  type: 'object',
+                  properties: {
+                    id: { type: 'number' },
+                    author: { type: 'string' },
+                    blogPlatform: { type: 'string' },
+                    title: { type: 'string' },
+                    path: { type: 'string', format: 'url' },
+                    createAt: { type: 'string', format: 'date-time' },
+                    thumbnail: { type: 'string', format: 'url' },
+                    viewCount: { type: 'number' },
+                  },
+                },
+              },
+              lastId: { type: 'number' },
+              hasMore: { type: 'boolean' },
+            },
+          },
+        },
+      },
+      example: {
+        message: '피드 조회 완료',
+        data: {
+          result: [
+            {
+              id: 3,
+              author: '블로그 이름',
+              blogPlatform: '블로그 서비스 플랫폼',
+              title: '피드 제목',
+              path: 'https://test.com',
+              createAt: '2024-06-16T20:00:57.000Z',
+              thumbnail: 'https://test.com/image.png',
+              viewCount: 1,
+            },
+          ],
+          lastId: 3,
+          hasMore: true,
+        },
+      },
+    }),
+    ApiBadRequestResponse({
+      description: 'Bad Request',
+      example: {
+        message: '오류 메세지',
+      },
+    }),
+  );
+}

server/src/feed/api-docs/readRecentFeedList.api-docs.ts

@@ -0,0 +1,54 @@
+import { applyDecorators } from '@nestjs/common';
+import { ApiOkResponse, ApiOperation } from '@nestjs/swagger';
+
+export function ApiReadRecentFeedList() {
+  return applyDecorators(
+    ApiOperation({
+      summary: '최신 피드 업데이트 API',
+    }),
+    ApiOkResponse({
+      description: 'Ok',
+      schema: {
+        properties: {
+          message: {
+            type: 'string',
+          },
+          data: {
+            type: 'array',
+            items: {
+              type: 'object',
+              properties: {
+                id: { type: 'number' },
+                author: { type: 'string' },
+                blogPlatform: { type: 'string' },
+                title: { type: 'string' },
+                path: { type: 'string' },
+                createdAt: {
+                  type: 'string',
+                  format: 'date-time',
+                },
+                thumbnail: { type: 'string' },
+                viewCount: { type: 'number' },
+              },
+            },
+          },
+        },
+      },
+      example: {
+        message: '최신 피드 업데이트 완료',
+        data: [
+          {
+            id: 1,
+            author: '블로그 이름',
+            blogPlatform: 'etc',
+            title: '게시글 제목',
+            path: 'https://test1.com/1',
+            createdAt: '2024-11-24T01:00:00.000Z',
+            thumbnail: 'https://test1.com/test.png',
+            viewCount: 0,
+          },
+        ],
+      },
+    }),
+  );
+}