Merged in feat/SW-431-payment-flow (pull request #635)

Feat/SW-431 payment flow * feat(SW-431): Update mock hotel data * feat(SW-431): Added route handler and trpc routes * feat(SW-431): List payment methods and handle booking status and redirection * feat(SW-431): Updated booking page to poll for booking status * feat(SW-431): Updated create booking contract * feat(SW-431): small fix * fix(SW-431): Added intl string and sorted dictionaries * fix(SW-431): Changes from PR * fix(SW-431): fixes from PR * fix(SW-431): add todo comments * fix(SW-431): update schema prop Approved-by: Simon.Emanuelsson
2024-10-04 09:37:09 +00:00
parent 105f721dc9
commit 4103e3fb37
26 changed files with 711 additions and 287 deletions
--- a/server/routers/booking/query.ts
+++ b/server/routers/booking/query.ts
@@ -0,0 +1,85 @@
+import { metrics } from "@opentelemetry/api"
+
+import * as api from "@/lib/api"
+import { badRequestError, serverErrorByStatus } from "@/server/errors/trpc"
+import { bookingServiceProcedure, router } from "@/server/trpc"
+
+import { getBookingStatusInput } from "./input"
+import { createBookingSchema } from "./output"
+
+const meter = metrics.getMeter("trpc.booking")
+const getBookingStatusCounter = meter.createCounter("trpc.booking.status")
+const getBookingStatusSuccessCounter = meter.createCounter(
+  "trpc.booking.status-success"
+)
+const getBookingStatusFailCounter = meter.createCounter(
+  "trpc.booking.status-fail"
+)
+
+export const bookingQueryRouter = router({
+  status: bookingServiceProcedure
+    .input(getBookingStatusInput)
+    .query(async function ({ ctx, input }) {
+      const { confirmationNumber } = input
+      getBookingStatusCounter.add(1, { confirmationNumber })
+
+      const apiResponse = await api.get(
+        `${api.endpoints.v1.booking}/${confirmationNumber}/status`,
+        {
+          headers: {
+            Authorization: `Bearer ${ctx.serviceToken}`,
+          },
+        }
+      )
+
+      if (!apiResponse.ok) {
+        const responseMessage = await apiResponse.text()
+        getBookingStatusFailCounter.add(1, {
+          confirmationNumber,
+          error_type: "http_error",
+          error: responseMessage,
+        })
+        console.error(
+          "api.booking.status error",
+          JSON.stringify({
+            query: { confirmationNumber },
+            error: {
+              status: apiResponse.status,
+              statusText: apiResponse.statusText,
+              text: responseMessage,
+            },
+          })
+        )
+
+        throw serverErrorByStatus(apiResponse.status, apiResponse)
+      }
+
+      const apiJson = await apiResponse.json()
+      const verifiedData = createBookingSchema.safeParse(apiJson)
+      if (!verifiedData.success) {
+        getBookingStatusFailCounter.add(1, {
+          confirmationNumber,
+          error_type: "validation_error",
+          error: JSON.stringify(verifiedData.error),
+        })
+        console.error(
+          "api.booking.status validation error",
+          JSON.stringify({
+            query: { confirmationNumber },
+            error: verifiedData.error,
+          })
+        )
+        throw badRequestError()
+      }
+
+      getBookingStatusSuccessCounter.add(1, { confirmationNumber })
+      console.info(
+        "api.booking.status success",
+        JSON.stringify({
+          query: { confirmationNumber },
+        })
+      )
+
+      return verifiedData.data
+    }),
+})