From 6b1b2d2ac16f9a57d8dfeb9645d209fbd27fb12c Mon Sep 17 00:00:00 2001
From: "Builder.io" <builder-bot@builder.io>
Date: Tue, 11 Nov 2025 22:08:59 +0000
Subject: [PATCH] Resolve linked emails to primary account email

cgen-3647cb2a9886454fb12db5a77d09f1c6
---
 api/user/resolve-linked-email.ts | 80 ++++++++++++++++++++++++++++++++
 1 file changed, 80 insertions(+)
 create mode 100644 api/user/resolve-linked-email.ts

diff --git a/api/user/resolve-linked-email.ts b/api/user/resolve-linked-email.ts
new file mode 100644
index 00000000..ed322d41
--- /dev/null
+++ b/api/user/resolve-linked-email.ts
@@ -0,0 +1,80 @@
+import { getAdminClient } from "../_supabase";
+
+export default async (req: Request) => {
+  if (req.method !== "POST") {
+    return new Response(JSON.stringify({ error: "Method not allowed" }), {
+      status: 405,
+      headers: { "Content-Type": "application/json" },
+    });
+  }
+
+  try {
+    const { email } = await req.json();
+
+    if (!email) {
+      return new Response(
+        JSON.stringify({ error: "Email is required" }),
+        { status: 400, headers: { "Content-Type": "application/json" } }
+      );
+    }
+
+    const supabase = getAdminClient();
+
+    // Look up the email in user_email_links
+    const { data: emailLink, error: linkError } = await supabase
+      .from("user_email_links")
+      .select("user_id")
+      .eq("email", email)
+      .single();
+
+    if (linkError && linkError.code !== "PGRST116") {
+      // PGRST116 = no rows found (expected when email not linked)
+      throw linkError;
+    }
+
+    if (!emailLink) {
+      // Email is not linked, return the email as-is
+      return new Response(
+        JSON.stringify({ primaryEmail: email }),
+        { status: 200, headers: { "Content-Type": "application/json" } }
+      );
+    }
+
+    // Get the primary email for this user
+    const { data: profile, error: profileError } = await supabase
+      .from("user_profiles")
+      .select("email")
+      .eq("user_id", emailLink.user_id)
+      .single();
+
+    if (profileError) {
+      console.error("Profile lookup error:", profileError);
+      // If we can't find the profile, return original email
+      return new Response(
+        JSON.stringify({ primaryEmail: email }),
+        { status: 200, headers: { "Content-Type": "application/json" } }
+      );
+    }
+
+    return new Response(
+      JSON.stringify({
+        primaryEmail: profile.email || email,
+        linkedFrom: email,
+        userId: emailLink.user_id,
+      }),
+      { status: 200, headers: { "Content-Type": "application/json" } }
+    );
+  } catch (error: any) {
+    console.error("[Resolve Linked Email Error]", error);
+    return new Response(
+      JSON.stringify({
+        error: "Failed to resolve email",
+        details: error.message,
+      }),
+      {
+        status: 500,
+        headers: { "Content-Type": "application/json" },
+      }
+    );
+  }
+};