diff --git a/server/routers/hotels/query.ts b/server/routers/hotels/query.ts index 3f9d6ec33..70b8363ed 100644 --- a/server/routers/hotels/query.ts +++ b/server/routers/hotels/query.ts @@ -1,3 +1,5 @@ +import { metrics } from "@opentelemetry/api" + import * as api from "@/lib/api" import { badRequestError } from "@/server/errors/trpc" import { publicProcedure, router, serviceProcedure } from "@/server/trpc" @@ -17,11 +19,17 @@ import { import tempFilterData from "./tempFilterData.json" import tempRatesData from "./tempRatesData.json" +const meter = metrics.getMeter("trpc.hotels") +let getHotelCounter = meter.createCounter("trpc.hotel.get") +let getHotelSuccessCounter = meter.createCounter("trpc.hotel.get-success") +let getHotelFailCounter = meter.createCounter("trpc.hotel.get-fail") + export const hotelQueryRouter = router({ getHotel: serviceProcedure .input(getHotelInputSchema) .query(async ({ ctx, input }) => { const { hotelId, language, include } = input + getHotelCounter.add(1, { hotelId, language, include }) const apiLang = toApiLang(language) const params: Record = {