Function handleChargeDispute

apps/sim/lib/billing/webhooks/disputes.ts:23–71

(event: Stripe.Event)

 * Handles charge.dispute.created - blocks the responsible user
 */
export async function handleChargeDispute(event: Stripe.Event): Promise<void> {
  const dispute = event.data.object as Stripe.Dispute

  const customerId = await getCustomerIdFromDispute(dispute)
  if (!customerId) {
    logger.warn('No customer ID found in dispute', { disputeId: dispute.id })
    return
  }

  // Find user by stripeCustomerId (Pro plans)
  const users = await db
    .select({ id: user.id })
    .from(user)
    .where(eq(user.stripeCustomerId, customerId))
    .limit(1)

  if (users.length > 0) {
    await db
      .update(userStats)
      .set({ billingBlocked: true, billingBlockedReason: 'dispute' })
      .where(eq(userStats.userId, users[0].id))

    logger.warn('Blocked user due to dispute', {
      disputeId: dispute.id,
      userId: users[0].id,
    })
    return
  }

  // Find subscription by stripeCustomerId (Team/Enterprise)
  const subs = await db
    .select({ referenceId: subscription.referenceId })
    .from(subscription)
    .where(eq(subscription.stripeCustomerId, customerId))
    .limit(1)

  if (subs.length > 0) {
    const orgId = subs[0].referenceId
    const memberCount = await blockOrgMembers(orgId, 'dispute')

    if (memberCount > 0) {
      logger.warn('Blocked all org members due to dispute', {
        disputeId: dispute.id,
        organizationId: orgId,
        memberCount,
      })
    }
  }
}

/**
 * Handles charge.dispute.closed - unblocks user if dispute was won or warning closed