이벤트 및 알림 관리

[Miensoap]

DB에 알림 저장

알림 데이터를 DB에 저장하여 이력이 남도록 하고, 사용자가 로그인할 때 조회 가능
알림 생성 시 트랜잭션을 통해 필요한 경우 알림 저장이 보장되도록 설정

실시간 알림 전송

• 웹소켓(WebSocket)
• Socket.IO
• Pub/Sub 시스템: Redis Pub/Sub이나 Kafka 같은 메시지 큐를 활용

알림 서비스 구조

알림 생성 시, DB에 저장하는 동시에 웹소켓을 통해 사용자에게 실시간으로 전송

사용자 로그인 시 서버는 DB에 저장된 모든 알림을 조회하여 화면에 표시하고,
새 알림이 오면 (웹소켓) 으로 실시간 알림을 받아 추가로 표시.

알림 상태 업데이트

알림을 읽음 처리할 경우, 알림의 read 필드를 업데이트해 DB와 실시간 상태를 일치시킴
읽음 처리된 알림은 이후 알림 목록에서 제외되거나 상태가 변경되도록 구현

[Miensoap]

프록시 이용한 트랜잭션 데코레이터

1. getTransactionalRepository

Proxy와 AsyncLocalStorage를 통해 Repository 메서드를 가로채고,
트랜잭션이 시작된 상태라면 AsyncLocalStorage에 저장된 QueryRunner를 통해 메서드를 실행

import { AsyncLocalStorage } from 'async_hooks';
import { QueryRunner, Repository } from 'typeorm';

const asyncLocalStorage = new AsyncLocalStorage<QueryRunner>();

// SoftDeleteRepository를 받아 트랜잭션 전파가 가능한 프록시로 래핑
export function wrapWithTransaction<T>(repository: Repository<T>): Repository<T> {
  return new Proxy(repository, {
    get(target, prop, receiver) {
      const originalMethod = target[prop as keyof Repository<T>];

      if (typeof originalMethod !== 'function') return Reflect.get(target, prop, receiver);

      return (...args: any[]) => {
        const queryRunner = asyncLocalStorage.getStore();
        if (queryRunner) {
          return queryRunner.manager.getRepository(target.target)[prop](...args);
        } else {
          return (originalMethod as Function).apply(target, args);
        }
      };
    },
  });
}

2. TransactionInterceptor

트랜잭션 데코레이터가 적용된 서비스 메서드가 호출될 때 트랜잭션을 시작하고,
AsyncLocalStorage에 QueryRunner를 저장

import { Injectable, NestInterceptor, ExecutionContext, CallHandler } from '@nestjs/common';
import { Observable } from 'rxjs';
import { DataSource } from 'typeorm';
import { tap, catchError } from 'rxjs/operators';

@Injectable()
export class TransactionInterceptor implements NestInterceptor {
  constructor(private dataSource: DataSource) {}

  async intercept(context: ExecutionContext, next: CallHandler): Promise<Observable<any>> {
    const queryRunner = this.dataSource.createQueryRunner();
    await queryRunner.connect();
    await queryRunner.startTransaction();

    // 요청별 QueryRunner를 AsyncLocalStorage에 저장
    return asyncLocalStorage.run(queryRunner, () => {
      return next
        .handle()
        .pipe(
          tap(async () => {
            await queryRunner.commitTransaction();
          }),
          catchError(async (error) => {
            await queryRunner.rollbackTransaction();
            throw error;
          }),
        )
        .finally(async () => {
          await queryRunner.release();
        });
    });
  }
}

export function Transactional() {
  return applyDecorators(UseInterceptors(TransactionInterceptor));
}

적용

@Module({
  providers: [
    MyService,
    {
      provide: CourseRepository,
      useFactory: (dataSource: DataSource) => {
        const courseRepository = new CourseRepository(dataSource);
        return wrapWithTransaction(courseRepository);
      },
      inject: [DataSource],
    },
  ],
  exports: [CourseRepository],
})
export class CourseModule {}

@Injectable()
export class CourseService {
  constructor(private readonly courseRepository: CourseRepository) {}
  
  @Transactional()
  async someMethod() {
    const result = await this.courseRepository.findById(1);
    // 트랜잭션 내에서 다른 메서드도 실행 가능
  }
}

[Miensoap]

가능하면 전파 레벨 설정 구현

REQUIRED: 트랜잭션이 없으면 새로 시작하고, 이미 존재하면 기존 트랜잭션을 사용.
REQUIRES_NEW: 항상 새 트랜잭션을 시작.
SUPPORTS: 트랜잭션이 있으면 그 안에서 실행하고, 없으면 트랜잭션 없이 실행.

[Miensoap]

https://www.npmjs.com/package/typeorm-transactional

만들어진게 있네용