feat(SW-285): add support for tags

2024-08-30 14:31:27 +02:00
parent 57cd8c72da
commit dd336ca4ab
4 changed files with 235 additions and 4 deletions
--- a/server/routers/contentstack/contentPage/utils.ts
+++ b/server/routers/contentstack/contentPage/utils.ts
@@ -0,0 +1,132 @@
+import { metrics } from "@opentelemetry/api"
+
+import { Lang } from "@/constants/languages"
+import { GetContentPageRefs } from "@/lib/graphql/Query/ContentPage.graphql"
+import { request } from "@/lib/graphql/request"
+import { notFound } from "@/server/errors/trpc"
+
+import { generateTag, generateTags } from "@/utils/generateTag"
+
+import { removeEmptyObjects } from "../../utils"
+import { ContentPageRefsDataRaw, validateContentPageRefsSchema } from "./output"
+
+import { ContentBlocksTypenameEnum } from "@/types/components/content/enums"
+import { Edges } from "@/types/requests/utils/edges"
+import { NodeRefs } from "@/types/requests/utils/refs"
+
+const meter = metrics.getMeter("trpc.contentPage")
+// OpenTelemetry metrics: ContentPage
+
+export const getContentPageCounter = meter.createCounter(
+  "trpc.contentstack.contentPage.get"
+)
+
+const getContentPageRefsCounter = meter.createCounter(
+  "trpc.contentstack.contentPage.get"
+)
+const getContentPageRefsFailCounter = meter.createCounter(
+  "trpc.contentstack.contentPage.get-fail"
+)
+const getContentPageRefsSuccessCounter = meter.createCounter(
+  "trpc.contentstack.contentPage.get-success"
+)
+
+export async function fetchContentPageRefs(lang: Lang, uid: string) {
+  getContentPageRefsCounter.add(1, { lang, uid })
+  console.info(
+    "contentstack.contentPage.refs start",
+    JSON.stringify({
+      query: { lang, uid },
+    })
+  )
+  const refsResponse = await request<ContentPageRefsDataRaw>(
+    GetContentPageRefs,
+    { locale: lang, uid },
+    { cache: "force-cache", next: { tags: [generateTag(lang, uid)] } }
+  )
+  if (!refsResponse.data) {
+    const notFoundError = notFound(refsResponse)
+    getContentPageRefsFailCounter.add(1, {
+      lang,
+      uid,
+      error_type: "http_error",
+      error: JSON.stringify({
+        code: notFoundError.code,
+      }),
+    })
+    console.error(
+      "contentstack.contentPage.refs not found error",
+      JSON.stringify({
+        query: {
+          lang,
+          uid,
+        },
+        error: { code: notFoundError.code },
+      })
+    )
+    throw notFoundError
+  }
+
+  return removeEmptyObjects(refsResponse.data)
+}
+
+export function validateContentPageRefs(data: any, lang: Lang, uid: string) {
+  const validatedData = validateContentPageRefsSchema.safeParse(data)
+  if (!validatedData.success) {
+    getContentPageRefsFailCounter.add(1, {
+      lang,
+      uid,
+      error_type: "validation_error",
+      error: JSON.stringify(validatedData.error),
+    })
+    console.error(
+      "contentstack.contentPage.refs validation error",
+      JSON.stringify({
+        query: { lang, uid },
+        error: validatedData.error,
+      })
+    )
+    return null
+  }
+  getContentPageRefsSuccessCounter.add(1, { lang, uid })
+  console.info(
+    "contentstack.contentPage.refs success",
+    JSON.stringify({
+      query: { lang, uid },
+    })
+  )
+  return validatedData.data
+}
+
+export function generatePageTags(validatedData: any, lang: Lang): string[] {
+  const connections = getConnections(validatedData)
+  return [
+    generateTags(lang, connections),
+    generateTag(lang, validatedData.content_page.system.uid),
+  ].flat()
+}
+
+export function getConnections(refs: ContentPageRefsDataRaw) {
+  const connections: Edges<NodeRefs>[] = []
+  if (refs.content_page.blocks) {
+    refs.content_page.blocks.forEach((item) => {
+      switch (item.__typename) {
+        case ContentBlocksTypenameEnum.ContentPageBlocksContent: {
+          if (item.content.content.embedded_itemsConnection.edges.length) {
+            connections.push(item.content.content.embedded_itemsConnection)
+          }
+          break
+        }
+        case ContentBlocksTypenameEnum.ContentPageBlocksShortcuts: {
+          item.shortcuts.shortcuts.forEach((shortcut) => {
+            if (shortcut.linkConnection.edges.length) {
+              connections.push(shortcut.linkConnection)
+            }
+          })
+          break
+        }
+      }
+    })
+  }
+  return connections
+}