feat(auth): 🛂 create new public user profile when signing up

Author: JasonWarrenUK

deno.jsonc

@@ -1,10 +1,10 @@
 {
   "tasks": {
-    "runDev": {
+    "rundev": {
       "description": "Run the local development build",
       "command": "deno run -A --watch --unstable-cron --env-file=.env.local main.ts"
     },
-    "runProd": {
+    "runprod": {
       "description": "Run the local production build",
       "command": "deno run -A --watch --unstable-cron --env-file=.env.production main.ts"
     },
@@ -13,29 +13,29 @@
       "description": "Run the tests",
       "command": "deno test -A --unstable-kv --no-check"
     },
-    "testAuth": {
+    "testauth": {
       "description": "Run only authentication tests",
       "command": "deno test -A --unstable-kv --no-check tests/auth-test.ts"
     },
     // Resend API
-    "resendCheck": {
+    "resendcheck": {
       "description": "Tests the Resend API",
       "command": "deno run -A --watch --unstable-cron --env-file=.env.local ./utils/emails/sendTest.ts"
     },
     // Neo4j API
-    "n4jSeedL": {
+    "n4jseedl": {
       "description": "Seed the local instance of neo4j",
       "command": "deno run -A --env-file=.env.local queries/seed.ts"
     },
-    "n4jSeedP": {
+    "n4jseedp": {
       "description": "Seed the production instance of neo4j",
       "command": "deno run -A --env-file=.env.production queries/seed.ts"
     },
-    "n4jResetL": {
+    "n4jresetl": {
       "description": "Reset the local instance of neo4j",
       "command": "deno run -A --env-file=.env.local queries/reset.ts"
     },
-    "n4jResetP": {
+    "n4jresetp": {
       "description": "Reset the production instance of neo4j",
       "command": "deno run -A --env-file=.env.production queries/reset.ts"
     },

routes/authRoutes.ts

@@ -8,6 +8,7 @@ const routes: string[] = [];
 router.post("/signin/magic-link", async (ctx) => {
   console.group(`|============ Sign In Request ============|`);
   const body = await ctx.request.body.json();
+  const name = body.name;
   const email = body.email;
 
   if (!email) {
@@ -16,37 +17,111 @@ router.post("/signin/magic-link", async (ctx) => {
     return;
   }
 
-  const supabaseUrl = Deno.env.get("SUPABASE_URL")!;
-  const supabaseKey = Deno.env.get("SUPABASE_SERVICE_ROLE_KEY")!;
-  const supabase = createClient(supabaseUrl, supabaseKey);
+  try {
+    const supabaseUrl = Deno.env.get("SUPABASE_URL")!;
+    const supabaseKey = Deno.env.get("SUPABASE_SERVICE_ROLE_KEY")!;
+    const supabase = createClient(supabaseUrl, supabaseKey);
 
-  const { data, error } = await supabase.auth.signInWithOtp({
-    email,
-    options: { emailRedirectTo: "http://localhost:5000/auth/callback" },
-  });
+    const { data, error } = await supabase.auth.signInWithOtp({
+      email,
+      options: {
+        emailRedirectTo: "http://localhost:8080/auth/callback",
+        // [ ] tdHi: Get callback URL from Alex
+        data: {
+          name: name
+        }
+      },
+    });
 
-  // [ ] tdHi: Get callback URL from Alex
+    console.group(`|====== Sign In Result ======|`);
+    if (error) {
+      console.info(`| Error`);
+      console.error(error);
 
-  console.group(`|====== Sign In Result ======|`);
-  if (error) {
-    console.info(`| Error`);
-    console.error(error);
+      ctx.response.status = 500;
+      ctx.response.body = { error: error.message };
+    } else {
+      console.info(`| Success`);
+      console.log(data);
 
+      ctx.response.status = 200;
+      ctx.response.body = { message: "Magic link sent", data };
+    }
+    console.groupEnd();
+  } catch (error) {
+    console.error(error);
     ctx.response.status = 500;
-    ctx.response.body = { error: error.message };
-  } else {
-    console.info(`| Success`);
-    console.log(data);
-
-    ctx.response.status = 200;
-    ctx.response.body = { message: "Magic link sent", data };
+    ctx.response.body = { error };
   }
-  console.groupEnd();
 
   console.groupEnd();
 });
 routes.push("signin/magic-link");
 
+router.get("/auth/callback", async (ctx) => {
+  console.group("|============ Auth Callback ============|");
+  
+  try {
+    const supabaseUrl = Deno.env.get("SUPABASE_URL")!;
+    const supabaseKey = Deno.env.get("SUPABASE_SERVICE_ROLE_KEY")!;
+    const supabase = createClient(supabaseUrl, supabaseKey);
+
+    // Get the access_token and refresh_token from URL params
+    const params = new URLSearchParams(ctx.request.url.search);
+    const access_token = params.get("access_token");
+    const refresh_token = params.get("refresh_token");
+
+    if (!access_token || !refresh_token) {
+      throw new Error("No tokens provided in callback");
+    }
+
+    // Get the user data using the tokens
+    const { data: { user }, error: getUserError } = await supabase.auth.getUser(access_token);
+    
+    if (getUserError || !user) {
+      throw getUserError || new Error("No user found");
+    }
+
+    // Get the user's profile
+    
+
+    console.group(`|============ Supabase Auth User ============|`);
+    const { data: profile, error: profileError } = await supabase
+      .from("profiles")
+      .select("*")
+      .eq("id", user.id)
+      .single();
+
+    if (profileError) {
+      throw profileError;
+    }
+
+    console.log(user);
+    console.groupEnd();
+
+    console.group(`|============ Neo4j User ============|`)
+    const neoUser = {
+      authId: user.id,
+      name: user.user_metadata.name,
+      email: user.email
+    };
+    console.log(neoUser);
+    console.groupEnd();
+    
+    // Redirect to frontend with success
+    ctx.response.redirect(`${Deno.env.get("FRONTEND_URL")}/login/success`);
+
+  } catch (error: unknown) {
+    console.error("Callback error:", error);
+    // Redirect to frontend with error
+    const errorMessage = error instanceof Error ? error.message : "An unknown error occurred";
+    ctx.response.redirect(`${Deno.env.get("FRONTEND_URL")}/login/error?message=${encodeURIComponent(errorMessage)}`);
+  }
+
+  console.groupEnd();
+});
+routes.push("auth/callback");
+
 router.get("/user", verifyUser, (ctx) => {});
 // routes.push("user");