scandic/web
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: add metrics PoC counters to getHotel trpc query

Browse Source
This commit is contained in:
Arvid Norlin
2024-08-15 09:26:49 +02:00
parent 7388df5f5f
commit e3ca26d0df
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
server/routers/hotels/query.ts
View File

@@ -1,3 +1,5 @@
import { metrics } from "@opentelemetry/api"
import * as api from "@/lib/api" import * as api from "@/lib/api"
import { badRequestError } from "@/server/errors/trpc" import { badRequestError } from "@/server/errors/trpc"
import { publicProcedure, router, serviceProcedure } from "@/server/trpc" import { publicProcedure, router, serviceProcedure } from "@/server/trpc"
@@ -17,11 +19,17 @@ import {
import tempFilterData from "./tempFilterData.json" import tempFilterData from "./tempFilterData.json"
import tempRatesData from "./tempRatesData.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({ export const hotelQueryRouter = router({
getHotel: serviceProcedure getHotel: serviceProcedure
.input(getHotelInputSchema) .input(getHotelInputSchema)
.query(async ({ ctx, input }) => { .query(async ({ ctx, input }) => {
const { hotelId, language, include } = input const { hotelId, language, include } = input
getHotelCounter.add(1, { hotelId, language, include })
const apiLang = toApiLang(language) const apiLang = toApiLang(language)
const params: Record<string, string> = { const params: Record<string, string> = {