# 예시: 로그인 테스트 시나리오
appId: com.example.medical
---
- launchApp
- tapOn: "아이디 입력"
- inputText: "test@hospital.com"
- tapOn: "비밀번호 입력"
- inputText: "password123"
- tapOn: "로그인"
- assertVisible: "검사 목록"

-- 핵심 테이블 구조
CREATE TABLE test_cases (
    id          UUID PRIMARY KEY,
    version_id  UUID REFERENCES versions(id),
    tc_id       VARCHAR NOT NULL,           -- 사람이 읽을 수 있는 ID (예: TC-001)
    title       VARCHAR NOT NULL,
    yaml_content TEXT NOT NULL,             -- Maestro YAML 원문
    automation_status VARCHAR NOT NULL      -- in_progress | pending | completed | excluded
    CHECK (automation_status IN ('in_progress', 'pending', 'completed', 'excluded'))
);
 
CREATE TABLE runs (
    id          UUID PRIMARY KEY,
    version_id  UUID REFERENCES versions(id),
    status      VARCHAR NOT NULL,           -- queued | running | done | failed
    created_at  TIMESTAMP DEFAULT NOW()
);
 
CREATE TABLE run_results (
    id          UUID PRIMARY KEY,
    run_id      UUID REFERENCES runs(id),
    tc_id       UUID REFERENCES test_cases(id),
    status      VARCHAR NOT NULL            -- pass | fail | skipped
);

// runs.service.ts
async create(dto: CreateRunDto): Promise<Run> {
  // tcIds가 없으면 해당 버전의 전체 TC를 대상으로
  const tcIds = dto.tcIds ?? (
    await this.testCaseRepository.findByVersionId(dto.versionId)
  ).map(tc => tc.id);
 
  // Run을 'queued' 상태로 적재. 이 row 자체가 대기열이다
  return this.runRepository.save({
    versionId: dto.versionId,
    tcIds,
    status: 'queued',
  });
}

// 워커가 폴링하는 엔드포인트 (GET /v1/runs/next)
async claimNext(): Promise<Run | null> {
  // 가장 오래 기다린 queued Run 하나를 running으로 선점하고 반환
  // UPDATE runs SET status='running'
  //  WHERE id = (SELECT id FROM runs WHERE status='queued'
  //              ORDER BY created_at LIMIT 1)
  //  RETURNING *
  return this.runRepository.claimOneQueued();
}

// worker.ts - 핵심 루프
async function pollAndProcess() {
  while (true) {
    // 다음 Run 요청 (큐 역할은 API 뒤의 DB가 한다)
    const job = await fetchNextRun();  // GET /v1/runs/next
 
    if (!job) {
      await sleep(5000);  // 대기 중인 Run이 없으면 5초 쉬고 다시
      continue;
    }
 
    await processJob(job);  // 결과는 API로 보내 runs.status 갱신
  }
}

async function processJob(job: Job) {
  for (const tcId of job.tcIds) {
    // 1. API 서버에서 YAML 가져오기
    const tc = await fetchTestCase(tcId);
 
    // 2. 임시 파일로 저장
    const tmpFile = `/tmp/maestro-${tcId}.yaml`;
    fs.writeFileSync(tmpFile, tc.yamlContent);
 
    // 3. Maestro 실행
    const result = await runMaestro(tmpFile);
 
    // 4. 결과 API 서버로 전송
    await postResult(job.runId, tcId, result);
 
    // 5. 임시 파일 정리
    fs.unlinkSync(tmpFile);
  }
}
 
async function runMaestro(yamlPath: string) {
  return new Promise((resolve) => {
    execFile(
      process.env.MAESTRO_BIN!,
      ['test', yamlPath],
      {
        env: {
          ...process.env,
          LANG: 'en_US.UTF-8',   // 한글 로그 깨짐 방지
          LC_ALL: 'en_US.UTF-8',
        },
      },
      (err, stdout, stderr) => {
        console.log('[maestro stdout]', stdout);  // 로컬 디버깅용
        console.log('[maestro stderr]', stderr);
        resolve({
          success: !err,
          stdout,
          stderr: stderr || (err?.message ?? ''),
        });
      }
    );
  });
}

// 수정 전
execFile(MAESTRO_BIN, ['test', yamlPath], callback);
 
// 수정 후
execFile(MAESTRO_BIN, ['test', yamlPath], {
  env: { ...process.env, LANG: 'en_US.UTF-8', LC_ALL: 'en_US.UTF-8' }
}, callback);

// 수정 전
const data = await res.json(); // 빈 body에서 실패
 
// 수정 후
const text = await res.text();
const data = text ? JSON.parse(text) : undefined;