방관자가 아닌실행자입니다.

@Injectable()
export class SagaOrchestratorService implements OnModuleInit {

  private static readonly STEP_TIMEOUTS: Record<SagaStep, number> = {
    [SagaStep.DB_SAVED]: 5 * 60 * 1000,       // 5분
    [SagaStep.GITHUB_QUEUED]: 15 * 60 * 1000,  // 15분
    [SagaStep.AI_QUEUED]: 30 * 60 * 1000,      // 30분
  };

  // Startup — 미완료 Saga 자동 재개
  async onModuleInit(): Promise<void> {
    const oneHourAgo = new Date(Date.now() - 60 * 60 * 1000);
    const incomplete = await this.submissionRepo.find({
      where: {
        sagaStep: Not(In([SagaStep.DONE, SagaStep.FAILED])),
        createdAt: MoreThan(oneHourAgo),
      },
    });
    for (const sub of incomplete) {
      await this.resumeSaga(sub);
    }
  }

  // 낙관적 락 + 멱등성
  async advanceToGitHubQueued(id: string): Promise<void> {
    const result = await this.submissionRepo.update(
      { id, sagaStep: SagaStep.DB_SAVED },
      { sagaStep: SagaStep.GITHUB_QUEUED },
    );
    if (result.affected === 0) return;  // 이미 진행됨
    await this.mqPublisher.publishGitHubPush({ submissionId: id });
  }
}