Mira collab

apps/website/app/api/content/[space_id]/[resource_id]/route.ts

@@ -0,0 +1,203 @@
+import { NextResponse, NextRequest } from "next/server";
+import { createClient } from "~/utils/supabase/server";
+import { asPostgrestFailure } from "@repo/database/lib/contextFunctions";
+import {
+  defaultOptionsHandler,
+  createApiResponse,
+} from "~/utils/supabase/apiUtils";
+import { asJsonLD, conceptName } from "~/utils/conversion/jsonld";
+import { Tables, Enums } from "@repo/database/dbTypes";
+import { convert, MIMETYPES, type DocType } from "~/utils/conversion/convert";
+
+type Concept = Tables<"Concept">;
+type Content = Tables<"Content">;
+type PlatformAccount = Tables<"PlatformAccount">;
+type Platform = Enums<"Platform">;
+
+export type SegmentDataType = { params: Promise<Record<string, string>> };
+
+export const GET = async (
+  request: NextRequest,
+  segmentData: SegmentDataType,
+): Promise<NextResponse> => {
+  const { space_id, resource_id } = await segmentData.params;
+  let targetFormat: DocType = (request.nextUrl.searchParams.get("format") ??
+    "html") as DocType;
+  if (MIMETYPES[targetFormat] === undefined) {
+    targetFormat = "html";
+  }
+  const targetMimetype = MIMETYPES[targetFormat];
+  if (!targetMimetype) {
+    return createApiResponse(
+      request,
+      asPostgrestFailure("Unsupported format", "404", 404),
+    );
+  }
+  const includeData =
+    targetFormat === "html" &&
+    request.nextUrl.searchParams.get("data") !== "false";
+  const spaceIdN = Number.parseInt(space_id || "NaN");
+  if (isNaN(spaceIdN)) {
+    return createApiResponse(
+      request,
+      asPostgrestFailure(`${space_id} is not a number`, "type"),
+    );
+  }
+  const resourceIdN = Number.parseInt(resource_id || "NaN");
+  if (isNaN(resourceIdN)) {
+    return createApiResponse(
+      request,
+      asPostgrestFailure(`${resource_id} is not a number`, "type"),
+    );
+  }
+  const supabase = await createClient();
+  const spaceResponse = await supabase
+    .from("Space")
+    .select()
+    .eq("id", spaceIdN)
+    .maybeSingle();
+  if (spaceResponse.error) {
+    return createApiResponse(request, spaceResponse);
+  }
+  let platform: Platform = "Obsidian";
+  if (spaceResponse.data) {
+    platform = spaceResponse.data.platform;
+  } else {
+    // consideration: We may not see it because we don't have access,
+    // We should find a way to check its platform otherwise.
+    // Let's just keep the Obsidian guess for MIRA demo.
+    // return createApiResponse(
+    //   request,
+    //   asPostgrestFailure("Space not found", "401", 401),
+    // );
+  }
+  const conceptResponse = await supabase
+    .from("Concept")
+    .select()
+    .eq("id", resourceIdN)
+    .eq("space_id", spaceIdN)
+    .maybeSingle();
+  if (conceptResponse.error) {
+    return createApiResponse(request, conceptResponse);
+  }
+  const concept = conceptResponse.data;
+  if (!concept) {
+    return createApiResponse(
+      request,
+      asPostgrestFailure("Resource not found", "401", 401),
+    );
+  }
+  const contentResponse = await supabase
+    .from("Content")
+    .select()
+    .eq("source_local_id", concept.source_local_id!);
+  if (contentResponse.error) {
+    return createApiResponse(request, conceptResponse);
+  }
+  const contents: Content[] = contentResponse.data;
+  const requestUrlParts = request.url.split("/");
+  const baseUrl = requestUrlParts
+    .slice(0, requestUrlParts.length - 1)
+    .join("/");
+  const fullContentsArray = contents.filter((c) => c.variant === "full");
+  const fullContents = fullContentsArray.length
+    ? fullContentsArray[0]
+    : undefined;
+  const titleArray = contents.filter((c) => c.variant === "direct");
+  const title = titleArray.length ? titleArray[0] : undefined;
+
+  if (!fullContents) {
+    return createApiResponse(
+      request,
+      asPostgrestFailure("Resource not found", "401", 401),
+    );
+  }
+
+  // await initRT(rootUrl);
+  const source: DocType | undefined =
+    platform === "Obsidian"
+      ? "obsidian"
+      : platform === "Roam"
+        ? "roam"
+        : undefined;
+  let text =
+    source && source !== targetFormat
+      ? convert(fullContents.text, source, targetFormat)
+      : fullContents.text;
+  const isSchema = concept.is_schema;
+  let schema: Concept | undefined = undefined;
+  if (!isSchema && concept.schema_id) {
+    const schemaResponse = await supabase
+      .from("Concept")
+      .select()
+      .eq("id", concept.schema_id)
+      .maybeSingle();
+    if (schemaResponse.error) {
+      return createApiResponse(request, schemaResponse);
+    }
+    if (!schemaResponse.data) {
+      return createApiResponse(
+        request,
+        asPostgrestFailure("Resource schema not found", "401", 401),
+      );
+    }
+    schema = schemaResponse.data;
+  }
+  const schemaName = conceptName(concept, schema);
+
+  if (includeData) {
+    const authorId = concept.author_id ?? (contents ?? [{}])[0]?.author_id;
+    let author: PlatformAccount | undefined = undefined;
+    if (authorId) {
+      try {
+        const authorResponse = await supabase
+          .from("PlatformAccount")
+          .select()
+          .eq("id", authorId)
+          .maybeSingle();
+        if (authorResponse.data) author = authorResponse.data;
+      } catch (error) {
+        console.error(error);
+        // if anonymous, we do not have access.
+      }
+    }
+
+    const jsonLdData = asJsonLD({
+      platform,
+      concept,
+      baseUrl,
+      title,
+      schema,
+      content: undefined,
+      author,
+      targetFormat,
+      wrap: true,
+    });
+    text = `<div id="content">\n<script type="application/ld+json">${JSON.stringify(jsonLdData)}</script>\n${text}\n</div>`;
+  }
+  const divideFM = fullContents.text.split("---\n");
+  const firstTextFragment =
+    divideFM.length > 2 && divideFM[0]!.trim().length == 0
+      ? divideFM[2]!
+      : fullContents.text;
+
+  const wrap = `<html><head>
+    ${title ? '<meta property="og:title" content="' + title.text + '" />' : ""}
+  <meta property="og:type" content="${schemaName}" />
+  <meta property="og:url" content="${request.url}" />
+  <meta property="og:description" content="${firstTextFragment.substring(0, 80)}" />
+  </head>
+  <body>
+  <main>
+  ${text}
+  </main>
+  </body>
+  </html>
+`;
+
+  return new NextResponse(wrap, {
+    headers: { "Content-Type": targetMimetype },
+  });
+};
+
+export const OPTIONS = defaultOptionsHandler;