Function handleSubscriptionCreated

apps/sim/lib/billing/webhooks/subscription.ts:202–270

(subscriptionData: {
  id: string
  referenceId: string
  plan: string | null
  status: string
  periodStart?: Date | null
  periodEnd?: Date | null
})

 * Handle new subscription creation - reset usage if transitioning from free to paid
 */
export async function handleSubscriptionCreated(subscriptionData: {
  id: string
  referenceId: string
  plan: string | null
  status: string
  periodStart?: Date | null
  periodEnd?: Date | null
}) {
  try {
    const otherActiveSubscriptions = await db
      .select()
      .from(subscription)
      .where(
        and(
          eq(subscription.referenceId, subscriptionData.referenceId),
          inArray(subscription.status, ENTITLED_SUBSCRIPTION_STATUSES),
          ne(subscription.id, subscriptionData.id) // Exclude current subscription
        )
      )

    const wasFreePreviously = otherActiveSubscriptions.length === 0
    const isPaidPlan = isPaid(subscriptionData.plan)

    if (wasFreePreviously && isPaidPlan) {
      logger.info('Detected free -> paid transition, resetting usage', {
        subscriptionId: subscriptionData.id,
        referenceId: subscriptionData.referenceId,
        plan: subscriptionData.plan,
      })

      await resetUsageForSubscription({
        plan: subscriptionData.plan,
        referenceId: subscriptionData.referenceId,
        periodStart: subscriptionData.periodStart ?? null,
        periodEnd: subscriptionData.periodEnd ?? null,
      })

      logger.info('Successfully reset usage for free -> paid transition', {
        subscriptionId: subscriptionData.id,
        referenceId: subscriptionData.referenceId,
        plan: subscriptionData.plan,
      })
    } else {
      logger.info('No usage reset needed', {
        subscriptionId: subscriptionData.id,
        referenceId: subscriptionData.referenceId,
        plan: subscriptionData.plan,
        wasFreePreviously,
        isPaidPlan,
        otherActiveSubscriptionsCount: otherActiveSubscriptions.length,
      })
    }

    if (wasFreePreviously && isPaidPlan) {
      captureServerEvent(subscriptionData.referenceId, 'subscription_created', {
        plan: subscriptionData.plan ?? 'unknown',
        status: subscriptionData.status,
        reference_id: subscriptionData.referenceId,