Function ensureActiveBlockGrant

packages/billing/src/subscription.ts:400–423

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

}

export async function ensureActiveBlockGrant(params: {
  userId: string
  subscription: SubscriptionRow
  logger: Logger
}): Promise<BlockGrantResult> {
  const { userId, subscription, logger } = params
  const subscriptionId = subscription.stripe_subscription_id

  const { result } = await withAdvisoryLockTransaction({
    callback: async (tx) => {
      return ensureActiveBlockGrantCallback({
        conn: tx,
        userId,
        subscription,
        logger,
      })
    },
    lockKey: `user:${userId}`,
    context: { userId, subscriptionId },
    logger,
  })

  return result
}

/**
 * Combined function that gets the active subscription and ensures a block grant exists.