From eb6e763e8d8f892c4a2dbc228c72bc1192771aea Mon Sep 17 00:00:00 2001 From: David Colburn Date: Mon, 30 Aug 2021 23:27:04 -0700 Subject: [PATCH] use request context in rtc service --- pkg/service/rtcservice.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/pkg/service/rtcservice.go b/pkg/service/rtcservice.go index 08cfd6a01..12cdd2658 100644 --- a/pkg/service/rtcservice.go +++ b/pkg/service/rtcservice.go @@ -1,7 +1,6 @@ package service import ( - "context" "fmt" "io" "net/http" @@ -109,14 +108,14 @@ func (s *RTCService) ServeHTTP(w http.ResponseWriter, r *http.Request) { } // create room if it doesn't exist, also assigns an RTC node for the room - rm, err := s.roomManager.CreateRoom(context.Background(), &livekit.CreateRoomRequest{Name: roomName}) + rm, err := s.roomManager.CreateRoom(r.Context(), &livekit.CreateRoomRequest{Name: roomName}) if err != nil { handleError(w, http.StatusInternalServerError, err.Error()) return } // this needs to be started first *before* using router functions on this node - connId, reqSink, resSource, err := s.router.StartParticipantSignal(context.Background(), roomName, pi) + connId, reqSink, resSource, err := s.router.StartParticipantSignal(r.Context(), roomName, pi) if err != nil { handleError(w, http.StatusInternalServerError, "could not start session: "+err.Error()) return