Update with schema changes

Author: maparent

apps/website/app/api/supabase/insert/account/route.ts

@@ -65,7 +65,7 @@ const getOrCreateAccount = async (
     } else if (result.details.includes("Account_platform_id_fkey")) {
       return {
         ...result,
-        error: `Invalid platform_id: No DiscoursePlatform record found for ID ${platform_id}.`,
+        error: `Invalid platform_id: No Space record found for ID ${platform_id}.`,
       };
     }
   }

apps/website/app/api/supabase/insert/content-embedding/batch/route.ts

@@ -14,7 +14,7 @@ import {
   outputProcessing,
   type ApiInputEmbeddingItem,
   type ApiOutputEmbeddingRecord,
-} from "../routes";
+} from "../route";
 
 const batchInsertEmbeddingsProcess = async (
   supabase: Awaited<ReturnType<typeof createClient>>,

apps/website/app/api/supabase/insert/content-embedding/routes.ts renamed to apps/website/app/api/supabase/insert/content-embedding/route.ts

@@ -104,7 +104,7 @@ const processAndUpsertContentEntry = async (
       // Be more general with FK name if it changes
       return {
         ...result,
-        error: `Invalid space_id: No DiscourseSpace record found for ID ${space_id}.`,
+        error: `Invalid space_id: No Space record found for ID ${space_id}.`,
       };
     }
     if (

apps/website/app/api/supabase/insert/content/route.ts

@@ -93,7 +93,7 @@ const getOrCreateAccountInternal = async (
     if (result.details.includes("Account_platform_id_fkey")) {
       return {
         ...result,
-        error: `Invalid platform_id for Account: No DiscoursePlatform record found for ID ${platformId}.`,
+        error: `Invalid platform_id for Account: No Space record found for ID ${platformId}.`,
       };
     }
   }

apps/website/app/api/supabase/insert/person/route.ts

@@ -11,13 +11,13 @@ import {
 } from "~/utils/supabase/apiUtils";
 import { Tables, TablesInsert } from "~/utils/supabase/types.gen";
 
-type DiscoursePlatformDataInput = TablesInsert<"DiscoursePlatform">;
-type DiscoursePlatformRecord = Tables<"DiscoursePlatform">;
+type SpaceDataInput = TablesInsert<"Space">;
+type SpaceRecord = Tables<"Space">;
 
-const getOrCreateDiscoursePlatformFromURL = async (
+const getOrCreateSpaceFromURL = async (
   supabase: ReturnType<typeof createClient>,
   url: string,
-): Promise<GetOrCreateEntityResult<DiscoursePlatformRecord>> => {
+): Promise<GetOrCreateEntityResult<SpaceRecord>> => {
   let platformName: string | null = null;
   let platformUrl: string | null = null;
   const lowerCaseURL = url.toLowerCase();
@@ -45,21 +45,21 @@ const getOrCreateDiscoursePlatformFromURL = async (
   }
 
   const resolvedSupabaseClient = await supabase;
-  return getOrCreateEntity<"DiscoursePlatform">(
+  return getOrCreateEntity<"Space">(
     resolvedSupabaseClient,
-    "DiscoursePlatform",
+    "Space",
     "id, name, url",
     { url: platformUrl },
     { name: platformName, url: platformUrl },
-    "DiscoursePlatform",
+    "Space",
   );
 };
 
 export const POST = async (request: NextRequest): Promise<NextResponse> => {
   const supabase = createClient();
 
   try {
-    const body: DiscoursePlatformDataInput = await request.json();
+    const body: SpaceDataInput = await request.json();
     const { url } = body;
 
     if (!url || typeof url !== "string") {
@@ -69,7 +69,7 @@ export const POST = async (request: NextRequest): Promise<NextResponse> => {
       });
     }
 
-    const result = await getOrCreateDiscoursePlatformFromURL(supabase, url);
+    const result = await getOrCreateSpaceFromURL(supabase, url);
 
     return createApiResponse(request, {
       data: result.entity,
@@ -79,11 +79,7 @@ export const POST = async (request: NextRequest): Promise<NextResponse> => {
       created: result.created,
     });
   } catch (e: unknown) {
-    return handleRouteError(
-      request,
-      e,
-      "/api/supabase/insert/discourse-platform",
-    );
+    return handleRouteError(request, e, "/api/supabase/insert/platform");
   }
 };
 

apps/website/app/api/supabase/insert/discourse-platform/route.ts renamed to apps/website/app/api/supabase/insert/platform/route.ts

@@ -11,14 +11,14 @@ import {
 } from "~/utils/supabase/apiUtils";
 import { Tables, TablesInsert } from "~/utils/supabase/types.gen";
 
-type DiscourseSpaceDataInput = TablesInsert<"DiscourseSpace">;
-type DiscourseSpaceRecord = Tables<"DiscourseSpace">;
+type SpaceDataInput = TablesInsert<"Space">;
+type SpaceRecord = Tables<"Space">;
 
 // Renamed and refactored helper function
-const processAndGetOrCreateDiscourseSpace = async (
+const processAndGetOrCreateSpace = async (
   supabasePromise: ReturnType<typeof createClient>,
-  data: DiscourseSpaceDataInput,
-): Promise<GetOrCreateEntityResult<DiscourseSpaceRecord>> => {
+  data: SpaceDataInput,
+): Promise<GetOrCreateEntityResult<SpaceRecord>> => {
   const { name, url, discourse_platform_id } = data;
 
   // --- Start of validation ---
@@ -56,17 +56,17 @@ const processAndGetOrCreateDiscourseSpace = async (
   const trimmedName = name.trim();
   const supabase = await supabasePromise;
 
-  const result = await getOrCreateEntity<"DiscourseSpace">(
+  const result = await getOrCreateEntity<"Space">(
     supabase,
-    "DiscourseSpace",
+    "Space",
     "id, name, url, discourse_platform_id",
     { url: normalizedUrl, discourse_platform_id: discourse_platform_id },
     {
       name: trimmedName,
       url: normalizedUrl,
       discourse_platform_id: discourse_platform_id,
     },
-    "DiscourseSpace",
+    "Space",
   );
 
   // Custom handling for specific foreign key error related to discourse_platform_id
@@ -79,12 +79,12 @@ const processAndGetOrCreateDiscourseSpace = async (
     if (
       result.details
         .toLowerCase()
-        .includes("discoursespace_discourse_platform_id_fkey") ||
+        .includes("Space_discourse_platform_id_fkey") ||
       result.details.toLowerCase().includes("discourse_platform_id")
     ) {
       return {
         ...result,
-        error: `Invalid discourse_platform_id: No DiscoursePlatform record found for ID ${discourse_platform_id}.`,
+        error: `Invalid discourse_platform_id: No Space record found for ID ${discourse_platform_id}.`,
       };
     }
   }
@@ -96,7 +96,7 @@ export const POST = async (request: NextRequest): Promise<NextResponse> => {
   const supabasePromise = createClient();
 
   try {
-    const body: DiscourseSpaceDataInput = await request.json();
+    const body: SpaceDataInput = await request.json();
 
     // Minimal validation here, more detailed in the helper
     if (!body || typeof body !== "object") {
@@ -106,10 +106,7 @@ export const POST = async (request: NextRequest): Promise<NextResponse> => {
       });
     }
 
-    const result = await processAndGetOrCreateDiscourseSpace(
-      supabasePromise,
-      body,
-    );
+    const result = await processAndGetOrCreateSpace(supabasePromise, body);
 
     return createApiResponse(request, {
       data: result.entity,
@@ -119,7 +116,7 @@ export const POST = async (request: NextRequest): Promise<NextResponse> => {
       created: result.created,
     });
   } catch (e: unknown) {
-    return handleRouteError(request, e, "/api/supabase/insert/discourse-space");
+    return handleRouteError(request, e, "/api/supabase/insert/space");
   }
 };