From 808c27df078ab0f48cf5dc9873384ebebbfc2e3c Mon Sep 17 00:00:00 2001
From: Benjamin Pracht <benjamin@livekit.io>
Date: Tue, 26 Nov 2024 16:41:48 -0800
Subject: [PATCH] Test

---
 test/ffprobe.go | 7 +++++++
 test/runner.go  | 1 +
 2 files changed, 8 insertions(+)

diff --git a/test/ffprobe.go b/test/ffprobe.go
index 7f5a3577..2df4a861 100644
--- a/test/ffprobe.go
+++ b/test/ffprobe.go
@@ -121,6 +121,13 @@ func verify(t *testing.T, in string, p *config.PipelineConfig, res *livekit.Egre
 		require.NoError(t, err, "ffprobe failed for input %s", in)
 	}
 
+	// Check source type
+	if p.RequestType == types.RequestTypeRoomComposite && p.VideoEnabled {
+		require.Equal(t, types.SourceTypeWeb, res.SourceType)
+	} else {
+		require.Equal(t, types.SourceTypeSDK, res.SourceType)
+	}
+
 	switch egressType {
 	case types.EgressTypeFile:
 		// size
diff --git a/test/runner.go b/test/runner.go
index 922d5ddd..ff6dac29 100644
--- a/test/runner.go
+++ b/test/runner.go
@@ -147,6 +147,7 @@ func NewRunner(t *testing.T) *Runner {
 	require.NoError(t, err)
 
 	r.ServiceConfig = conf
+	r.ServiceConfig.EnableRoomCompositeSDKSource = true
 
 	if conf.ApiKey == "" || conf.ApiSecret == "" || conf.WsUrl == "" {
 		t.Fatal("api key, secret, and ws url required")