shellphone.app/app/settings/mutations/update-subscription.ts

import { NotFoundError, resolver } from "blitz";
import { z } from "zod";

import db, { Prisma, SubscriptionStatus } from "db";
import { updateSubscriptionPlan } from "integrations/paddle";

const Body = z.object({
	planId: z.number(),
});

export default resolver.pipe(resolver.zod(Body), resolver.authorize(), async ({ planId }, ctx) => {
	const subscription = await db.subscription.findFirst({
		where: {
			organizationId: ctx.session.orgId,
			status: { not: SubscriptionStatus.deleted },
		},
		orderBy: { lastEventTime: Prisma.SortOrder.desc },
	});
	if (!subscription) {
		throw new NotFoundError();
	}

	const subscriptionId = subscription.paddleSubscriptionId;
	await updateSubscriptionPlan({ productId: planId, subscriptionId });
});