Overview

import { scrawn } from "@scrawn/core";

const biller = scrawn({
  apiKey: process.env.SCRAWN_KEY as `scrn_${string}`,
  baseURL: process.env.SCRAWN_BASE_URL || "http://localhost:8069",
});

async function* generateUsage() {
  yield {
    userId: "user-123",
    model: "gpt-4",
    inputTokens: 100,
    outputTokens: 50,
    inputDebit: 3,     // 3¢ per input token
    outputDebit: 6,    // 6¢ per output token
  };
}

const response = await biller.aiTokenStreamConsumer(generateUsage());
// → { eventsProcessed: 1 }

async function* tokenStream() {
  yield {
    userId: "user-123",
    model: "gpt-4",
    inputTokens: 100,
    outputTokens: 50,
    inputDebit: 3,
    outputDebit: 6,
  };
}

const { response, stream } = await biller.aiTokenStreamConsumer(
  tokenStream(),
  { return: true }
);

// Stream tokens to user while billing runs in background
for await (const token of stream) {
  process.stdout.write(token.outputTokens.toString());
}

const result = await response;