Merge branch 'main' of https://github.com/Dhravya/supermemory into new-uinew-ui

1 files changed, 127 insertions, 92 deletions

diff --git a/apps/web/src/app/api/store/route.ts b/apps/web/src/app/api/store/route.ts
index 06db08b9..ebe23077 100644
--- a/apps/web/src/app/api/store/route.ts
+++ b/apps/web/src/app/api/store/route.ts
@@ -1,6 +1,12 @@
 import { db } from "@/server/db";
 import { and, eq } from "drizzle-orm";
-import { contentToSpace, sessions, storedContent, users, space } from "@/server/db/schema";
+import {
+  contentToSpace,
+  sessions,
+  storedContent,
+  users,
+  space,
+} from "@/server/db/schema";
 import { type NextRequest, NextResponse } from "next/server";
 import { env } from "@/env";
 import { getMetaData } from "@/server/helpers";
@@ -8,94 +14,123 @@ import { getMetaData } from "@/server/helpers";
 export const runtime = "edge";
 
 export async function POST(req: NextRequest) {
-    const token = req.cookies.get("next-auth.session-token")?.value ?? req.cookies.get("__Secure-authjs.session-token")?.value ?? req.cookies.get("authjs.session-token")?.value ?? req.headers.get("Authorization")?.replace("Bearer ", "");
-
-    if (!token) {
-        return new Response(JSON.stringify({ message: "Invalid Key, session not found." }), { status: 404 });
-    }
-
-    const sessionData = await db.select().from(sessions).where(eq(sessions.sessionToken, token!))
-
-    if (!sessionData || sessionData.length === 0) {
-        return new Response(JSON.stringify({ message: "Invalid Key, session not found." }), { status: 404 });
-    }
-
-    const user = await db.select().from(users).where(eq(users.id, sessionData[0].userId)).limit(1)
-
-    if (!user || user.length === 0) {
-        return NextResponse.json({ message: "Invalid Key, session not found." }, { status: 404 });
-    }
-
-    const session = { session: sessionData[0], user: user[0] }
-
-    const data = await req.json() as {
-        pageContent: string,
-        url: string,
-        space?: string
-    };
-
-    const metadata = await getMetaData(data.url);
-
-
-    let id: number | undefined = undefined;
-
-    let storeToSpace = data.space
-
-    if (!storeToSpace) {
-        storeToSpace = 'all'
-    }
-
-    const storedContentId = await db.insert(storedContent).values({
-        content: data.pageContent,
-        title: metadata.title,
-        description: metadata.description,
-        url: data.url,
-        baseUrl: metadata.baseUrl,
-        image: metadata.image,
-        savedAt: new Date(),
-        user: session.user.id
-    })
-
-    id = storedContentId.meta.last_row_id;
-
-    if (!id) {
-        return NextResponse.json({ message: "Error", error: "Error in CF function" }, { status: 500 });
-    }
-
-    let spaceID = 0;
-
-    const spaceData = await db.select().from(space).where(and(eq(space.name, storeToSpace), eq(space.user, session.user.id))).limit(1)
-    spaceID = spaceData[0]?.id
-
-    if (!spaceData || spaceData.length === 0) {
-        const spaceId = await db.insert(space).values({
-            name: storeToSpace,
-            user: session.user.id
-        })
-        spaceID = spaceId.meta.last_row_id;
-    }
-
-    await db.insert(contentToSpace).values({
-        contentId: id as number,
-        spaceId: spaceID
-    })
-
-    const res = await Promise.race([
-        fetch("https://cf-ai-backend.dhravya.workers.dev/add", {
-            method: "POST",
-            headers: {
-                "X-Custom-Auth-Key": env.BACKEND_SECURITY_KEY,
-            },
-            body: JSON.stringify({ ...data, user: session.user.email }),
-        }),
-        new Promise((_, reject) =>
-            setTimeout(() => reject(new Error('Request timed out')), 40000)
-        )
-    ]) as Response
-
-    if (res.status !== 200) {
-        return NextResponse.json({ message: "Error", error: "Error in CF function" }, { status: 500 });
-    }
-
-    return NextResponse.json({ message: "OK", data: "Success" }, { status: 200 });
-}
\ No newline at end of file
+  const token =
+    req.cookies.get("next-auth.session-token")?.value ??
+    req.cookies.get("__Secure-authjs.session-token")?.value ??
+    req.cookies.get("authjs.session-token")?.value ??
+    req.headers.get("Authorization")?.replace("Bearer ", "");
+
+  if (!token) {
+    return new Response(
+      JSON.stringify({ message: "Invalid Key, session not found." }),
+      { status: 404 },
+    );
+  }
+
+  const sessionData = await db
+    .select()
+    .from(sessions)
+    .where(eq(sessions.sessionToken, token!));
+
+  if (!sessionData || sessionData.length === 0) {
+    return new Response(
+      JSON.stringify({ message: "Invalid Key, session not found." }),
+      { status: 404 },
+    );
+  }
+
+  const user = await db
+    .select()
+    .from(users)
+    .where(eq(users.id, sessionData[0].userId))
+    .limit(1);
+
+  if (!user || user.length === 0) {
+    return NextResponse.json(
+      { message: "Invalid Key, session not found." },
+      { status: 404 },
+    );
+  }
+
+  const session = { session: sessionData[0], user: user[0] };
+
+  const data = (await req.json()) as {
+    pageContent: string;
+    url: string;
+    space?: string;
+  };
+
+  const metadata = await getMetaData(data.url);
+
+  let id: number | undefined = undefined;
+
+  let storeToSpace = data.space;
+
+  if (!storeToSpace) {
+    storeToSpace = "all";
+  }
+
+  const storedContentId = await db.insert(storedContent).values({
+    content: data.pageContent,
+    title: metadata.title,
+    description: metadata.description,
+    url: data.url,
+    baseUrl: metadata.baseUrl,
+    image: metadata.image,
+    savedAt: new Date(),
+    user: session.user.id,
+  });
+
+  id = storedContentId.meta.last_row_id;
+
+  if (!id) {
+    return NextResponse.json(
+      { message: "Error", error: "Error in CF function" },
+      { status: 500 },
+    );
+  }
+
+  let spaceID = 0;
+
+  const spaceData = await db
+    .select()
+    .from(space)
+    .where(and(eq(space.name, storeToSpace), eq(space.user, session.user.id)))
+    .limit(1);
+  spaceID = spaceData[0]?.id;
+
+  if (!spaceData || spaceData.length === 0) {
+    const spaceId = await db.insert(space).values({
+      name: storeToSpace,
+      user: session.user.id,
+    });
+    spaceID = spaceId.meta.last_row_id;
+  }
+
+  await db.insert(contentToSpace).values({
+    contentId: id as number,
+    spaceId: spaceID,
+  });
+
+  const res = (await Promise.race([
+    fetch("https://cf-ai-backend.dhravya.workers.dev/add", {
+      method: "POST",
+      headers: {
+        "X-Custom-Auth-Key": env.BACKEND_SECURITY_KEY,
+      },
+      body: JSON.stringify({ ...data, user: session.user.email }),
+    }),
+    new Promise((_, reject) =>
+      setTimeout(() => reject(new Error("Request timed out")), 40000),
+    ),
+  ])) as Response;
+
+  if (res.status !== 200) {
+    return NextResponse.json(
+      { message: "Error", error: "Error in CF function" },
+      { status: 500 },
+    );
+  }
+
+  return NextResponse.json({ message: "OK", data: "Success" }, { status: 200 });
+}