Feat/sync newsletter settings

app/(app)/settings/page.tsx

@@ -1,8 +1,9 @@
-import { redirect } from "next/navigation";
+import { notFound, redirect } from "next/navigation";
 import Content from "./_client";
 import { getServerAuthSession } from "@/server/auth";
 import { customAlphabet } from "nanoid";
 import prisma from "@/server/db/client";
+import { isUserSubscribedToNewsletter } from "@/server/lib/newsletter";
 
 export const metadata = {
   title: "Settings - Update your profile",
@@ -55,5 +56,19 @@ export default async function Page() {
     return <Content profile={newUser} />;
   }
 
-  return <Content profile={user} />;
+  if (!session.user.email) {
+    return notFound();
+  }
+
+  try {
+    const newsletter = await isUserSubscribedToNewsletter(session.user.email);
+    const cleanedUser = {
+      ...user,
+      newsletter,
+    };
+    return <Content profile={cleanedUser} />;
+  } catch (error) {
+    Sentry.captureException(error);
+    return <Content profile={user} />;
+  }
 }

package.json

@@ -11,7 +11,7 @@
     "lint:fix": "next lint --fix",
     "prettier": "prettier --check -c '**/*.{ts,tsx,js,jsx,json,json5,scss,css,html,mdx}'",
     "prettier:fix": "prettier --write -c '**/*.{ts,tsx,js,jsx,json,json5,scss,css,html,mdx}'",
-    "test": "playwright test",
+    "test": "npx playwright install && playwright test",
     "studio": "prisma studio",
     "migrate": "npx prisma migrate",
     "prepare": "husky install"

server/api/router/profile.ts

@@ -8,7 +8,10 @@ import {
 import { getPresignedUrl } from "../../common/getPresignedUrl";
 
 import { createTRPCRouter, publicProcedure, protectedProcedure } from "../trpc";
-import { manageNewsletterSubscription } from "@/server/lib/newsletter";
+import {
+  isUserSubscribedToNewsletter,
+  manageNewsletterSubscription,
+} from "@/server/lib/newsletter";
 import { TRPCError } from "@trpc/server";
 import { nanoid } from "nanoid";
 
@@ -22,7 +25,18 @@ export const profileRouter = createTRPCRouter({
         },
       });
 
-      if (existingProfile?.newsletter !== input.newsletter) {
+      const { email } = ctx.session.user;
+
+      if (!email) {
+        throw new TRPCError({
+          code: "BAD_REQUEST",
+          message: "Email not found",
+        });
+      }
+
+      const newsletter = await isUserSubscribedToNewsletter(email);
+
+      if (newsletter !== input.newsletter) {
         const email = existingProfile?.email;
         const action = input.newsletter ? "subscribe" : "unsubscribe";
         if (!email) {

server/lib/newsletter.ts

@@ -20,21 +20,51 @@ export async function manageNewsletterSubscription(
     silent: "true", // Don't send a confirmation email (using this option for users signed up to platform, not newsletter only option)
   }).toString();
 
-  try {
-    const response = await fetch(`${EMAIL_API_ENDPOINT}/${action}`, {
+  const response = await fetch(`${EMAIL_API_ENDPOINT}/${action}`, {
+    method: "POST",
+    headers: {
+      "Content-type": "application/x-www-form-urlencoded",
+    },
+    body: payload,
+  });
+
+  if (response.ok) {
+    return { message: `Successfully ${action}d to the newsletter.` };
+  } else {
+    throw new Error(`Failed to ${action} to the newsletter`);
+  }
+}
+
+export async function isUserSubscribedToNewsletter(email: string) {
+  const EMAIL_API_ENDPOINT = process.env.EMAIL_API_ENDPOINT;
+  const EMAIL_API_KEY = process.env.EMAIL_API_KEY;
+  const EMAIL_NEWSLETTER_ID = process.env.EMAIL_NEWSLETTER_ID;
+
+  if (!EMAIL_API_ENDPOINT || !EMAIL_API_KEY || !EMAIL_NEWSLETTER_ID) {
+    throw new Error("Email API not configured");
+  }
+
+  const payload = new URLSearchParams({
+    email,
+    api_key: EMAIL_API_KEY,
+    list_id: EMAIL_NEWSLETTER_ID,
+  }).toString();
+
+  const response = await fetch(
+    `${EMAIL_API_ENDPOINT}/api/subscribers/subscription-status.php`,
+    {
       method: "POST",
       headers: {
         "Content-type": "application/x-www-form-urlencoded",
       },
       body: payload,
-    });
-
-    if (response.ok) {
-      return { message: `Successfully ${action}d to the newsletter.` };
-    } else {
-      throw new Error(`Failed to ${action} to the newsletter`);
-    }
-  } catch (error) {
-    Sentry.captureException(error);
+    },
+  );
+
+  if (response.ok) {
+    const status = await response.text();
+    return status === "Subscribed";
+  } else {
+    throw new Error("Failed to check newsletter subscription");
   }
 }