Inhaltssynchronisation Contentful zu Algolia mit Next.js 14

NEXT_PUBLIC_ALGOLIA_APP_ID=xxxx -> Algolia ApplicationID 
NEXT_PUBLIC_ALGOLIA_API_KEY=xxxx -> Algolia Search-Only Key used later
ALGOLIA_MASTER_KEY=xxxx -> Algolia Admin Key (Write rights)
NEXT_PUBLIC_ALGOLIA_INDEX_NAME=example_dev
API_KEY=xxxxx -> Random Key, which we use for securing the endpoint

node -e "console.log(crypto.randomBytes(32).toString('hex'))"

import { NextRequest, NextResponse } from "next/server";
import { documentToPlainTextString } from "@contentful/rich-text-plain-text-renderer";
import { client } from "@/lib/client";
import { fallbackLng, locales } from "@/app/i18n/settings";

const apikey = process.env.API_KEY;

export async function POST(request: NextRequest) {
  const document = await request.json();
  let json_de: string = "";
  let json_en: string = "";

  if (request.headers.get("x-api-key") !== apikey) {
    return new NextResponse(
      JSON.stringify({ status: "fail", message: "You are not authorized" }),
      { status: 401 }
    );
  }

  const locale = fallbackLng as string;

  const blogPagedata = await client.pageBlogPost({
    locale,
    preview: false,
    slug: document.slug,
  });

  const blogPost = blogPagedata.pageBlogPostCollection?.items[0];
  json_en = documentToPlainTextString(blogPost.content?.json);
  const tags = blogPost.contentfulMetadata?.tags;
  const tagsnew: any = [];

  tags.map((tag) => {
    tagsnew.push(tag.id);
  }); 

  const blogPagedata_de = await client.pageBlogPost({
    locale: "de-DE",
    preview: false,
    slug: document.slug,
  });

  const blogPost_de = blogPagedata_de.pageBlogPostCollection?.items[0];
  json_de = documentToPlainTextString(blogPost_de.content?.json);

  const AlgoliaUrl =
    "https://" +
    process.env.NEXT_PUBLIC_ALGOLIA_APP_ID +
    ".algolia.net/1/indexes/" +
    process.env.NEXT_PUBLIC_ALGOLIA_INDEX_NAME +
    "/" +
    document.entityId;

  const date = blogPost.publishedDate;
  const formatDate = new Date(date).toISOString().substring(0, 10);
  const timeStamp = new Date(date).getTime() / 1000;

  const jsonData: any = {
    entityId: document.entityId,
    height: blogPost?.featuredImage?.height.toString(),
    width: blogPost?.featuredImage?.width.toString(),
    image: blogPost?.featuredImage?.url,
    intName: document.intName,
    lang: {
      "de-DE": {
        content: json_de,
        shortDescription: document.shortDescription_de,
        title: document.title_de,
      },
      "en-US": {
        content: json_en,
        shortDescription: document.shortDescription_en,
        title: document.title_en,
      },
    },
    pubdate: formatDate,
    pubdatetimestamp: timeStamp,
    slug: document.slug,
    spaceId: document.spaceId,
    tags: tagsnew,
  };

  const res = await fetch(AlgoliaUrl, {
    method: "PUT",
    body: JSON.stringify(jsonData),
    headers: {
      "Content-Type": "application/json; charset=utf-8",
      "X-Algolia-API-Key": process.env.ALGOLIA_MASTER_KEY,
      "X-Algolia-Application-Id": process.env.NEXT_PUBLIC_ALGOLIA_APP_ID,
    },
  });

  if (!res.ok) {
    const text = await res.text();

    throw new Error(`
      Failed to fetch data
      Status: ${res.status}
      Response: ${text}
    `);
  }

  const result: any = await res.json();
  // console.log("result", result);

  return NextResponse.json(
    { transformed: true, date: Date.now() },
    { status: 200 }
  );
}

import { NextRequest, NextResponse } from "next/server"; -> standard Nextjs Api package
import { documentToPlainTextString } from "@contentful/rich-text-plain-text-renderer"; -> needed to extract the text part out of the JSON (Contentful Rich Text field)
import { client } from "@/lib/client"; -> client for Contentful graphQL operations
import { fallbackLng, locales } from "@/app/i18n/settings"; -> Language settings

const apikey = process.env.API_KEY; -> getting API Key 

// Return 401 in case we provide the wrong "x-api-key" in the header

if (request.headers.get("x-api-key") !== apikey) {
    return new NextResponse(
      JSON.stringify({ status: "fail", message: "You are not authorized" }),
      { status: 401 }
    );
  }