Function hasPaidSubscription

apps/sim/lib/billing/core/subscription.ts:151–179

(
  referenceId: string,
  options: HasPaidSubscriptionOptions = {}
)

 * Fails closed by default: returns true on error to prevent duplicate creation.
 */
export async function hasPaidSubscription(
  referenceId: string,
  options: HasPaidSubscriptionOptions = {}
): Promise<boolean> {
  const { onError = 'assume-active' } = options

  try {
    const [activeSub] = await db
      .select({ id: subscription.id })
      .from(subscription)
      .where(
        and(
          eq(subscription.referenceId, referenceId),
          inArray(subscription.status, ENTITLED_SUBSCRIPTION_STATUSES)
        )
      )
      .limit(1)

    return !!activeSub
  } catch (error) {
    logger.error('Error checking active subscription', { error, referenceId })

    if (onError === 'throw') {
      throw error
    }

    return true
  }
}

export async function getOrganizationIdForSubscriptionReference(
  referenceId: string