update test

livekit · Jul 29, 2024 · 0cc3877 · 0cc3877
1 parent 3358451
commit 0cc3877
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/pkg/config/urls_test.go b/pkg/config/urls_test.go
@@ -28,6 +28,8 @@ func TestValidateUrl(t *testing.T) {
 	var twitchUpdated = regexp.MustCompile("rtmps://(.*).contribute.live-video.net/app/streamkey")
 	var twitchRedacted = regexp.MustCompile("rtmps://(.*).contribute.live-video.net/app/\\{str\\.\\.\\.key}")
 
+	o := &StreamConfig{}
+
 	for _, test := range []struct {
 		url      string
 		twitch   bool
@@ -58,7 +60,7 @@ func TestValidateUrl(t *testing.T) {
 			redacted: "rtmps://localhost:1935/live/{str...key}",
 		},
 	} {
-		updated, redacted, err := ValidateUrl(test.url, types.OutputTypeRTMP)
+		updated, redacted, err := o.ValidateUrl(test.url, types.OutputTypeRTMP)
 		require.NoError(t, err)
 
 		if test.twitch {

diff --git a/pkg/pipeline/controller.go b/pkg/pipeline/controller.go
@@ -264,7 +264,7 @@ func (c *Controller) UpdateStream(ctx context.Context, req *livekit.UpdateStream
 	// add stream outputs first
 	for _, rawUrl := range req.AddOutputUrls {
 		// validate and redact url
-		url, redacted, err := config.ValidateUrl(rawUrl, o.OutputType)
+		url, redacted, err := o.ValidateUrl(rawUrl, o.OutputType)
 		if err != nil {
 			errs.AppendErr(err)
 			continue