Function getUserIdFromEvent

apps/app-server/src/fastify/stripe-webhook.ts:48–66

(input: {
  event: Stripe.Event;
  dataAbstraction: ReturnType<typeof dataAbstraction>;
})

}

async function getUserIdFromEvent(input: {
  event: Stripe.Event;
  dataAbstraction: ReturnType<typeof dataAbstraction>;
}) {
  const userId = await input.dataAbstraction.hget(
    'customer',
    (input.event.data.object as any).customer,
    'user-id',
  );

  if (userId == null) {
    throw new TRPCError({
      code: 'NOT_FOUND',
      message: 'User not found.',
    });
  }

  return userId;
}

async function customerSubscriptionUpdated(input: {
  event: Stripe.Event;