Function syncOrganizationBillingCycle

packages/billing/src/org-billing.ts:28–125

(params: {
  organizationId: string
  logger: Logger
})

 * All organizations are expected to have Stripe subscriptions.
 */
export async function syncOrganizationBillingCycle(params: {
  organizationId: string
  logger: Logger
}): Promise<Date> {
  const { organizationId, logger } = params

  const organization = await db.query.org.findFirst({
    where: eq(schema.org.id, organizationId),
    columns: {
      stripe_customer_id: true,
      current_period_start: true,
      current_period_end: true,
    },
  })

  if (!organization) {
    throw new Error(`Organization ${organizationId} not found`)
  }

  if (!organization.stripe_customer_id) {
    throw new Error(
      `Organization ${organizationId} does not have a Stripe customer ID`,
    )
  }

  const now = new Date()

  try {
    const subscriptions = await stripeServer.subscriptions.list({
      customer: organization.stripe_customer_id,
      status: 'active',
      limit: 1,
    })

    if (subscriptions.data.length === 0) {
      throw new Error(
        `No active Stripe subscription found for organization ${organizationId}`,
      )
    }

    const subscription = subscriptions.data[0]
    const stripeCurrentStart = new Date(
      subscription.current_period_start * 1000,
    )
    const stripeCurrentEnd = new Date(subscription.current_period_end * 1000)

    // Check if we need to update the stored billing cycle dates
    const needsUpdate =
      !organization.current_period_start ||
      !organization.current_period_end ||
      Math.abs(
        stripeCurrentStart.getTime() -
          organization.current_period_start.getTime(),
      ) >
        60 * 1000 ||
      Math.abs(
        stripeCurrentEnd.getTime() - organization.current_period_end.getTime(),
      ) >