[feat] 스몰톡 생성 시 알림 추가

Author: Ryeolee

src/domain/smalltalk/infrastructure/Challenge.Api.ts

@@ -0,0 +1,11 @@
+import { Injectable } from '@nestjs/common';
+import { ChallengeHelper } from 'src/domain/challenge/application/helper/Challenge.Helper';
+import { Challenge } from 'src/domain/challenge/domain/entity/Challenge';
+@Injectable()
+export class ChallengeApi {
+  constructor(private readonly challengeHelper: ChallengeHelper) {}
+
+  public async requestChallengeById(challengeId: number): Promise<Challenge> {
+    return this.challengeHelper.giveChallengeById(challengeId);
+  }
+}

src/domain/smalltalk/infrastructure/User.Api.ts

@@ -93,4 +93,12 @@ export class UserApi {
     // 검증 x
     return this.affiliationHelper.giveAffiliationAndUserById(affiliationId);
   }
+
+  public async requestUserChallengeAndAffiliationAndUserAndFirebaseTokenByChallengeId(
+    challengeId: number,
+  ) {
+    return this.userChallengeHelper.giveUserChallengeAndAffiliationAndUserAndFirebaseTokenByChallengeId(
+      challengeId,
+    );
+  }
 }

src/domain/smalltalk/service/SmallTalk.Service.ts

@@ -10,12 +10,16 @@ import { SmallTalkErrorCode } from '../../../global/exception/smalltalk/SmallTal
 import { getTodayDateString } from '../util/date';
 import { SmallTalk } from '../domain/entity/SmallTalk';
 import { MutexAlgorithm } from '../../../global/decorator/mutex';
