Contentful

import { createLens, registerLens } from "@avocadostudio-ai/site-sdk/lens"
import {
  contentfulLocale,
  contentfulPrimitives,
  createContentfulDelivery,
  localizedFields,
  type LocalizedFields,
} from "@avocadostudio-ai/site-sdk/lens/contentful"
import { TABLE } from "./table"

export const DEFAULT_LOCALE = "en-US"
export const LOCALES = ["en-US", "de-DE"] as const
export type Locale = (typeof LOCALES)[number]

export const cda = createContentfulDelivery({
  spaceId: process.env.CONTENTFUL_SPACE_ID!,
  accessToken: process.env.CONTENTFUL_PREVIEW_TOKEN!,
  preview: true,
})

// Which fields are localised is a fact about the space, not the table.
let schema: LocalizedFields | undefined
export async function loadSchema() {
  schema = localizedFields(await cda.contentTypes())
  return schema
}

export const lens = createLens<Locale>({
  table: TABLE,
  locale: contentfulLocale<Locale>(DEFAULT_LOCALE, LOCALES, { localized: () => schema }),
  primitives: contentfulPrimitives(),
})

registerLens(lens)

import type { OnPublishFn } from "@avocadostudio-ai/site-sdk/routes"
import {
  createContentfulManagement,
  entryPatch,
  readEntry,
  type EntryWrite,
} from "@avocadostudio-ai/site-sdk/lens/contentful"
import { cda, lens, loadSchema, DEFAULT_LOCALE, type Locale } from "./contentful"

const cma = createContentfulManagement({
  spaceId: process.env.CONTENTFUL_SPACE_ID!,
  accessToken: process.env.CONTENTFUL_MANAGEMENT_TOKEN!,
})

export const onPublish: OnPublishFn = async (pages, _config, context) => {
  const localized = await loadSchema()
  const writes: EntryWrite[] = []
  // Edits the lens refused (shared alt text, a non-localized field edited on a
  // de-DE page). The editor lists each as "Not published: …".
  const skipped: string[] = []

  for (const page of pages) {
    // The adapter put the entry id and the locale in the page id.
    const [entryId, locale] = page.id.split("~") as [string, Locale]
    const { entry, includes } = await cda.entry(entryId)
    if (!entry?.sys.contentType) continue

    const source = readEntry(entry, { defaultLocale: DEFAULT_LOCALE, localized, includes })
    let doc = source
    for (const block of page.blocks) {
      const merged = lens.merge(doc, block.props, block.type, locale)
      for (const w of merged.warnings) skipped.push(`${page.slug} › ${w.where}: ${w.reason}`)
      doc = merged.doc
    }

    const contentType = entry.sys.contentType.sys.id
    writes.push({
      entryId,
      label: page.slug,
      patch: entryPatch(source, doc, { defaultLocale: DEFAULT_LOCALE, localized, contentType }),
    })
  }

  const result = await cma.publishEntries(writes, {
    defaultLocale: DEFAULT_LOCALE,
    inlineAssets: context?.assets,
  })
  if (!result.ok) return { ok: false, error: result.error }
  return skipped.length > 0 ? { ok: true, unsupported: skipped } : { ok: true }
}