How ChainOps billed
$180k/month from a single AI agent workflow

// Step 1: Register the task when lead arrives
async function onLeadReceived(lead) {
  const taskId = crypto.randomUUID();

  const res = await fetch('https://rev.polsia.app/v1/meter', {
    method: 'POST',
    headers: {
      'Authorization': 'Bearer YOUR_API_KEY',
      'Content-Type': 'application/json',
      'Idempotency-Key': taskId,
    },
    body: JSON.stringify({
      agent_id:     'lead-qualifier-v3',
      action:       'lead.received',
      outcome:      'pending',    // ← deferred: bonus not charged yet
      metadata: {
        lead_id:    lead.id,
        source:     lead.source,
        task_id:    taskId,         // store this for later resolve
      },
    }),
  });

  const { price_charged, outcome_id } = await res.json();
  console.log(`Base fee charged: $${price_charged}`);
  return outcome_id;            // save this to resolve later
}

// Step 2: Meter after LLM call — captures tokens and outcome
async function enrichLead(lead) {
  // Your LLM call
  const llmResponse = await openai.chat.completions.create({
    model: 'gpt-4o',
    messages: [{ role: 'user', content: `Enrich and score: ${lead.company}` }],
  });

  // Fire meter event — Rev computes price from your pricing config
  const meterRes = await fetch('https://rev.polsia.app/v1/meter', {
    method: 'POST',
    headers: {
      'Authorization': 'Bearer YOUR_API_KEY',
      'Content-Type': 'application/json',
    },
    body: JSON.stringify({
      agent_id:      'lead-qualifier-v3',
      action:        'lead.enriched',
      tokens_input:  llmResponse.usage.prompt_tokens,
      tokens_output: llmResponse.usage.completion_tokens,
      outcome:       'success',
      metadata: {
        lead_id:      lead.id,
        enriched_at: new Date().toISOString(),
        model:       'gpt-4o',
      },
    }),
  });

  const { price_charged } = await meterRes.json();
  console.log(`Token rate charged: $${price_charged}`);
}

// Step 3: Resolve outcome when lead qualifies
async function resolveLeadOutcome(outcomeId, lead, score) {
  const resolvedOutcome = score >= 70 ? 'success' : 'failure';

  const res = await fetch(
    `https://rev.polsia.app/v1/outcomes/${outcomeId}/resolve`,
    {
      method: 'POST',
      headers: {
        'Authorization': 'Bearer YOUR_API_KEY',
        'Content-Type': 'application/json',
      },
      body: JSON.stringify({
        outcome: resolvedOutcome,
        metadata: {
          lead_id:    lead.id,
          score:       score,
          resolved_at: new Date().toISOString(),
        },
      }),
    }
  );

  const { outcome_bonus, total_charged } = await res.json();
  if (resolvedOutcome === 'success') {
    console.log(`Outcome bonus: $${outcome_bonus} — lead qualified!`);
  }
}