create signalStats from out of order join (#1640)

pkg/routing/signal.go

@@ -185,9 +185,7 @@ func CopySignalStreamToMessageChannel[SendType, RecvType RelaySignalMessage](
 	for msg := range stream.Channel() {
 		res, err := r.Read(msg)
 		if err != nil {
-			if errors.Is(err, ErrSignalMessageDropped) {
-				prometheus.MessageCounter.WithLabelValues("signal", "failure").Add(1)
-			}
+			prometheus.MessageCounter.WithLabelValues("signal", "failure").Add(1)
 			return err
 		}
 

pkg/service/rtcservice.go

@@ -302,6 +302,14 @@ func (s *RTCService) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 					pLogger.Debugw("sending answer", "answer", m)
 				}
 
+				if pi.ID == "" && res.GetJoin() != nil {
+					pi.ID = livekit.ParticipantID(res.GetJoin().GetParticipant().GetSid())
+					signalStats = telemetry.NewBytesTrackStats(
+						telemetry.BytesTrackIDForParticipantID(telemetry.BytesTrackTypeSignal, pi.ID),
+						pi.ID,
+						s.telemetry)
+				}
+
 				if count, err := sigConn.WriteResponse(res); err != nil {
 					pLogger.Warnw("error writing to websocket", err)
 					return