Merge pull request #216 from Dash-Industry-Forum/cmaf-receiver-update

cmaf-ingest-receiver update

CHANGELOG.md

@@ -14,6 +14,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - Generation of CMAF ingest streams with a REST-based API
 - New program `cmaf-ingest-receiver` that can receive one or more CMAF ingest streams
 - New option `--whitelistblocks` for unlimited number of requests to some CIDR blocks
+- Much improved `cmaf-ingest-receiver`
 
 ### Fixed
 

cmd/cmaf-ingest-receiver/app/basicauth_test.go

@@ -54,17 +54,19 @@ func TestBasicAuth(t *testing.T) {
 	defer cancel()
 	receiver, err := NewReceiver(ctx, &opts, &config)
 	require.NoError(t, err)
-	router := setupRouter(receiver)
+	router := setupRouter(receiver, opts.storage, "")
 	server := httptest.NewServer(router)
 	defer server.Close()
 	for _, c := range cases {
-		buf := bytes.NewBuffer(data)
-		url := fmt.Sprintf("%s%s/%s", server.URL, opts.prefix, c.url)
-		req, err := http.NewRequest(http.MethodPut, url, buf)
-		require.NoError(t, err)
-		req.SetBasicAuth(c.user, c.password)
-		resp, err := http.DefaultClient.Do(req)
-		require.NoError(t, err)
-		assert.Equal(t, c.expectedResponseCode, resp.StatusCode)
+		t.Run(c.desc, func(t *testing.T) {
+			buf := bytes.NewBuffer(data)
+			url := fmt.Sprintf("%s%s/%s", server.URL, opts.prefix, c.url)
+			req, err := http.NewRequest(http.MethodPut, url, buf)
+			require.NoError(t, err)
+			req.SetBasicAuth(c.user, c.password)
+			resp, err := http.DefaultClient.Do(req)
+			require.NoError(t, err)
+			assert.Equal(t, c.expectedResponseCode, resp.StatusCode)
+		})
 	}
 }