diff --git a/internal/onvif/onvif.go b/internal/onvif/onvif.go index 6dfa633a..3c64cb5c 100644 --- a/internal/onvif/onvif.go +++ b/internal/onvif/onvif.go @@ -45,6 +45,10 @@ func streamOnvif(rawURL string) (core.Producer, error) { log.Debug().Msgf("[onvif] new uri=%s", uri) + if err = streams.Validate(uri); err != nil { + return nil, err + } + return streams.GetProducer(uri) }