revert handlers
This commit is contained in:
@@ -4,7 +4,6 @@ import (
|
|||||||
"errors"
|
"errors"
|
||||||
"strings"
|
"strings"
|
||||||
|
|
||||||
"github.com/AlexxIT/go2rtc/internal/app"
|
|
||||||
"github.com/AlexxIT/go2rtc/pkg/core"
|
"github.com/AlexxIT/go2rtc/pkg/core"
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -47,8 +46,7 @@ func GetProducer(url string) (core.Producer, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
if handler, ok := handlers[scheme]; ok {
|
if handler, ok := handlers[scheme]; ok {
|
||||||
parsedURL := app.ResolveSecrets(url)
|
return handler(url)
|
||||||
return handler(parsedURL)
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -91,8 +89,7 @@ func GetConsumer(url string) (core.Consumer, func(), error) {
|
|||||||
scheme := url[:i]
|
scheme := url[:i]
|
||||||
|
|
||||||
if handler, ok := consumerHandlers[scheme]; ok {
|
if handler, ok := consumerHandlers[scheme]; ok {
|
||||||
parsedURL := app.ResolveSecrets(url)
|
return handler(url)
|
||||||
return handler(parsedURL)
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user