Function monitorOrganizationCredits

packages/billing/src/org-monitoring.ts:260–314

(params: {
  organizationId: string
  currentBalance: number
  recentUsage: number
  organizationName?: string
  logger: Logger
})

 * Monitors organization credit consumption and sends alerts when needed
 */
export async function monitorOrganizationCredits(params: {
  organizationId: string
  currentBalance: number
  recentUsage: number
  organizationName?: string
  logger: Logger
}): Promise<void> {
  const {
    organizationId,
    currentBalance,
    recentUsage,
    organizationName: _organizationName,
    logger,
  } = params

  const LOW_BALANCE_THRESHOLD = 100 // Credits
  const HIGH_USAGE_THRESHOLD = 1000 // Credits per day

  try {
    // Check for low balance
    if (currentBalance < LOW_BALANCE_THRESHOLD) {
      await sendOrganizationAlert({
        ...params,
        alertType: 'low_balance',
        currentBalance,
        threshold: LOW_BALANCE_THRESHOLD,
      })
    }

    // Check for high usage
    if (recentUsage > HIGH_USAGE_THRESHOLD) {
      await sendOrganizationAlert({
        ...params,
        alertType: 'high_usage',
        usageAmount: recentUsage,
        threshold: HIGH_USAGE_THRESHOLD,
      })
    }

    // Check for negative balance (debt)
    if (currentBalance < 0) {
      await sendOrganizationAlert({
        ...params,
        alertType: 'failed_consumption',
        currentBalance,
        error: 'Organization has negative credit balance',
      })
    }
  } catch (error) {
    logger.error(
      { organizationId, error },
      'Error monitoring organization credits',
    )
  }
}

/**
 * Tracks organization usage metrics for analytics