dandri/livekit
1
0
Fork 0
mirror of https://github.com/livekit/livekit.git synced 2026-08-28 11:44:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

Log offer/answer close to WebSocket connection ingress/egress. (#1359)

Browse Source
This commit is contained in:
Raja Subramanian
2023-01-31 17:50:56 +05:30
committed by GitHub
parent 2048cfbfc7
commit 71eac631a1
1 changed files with 15 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/service/rtcservice.go
+15
View File
@@ -278,6 +278,13 @@ func (s *RTCService) ServeHTTP(w http.ResponseWriter, r *http.Request) {
continue
}
switch m := res.Message.(type) {
case *livekit.SignalResponse_Offer:
pLogger.Infow("sending offer", "offer", m)
case *livekit.SignalResponse_Answer:
pLogger.Infow("sending answer", "answer", m)
}
if pi.ID == "" && cr.InitialResponse.GetJoin() != nil {
pi.ID = livekit.ParticipantID(cr.InitialResponse.GetJoin().GetParticipant().GetSid())
signalStats = telemetry.NewBytesTrackStats(
@@ -328,6 +335,14 @@ func (s *RTCService) ServeHTTP(w http.ResponseWriter, r *http.Request) {
}
continue
}
switch m := req.Message.(type) {
case *livekit.SignalRequest_Offer:
pLogger.Infow("received offer", "offer", m)
case *livekit.SignalRequest_Answer:
pLogger.Infow("received answer", "answer", m)
}
if err := cr.RequestSink.WriteMessage(req); err != nil {
pLogger.Warnw("error writing to request sink", err,
"connID", cr.ConnectionID)