[feat]: Topic을 활용한 FCM push 로직 구성

.gitignore

@@ -1,6 +1,7 @@
 *.env
 env_files/*
 db_data
+pog-adminsdk.json
 
 # compiled output
 /dist

apps/push/src/push/PushApiConsumer.ts

@@ -1,3 +1,4 @@
+import { PushJobService } from './../../../../libs/common-config/src/job/src/PushJobService';
 import { Process, Processor } from '@nestjs/bull';
 import { Logger } from '@nestjs/common';
 import { Job } from 'bull';
@@ -6,8 +7,11 @@ import { Job } from 'bull';
 export class PushApiConsumer {
   private readonly logger = new Logger(PushApiConsumer.name);
 
+  constructor(private readonly pushJobService: PushJobService) {}
+
   @Process('summonerList')
-  getSummonerIdQueue(job: Job) {
-    this.logger.log(`${job.id} 번 작업을 수신했습니다.`);
+  async getSummonerIdQueue(job: Job) {
+    await this.pushJobService.send(job.data['summonerId']);
+    this.logger.log(`${job.data['summonerId']} topic 푸시를 전송했습니다.`);
   }
 }

apps/push/src/push/PushApiModule.ts

@@ -1,3 +1,4 @@
+import { PushJobModule } from './../../../../libs/common-config/src/job/src/PushJobModule';
 import { Module } from '@nestjs/common';
 import { WinstonModule } from 'nest-winston';
 import { getWinstonLogger } from '@app/common-config/getWinstonLogger';
@@ -11,6 +12,7 @@ import { ScheduleModule } from '@nestjs/schedule';
 
 @Module({
   imports: [
+    PushJobModule,
     WinstonModule.forRoot(getWinstonLogger(process.env.NODE_ENV, 'push')),
     getBullQueue(),
     RedisModule.register(RedisModuleConfig),

apps/push/src/push/PushApiService.ts

@@ -16,29 +16,48 @@ export class PushApiService {
     private readonly redisService: RedisService,
   ) {}
 
-  @Interval('pushCronTask', 10000)
+  // @Interval('pushCronTask', 10000)
   async addMessageQueue(): Promise<void> {
     const redisClient: Redis = this.redisService.getClient();
     const summonerIds = await redisClient.smembers('summonerId');
-    summonerIds.map(async summonerId => {
-      const riotApiResponse = plainToInstance(
-        PushRiotApi,
-        await RiotApiJobs(summonerId),
-      );
-      const redisResponse = await redisClient.mget(
-        `summonerId:${summonerId}:win`,
-        `summonerId:${summonerId}:lose`,
-        `summonerId:${summonerId}:tier`,
-      );
-      const isChangeRecord = await this.compareRecord(
-        riotApiResponse,
-        redisResponse,
-      );
-      if (isChangeRecord) {
-        await this.addPushQueue();
-        await this.changeRecord(riotApiResponse, redisClient, summonerId);
-      }
-    });
+    // summonerIds.map(async summonerId => {
+    // const riotApiResponse = plainToInstance(
+    //   PushRiotApi,
+    //   await RiotApiJobs(summonerId),
+    // );
+    // const redisResponse = await redisClient.mget(
+    //   `summonerId:${summonerId}:win`,
+    //   `summonerId:${summonerId}:lose`,
+    //   `summonerId:${summonerId}:tier`,
+    // );
+    // const isChangeRecord = await this.compareRecord(
+    //   riotApiResponse,
+    //   redisResponse,
+    // );
+    // if (isChangeRecord) {
+    // await this.addPushQueue(summonerId);
+    // await this.changeRecord(riotApiResponse, redisClient, summonerId);
+    // }
+    // });
+    const summonerId =
+      'sqyAJOaCU72G_FT6kahr0RVPCnv6ciDse-xq50DrjgrXpmkGtlwsdFgGkA';
+    const riotApiResponse = plainToInstance(
+      PushRiotApi,
+      await RiotApiJobs(summonerId),
+    );
+    // const redisResponse = await redisClient.mget(
+    //   `summonerId:${summonerId}:win`,
+    //   `summonerId:${summonerId}:lose`,
+    //   `summonerId:${summonerId}:tier`,
+    // );
+    // const isChangeRecord = await this.compareRecord(
+    //   riotApiResponse,
+    //   redisResponse,
+    // );
+    // if (isChangeRecord) {
+    await this.addPushQueue(summonerId);
+    // await this.changeRecord(riotApiResponse, redisClient, summonerId);
+    // }
   }
 
   private async compareRecord(
@@ -51,11 +70,11 @@ export class PushApiService {
     if (riotApiResponse.lose !== Number(lose)) return true;
   }
 
-  private async addPushQueue() {
-    await this.pushQueue.add(
+  private async addPushQueue(summonerId: string) {
+    return await this.pushQueue.add(
       'summonerList',
       {
-        dataId: 1,
+        summonerId,
       },
       { delay: 10000, removeOnComplete: true },
     );

libs/common-config/src/job/src/PushJobModule.ts

@@ -0,0 +1,8 @@
+import { Module } from '@nestjs/common';
+import { PushJobService } from './PushJobService';
+
+@Module({
+  providers: [PushJobService],
+  exports: [PushJobService],
+})
+export class PushJobModule {}

libs/common-config/src/job/src/PushJobService.ts

@@ -0,0 +1,25 @@
+import { Injectable } from '@nestjs/common';
+
+import * as admin from 'firebase-admin';
+import { ServiceAccount } from 'firebase-admin';
+import * as serviceAccount from '../../../../../pog-adminsdk.json';
+
+@Injectable()
+export class PushJobService {
+  constructor() {
+    admin.initializeApp({
+      credential: admin.credential.cert(serviceAccount as ServiceAccount),
+    });
+  }
+
+  async send(summonerId: string) {
+    const message = {
+      notification: {
+        title: 'test',
+        body: 'test',
+      },
+      topic: summonerId,
+    };
+    return Promise.all([await admin.messaging().send(message)]);
+  }
+}