Function getOrganizationAlerts

packages/billing/src/org-monitoring.ts:45–124

(params: {
  organizationId: string
  logger: Logger
})

 * Gets organization alerts for UI display
 */
export async function getOrganizationAlerts(params: {
  organizationId: string
  logger: Logger
}): Promise<OrganizationAlert[]> {
  const { organizationId, logger } = params

  const alerts: OrganizationAlert[] = []

  try {
    // Get organization settings
    const organization = await db.query.org.findFirst({
      where: eq(schema.org.id, organizationId),
    })

    if (!organization) {
      return alerts
    }

    // Check current balance
    const now = new Date()
    const quotaResetDate = getNextQuotaReset(now)
    const { balance, usageThisCycle } =
      await calculateOrganizationUsageAndBalance({
        ...params,
        quotaResetDate,
        now,
      })

    // Low balance alert
    if (organization.billing_alerts && balance.netBalance < 500) {
      alerts.push({
        id: `low-balance-${organizationId}`,
        type: 'low_balance',
        severity: balance.netBalance < 100 ? 'critical' : 'warning',
        title: 'Low Credit Balance',
        message: `Organization has ${balance.netBalance} credits remaining`,
        timestamp: new Date(),
      })
    }

    // High usage alert
    if (organization.usage_alerts && usageThisCycle > 5000) {
      alerts.push({
        id: `high-usage-${organizationId}`,
        type: 'high_usage',
        severity: 'info',
        title: 'High Usage This Cycle',
        message: `Organization has used ${usageThisCycle} credits this billing cycle`,
        timestamp: new Date(),
      })
    }

    // Credit limit alert
    if (
      organization.credit_limit &&
      usageThisCycle >= organization.credit_limit * 0.9
    ) {
      alerts.push({