feat(sw-453): implemented filter from packages

server/routers/hotels/query.ts

@@ -25,6 +25,10 @@ import {
   getHotelPageCounter,
   validateHotelPageRefs,
 } from "../contentstack/hotelPage/utils"
+import {
+  getRoomPackagesInputSchema,
+  getRoomPackagesSchema,
+} from "./schemas/packages"
 import {
   getHotelInputSchema,
   getHotelsAvailabilityInputSchema,
@@ -57,6 +61,14 @@ const getHotelCounter = meter.createCounter("trpc.hotel.get")
 const getHotelSuccessCounter = meter.createCounter("trpc.hotel.get-success")
 const getHotelFailCounter = meter.createCounter("trpc.hotel.get-fail")
 
+const getPackagesCounter = meter.createCounter("trpc.hotel.packages.get")
+const getPackagesSuccessCounter = meter.createCounter(
+  "trpc.hotel.packages.get-success"
+)
+const getPackagesFailCounter = meter.createCounter(
+  "trpc.hotel.packages.get-fail"
+)
+
 const hotelsAvailabilityCounter = meter.createCounter(
   "trpc.hotel.availability.hotels"
 )
@@ -694,4 +706,89 @@ export const hotelQueryRouter = router({
       return locations
     }),
   }),
+  packages: router({
+    get: serviceProcedure
+      .input(getRoomPackagesInputSchema)
+      .query(async ({ input, ctx }) => {
+        const { hotelId, startDate, endDate, adults, children, packageCodes } =
+          input
+
+        const searchParams = new URLSearchParams({
+          startDate,
+          endDate,
+          adults: adults.toString(),
+          children: children.toString(),
+        })
+
+        packageCodes.forEach((code) => {
+          searchParams.append("packageCodes", code)
+        })
+
+        const params = searchParams.toString()
+
+        getPackagesCounter.add(1, {
+          hotelId,
+        })
+        console.info(
+          "api.hotels.packages start",
+          JSON.stringify({ query: { hotelId, params } })
+        )
+
+        const apiResponse = await api.get(
+          `${api.endpoints.v1.packages}/${hotelId}`,
+          {
+            headers: {
+              Authorization: `Bearer ${ctx.serviceToken}`,
+            },
+          },
+          params
+        )
+
+        if (!apiResponse.ok) {
+          getPackagesFailCounter.add(1, {
+            hotelId,
+            error_type: "http_error",
+            error: JSON.stringify({
+              status: apiResponse.status,
+              statusText: apiResponse.statusText,
+            }),
+          })
+          console.error(
+            "api.hotels.packages error",
+            JSON.stringify({ query: { hotelId, params } })
+          )
+          throw serverErrorByStatus(apiResponse.status, apiResponse)
+        }
+
+        const apiJson = await apiResponse.json()
+        const validatedPackagesData = getRoomPackagesSchema.safeParse(apiJson)
+
+        if (!validatedPackagesData.success) {
+          getHotelFailCounter.add(1, {
+            hotelId,
+            error_type: "validation_error",
+            error: JSON.stringify(validatedPackagesData.error),
+          })
+
+          console.error(
+            "api.hotels.packages validation error",
+            JSON.stringify({
+              query: { hotelId, params },
+              error: validatedPackagesData.error,
+            })
+          )
+          throw badRequestError()
+        }
+
+        getPackagesSuccessCounter.add(1, {
+          hotelId,
+        })
+        console.info(
+          "api.hotels.packages success",
+          JSON.stringify({ query: { hotelId, params: params } })
+        )
+
+        return validatedPackagesData.data
+      }),
+  }),
 })