Function expireActiveBlockGrants

packages/billing/src/subscription.ts:553–582

(params: {
  userId: string
  subscriptionId: string
  logger: Logger
  conn?: DbConn
})

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

export async function expireActiveBlockGrants(params: {
  userId: string
  subscriptionId: string
  logger: Logger
  conn?: DbConn
}): Promise<number> {
  const { userId, subscriptionId, logger, conn = db } = params
  const now = new Date()

  const expired = await conn
    .update(schema.creditLedger)
    .set({ expires_at: now })
    .where(
      and(
        eq(schema.creditLedger.user_id, userId),
        eq(schema.creditLedger.type, 'subscription'),
        gt(schema.creditLedger.expires_at, now),
      ),
    )
    .returning({ operation_id: schema.creditLedger.operation_id })

  if (expired.length > 0) {
    logger.info(
      { userId, subscriptionId, expiredCount: expired.length },
      'Expired active block grants',
    )
  }

  return expired.length
}

// ---------------------------------------------------------------------------
// Subscription lookup