check track prefix (#789)

livekit · Oct 7, 2024 · 1257cc6 · 1257cc6
1 parent a6ee73e
commit 1257cc6
Showing 1 changed file with 6 additions and 0 deletions.
diff --git 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
 						}