Function getActiveSubscription

packages/billing/src/subscription.ts:588–607

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

// ---------------------------------------------------------------------------

export async function getActiveSubscription(params: {
  userId: string
  logger: Logger
}): Promise<SubscriptionRow | null> {
  const { userId } = params

  const subs = await db
    .select()
    .from(schema.subscription)
    .where(
      and(
        eq(schema.subscription.user_id, userId),
        eq(schema.subscription.status, 'active'),
      ),
    )
    .orderBy(desc(schema.subscription.updated_at))
    .limit(1)

  return subs[0] ?? null
}

export async function isSubscriber(params: {
  userId: string