Function buildSubscriptionUpdate

server/src/db/organization-db.ts:343–389

(
  subscription: {
    status: string;
    id: string;
    current_period_end: number | null;
    canceled_at: number | null;
    items: { data: Array<{ price: {
      unit_amount: number | null;
      currency: string;
      recurring: { interval: string } | null;
      id: string;
      product: string | { id: string; name?: string };
      lookup_key: string | null;
    } }> };
  },
  isPersonal: boolean,
)

 * Single source of truth for tier resolution — all write paths should use this.
 */
export function buildSubscriptionUpdate(
  subscription: {
    status: string;
    id: string;
    current_period_end: number | null;
    canceled_at: number | null;
    items: { data: Array<{ price: {
      unit_amount: number | null;
      currency: string;
      recurring: { interval: string } | null;
      id: string;
      product: string | { id: string; name?: string };
      lookup_key: string | null;
    } }> };
  },
  isPersonal: boolean,
): SubscriptionUpdatePayload {
  const priceData = subscription.items?.data?.[0]?.price;
  const amount = priceData?.unit_amount ?? null;
  const currency = priceData?.currency ?? null;
  const interval = priceData?.recurring?.interval ?? null;
  const lookupKey = priceData?.lookup_key ?? null;
  const productRef = priceData?.product;
  const productId = typeof productRef === 'string' ? productRef : productRef?.id ?? null;
  const productName = typeof productRef === 'object' ? productRef?.name ?? null : null;

  const membershipTier = (TIER_PRESERVING_STATUSES as readonly string[]).includes(subscription.status)
    ? (tierFromLookupKey(lookupKey) ?? inferMembershipTier(amount, interval, isPersonal))
    : null;

  return {
    subscription_status: subscription.status,
    stripe_subscription_id: subscription.id,
    subscription_current_period_end: subscription.current_period_end
      ? new Date(subscription.current_period_end * 1000) : null,
    subscription_amount: amount,
    subscription_currency: currency,
    subscription_interval: interval,
    subscription_canceled_at: subscription.canceled_at
      ? new Date(subscription.canceled_at * 1000) : null,
    subscription_product_id: productId,
    subscription_product_name: productName,
    subscription_price_id: priceData?.id ?? null,
    subscription_price_lookup_key: lookupKey,
    membership_tier: membershipTier,
  };
}

/**
 * Count current seat usage by type for an organization.