feat: added audience email added

Author: Rieranthony

apps/api/src/lib/auth-user-audience.test.ts

@@ -0,0 +1,111 @@
+import { beforeEach, describe, expect, it, mock } from "bun:test";
+
+const addUserToDefaultAudienceMock = mock(
+	(async () => true) as (...args: unknown[]) => Promise<boolean>
+);
+
+mock.module("@cossistant/transactional", () => ({
+	addUserToDefaultAudience: addUserToDefaultAudienceMock,
+}));
+
+const authUserAudienceModulePromise = import("./auth-user-audience");
+
+function spyConsole() {
+	const warnSpy = mock(() => {});
+	const errorSpy = mock(() => {});
+	const originalWarn = console.warn;
+	const originalError = console.error;
+
+	console.warn = warnSpy as unknown as typeof console.warn;
+	console.error = errorSpy as unknown as typeof console.error;
+
+	return {
+		warnSpy,
+		errorSpy,
+		restore: () => {
+			console.warn = originalWarn;
+			console.error = originalError;
+		},
+	};
+}
+
+describe("syncUserToDefaultResendAudience", () => {
+	beforeEach(() => {
+		addUserToDefaultAudienceMock.mockReset();
+		addUserToDefaultAudienceMock.mockResolvedValue(true);
+	});
+
+	it("calls addUserToDefaultAudience when user email exists", async () => {
+		const { syncUserToDefaultResendAudience } =
+			await authUserAudienceModulePromise;
+
+		await syncUserToDefaultResendAudience({
+			id: "user-1",
+			email: "person@example.com",
+			name: "Person Example",
+		});
+
+		expect(addUserToDefaultAudienceMock).toHaveBeenCalledTimes(1);
+		expect(addUserToDefaultAudienceMock).toHaveBeenCalledWith(
+			"person@example.com",
+			"Person Example"
+		);
+	});
+
+	it("skips and logs a warning when email is missing", async () => {
+		const { syncUserToDefaultResendAudience } =
+			await authUserAudienceModulePromise;
+		const { warnSpy, restore } = spyConsole();
+
+		try {
+			await syncUserToDefaultResendAudience({
+				id: "user-2",
+			});
+		} finally {
+			restore();
+		}
+
+		expect(addUserToDefaultAudienceMock).not.toHaveBeenCalled();
+		expect(warnSpy).toHaveBeenCalledTimes(1);
+	});
+
+	it("does not throw and logs an error when enrollment returns false", async () => {
+		const { syncUserToDefaultResendAudience } =
+			await authUserAudienceModulePromise;
+		const { errorSpy, restore } = spyConsole();
+		addUserToDefaultAudienceMock.mockResolvedValue(false);
+
+		try {
+			await syncUserToDefaultResendAudience({
+				id: "user-3",
+				email: "person@example.com",
+				name: "Person Example",
+			});
+		} finally {
+			restore();
+		}
+
+		expect(addUserToDefaultAudienceMock).toHaveBeenCalledTimes(1);
+		expect(errorSpy).toHaveBeenCalledTimes(1);
+	});
+
+	it("does not throw and logs an error when enrollment throws", async () => {
+		const { syncUserToDefaultResendAudience } =
+			await authUserAudienceModulePromise;
+		const { errorSpy, restore } = spyConsole();
+		addUserToDefaultAudienceMock.mockRejectedValue(new Error("resend failed"));
+
+		try {
+			await syncUserToDefaultResendAudience({
+				id: "user-4",
+				email: "person@example.com",
+				name: "Person Example",
+			});
+		} finally {
+			restore();
+		}
+
+		expect(addUserToDefaultAudienceMock).toHaveBeenCalledTimes(1);
+		expect(errorSpy).toHaveBeenCalledTimes(1);
+	});
+});

apps/api/src/lib/auth-user-audience.ts

@@ -0,0 +1,45 @@
+import { addUserToDefaultAudience } from "@cossistant/transactional";
+
+type AuthUserLike = {
+	id?: unknown;
+	email?: unknown;
+	name?: unknown;
+};
+
+function toNonEmptyString(value: unknown): string | undefined {
+	if (typeof value !== "string") {
+		return;
+	}
+
+	const trimmed = value.trim();
+	return trimmed.length > 0 ? trimmed : undefined;
+}
+
+export async function syncUserToDefaultResendAudience(
+	user: AuthUserLike
+): Promise<void> {
+	const userId = toNonEmptyString(user.id);
+	const email = toNonEmptyString(user.email);
+	const name = toNonEmptyString(user.name);
+
+	if (!email) {
+		console.warn(
+			`[auth] Skipping Resend audience sync: missing email${userId ? ` (userId: ${userId})` : ""}`
+		);
+		return;
+	}
+
+	try {
+		const didAddUser = await addUserToDefaultAudience(email, name);
+		if (!didAddUser) {
+			console.error(
+				`[auth] Failed to add user to default Resend audience: ${email}${userId ? ` (userId: ${userId})` : ""}`
+			);
+		}
+	} catch (error) {
+		console.error(
+			`[auth] Error adding user to default Resend audience: ${email}${userId ? ` (userId: ${userId})` : ""}`,
+			error
+		);
+	}
+}

apps/api/src/lib/auth.tsx

@@ -13,6 +13,7 @@ import {
 } from "better-auth/plugins";
 import type { BetterAuthPlugin } from "better-auth/types";
 import React from "react";
+import { syncUserToDefaultResendAudience } from "./auth-user-audience";
 import polarClient from "./polar";
 
 // Needed for email templates
@@ -29,6 +30,15 @@ export const auth = betterAuth({
 			...schema,
 		},
 	}),
+	databaseHooks: {
+		user: {
+			create: {
+				after: async (user) => {
+					await syncUserToDefaultResendAudience(user);
+				},
+			},
+		},
+	},
 	emailAndPassword: {
 		enabled: true,
 		autoSignIn: true,

apps/api/src/workflows/index.ts

@@ -1,11 +1,9 @@
 import { Hono } from "hono";
-import aiAgentWorkflow from "./ai-agent";
 import messageWorkflow from "./message";
 
 const workflowsRouters = new Hono();
 
 // Include all workflows below
 workflowsRouters.route("/message", messageWorkflow);
-workflowsRouters.route("/ai-agent", aiAgentWorkflow);
 
 export { workflowsRouters };

packages/transactional/resend-utils/constants.ts

@@ -1,7 +1,10 @@
 // Email system constants
 export const ANTHONY_EMAIL = "anthony@cossistant.com";
 export const TRANSACTIONAL_EMAIL_DOMAIN = "updates.cossistant.com";
-export const RESEND_AUDIENCE_ID = "668cc440-8027-4a31-9f8f-2633efbf12a4";
+export const DEFAULT_RESEND_AUDIENCE_ID =
+	"668cc440-8027-4a31-9f8f-2633efbf12a4";
+export const RESEND_AUDIENCE_ID =
+	process.env.RESEND_AUDIENCE_ID?.trim() || DEFAULT_RESEND_AUDIENCE_ID;
 
 // Email variant to sender mapping (only notifications and marketing)
 export const VARIANT_TO_FROM_MAP = {