Merged in feat/sw-1732-trigger-tier-match (pull request #1408)

SW-1732 Trigger SAS tier match

* Add endpoint for SAS tier match

* Add comment about future fix

* Move tier match to background request on my-pages/*

* Log result from tier match

* Clean up name etc

* Fix tier matched toast

Approved-by: Joakim Jäderberg

apps/scandic-web/server/routers/partners/sas/performLevelUpgrade.ts

@@ -1,21 +1,97 @@
-import { TRPCError } from "@trpc/server"
+import { cookies } from "next/headers"
 import { z } from "zod"
 
+import * as api from "@/lib/api"
+import { getVerifiedUser } from "@/server/routers/user/query"
 import { protectedProcedure } from "@/server/trpc"
 
 import { timeout } from "@/utils/timeout"
 
-const outputSchema = z.object({})
+const matchedSchema = z.object({
+  tierMatchState: z.enum(["matched"]),
+  toLevel: z.enum(["L1", "L2", "L3", "L4", "L5", "L6", "L7"]),
+})
+const notMatchedSchema = z.object({
+  tierMatchState: z.enum(["alreadyMatched", "notLinked", "error", "cached"]),
+})
+
+const outputSchema = z.union([matchedSchema, notMatchedSchema])
 
 export const performLevelUpgrade = protectedProcedure
   .output(outputSchema)
-  .mutation(async function ({ ctx, input }) {
-    console.log("[SAS] perform upgrade")
-    await timeout(1000)
-    //TODO: Call actual API here
+  .mutation(async function ({ ctx }) {
+    console.log("[SAS] tier match")
 
-    throw new TRPCError({
-      message: "Unable to perform ugprade",
-      code: "BAD_REQUEST",
+    const cookieStore = cookies()
+    const sasTierMatch = cookieStore.get("sasTierMatch")
+    if (sasTierMatch) {
+      return { tierMatchState: "cached" }
+    }
+
+    const userBeforeTierMatch = await getVerifiedUser({
+      session: ctx.session,
     })
+    if (!userBeforeTierMatch || userBeforeTierMatch?.error) {
+      return { tierMatchState: "error" }
+    }
+
+    const apiResponse = await api.post(api.endpoints.v1.Profile.matchTier, {
+      headers: {
+        Authorization: `Bearer ${ctx.session.token.access_token}`,
+      },
+      body: {
+        partner: "sas_eb",
+        partnerSpecific: {},
+      },
+    })
+
+    cookieStore.set("sasTierMatch", "true", {
+      maxAge: 60 * 60 * 24,
+      httpOnly: true,
+    })
+
+    if (apiResponse.status === 202) {
+      console.log("[SAS] tier match started")
+
+      // Since the tier match is async we need to wait for it to complete before checking the result
+      await timeout(1000)
+
+      const userAfterTierMatch = await getVerifiedUser({
+        session: ctx.session,
+      })
+      if (!userAfterTierMatch || userAfterTierMatch?.error) {
+        return { tierMatchState: "error" }
+      }
+
+      const beforeLevel = userBeforeTierMatch.data.membership?.membershipLevel
+      const afterLevel = userAfterTierMatch.data.membership?.membershipLevel
+
+      if (!beforeLevel || !afterLevel) {
+        console.log("[SAS] tier match error, user tier not found")
+        return { tierMatchState: "error" }
+      }
+
+      if (beforeLevel !== afterLevel) {
+        console.log(
+          `[SAS] tier match success, user tier changed from ${beforeLevel} to ${afterLevel}`
+        )
+        return { tierMatchState: "matched", toLevel: afterLevel }
+      }
+
+      return { tierMatchState: "alreadyMatched" }
+    }
+
+    if (apiResponse.status === 204) {
+      console.log("[SAS] tier already matched")
+      return { tierMatchState: "alreadyMatched" }
+    }
+
+    if (apiResponse.status === 404) {
+      return { tierMatchState: "notLinked" }
+    }
+
+    console.log(
+      `[SAS] tier match error with status code ${apiResponse.status} and response ${await apiResponse.text()}`
+    )
+    return { tierMatchState: "error" }
   })