Merged in fix/move-sas-comparison-to-dynamic-content (pull request #1279)

Move SASTierComparison block to DynamicContent Approved-by: Erik Tiekstra
2025-02-11 09:36:41 +00:00
parent 1d4993fb7f
commit 6eb01750e8
20 changed files with 211 additions and 147 deletions
@@ -0,0 +1,5 @@
+import { mergeRouters } from "@/server/trpc"
+
+import { partnerQueryRouter } from "./query"
+
+export const partnerRouter = mergeRouters(partnerQueryRouter)
@@ -0,0 +1,31 @@
+import { z } from "zod"
+
+const link = z.object({
+  href: z.string(),
+  title: z.string(),
+})
+
+export const validateSasTierComparisonSchema = z
+  .object({
+    all_sas_tier_comparison: z.object({
+      items: z.array(
+        z.object({
+          scandic_column_title: z.string(),
+          sas_column_title: z.string(),
+          tier_matches: z.array(
+            z.object({
+              scandic_friends_tier_name: z.string(),
+              sas_eb_tier_name: z.string(),
+              title: z.string(),
+              content: z.object({
+                json: z.any(), // json
+              }),
+              link: link.optional(),
+            })
+          ),
+          cta: link.optional(),
+        })
+      ),
+    }),
+  })
+  .transform((data) => data.all_sas_tier_comparison.items.at(0))
@@ -0,0 +1,86 @@
+import { metrics } from "@opentelemetry/api"
+import { cache } from "react"
+
+import { GetAllSasTierComparison } from "@/lib/graphql/Query/SASTierComparison.graphql"
+import { request } from "@/lib/graphql/request"
+import { notFound } from "@/server/errors/trpc"
+import { contentstackBaseProcedure, router } from "@/server/trpc"
+
+import { validateSasTierComparisonSchema } from "./output"
+
+import type { SasTierComparisonResponse } from "@/types/trpc/routers/contentstack/partner"
+import type { Context } from "@/server/context"
+
+const meter = metrics.getMeter("trpc.partner")
+const getSasTierComparisonCounter = meter.createCounter(
+  "trpc.contentstack.partner.getSasTierComparison"
+)
+
+const getSasTierComparisonSuccessCounter = meter.createCounter(
+  "trpc.contentstack.partner.getSasTierComparison-success"
+)
+const getSasTierComparisonFailCounter = meter.createCounter(
+  "trpc.contentstack.partner.getSasTierComparison-fail"
+)
+
+export const getSasTierComparison = cache(async (ctx: Context) => {
+  getSasTierComparisonCounter.add(1)
+
+  const tag = `${ctx.lang}:sas_tier_comparison`
+  const sasTierComparisonConfigResponse =
+    await request<SasTierComparisonResponse>(
+      GetAllSasTierComparison,
+      { lang: ctx.lang },
+      {
+        next: {
+          tags: [tag],
+        },
+        cache: "force-cache",
+      }
+    )
+
+  if (!sasTierComparisonConfigResponse.data) {
+    getSasTierComparisonFailCounter.add(1)
+    const notFoundError = notFound(sasTierComparisonConfigResponse)
+    console.error(
+      "contentstack.sas not found error",
+      JSON.stringify({
+        query: {
+          lang: ctx.lang,
+        },
+        error: { code: notFoundError.code },
+      })
+    )
+    throw notFoundError
+  }
+
+  const validatedSasTierComparison = validateSasTierComparisonSchema.safeParse(
+    sasTierComparisonConfigResponse.data
+  )
+
+  if (!validatedSasTierComparison.success) {
+    getSasTierComparisonFailCounter.add(1)
+    console.error(validatedSasTierComparison.error)
+    console.error(
+      "contentstack.sas validation error",
+      JSON.stringify({
+        query: {
+          lang: ctx.lang,
+        },
+        error: validatedSasTierComparison.error,
+      })
+    )
+    return null
+  }
+
+  getSasTierComparisonSuccessCounter.add(1)
+  return validatedSasTierComparison.data
+})
+
+export const partnerQueryRouter = router({
+  getSasTierComparison: contentstackBaseProcedure.query(async function ({
+    ctx,
+  }) {
+    return getSasTierComparison(ctx)
+  }),
+})