# 예시: 로그인 테스트 시나리오
appId: com.hitek.snsb
---
- 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> {
  // 1. tcIds가 명시되지 않으면 해당 버전의 전체 TC 조회
  const tcIds = dto.tcIds ?? (
    await this.testCaseRepository.findByVersionId(dto.versionId)
  ).map(tc => tc.id);
 
  // 2. Run 레코드 생성
  const run = await this.runRepository.save({
    versionId: dto.versionId,
    status: 'queued',
  });
 
  // 3. SQS에 Job 푸시
  await this.queueService.enqueue({
    runId: run.id,
    tcIds,
    versionId: dto.versionId,
  });
 
  return run;
}

// sqs-queue.service.ts
async enqueue(job: Job): Promise<void> {
  await this.sqsClient.send(new SendMessageCommand({
    QueueUrl: process.env.SQS_QUEUE_URL,
    MessageBody: JSON.stringify(job),
  }));
}

// worker.ts - 핵심 루프
async function pollAndProcess() {
  while (true) {
    // 1. SQS Long Polling (최대 20초 대기)
    const response = await sqsClient.send(new ReceiveMessageCommand({
      QueueUrl: process.env.SQS_QUEUE_URL,
      MaxNumberOfMessages: 1,
      WaitTimeSeconds: 20,  // Long Polling
    }));
 
    if (!response.Messages?.length) continue;
 
    const message = response.Messages[0];
    const job: Job = JSON.parse(message.Body!);
 
    // 2. 메시지 먼저 삭제 (중복 실행 방지)
    await sqsClient.send(new DeleteMessageCommand({
      QueueUrl: process.env.SQS_QUEUE_URL,
      ReceiptHandle: message.ReceiptHandle!,
    }));
 
    // 3. Job 처리
    await processJob(job);
  }
}

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 ?? ''),
        });
      }
    );
  });
}

// 초기 Redis 방식
const result = await redis.brpop('maestro:queue', 0); // 블로킹 대기

// 수정 전
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;