[feat] Saga에서 발생하는 처리되지 않은 예외 처리 추가

Author: easdkr

src/user/saga/user.saga.ts

@@ -1,11 +1,28 @@
 import { Injectable } from '@nestjs/common';
-import { ICommand, ofType, Saga } from '@nestjs/cqrs';
-import { map, Observable } from 'rxjs';
+import {
+  ICommand,
+  ofType,
+  Saga,
+  UnhandledExceptionBus,
+  UnhandledExceptionInfo,
+} from '@nestjs/cqrs';
+import { map, Observable, Subject, takeUntil } from 'rxjs';
 import { CreateUserEvent } from '../event';
 import { CreateRegisterCouponCommand } from '../command';
 
 @Injectable()
 export class UserSaga {
+  private destroy$ = new Subject<void>();
+
+  constructor(private unhandledExceptionsBus: UnhandledExceptionBus) {
+    this.unhandledExceptionsBus
+      .pipe(takeUntil(this.destroy$))
+      .subscribe((exceptionInfo: UnhandledExceptionInfo) => {
+        console.error('Unhandled exception in saga:', exceptionInfo);
+        // 재시도나 에러 알림 등 처리
+      });
+  }
+
   /** @Saga() 가 있으면 애플리케이션의 이벤트 스트림을 구독하고 `ofType`으로 처리할 이벤트를 선택  */
   @Saga()
   public userCreated(event$: Observable<any>): Observable<ICommand> {
@@ -15,4 +32,9 @@ export class UserSaga {
       map((event) => new CreateRegisterCouponCommand(fakeCouponId, event.id)),
     );
   }
+
+  onModuleDestroy() {
+    this.destroy$.next();
+    this.destroy$.complete();
+  }
 }