From 35dda8ea432095a720da36182ac837d618a18608 Mon Sep 17 00:00:00 2001 From: Paul Wells Date: Tue, 10 Jun 2025 11:27:34 -0700 Subject: [PATCH] swap pub/sub track metrics (#3717) --- pkg/rtc/mediatrack.go | 2 +- pkg/rtc/mediatracksubscriptions.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/rtc/mediatrack.go b/pkg/rtc/mediatrack.go index bc0dad745..a6c26c2a9 100644 --- a/pkg/rtc/mediatrack.go +++ b/pkg/rtc/mediatrack.go @@ -334,7 +334,7 @@ func (t *MediaTrack) AddReceiver(receiver *webrtc.RTPReceiver, track sfu.TrackRe if cs, ok := telemetry.CondenseStat(stat); ok { t.params.Reporter.Tx(func(tx roomobs.TrackTx) { tx.ReportName(ti.Name) - tx.ReportKind(roomobs.TrackKindSub) + tx.ReportKind(roomobs.TrackKindPub) tx.ReportType(roomobs.TrackTypeFromProto(ti.Type)) tx.ReportSource(roomobs.TrackSourceFromProto(ti.Source)) tx.ReportMime(mime.NormalizeMimeType(ti.MimeType).ReporterType()) diff --git a/pkg/rtc/mediatracksubscriptions.go b/pkg/rtc/mediatracksubscriptions.go index d79d483b4..0095171af 100644 --- a/pkg/rtc/mediatracksubscriptions.go +++ b/pkg/rtc/mediatracksubscriptions.go @@ -219,7 +219,7 @@ func (t *MediaTrackSubscriptions) AddSubscriber(sub types.LocalParticipant, wr * reporter.Tx(func(tx roomobs.TrackTx) { ti := wr.TrackInfo() tx.ReportName(ti.Name) - tx.ReportKind(roomobs.TrackKindPub) + tx.ReportKind(roomobs.TrackKindSub) tx.ReportType(roomobs.TrackTypeFromProto(ti.Type)) tx.ReportSource(roomobs.TrackSourceFromProto(ti.Source)) tx.ReportMime(mime.NormalizeMimeType(ti.MimeType).ReporterType())