fix: move crunching of data to trpc layer

server/routers/hotels/input.ts

@@ -29,6 +29,23 @@ export const getRoomsAvailabilityInputSchema = z.object({
   rateCode: z.string().optional(),
 })
 
+export const getSelectedRoomAvailabilityInputSchema = z.object({
+  hotelId: z.number(),
+  roomStayStartDate: z.string(),
+  roomStayEndDate: z.string(),
+  adults: z.number(),
+  children: z.string().optional(),
+  promotionCode: z.string().optional(),
+  reservationProfileType: z.string().optional().default(""),
+  attachedProfileId: z.string().optional().default(""),
+  rateCode: z.string(),
+  roomTypeCode: z.string(),
+})
+
+export type GetSelectedRoomAvailabilityInput = z.input<
+  typeof getSelectedRoomAvailabilityInputSchema
+>
+
 export type GetRoomsAvailabilityInput = z.input<
   typeof getRoomsAvailabilityInputSchema
 >

server/routers/hotels/query.ts

@@ -37,6 +37,7 @@ import {
   getHotelsAvailabilityInputSchema,
   getRatesInputSchema,
   getRoomsAvailabilityInputSchema,
+  getSelectedRoomAvailabilityInputSchema,
 } from "./input"
 import {
   breakfastPackagesSchema,
@@ -93,6 +94,16 @@ const roomsAvailabilityFailCounter = meter.createCounter(
   "trpc.hotel.availability.rooms-fail"
 )
 
+const selectedRoomAvailabilityCounter = meter.createCounter(
+  "trpc.hotel.availability.room"
+)
+const selectedRoomAvailabilitySuccessCounter = meter.createCounter(
+  "trpc.hotel.availability.room-success"
+)
+const selectedRoomAvailabilityFailCounter = meter.createCounter(
+  "trpc.hotel.availability.room-fail"
+)
+
 const breakfastPackagesCounter = meter.createCounter("trpc.package.breakfast")
 const breakfastPackagesSuccessCounter = meter.createCounter(
   "trpc.package.breakfast-success"
@@ -545,6 +556,161 @@ export const hotelQueryRouter = router({
 
         return validateAvailabilityData.data
       }),
+    room: serviceProcedure
+      .input(getSelectedRoomAvailabilityInputSchema)
+      .query(async ({ input, ctx }) => {
+        const {
+          hotelId,
+          roomStayStartDate,
+          roomStayEndDate,
+          adults,
+          children,
+          promotionCode,
+          reservationProfileType,
+          attachedProfileId,
+          rateCode,
+          roomTypeCode,
+        } = input
+
+        const params: Record<string, string | number | undefined> = {
+          roomStayStartDate,
+          roomStayEndDate,
+          adults,
+          ...(children && { children }),
+          promotionCode,
+          reservationProfileType,
+          attachedProfileId,
+        }
+
+        selectedRoomAvailabilityCounter.add(1, {
+          hotelId,
+          roomStayStartDate,
+          roomStayEndDate,
+          adults,
+          children,
+          promotionCode,
+          reservationProfileType,
+        })
+        console.info(
+          "api.hotels.selectedRoomAvailability start",
+          JSON.stringify({ query: { hotelId, params } })
+        )
+        const apiResponseAvailability = await api.get(
+          api.endpoints.v1.Availability.hotel(hotelId.toString()),
+          {
+            headers: {
+              Authorization: `Bearer ${ctx.serviceToken}`,
+            },
+          },
+          params
+        )
+
+        if (!apiResponseAvailability.ok) {
+          const text = await apiResponseAvailability.text()
+          selectedRoomAvailabilityFailCounter.add(1, {
+            hotelId,
+            roomStayStartDate,
+            roomStayEndDate,
+            adults,
+            children,
+            promotionCode,
+            reservationProfileType,
+            error_type: "http_error",
+            error: JSON.stringify({
+              status: apiResponseAvailability.status,
+              statusText: apiResponseAvailability.statusText,
+              text,
+            }),
+          })
+          console.error(
+            "api.hotels.selectedRoomAvailability error",
+            JSON.stringify({
+              query: { hotelId, params },
+              error: {
+                status: apiResponseAvailability.status,
+                statusText: apiResponseAvailability.statusText,
+                text,
+              },
+            })
+          )
+          return null
+        }
+        const apiJsonAvailability = await apiResponseAvailability.json()
+        const validateAvailabilityData =
+          getRoomsAvailabilitySchema.safeParse(apiJsonAvailability)
+        if (!validateAvailabilityData.success) {
+          selectedRoomAvailabilityFailCounter.add(1, {
+            hotelId,
+            roomStayStartDate,
+            roomStayEndDate,
+            adults,
+            children,
+            promotionCode,
+            reservationProfileType,
+            error_type: "validation_error",
+            error: JSON.stringify(validateAvailabilityData.error),
+          })
+          console.error(
+            "api.hotels.selectedRoomAvailability validation error",
+            JSON.stringify({
+              query: { hotelId, params },
+              error: validateAvailabilityData.error,
+            })
+          )
+          throw badRequestError()
+        }
+
+        const selectedRoom = validateAvailabilityData.data.roomConfigurations
+          .filter((room) => room.status === "Available")
+          .find((room) => room.roomTypeCode === roomTypeCode)
+
+        if (!selectedRoom) {
+          console.error("No matching room found")
+          return null
+        }
+
+        const memberRate = selectedRoom.products.find(
+          (rate) => rate.productType.member?.rateCode === rateCode
+        )?.productType.member
+
+        const publicRate = selectedRoom.products.find(
+          (rate) => rate.productType.public?.rateCode === rateCode
+        )?.productType.public
+
+        const mustBeGuaranteed =
+          validateAvailabilityData.data.rateDefinitions.filter(
+            (rate) => rate.rateCode === rateCode
+          )[0].mustBeGuaranteed
+
+        const cancellationText =
+          validateAvailabilityData.data.rateDefinitions.find(
+            (rate) => rate.rateCode === rateCode
+          )?.cancellationText ?? ""
+
+        selectedRoomAvailabilitySuccessCounter.add(1, {
+          hotelId,
+          roomStayStartDate,
+          roomStayEndDate,
+          adults,
+          children,
+          promotionCode,
+          reservationProfileType,
+        })
+        console.info(
+          "api.hotels.selectedRoomAvailability success",
+          JSON.stringify({
+            query: { hotelId, params: params },
+          })
+        )
+
+        return {
+          selectedRoom,
+          mustBeGuaranteed,
+          cancellationText,
+          memberRate,
+          publicRate,
+        }
+      }),
   }),
   rates: router({
     get: publicProcedure