Function recordCost

scripts/pipeline/batch-processor.ts:276–308

(
  documentId: number,
  costCents: number,
  inputTokens: number,
  outputTokens: number,
  modelId?: string,
)

}

async function recordCost(
  documentId: number,
  costCents: number,
  inputTokens: number,
  outputTokens: number,
  modelId?: string,
): Promise<void> {
  const today = new Date().toISOString().slice(0, 10);
  const config = getModelConfig(modelId);

  await db.insert(budgetTracking).values({
    date: today,
    model: config.model,
    inputTokens,
    outputTokens,
    costCents: Math.round(costCents * 100) / 100,
    documentId,
    jobType: "ai_analysis",
  });

  // Update per-document cost
  const existing = await db
    .select({ aiCostCents: documents.aiCostCents })
    .from(documents)
    .where(eq(documents.id, documentId))
    .limit(1);

  const currentCost = existing[0]?.aiCostCents ?? 0;
  await db
    .update(documents)
    .set({ aiCostCents: currentCost + Math.ceil(costCents) })
    .where(eq(documents.id, documentId));
}

function formatETA(progress: BatchProgress): string {
  if (progress.completed === 0) return "calculating...";