An AI task harness.
A check you can run.

// OY1 worked example. Node.js 24+; no dependencies or model calls.
// Uses your OY_API_KEY and creates one saved task in your OY Labs account.
import { randomUUID } from 'node:crypto';
import { pathToFileURL } from 'node:url';

export async function runCheckedTask(call) {
  const trace = [];
  const step = async (name, args) => {
    const task = await call(name, args);
    trace.push({ tool: name, phase: task.phase, version: task.version });
    return task;
  };
  const write = task => ({
    taskId: task.taskId, expectedVersion: task.version, operationId: randomUUID(),
  });
  let task = await step('oy1_begin', {
    goal: 'Calculate three items at 17 plus 9 delivery; check a budget of 65.',
    successCriteria: ['Calculate the total.', 'Check the budget.'],
    operationId: randomUUID(),
  });
  task = await step('oy1_propose', {
    ...write(task), hypothesis: 'A provisional total of 50 needs checking.',
    action: { tool: 'client_calculation', inputSummary: 'Calculate 3 * 17 + 9' },
    predictions: [{ key: 'total', expected: 50 }],
  });
  const total = 3 * 17 + 9;
  task = await step('oy1_observe', {
    ...write(task), actionId: task.pending.id, outcome: 'observed',
    summary: 'The calculation returns 60, contradicting the prediction of 50.',
    values: { total },
    source: { kind: 'calculation', reference: 'JavaScript in checked-task.mjs' },
    criterionResults: [{ criterionId: 'c1', verdict: 'pass', observationKeys: ['total'] }],
  });
  task = await step('oy1_remember', {
    ...write(task), key: 'total', knowledge: 'The calculated total is 60.',
    confidence: 'supported', evidence: [0],
  });
  await step('oy1_recall', { taskId: task.taskId, query: 'total' });
  task = await step('oy1_propose', {
    ...write(task), hypothesis: 'The observed total of 60 fits the 65 budget.',
    revisionReason: 'The calculation contradicted the provisional total; use 60.',
    action: { tool: 'client_calculation', inputSummary: 'Compare total <= 65' },
    predictions: [{ key: 'withinBudget', expected: true }],
  });
  task = await step('oy1_observe', {
    ...write(task), actionId: task.pending.id, outcome: 'observed',
    summary: 'The total is within budget.', values: { withinBudget: total <= 65 },
    source: { kind: 'calculation', reference: 'JavaScript in checked-task.mjs' },
    criterionResults: [{ criterionId: 'c2', verdict: 'pass', observationKeys: ['withinBudget'] }],
  });
  task = await step('oy1_finish', {
    ...write(task), answer: `The total is ${total}, leaving ${65 - total} within the 65 budget.`,
  });
  return { trace, answer: task.answer, assessment: task.assessment, modelCalls: 0 };
}

export async function connectOY1({ endpoint = 'https://oylabs.ai/mcp', apiKey }) {
  if (!apiKey) throw new Error('Set OY_API_KEY to a personal key with harness:run permission.');
  let id = 0, protocolVersion;
  const rpc = async (method, params, notification = false) => {
    const response = await fetch(endpoint, {
      method: 'POST',
      headers: {
        Authorization: `Bearer ${apiKey}`,
        'Content-Type': 'application/json',
        Accept: 'application/json, text/event-stream',
        ...(protocolVersion ? { 'MCP-Protocol-Version': protocolVersion } : {}),
      },
      body: JSON.stringify({ jsonrpc: '2.0', ...(notification ? {} : { id: ++id }), method, params }),
      signal: AbortSignal.timeout(30000),
    });
    if (!response.ok) throw new Error(`MCP HTTP ${response.status}. Check your connection and key permissions.`);
    if (notification) return;
    const message = await response.json();
    if (message.error) throw new Error(`MCP error ${message.error.code}: ${message.error.message}`);
    return message.result;
  };
  const initialized = await rpc('initialize', {
    protocolVersion: '2025-11-25', capabilities: {},
    clientInfo: { name: 'oy1-worked-example', version: '1.0.0' },
  });
  protocolVersion = initialized.protocolVersion;
  await rpc('notifications/initialized', {}, true);
  return async (name, args) => {
    const result = await rpc('tools/call', { name, arguments: args });
    if (result.isError) throw new Error(`${name} failed. Stop and recall the task before retrying.`);
    return result.structuredContent.result;
  };
}

if (process.argv[1] && import.meta.url === pathToFileURL(process.argv[1]).href) {
  const call = await connectOY1({ apiKey: process.env.OY_API_KEY });
  console.log(JSON.stringify(await runCheckedTask(call), null, 2));
}