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) { 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) { init { val taskProjection = TaskProjection(events) + readStreamsTaskStatus = taskProjection.projectStreamReadStatus() metadataTaskStatus = taskProjection.projectMetadataSearchStatus() encodeTaskStatus = taskProjection.projectEncodingPerformedStatus() extreactTaskStatus = taskProjection.projectExtractSubtitleStatus()