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 89e03cdb..60cd54b0 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 @@ -2,8 +2,10 @@ package no.iktdev.mediaprocessing.coordinator.services import no.iktdev.eventi.ZDS.toEvent import no.iktdev.eventi.models.store.PersistedEvent +import no.iktdev.mediaprocessing.shared.common.dto.Mode import no.iktdev.mediaprocessing.shared.common.dto.SequenceSummary import no.iktdev.mediaprocessing.shared.common.event_task_contract.events.CollectedEvent +import no.iktdev.mediaprocessing.shared.common.event_task_contract.events.StartFlow import no.iktdev.mediaprocessing.shared.common.projection.CollectProjection import no.iktdev.mediaprocessing.shared.database.stores.EventStore import org.springframework.stereotype.Service @@ -55,6 +57,11 @@ class SequenceAggregatorService() { extractTaskStatus = projection.extreactTaskStatus, convertTaskStatus = projection.convertTaskStatus, coverDownloadTaskStatus = projection.coverDownloadTaskStatus, + mode = when (projection.startedWith?.mode) { + StartFlow.Auto -> Mode.Auto + StartFlow.Manual -> Mode.Manual + else -> Mode.Auto + }, hasErrors = projection.getTaskStatus().any { it == CollectProjection.TaskStatus.Failed } ) } 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 01d7366d..20e04514 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 @@ -15,6 +15,7 @@ data class SequenceSummary( val extractTaskStatus: CollectProjection.TaskStatus, val convertTaskStatus: CollectProjection.TaskStatus, val coverDownloadTaskStatus: CollectProjection.TaskStatus, + val mode: Mode, val hasErrors: Boolean, ) @@ -22,3 +23,8 @@ enum class ContextType { Content, Metadata } + +enum class Mode { + Auto, + Manual +} \ No newline at end of file