Function main

e2e/telegram-run.ts:283–341

()

// ── Main ───────────────────────────────────────────────────────────────────────

async function main() {
  mkdirSync(RESULTS_DIR, { recursive: true });
  const stamp = new Date().toISOString().replace(/[:.]/g, "-");
  const runDir = join(RESULTS_DIR, stamp);
  mkdirSync(runDir, { recursive: true });

  const results: CaseResult[] = [];
  const filter = process.env["CASE_FILTER"];
  const selected = filter
    ? CASES.filter((c) => c.name.includes(filter))
    : CASES;

  for (const spec of selected) {
    process.stdout.write(`\n──── ${spec.name} ────\n`);
    try {
      const r = await runCase(spec);
      const flag = r.status === "pass" ? "✓" : "✗";
      console.log(
        `  ${flag} ${r.durationMs}ms  len=${r.finalText?.length ?? 0}  samples=${r.samples.length}`,
      );
      if (r.errors.length) console.log("    " + r.errors.join("\n    "));
      if (r.followUp) {
        const fflag = r.followUp.status === "pass" ? "✓" : "✗";
        console.log(
          `    ↳ followUp ${fflag} ${r.followUp.durationMs}ms  len=${r.followUp.finalText?.length ?? 0}  samples=${r.followUp.samples.length}`,
        );
        if (r.followUp.errors.length) {
          console.log("      " + r.followUp.errors.join("\n      "));
        }
      }
      results.push(r);
    } catch (err) {
      console.log(`  ✗ exception: ${(err as Error).message}`);
      results.push({
        name: spec.name,
        prompt: spec.prompt,
        status: "fail",
        errors: [(err as Error).message],
        durationMs: 0,
        finalText: undefined,
        samples: [],
      });
    }
  }

  writeFileSync(
    join(runDir, "report.json"),
    JSON.stringify(
      { ranAt: stamp, mode: AUTOMATED ? "automated" : "manual", results },
      null,
      2,
    ),
  );
  const pass = results.filter((r) => r.status === "pass").length;
  console.log(
    `\n${pass}/${results.length} cases passed. Report: ${runDir}/report.json`,
  );
  process.exit(pass === results.length ? 0 : 1);