Method recordExecutionUsage

apps/sim/lib/logs/execution/logger.ts:1179–1459

(
    workflowId: string | null,
    costSummary: {
      totalCost: number
      totalInputCost: number
      totalOutputCost: number
      totalTokens: number
      totalPromptTokens: number
      totalCompletionTokens: number
      baseExecutionCharge: number
      models?: Record<
        string,
        {
          input: number
          output: number
          total: number
          toolCost?: number
          tokens: { input: number; output: number; total: number }
        }
      >
      charges?: Record<string, { total: number }>
    },
    trigger: ExecutionTrigger['type'],
    executionId?: string,
    billingUserId?: string | null,
    // Pre-resolved billing context. The completion path already fetches the
    // subscription for usage-threshold emails; passing the derived context here
    // lets recordUsage skip a redundant subscription lookup per completion.
    billingContext?: BillingContext
  )

  }

  private async recordExecutionUsage(
    workflowId: string | null,
    costSummary: {
      totalCost: number
      totalInputCost: number
      totalOutputCost: number
      totalTokens: number
      totalPromptTokens: number
      totalCompletionTokens: number
      baseExecutionCharge: number
      models?: Record<
        string,
        {
          input: number
          output: number
          total: number
          toolCost?: number
          tokens: { input: number; output: number; total: number }
        }
      >
      charges?: Record<string, { total: number }>
    },
    trigger: ExecutionTrigger['type'],
    executionId?: string,
    billingUserId?: string | null,
    // Pre-resolved billing context. The completion path already fetches the
    // subscription for usage-threshold emails; passing the derived context here
    // lets recordUsage skip a redundant subscription lookup per completion.
    billingContext?: BillingContext
  ): Promise<number> {
    const statsLog = logger.withMetadata({ workflowId: workflowId ?? undefined, executionId })

    // The usage ledger (recordUsage below) is written regardless of
    // BILLING_ENABLED so cost is available everywhere (incl. self-hosted).
    // Only enforcement (overage/Stripe) is gated on the flag.
    // Returns the amount actually recorded at THIS boundary (the increment), so
    // callers drive usage-threshold math off the delta rather than the
    // cumulative run total (which would double-count pre-pause cost on resume).

    if (!workflowId) {
      statsLog.debug('Workflow was deleted, skipping usage recording')
      return 0
    }

    let recordedIncrement = 0
    try {
      const [workflowRecord] = await db
        .select()
        .from(workflow)
        .where(eq(workflow.id, workflowId))
        .limit(1)

      if (!workflowRecord) {
        statsLog.error('Workflow not found for usage recording')
        return 0
      }

      const userId = billingUserId?.trim() || null