From 30b5d6907c4fdadfd6bf5482dc349d2c8331ba83 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Brage=20Skj=C3=B8nborg?= <bskjon@outlook.com>
Date: Fri, 30 Jan 2026 22:42:42 +0100
Subject: [PATCH] Added more tasks

---
 .../coordinator/services/SequenceAggregatorService.kt          | 1 +
 .../mediaprocessing/shared/common/dto/SequenceSummary.kt       | 1 +
 .../shared/common/projection/CollectProjection.kt              | 3 +++
 3 files changed, 5 insertions(+)

diff --git a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/services/SequenceAggregatorService.kt b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/services/SequenceAggregatorService.kt
index 51e073ab..52de885d 100644
--- a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/services/SequenceAggregatorService.kt
+++ b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/services/SequenceAggregatorService.kt
@@ -60,6 +60,7 @@ class SequenceAggregatorService() {
             inputFileName = projection.useFile?.name,
             lastEventId = last.eventId.toString(),
             lastEventTime = last.persistedAt,
+            readStreamsTaskStatus = projection.readStreamsTaskStatus,
             metadataTaskStatus = projection.metadataTaskStatus,
             encodeTaskStatus = projection.encodeTaskStatus,
             extractTaskStatus = projection.extreactTaskStatus,
diff --git a/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/dto/SequenceSummary.kt b/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/dto/SequenceSummary.kt
index a777510f..36b3d308 100644
--- a/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/dto/SequenceSummary.kt
+++ b/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/dto/SequenceSummary.kt
@@ -10,6 +10,7 @@ data class SequenceSummary(
     val type: ContextType = ContextType.Content,
     val lastEventId: String,
     val lastEventTime: Instant,
+    val readStreamsTaskStatus: CollectProjection.TaskStatus,
     val metadataTaskStatus: CollectProjection.TaskStatus,
     val encodeTaskStatus: CollectProjection.TaskStatus,
     val extractTaskStatus: CollectProjection.TaskStatus,
diff --git a/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/projection/CollectProjection.kt b/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/projection/CollectProjection.kt
index e96ec0f7..2939b41e 100644
--- a/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/projection/CollectProjection.kt
+++ b/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/projection/CollectProjection.kt
@@ -9,6 +9,8 @@ class CollectProjection(val events: List<Event>) {
 
     val useFile: File? by lazy { projectUseFile() }
     val startedWith: StartProjection? by lazy { projectStartedWith() }
+    var readStreamsTaskStatus: TaskStatus = TaskStatus.NotInitiated
+        private set
     var metadataTaskStatus: TaskStatus = TaskStatus.NotInitiated
         private set
     var encodeTaskStatus: TaskStatus = TaskStatus.NotInitiated
@@ -29,6 +31,7 @@ class CollectProjection(val events: List<Event>) {
 
     init {
         val taskProjection = TaskProjection(events)
+        readStreamsTaskStatus = taskProjection.projectStreamReadStatus()
         metadataTaskStatus = taskProjection.projectMetadataSearchStatus()
         encodeTaskStatus = taskProjection.projectEncodingPerformedStatus()
         extreactTaskStatus = taskProjection.projectExtractSubtitleStatus()