Function ensureBilled

web/src/llm-api/openrouter.ts:377–399

()

  // capture what we were charged. Without this, a well-timed mid-stream failure
  // lets the caller walk away with free completion tokens.
  const ensureBilled = async () => {
    if (state.billed || !state.generationId) return
    await new Promise((resolve) =>
      setTimeout(resolve, GENERATION_LOOKUP_DELAY_MS),
    )
    await fallbackBillFromGeneration({
      generationId: state.generationId,
      openrouterApiKey,
      userId,
      stripeCustomerId,
      agentId,
      clientId,
      clientRequestId,
      costMode,
      byok,
      startTime,
      state,
      request: auditRequest,
      fetch,
      logger,
      insertMessage: insertMessageBigquery,
    })
  }

  // Create a ReadableStream that Next.js can handle
  const stream = new ReadableStream({