Function getOrganizationSubscription

apps/sim/lib/billing/core/billing.ts:51–77

(
  organizationId: string,
  options: GetOrganizationSubscriptionOptions = {}
)

 * omit the executor (or pass `db`).
 */
export async function getOrganizationSubscription(
  organizationId: string,
  options: GetOrganizationSubscriptionOptions = {}
) {
  const { onError = 'return-null', executor = db } = options
  try {
    const orgSubs = await executor
      .select()
      .from(subscription)
      .where(
        and(
          eq(subscription.referenceId, organizationId),
          inArray(subscription.status, ENTITLED_SUBSCRIPTION_STATUSES)
        )
      )
      .orderBy(desc(subscription.periodStart), desc(subscription.id))
      .limit(1)

    return orgSubs.length > 0 ? orgSubs[0] : null
  } catch (error) {
    logger.error('Error getting organization subscription', { error, organizationId })
    if (onError === 'throw') {
      throw error
    }
    return null
  }
}

/**
 * BILLING MODEL: