diff --git a/pkg/service/roomservice.go b/pkg/service/roomservice.go index be0f129f3..558855322 100644 --- a/pkg/service/roomservice.go +++ b/pkg/service/roomservice.go @@ -133,7 +133,7 @@ func (s *RoomService) DeleteRoom(ctx context.Context, req *livekit.DeleteRoomReq } // ensure at least one node is available to handle the request - _, err = s.router.CreateRoom(ctx, &livekit.CreateRoomRequest{Name: req.Room}) + room, err := s.router.CreateRoom(ctx, &livekit.CreateRoomRequest{Name: req.Room}) if err != nil { return nil, err } @@ -145,7 +145,7 @@ func (s *RoomService) DeleteRoom(ctx context.Context, req *livekit.DeleteRoomReq err = s.roomStore.DeleteRoom(ctx, livekit.RoomName(req.Room)) res := &livekit.DeleteRoomResponse{} - RecordResponse(ctx, res) + RecordResponse(ctx, room) return res, err } diff --git a/pkg/service/twirp.go b/pkg/service/twirp.go index 556bfa01d..c7ff5b96c 100644 --- a/pkg/service/twirp.go +++ b/pkg/service/twirp.go @@ -231,6 +231,7 @@ func TwirpTelemetry( ResponseSent: func(ctx context.Context) { telemetryResponseSent(ctx, nodeID, getProjectID, telemetry) }, + RequestRouted: telemetryRequestRouted, } }