feat ✨ daily materialized view 추가

feat: ✨ mv_daily_scale_team_counts 추가 feat: ✨ mv_daily_team_close_counts 추가 feat: ✨ mv_daily_score_values 추가 chore: ⬆️ mongodb client version update, TZ 시간 형태로 변경 - #54
42Statistics · Nov 13, 2023 · a44fa3b · a44fa3b
1 parent cfab9ec
commit a44fa3b
Show file tree

Hide file tree

Showing 9 changed files with 346 additions and 86 deletions.
diff --git a/app/package.json b/app/package.json
@@ -40,7 +40,7 @@
     "camelcase-keys": "^8.0.2",
     "dotenv": "^16.0.3",
     "la-seine": "^0.0.7",
-    "mongodb": "^5.3.0",
+    "mongodb": "^6.2.0",
     "redis": "^4.6.6",
     "zod": "^3.21.4"
   }

diff --git a/app/pnpm-lock.yaml b/app/pnpm-lock.yaml
diff --git a/app/src/index.ts b/app/src/index.ts
@@ -38,6 +38,9 @@ const execUpdators = async (
   }
 };
 
+export const TIMEZONE = process.env.TIMEZONE;
+assertEnvExist(TIMEZONE);
+
 const main = async (): Promise<void> => {
   await initSeine();
 

diff --git a/app/src/location/location.ts b/app/src/location/location.ts
@@ -50,20 +50,21 @@ export class LocationUpdator {
    * E 의 경우, 접속을 종료하는 사람들이 100명을 넘을 때 마다 한번씩 요청을 더 보내야함.
    * 평소엔 1 ~ 2번으로 충분함.
    */
+  @UpdateAction
   static async update(mongo: LambdaMongo, end: Date): Promise<void> {
+    await LocationUpdator.updatePrevOngoing(mongo);
+
     await mongo.withCollectionUpdatedAt({
       end,
       collection: LOCATION_COLLECTION,
       callback: async (start, end) => {
-        await LocationUpdator.updatePrevOngoing(mongo);
         await LocationUpdator.updateOngoing(mongo, start, end);
         await LocationUpdator.updateEnded(mongo, start, end);
         await LocationUpdator.updateDailyLogtime(mongo, end);
       },
     });
   }
 
-  @UpdateAction
   @LogAsyncEstimatedTime
   private static async updateOngoing(
     mongo: LambdaMongo,
@@ -93,7 +94,6 @@ export class LocationUpdator {
     return parseLocations(locationDtos);
   }
 
-  @UpdateAction
   @LogAsyncEstimatedTime
   private static async updateEnded(
     mongo: LambdaMongo,
@@ -128,7 +128,6 @@ export class LocationUpdator {
    * location api 에 버그가 생기면 end_at 이 null 인 상태로 존재하기 때문에,
    * 기존에 있던 location 들의 점검이 필요함.
    */
-  @UpdateAction
   @LogAsyncEstimatedTime
   private static async updatePrevOngoing(mongo: LambdaMongo): Promise<void> {
     const prevOngoingIds = await mongo

diff --git a/app/src/mongodb/mongodb.ts b/app/src/mongodb/mongodb.ts
@@ -11,6 +11,7 @@ import type { PROJECT_SESSIONS_SKILL_COLLECTION } from '#lambda/projectSessionsS
 import type { PROJECTS_USER_COLLECTION } from '#lambda/projectsUser/projectsUser.js';
 import type { QUESTS_USER_COLLECTION } from '#lambda/questsUser/questsUser.js';
 import type { SCALE_TEAM_COLLECTION } from '#lambda/scaleTeam/scaleTeam.js';
+import type { SCORE_COLLECTION } from '#lambda/score/score.js';
 import type { SKILL_COLLECTION } from '#lambda/skill/skill.js';
 import type { TEAM_COLLECTION } from '#lambda/team/team.js';
 import type { USER_COLLECTION } from '#lambda/user/user.js';
@@ -44,6 +45,7 @@ type LogUpdatedAt =
   | typeof COALITIONS_USER_COLLECTION
   | typeof PROJECT_SESSION_COLLECTION
   | typeof SKILL_COLLECTION
+  | typeof SCORE_COLLECTION
   | typeof PROJECT_SESSIONS_SKILL_COLLECTION
   | typeof USER_COLLECTION;