From 1257cc6d1a200ea3960e26ffefcc35e165250fbe Mon Sep 17 00:00:00 2001 From: David Colburn Date: Mon, 7 Oct 2024 14:00:40 -0700 Subject: [PATCH] check track prefix (#789) --- pkg/pipeline/source/sdk.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/pkg/pipeline/source/sdk.go b/pkg/pipeline/source/sdk.go index 9e6451bc..fb40f8a6 100644 --- a/pkg/pipeline/source/sdk.go +++ b/pkg/pipeline/source/sdk.go @@ -325,6 +325,12 @@ func (s *SDKSource) subscribeToTracks(expecting map[string]struct{}, deadline <- for _, track := range p.TrackPublications() { trackID := track.SID() if _, ok := expecting[trackID]; ok { + if trackID == s.AudioTrackID && track.Kind() == lksdk.TrackKindVideo { + return nil, errors.ErrInvalidInput("audio_track_id") + } else if trackID == s.VideoTrackID && track.Kind() == lksdk.TrackKindAudio { + return nil, errors.ErrInvalidInput("video_track_id") + } + if err := s.subscribe(track); err != nil { return nil, err }