Offline review and revision

import {
  defineJob,
  fnJob,
  loop,
  predicate,
  revisionRequest,
  run,
} from '@obversa/runtime';

let attempts = 0;
let config: { timeoutMs?: number } | undefined;

const productionLine = defineJob(
  loop({
    name: 'write-config',
    max: 4,
    body: fnJob('author', async (ctx) => {
      attempts += 1;
      const fix = ctx.lastReview?.revision?.reason;
      config = {};
      if (fix) config.timeoutMs = 1_000;
      return {
        status: 'pass',
        summary: fix ? `added a timeout after: ${fix}` : 'wrote the base config',
      };
    }),
    until: predicate(() => config !== undefined, 'a draft exists'),
    review: fnJob('review', async () =>
      (config?.timeoutMs ?? 0) > 0
        ? { status: 'pass', summary: 'config is complete' }
        : revisionRequest({
            reason: 'Missing a request timeout.',
            findings: [
              {
                reviewer: 'correctness',
                evidence: 'No timeout set; a hung upstream call blocks forever.',
              },
            ],
          }),
    ),
  }),
);

async function main(): Promise<void> {
  const result = await run(productionLine);

  console.log(
    JSON.stringify(
      {
        status: result.outcome.status,
        attempts,
        summary: result.outcome.summary,
      },
      null,
      2,
    ),
  );

  if (result.outcome.status !== 'pass') process.exitCode = 1;
}

void main();

pnpm example:offline

pnpm exec tsx offline-review.line.ts

{
  "status": "pass",
  "attempts": 2,
  "summary": "config is complete"
}