Added selfstream flag to stream request so correct command is executed

TUM-Dev · Oct 21, 2024 · 8583c0c · 8583c0c
1 parent efe784f
commit 8583c0c
Show file tree

Hide file tree

Showing 4 changed files with 154 additions and 619 deletions.
diff --git a/api/worker_grpc.go b/api/worker_grpc.go
@@ -704,6 +704,7 @@ func CreateStreamRequest(daoWrapper dao.DaoWrapper, stream model.Stream, course
 		StreamName:   slot.StreamName,
 		IngestServer: server.Url,
 		OutUrl:       server.OutUrl,
+		SelfStream:   stream.IsSelfStream(),
 	}
 	workerIndex := getWorkerWithLeastWorkload(workers)
 	workers[workerIndex].Workload += 3

diff --git a/worker/api/api.proto b/worker/api/api.proto
@@ -90,6 +90,7 @@ message StreamRequest {
   string StreamName = 13;
   string IngestServer = 14;
   string OutUrl = 15;
+  bool SelfStream = 16;
 }
 
 message PremiereRequest {