feat: ✨ dailyAliveUserCountRecords 추가

- close #392

app/src/page/home/user/home.user.resolver.ts

@@ -9,6 +9,7 @@ import { DateWrapper } from 'src/dateWrapper/dateWrapper';
 import { HttpExceptionFilter } from 'src/http-exception.filter';
 import { HomeUserService } from './home.user.service';
 import {
+  GetHomeUserAliveUserCountRecordsArgs,
   GetHomeUserBlackholedCountRecordsArgs,
   HomeUser,
   IntPerCircle,
@@ -29,6 +30,33 @@ export class HomeUserResolver {
     return {};
   }
 
+  @ResolveField((_returns) => [IntRecord])
+  async dailyAliveUserCountRecords(
+    @Args() { last }: GetHomeUserAliveUserCountRecordsArgs,
+  ): Promise<IntRecord[]> {
+    const nextDay = new DateWrapper().startOfDate().moveDate(1).toDate();
+    const start = new DateWrapper()
+      .startOfDate()
+      .moveDate(1 - last)
+      .toDate();
+
+    const cacheKey = `homeUserDailyAliveUserCountRecords:${start.getTime()}:${nextDay.getTime()}`;
+
+    const cached = await this.cacheUtilService.get<IntRecord[]>(cacheKey);
+    if (cached) {
+      return cached;
+    }
+
+    const result = await this.homeUserService.dailyAliveUserCountRecords({
+      start,
+      end: nextDay,
+    });
+
+    await this.cacheUtilService.set(cacheKey, result, DateWrapper.MIN);
+
+    return result;
+  }
+
   @ResolveField((_returns) => [IntRecord])
   async aliveUserCountRecords(): Promise<IntRecord[]> {
     return await this.homeUserService.aliveUserCountRecords();

app/src/page/home/user/home.user.service.ts

@@ -11,9 +11,9 @@ import {
   blackholedUserFilterByDateRange,
 } from 'src/api/cursusUser/db/cursusUser.database.query';
 import type { cursus_user } from 'src/api/cursusUser/db/cursusUser.database.schema';
+import { promo } from 'src/api/promo/db/promo.database.schema';
 import { QuestsUserService } from 'src/api/questsUser/questsUser.service';
 import { CacheOnReturn } from 'src/cache/decrators/onReturn/cache.decorator.onReturn.symbol';
-import { assertExist } from 'src/common/assertExist';
 import type { Rate } from 'src/common/models/common.rate.model';
 import type { UserRank } from 'src/common/models/common.user.model';
 import type { IntRecord } from 'src/common/models/common.valueRecord.model';
@@ -32,6 +32,150 @@ export class HomeUserService {
     private readonly runtimeConfig: ConfigType<typeof RUNTIME_CONFIG>,
   ) {}
 
+  // todo: 나중에 별도 service 로 분리해야 합니다.
+  async dailyAliveUserCountRecords({
+    start,
+    end,
+  }: DateRange): Promise<IntRecord[]> {
+    const totalUserIOs = await this.cursusUserService
+      .aggregate<{ date: Date; count: number }>()
+      .match(
+        blackholedUserFilterByDateRange({
+          start: new Date(0),
+          end,
+        }),
+      )
+      .group({
+        _id: {
+          $dateFromParts: {
+            year: {
+              $year: {
+                date: '$blackholedAt',
+                timezone: this.runtimeConfig.TIMEZONE,
+              },
+            },
+            month: {
+              $month: {
+                date: '$blackholedAt',
+                timezone: this.runtimeConfig.TIMEZONE,
+              },
+            },
+            day: {
+              $dayOfMonth: {
+                date: '$blackholedAt',
+                timezone: this.runtimeConfig.TIMEZONE,
+              },
+            },
+            timezone: this.runtimeConfig.TIMEZONE,
+          },
+        },
+        count: { $sum: -1 },
+      })
+      .project({
+        _id: 0,
+        date: '$_id',
+        count: 1,
+      })
+      .unionWith({
+        // todo: collection 분리
+        coll: 'transfer_ins',
+        pipeline: [
+          {
+            $match: {
+              date: {
+                $gte: start,
+                $lt: end,
+              },
+            },
+          },
+          {
+            $group: {
+              _id: '$date',
+              count: { $count: {} },
+            },
+          },
+          {
+            $project: {
+              _id: 0,
+              date: '$_id',
+              count: 1,
+            },
+          },
+        ],
+      })
+      .unionWith({
+        coll: `${promo.name}s`,
+        pipeline: [
+          {
+            $match: {
+              beginAt: {
+                $lt: end,
+              },
+            },
+          },
+          {
+            $project: {
+              _id: 0,
+              date: {
+                $dateFromParts: {
+                  year: {
+                    $year: {
+                      date: '$beginAt',
+                      timezone: this.runtimeConfig.TIMEZONE,
+                    },
+                  },
+                  month: {
+                    $month: {
+                      date: '$beginAt',
+                      timezone: this.runtimeConfig.TIMEZONE,
+                    },
+                  },
+                  day: {
+                    $dayOfMonth: {
+                      date: '$beginAt',
+                      timezone: this.runtimeConfig.TIMEZONE,
+                    },
+                  },
+                  timezone: this.runtimeConfig.TIMEZONE,
+                },
+              },
+              count: '$userCount',
+            },
+          },
+        ],
+      })
+      .group({
+        _id: '$date',
+        count: { $sum: '$count' },
+      })
+      .sort({ _id: 1 })
+      .project({
+        _id: 0,
+        date: '$_id',
+        count: 1,
+      });
+
+    const startDateIndex = totalUserIOs.findIndex(({ date }) => date >= start);
+    const beforeStart = totalUserIOs
+      .slice(0, startDateIndex)
+      .reduce((acc, { count }) => acc + count, 0);
+
+    return totalUserIOs.slice(startDateIndex).reduce(
+      ({ prev, records }, { date, count }) => {
+        records.push({
+          at: date,
+          value: prev + count,
+        });
+
+        return {
+          prev: prev + count,
+          records,
+        };
+      },
+      { prev: beforeStart, records: new Array<IntRecord>() },
+    ).records;
+  }
+
   @CacheOnReturn()
   async aliveUserCountRecords(): Promise<IntRecord[]> {
     const now = new DateWrapper();

app/src/page/home/user/models/home.user.model.ts

@@ -24,7 +24,12 @@ export class UserCountPerLevel {
 
 @ObjectType()
 export class HomeUser {
+  // todo: api version header 를 받는 등의 방식을 사용하면 기존 field 명으로 처리할 수 있습니다만,
+  // 프론트엔드가 현재 작업을 할 수 없는 상황이기 때문에 이렇게 처리합니다.
   @Field((_type) => [IntRecord])
+  dailyAliveUserCountRecords: IntRecord[];
+
+  @Field((_type) => [IntRecord], { deprecationReason: 'v0.10.0' })
   aliveUserCountRecords: IntRecord[];
 
   @Field((_type) => [UserCountPerLevel])
@@ -52,6 +57,14 @@ export class HomeUser {
   averageDurationPerCircle: IntPerCircle[];
 }
 
+@ArgsType()
+export class GetHomeUserAliveUserCountRecordsArgs {
+  @Min(1)
+  @Max(750)
+  @Field()
+  last: number;
+}
+
 @ArgsType()
 export class GetHomeUserBlackholedCountRecordsArgs {
   @Min(1)

app/src/schema.gql

@@ -240,7 +240,8 @@ type UserCountPerLevel {
 }
 
 type HomeUser {
-  aliveUserCountRecords: [IntRecord!]!
+  dailyAliveUserCountRecords(last: Int!): [IntRecord!]!
+  aliveUserCountRecords: [IntRecord!]! @deprecated(reason: "v0.10.0")
   userCountPerLevel: [UserCountPerLevel!]!
   memberRate: Rate!
   blackholedRate: Rate!