v1.0.0 릴리즈

.gitignore

@@ -131,4 +131,6 @@ dist
 .yarn/unplugged
 .yarn/build-state.yml
 .yarn/install-state.gz
-.pnp.*
+.pnp.*
+
+scripts/data/*

app.js

@@ -3,6 +3,7 @@ const conf = require('./src/common/config/index');
 const expressLoader = require('./src/common/modules/express');
 const initDB = require('./src/common/modules/mongodb');
 const { START_MESSAGE } = require('./src/common/constants/express');
+require('./src/common/modules/cron/sync-redis-to-db');
 
 const app = express();
 

package.json

@@ -11,7 +11,9 @@
         "lint": "eslint .",
         "lint:fix": "eslint . --fix",
         "format": "prettier --write .",
-        "prettier": "prettier --write --config ./.prettierrc './src/**'"
+        "prettier": "prettier --write --config ./.prettierrc './src/**'",
+        "generate:user": "node ./scripts/generate-users-data.js",
+        "generate:word": "node ./scripts/generate-words-data.js"
     },
     "author": "",
     "license": "ISC",
@@ -36,6 +38,7 @@
         "moment": "^2.30.1",
         "mongoose": "^8.4.3",
         "morgan": "^1.10.0",
+        "node-cron": "^3.0.3",
         "nodemon": "^3.1.0",
         "passport": "^0.7.0",
         "passport-jwt": "^4.0.1",

scripts/generate-users-data.js

@@ -0,0 +1,50 @@
+const fs = require('fs');
+
+function generateRandomId() {
+    return Array(24)
+        .fill(0)
+        .map(() => Math.floor(Math.random() * 16).toString(16))
+        .join('');
+}
+
+function generateRandomNickname(index) {
+    return `user${index}`;
+}
+
+function generateUser(index) {
+    const now = new Date().toISOString();
+    return {
+        _id: { $oid: generateRandomId() },
+        deletedAt: null,
+        nickname: generateRandomNickname(index),
+        email: `user${index}@example.com`,
+        password: '$2b$10$NWhqlRrE5W0YMHlnaBi.CODbFjPZzvgT5G993eKoziVzrhH3M6KNC',
+        role: 'user',
+        snsId: null,
+        provider: null,
+        recentSearches: [],
+        requests: [],
+        createdAt: { $date: now },
+        updatedAt: { $date: now },
+        __v: 0,
+    };
+}
+
+function generateUsers(count) {
+    const users = [];
+    for (let i = 0; i < count; i++) {
+        users.push(generateUser(i));
+    }
+    return users;
+}
+
+async function generateAndSaveData(totalCount) {
+    const userData = generateUsers(totalCount);
+    const fileName = './scripts/data/test-users-data.json';
+    fs.writeFileSync(fileName, JSON.stringify(userData, null, 2));
+
+    console.log('✅ 10000개의 유저 데이터가 생성되었습니다.');
+    console.log('📁 파일 위치: users.json');
+}
+
+generateAndSaveData(10000).catch(console.error);

scripts/generate-words-data.js

@@ -0,0 +1,58 @@
+const fs = require('fs');
+
+const prefixes = ['A', 'Ab', 'Ac', 'Ad', 'Af', 'Ag', 'Al', 'Am', 'An', 'Ap', 'Ar', 'As', 'At', 'Au'];
+const middles = ['sync', 'pi', 'data', 'net', 'web', 'cloud', 'tech', 'dev', 'sys', 'log'];
+const suffixes = ['Service', 'API', 'Hub', 'Lab', 'Flow', 'Base', 'Core', 'Plus', 'Pro', 'Box'];
+
+function generateRandomWord(index) {
+    const prefix = prefixes[Math.floor(Math.random() * prefixes.length)];
+    const middle = middles[Math.floor(Math.random() * middles.length)];
+    const suffix = suffixes[Math.floor(Math.random() * suffixes.length)];
+    return `${prefix}${middle}${suffix}${index}`;
+}
+
+function* generateWordBatch(totalCount, batchSize = 1000) {
+    for (let i = 0; i < totalCount; i += batchSize) {
+        const batch = [];
+        const currentBatchSize = Math.min(batchSize, totalCount - i);
+
+        for (let j = 0; j < currentBatchSize; j++) {
+            const word = generateRandomWord(i + j);
+            batch.push({
+                word,
+                awkPron: `어색한_${word}`,
+                comPron: `일반적인_${word}`,
+                info: `${word}에 대한 설명입니다. (테스트 데이터 ${i + j + 1})`,
+                suggestedBy: 'admin',
+                freq: Math.floor(Math.random() * 100),
+            });
+        }
+        yield batch;
+    }
+}
+
+async function generateAndSaveData(totalCount) {
+    console.time('Data Generation');
+    const fileName = './scripts/data/test-words-data.json';
+    const batchSize = 1000;
+    let currentBatch = 1;
+    const totalBatches = Math.ceil(totalCount / batchSize);
+
+    fs.writeFileSync(fileName, '[\n', 'utf8');
+
+    for (const batch of generateWordBatch(totalCount, batchSize)) {
+        console.log(`처리 중: ${currentBatch}/${totalBatches} 배치`);
+
+        const batchData = batch.map((item) => JSON.stringify(item)).join(',\n');
+        fs.appendFileSync(fileName, currentBatch === 1 ? batchData : ',\n' + batchData, 'utf8');
+
+        currentBatch++;
+    }
+
+    fs.appendFileSync(fileName, '\n]', 'utf8');
+
+    console.log(`✅ ${totalCount}개의 테스트 데이터 생성 완료!`);
+    console.log(`📁 파일 위치: ${fileName}`);
+}
+
+generateAndSaveData(100000).catch(console.error);

src/common/config/index.js

@@ -1,5 +1,6 @@
 const dotenv = require('dotenv');
 const path = require('path');
+const ErrorMessage = require('../constants/error-message');
 
 const envPath = path.join(__dirname, '../../../.env');
 
@@ -75,7 +76,7 @@ switch (process.env.NODE_ENV) {
         conf.envMode = 'dev';
         break;
     default:
-        console.error('NODE_ENV is not set correctly. It should be either production or development');
+        console.error(ErrorMessage.INVALID_NODE_ENV);
 }
 
 module.exports = conf;

src/common/constants/error-message.js

@@ -14,6 +14,7 @@ const ErrorMessage = Object.freeze({
     AUTHOLIZATION: '권한이 없습니다.',
     RETRY_LOGIN: '다시 로그인해주세요.',
     NOT_AUTHORIZED: '권한이 없습니다.',
+    INVALID_NODE_ENV: 'NODE_ENV가 올바르게 설정되지 않았습니다. production 또는 development 중 하나여야 합니다.',
 
     // USER
     REGISTER_ERROR: '회원가입중 오류가 발생하였습니다.',

src/common/modules/cron/sync-redis-to-db.js

@@ -0,0 +1,38 @@
+const cron = require('node-cron');
+const redisClient = require('../redis');
+const mongoose = require('mongoose');
+const Word = require('../../../routes/word/word.model');
+
+// NOTE : 매 정각마다 Redis 조회수를 DB에 반영
+cron.schedule('0 * * * *', async () => {
+    try {
+        const cachedWordsRaw = await redisClient.sendCommand(['ZRANGE', 'popular_words', '0', '-1', 'WITHSCORES']);
+
+        const updates = [];
+        for (let i = 0; i < cachedWordsRaw.length; i += 2) {
+            const word = cachedWordsRaw[i];
+            const redisFreq = Number(cachedWordsRaw[i + 1]);
+
+            // NOTE : word 스키마의 조회수 증가 미들웨어를 우회하기 위해 Mongoose 대신 MongoDB 드라이버를 사용
+            const dbWord = await mongoose.connection.collection('words').findOne({ word }, { projection: { freq: 1 } });
+            const dbFreq = dbWord ? dbWord.freq : 0;
+
+            if (redisFreq !== dbFreq) {
+                updates.push({
+                    updateOne: {
+                        filter: { word },
+                        update: { freq: redisFreq },
+                    },
+                });
+            }
+        }
+        if (updates.length > 0) {
+            await Word.bulkWrite(updates);
+            console.log('✅ Redis 조회수를 DB에 성공적으로 동기화했습니다.');
+        } else {
+            console.log('ℹ️ 이미 동기화된 조회수입니다.');
+        }
+    } catch (error) {
+        console.error('❌ Redis와 DB 동기화 중 오류 발생:', error);
+    }
+});