Function TestSingleNodeDataBlobDisabled

test/singlenode_test.go:1778–1824

(t *testing.T)

}

func TestSingleNodeDataBlobDisabled(t *testing.T) {
	if testing.Short() {
		t.SkipNow()
		return
	}

	_, finish := setupDataBlobServer(t, "TestSingleNodeDataBlobDisabled", false)
	defer finish()

	for _, testRTCServicePath := range testRTCServicePaths {
		t.Run(fmt.Sprintf("testRTCServicePath=%s", testRTCServicePath.String()), func(t *testing.T) {
			pubCapture := &dataBlobCapture{}
			pub := createRTCClient("pub", defaultServerPort, testRTCServicePath, &testclient.Options{
				AutoSubscribe:             true,
				SignalResponseInterceptor: pubCapture.interceptor(),
			})
			waitUntilConnected(t, pub)
			defer stopClients(pub)

			require.NoError(t, pub.SendRequest(&livekit.SignalRequest{
				Message: &livekit.SignalRequest_StoreDataBlobRequest{
					StoreDataBlobRequest: &livekit.StoreDataBlobRequest{
						Blob: &livekit.DataBlob{
							Key: &livekit.DataBlobKey{
								Key: &livekit.DataBlobKey_Generic{
									Generic: "blob-1",
								},
							},
							Contents: []byte("definition-bytes"),
						},
					},
				},
			}))

			testutils.WithTimeout(t, func() string {
				rr := pubCapture.takeRequestResponse()
				if rr == nil {
					return "publisher did not receive RequestResponse"
				}
				if rr.Reason != livekit.RequestResponse_NOT_ALLOWED {
					return fmt.Sprintf("expected NOT_ALLOWED, got %s", rr.Reason)
				}
				return ""
			})
		})
	}
}