feat: add communication preferences

feat: add generatePreferencesLink

feat: add subscriberId endpoint

server/routers/user/mutation.ts

@@ -1,5 +1,11 @@
+import { metrics } from "@opentelemetry/api"
+
+import { env } from "@/env/server"
 import * as api from "@/lib/api"
-import { initiateSaveCardSchema } from "@/server/routers/user/output"
+import {
+  initiateSaveCardSchema,
+  subscriberIdSchema,
+} from "@/server/routers/user/output"
 import { protectedProcedure, router } from "@/server/trpc"
 
 import {
@@ -8,6 +14,17 @@ import {
   saveCreditCardInput,
 } from "./input"
 
+const meter = metrics.getMeter("trpc.user")
+const generatePreferencesLinkCounter = meter.createCounter(
+  "trpc.user.generatePreferencesLink"
+)
+const generatePreferencesLinkSuccessCounter = meter.createCounter(
+  "trpc.user.generatePreferencesLink-success"
+)
+const generatePreferencesLinkFailCounter = meter.createCounter(
+  "trpc.user.generatePreferencesLink-fail"
+)
+
 export const userMutationRouter = router({
   creditCard: router({
     add: protectedProcedure.input(addCreditCardInput).mutation(async function ({
@@ -128,4 +145,62 @@ export const userMutationRouter = router({
         return true
       }),
   }),
+  generatePreferencesLink: protectedProcedure.mutation(async function ({
+    ctx,
+  }) {
+    generatePreferencesLinkCounter.add(1)
+    const apiResponse = await api.get(api.endpoints.v1.subscriberId, {
+      headers: {
+        Authorization: `Bearer ${ctx.session.token.access_token}`,
+      },
+    })
+
+    if (!apiResponse.ok) {
+      const text = await apiResponse.text()
+      generatePreferencesLinkFailCounter.add(1, {
+        error_type: "http_error",
+        error: JSON.stringify({
+          status: apiResponse.status,
+          statusText: apiResponse.statusText,
+          text,
+        }),
+      })
+      console.error(
+        "api.user.subscriberId error ",
+        JSON.stringify({
+          error: {
+            status: apiResponse.status,
+            statusText: apiResponse.statusText,
+            text,
+          },
+        })
+      )
+      return null
+    }
+
+    const data = await apiResponse.json()
+
+    const validatedData = subscriberIdSchema.safeParse(data)
+
+    if (!validatedData.success) {
+      generatePreferencesLinkSuccessCounter.add(1, {
+        error_type: "validation_error",
+        error: JSON.stringify(validatedData.error),
+      })
+      console.error(
+        "api.user.generatePreferencesLink validation error",
+        JSON.stringify({
+          error: validatedData.error,
+        })
+      )
+      console.error(validatedData.error.format())
+
+      return null
+    }
+    const preferencesLink = new URL(env.SALESFORCE_PREFRENCE_BASE_URL)
+    preferencesLink.searchParams.set("subKey", validatedData.data.subscriberId)
+
+    generatePreferencesLinkSuccessCounter.add(1)
+    return preferencesLink.toString()
+  }),
 })

server/routers/user/output.ts

@@ -234,3 +234,7 @@ export const initiateSaveCardSchema = z.object({
     type: z.string(),
   }),
 })
+
+export const subscriberIdSchema = z.object({
+  subscriberId: z.string(),
+})