+import { AlarmService } from 'src/global/alarm/Alarm.Service';
+import { ChallengeApi } from '../infrastructure/Challenge.Api';
 
 @Injectable()
 export class SmallTalkService {
   constructor(
     private readonly smallTalkHelper: SmallTalkHelper,
     private readonly userApi: UserApi,
+    private readonly challengeApi: ChallengeApi,
+    private readonly alarmService: AlarmService,
   ) {}
 
   public async checkSmallTalk(challengeId: number, date: string): Promise<SmallTalkResult> {
@@ -33,17 +37,46 @@ export class SmallTalkService {
     question: string,
   ): Promise<void> {
     await this.validateSmallTalkCount(challengeId, getTodayDateString());
-    const userChallengeData =
-      await this.userApi.requestUserChallengeAndAffiliationByChallengeIdWithUserIdAndOrganization(
+    const [userChallengeData, challenge] = await Promise.all([
+      this.userApi.requestUserChallengeAndAffiliationByChallengeIdWithUserIdAndOrganization(
         challengeId,
         userId,
         organization,
-      );
+      ),
+      this.challengeApi.requestChallengeById(challengeId),
+    ]);
     await this.smallTalkHelper.executeInsertSmallTalk(
       challengeId,
       userChallengeData.getId(),
       question,
     );
+    const userChallenges =
+      await this.userApi.requestUserChallengeAndAffiliationAndUserAndFirebaseTokenByChallengeId(
+        challengeId,
+      );
+    const userFirebaseTokenGroups = userChallenges
+      .filter((userChallenge) => userChallenge.getId() !== userChallengeData.getId())
+      .map((userChallenge) => {
+        const user = userChallenge.affiliation.user;
+        return {
+          userId: user.userId,
+          nickName: userChallenge.affiliation.getNickname(),
+          firebaseTokens: user.firebaseTokens ?? [],
+        };
+      })
+      .filter((entry) => entry.firebaseTokens.length > 0);
+    await Promise.all(
+      userFirebaseTokenGroups.map((group) => {
+        const engineValues = group.firebaseTokens.map((token) => token.engineValue);
+        return this.alarmService.sendPushAlarm(
+          group.userId,
+          engineValues,
+          `🚨${organization} ${challenge.getName()}챌린지 스몰톡 생성🚨$`,
+          `${userChallengeData.getAffiliation().getNickname()}님이 스몰톡을 생성했습니다. 확인해보세요😃`,
+          'https://your-url.com',
+        );
+      }),
+    );
   }
 
   private async validateSmallTalkCount(challengeId: number, date: string) {

src/domain/smalltalk/service/SmallTalkComment.Service.ts

@@ -27,6 +27,10 @@ export class SmallTalkCommentService {
       affiliationData.getId(),
       agoraComment,
     );
+    // smallTalkId를 통해 challengeId를 구함.
+
+    // challengeId를 통해 userChallenge -> affliliation -> user -> firebaseToken을 가져온다.
+    //  생성한 자신을 제외한, 같은 소속의 유저들에게 알림을 보냄 -> 템플릿 댓글과 같은 로직 수행
   }
 
   public async bringSmallTalkCommentRead(

src/domain/smalltalk/smalltalk.module.ts

@@ -13,9 +13,12 @@ import { SmallTalkDao } from './domain/repository/dao/SmallTalk.Dao';
 import { SmallTalkCommentDao } from './domain/repository/dao/SmallTalkComment.Dao';
 import { UserApi } from './infrastructure/User.Api';
 import { SmallTalkVerifyService } from 'src/global/exception/smalltalk/SmallTalkVerify.Service';
+import { AlarmService } from 'src/global/alarm/Alarm.Service';
+import { ChallengeApi } from './infrastructure/Challenge.Api';
+import { ChallengeModule } from '../challenge/challenge.module';
 
 @Module({
-  imports: [TypeOrmModule.forFeature([SmallTalk, SmallTalkComment]), UserModule],
+  imports: [TypeOrmModule.forFeature([SmallTalk, SmallTalkComment]), UserModule, ChallengeModule],
   providers: [
     { provide: 'smallTalkImpl', useClass: SmallTalkDao },
     { provide: 'smallTalkCommentImpl', useClass: SmallTalkCommentDao },
@@ -24,7 +27,9 @@ import { SmallTalkVerifyService } from 'src/global/exception/smalltalk/SmallTalk
     SmallTalkHelper,
     SmallTalkCommentHelper,
     UserApi,
+    ChallengeApi,
     SmallTalkVerifyService,
+    AlarmService,
   ],
   controllers: [SmallTalkController, SmallTalkCommentController],
   exports: [SmallTalkHelper, SmallTalkCommentHelper],

src/domain/user/domain/repository/UserChallenge.Repository.ts

@@ -50,4 +50,7 @@ export interface UserChallengeRepository extends Repository<UserChallenge> {
   findUserChallengeByChallengeId(challengeId: number): Promise<UserChallenge[]>;
   updateUserChallengeDeposit(challengeDeposit: ChallengeDeposit[]): Promise<void>;
   findUserChallengeById(userChallengeId: number): Promise<UserChallenge>;
+  findUserChallengeAndAffiliationAndUserAndFirebaseTokenByChallengeId(
+    challengeId: number,
+  ): Promise<UserChallenge[]>;
 }

src/domain/user/domain/repository/dao/UserChallenge.Dao.ts

@@ -237,4 +237,18 @@ export class UserChallengeDao extends Repository<UserChallenge> implements UserC
       })
       .getOne();
   }
+
+  async findUserChallengeAndAffiliationAndUserAndFirebaseTokenByChallengeId(
+    challengeId: number,
+  ): Promise<UserChallenge[]> {
+    return this.dataSource
+      .createQueryBuilder()
+      .select('uc')
+      .from(UserChallenge, 'uc')
+      .innerJoinAndSelect('uc.affiliation', 'a', 'a.affiliation_id = uc.affiliation_id')
+      .innerJoinAndSelect('a.user', 'u', 'u.user_id = a.user_id')
+      .leftJoinAndSelect('u.firebaseTokens', 'ft', 'ft.user_id = u.user_id')
+      .where('uc.challenge_id = :challengeId', { challengeId })
+      .getMany();
+  }
 }

src/domain/user/helper/UserChallenge.Helper.ts

@@ -185,4 +185,10 @@ export class UserChallengeHelper {
   async executeInsertWritonerChallenge(affiliation: Affiliation) {
     return this.writoner.execute(affiliation);
   }
+
+  async giveUserChallengeAndAffiliationAndUserAndFirebaseTokenByChallengeId(challengeId: number) {
+    return this.userChallengeRepository.findUserChallengeAndAffiliationAndUserAndFirebaseTokenByChallengeId(
+      challengeId,
+    );
+  }
 }