shellphone.app/app/settings/api/queue/subscription-created.ts

import { NotFoundError } from "blitz";
import { Queue } from "quirrel/blitz";
import type { PaddleSdkSubscriptionCreatedEvent } from "@devoxa/paddle-sdk";

import db, { MembershipRole } from "db";
import appLogger from "integrations/logger";
import { sendEmail } from "integrations/ses";
import { translateSubscriptionStatus } from "integrations/paddle";

const logger = appLogger.child({ queue: "subscription-created" });

type Payload = {
	event: PaddleSdkSubscriptionCreatedEvent<{ organizationId: string }>;
};

export const subscriptionCreatedQueue = Queue<Payload>("api/queue/subscription-created", async ({ event }) => {
	const { organizationId } = event.metadata;
	const organization = await db.organization.findFirst({
		where: { id: organizationId },
		include: {
			subscription: true,
			memberships: {
				include: { user: true },
			},
		},
	});
	if (!organization) {
		throw new NotFoundError();
	}

	const orgOwner = organization.memberships.find((membership) => membership.role === MembershipRole.OWNER);
	const email = orgOwner!.user!.email;
	await db.organization.update({
		where: { id: organizationId },
		data: {
			subscription: {
				create: {
					paddleSubscriptionId: event.subscriptionId,
					paddlePlanId: event.productId,
					paddleCheckoutId: event.checkoutId,
					nextBillDate: event.nextPaymentDate,
					status: translateSubscriptionStatus(event.status),
					lastEventTime: event.eventTime,
					updateUrl: event.updateUrl,
					cancelUrl: event.cancelUrl,
					currency: event.currency,
					unitPrice: event.unitPrice,
				},
			},
		},
	});

	if (!!organization.subscription) {
		sendEmail({
			subject: "Welcome back to Shellphone",
			body: "Welcome back to Shellphone",
			recipients: [email],
		}).catch((error) => {
			logger.error(error);
		});
	} else {
		sendEmail({
			subject: "Welcome to Shellphone",
			body: `Welcome to Shellphone`,
			recipients: [email],
		}).catch((error) => {
			logger.error(error);
		});
	}
});

export default subscriptionCreatedQueue;