return error for video over websocket

livekit · Jul 20, 2023 · f56bb07 · f56bb07
1 parent d5c0ca1
commit f56bb07
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/pkg/errors/errors.go b/pkg/errors/errors.go
@@ -18,6 +18,7 @@ var (
 	ErrNoCompatibleCodec          = psrpc.NewErrorf(psrpc.InvalidArgument, "no supported codec is compatible with all outputs")
 	ErrNoCompatibleFileOutputType = psrpc.NewErrorf(psrpc.InvalidArgument, "no supported file output type is compatible with the selected codecs")
 	ErrResourceExhausted          = psrpc.NewErrorf(psrpc.ResourceExhausted, "not enough CPU")
+	ErrVideoWebsocket             = psrpc.NewErrorf(psrpc.InvalidArgument, "cannot send video over websocket")
 )
 
 func New(err string) error {

diff --git a/pkg/pipeline/source/sdk.go b/pkg/pipeline/source/sdk.go
@@ -174,6 +174,11 @@ func (s *SDKSource) joinRoom(p *config.PipelineConfig) error {
 				p.TrackKind = "audio"
 			} else {
 				p.TrackKind = "video"
+				// check for video over websocket
+				if p.Outputs[types.EgressTypeWebsocket] != nil {
+					onSubscribeErr = errors.ErrVideoWebsocket
+					return
+				}
 			}
 			p.TrackSource = strings.ToLower(pub.Source().String())