MOPC-App/tests/integration/transition-routing.test.ts

/**
 * I-003: Transition + Routing — Filter Pass → Main + Award Parallel
 */

import { describe, it, expect, beforeAll, afterAll } from 'vitest'
import { prisma } from '../setup'
import {
  createTestUser,
  createTestProgram,
  createTestPipeline,
  createTestTrack,
  createTestStage,
  createTestTransition,
  createTestProject,
  createTestPSS,
  createTestRoutingRule,
  cleanupTestData,
} from '../helpers'
import { executeTransition } from '@/server/services/stage-engine'
import { evaluateRoutingRules, executeRouting } from '@/server/services/routing-engine'

let programId: string
let userIds: string[] = []

beforeAll(async () => {
  const program = await createTestProgram({ name: 'Transition+Routing Test' })
  programId = program.id
})

afterAll(async () => {
  await cleanupTestData(programId, userIds)
})

describe('I-003: Transition + Routing — Parallel Award Track', () => {
  it('transitions a project then routes it to a parallel award track', async () => {
    const admin = await createTestUser('SUPER_ADMIN')
    userIds.push(admin.id)

    const pipeline = await createTestPipeline(programId)

    // Main track: FILTER → EVALUATION
    const mainTrack = await createTestTrack(pipeline.id, {
      name: 'Main',
      kind: 'MAIN',
      sortOrder: 0,
    })
    const filterStage = await createTestStage(mainTrack.id, {
      name: 'Filter',
      stageType: 'FILTER',
      status: 'STAGE_ACTIVE',
      sortOrder: 0,
    })
    const evalStage = await createTestStage(mainTrack.id, {
      name: 'Evaluation',
      stageType: 'EVALUATION',
      status: 'STAGE_ACTIVE',
      sortOrder: 1,
    })
    await createTestTransition(filterStage.id, evalStage.id)

    // Award track (PARALLEL)
    const awardTrack = await createTestTrack(pipeline.id, {
      name: 'Innovation Award',
      kind: 'AWARD',
      sortOrder: 1,
      routingMode: 'PARALLEL',
    })
    const awardEvalStage = await createTestStage(awardTrack.id, {
      name: 'Award Eval',
      stageType: 'EVALUATION',
      status: 'STAGE_ACTIVE',
      sortOrder: 0,
    })

    // Routing rule: projects from France → Award track (parallel)
    await createTestRoutingRule(pipeline.id, awardTrack.id, {
      name: 'France → Innovation Award',
      priority: 0,
      predicateJson: { field: 'project.country', operator: 'eq', value: 'France' },
    })

    // Create project in filter stage
    const project = await createTestProject(programId, { country: 'France' })
    await createTestPSS(project.id, mainTrack.id, filterStage.id, { state: 'PENDING' })

    // Step 1: Transition from filter → evaluation
    const transResult = await executeTransition(
      project.id, mainTrack.id, filterStage.id, evalStage.id,
      'PENDING', admin.id, prisma
    )
    expect(transResult.success).toBe(true)

    // Step 2: Evaluate routing rules
    const matchedRule = await evaluateRoutingRules(
      project.id, evalStage.id, pipeline.id, prisma
    )
    expect(matchedRule).not.toBeNull()
    expect(matchedRule!.destinationTrackId).toBe(awardTrack.id)
    expect(matchedRule!.routingMode).toBe('PARALLEL')

    // Step 3: Execute routing
    const routeResult = await executeRouting(project.id, matchedRule!, admin.id, prisma)
    expect(routeResult.success).toBe(true)

    // Verify: Project should be in BOTH main eval stage AND award eval stage
    const mainPSS = await prisma.projectStageState.findFirst({
      where: { projectId: project.id, stageId: evalStage.id, exitedAt: null },
    })
    expect(mainPSS).not.toBeNull() // Still in main track

    const awardPSS = await prisma.projectStageState.findFirst({
      where: { projectId: project.id, stageId: awardEvalStage.id, exitedAt: null },
    })
    expect(awardPSS).not.toBeNull() // Also in award track
    expect(awardPSS!.state).toBe('PENDING')
  })
})