Function handler

pages/api/embed-text.ts:49–107

(req: NextRequest)

type EmbedTextType = z.infer<typeof EmbedTextZod>;

export default async function handler(req: NextRequest) {
  if (req.method !== "POST") {
    return new Response(
      JSON.stringify({
        error: "Only POST requests allowed",
      }),
      { status: 405, headers },
    );
  }
  const requestData = await req.json();
  if (!isValidBody<EmbedTextType>(requestData, EmbedTextZod)) {
    return new Response(JSON.stringify({ message: "Invalid request body" }), {
      status: 400,
      headers,
    });
  }
  const { session } = await getSessionFromCookie(req);
  if (!session) {
    return new Response(JSON.stringify({ error: "Unauthorized" }), {
      status: 401,
      headers,
    });
  }
  const profileRes = await supabase
    .from("profiles")
    .select("org_id")
    .eq("id", session.user.id)
    .single();
  if (profileRes.error) {
    return new Response(JSON.stringify({ error: "Server error" }), {
      status: 500,
      headers,
    });
  }
  if (profileRes.data.org_id === null) {
    return new Response(JSON.stringify({ error: "No organization found" }), {
      status: 400,
      headers,
    });
  }
  const embedInserts = await embedText(
    requestData.docsText,
    requestData.title,
    requestData.sectionName,
    requestData.url,
    requestData.createdAt,
  );
  await supabase.from("doc_chunks").insert(
    embedInserts.map((insert) => ({
      ...insert,
      org_id: profileRes.data.org_id!,
    })),
  );

  return new Response(JSON.stringify({ success: true }), {
    status: 200,
    headers,
  });