iktdev/MediaProcessing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Exposing mode

Browse Source
This commit is contained in:
Brage Skjønborg 2026-01-28 22:49:46 +01:00
parent 534400c738
commit b94864b00a
2 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/services/SequenceAggregatorService.kt
View File

@ -2,8 +2,10 @@ package no.iktdev.mediaprocessing.coordinator.services
import no.iktdev.eventi.ZDS.toEvent import no.iktdev.eventi.ZDS.toEvent
import no.iktdev.eventi.models.store.PersistedEvent 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.dto.SequenceSummary
import no.iktdev.mediaprocessing.shared.common.event_task_contract.events.CollectedEvent 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.common.projection.CollectProjection
import no.iktdev.mediaprocessing.shared.database.stores.EventStore import no.iktdev.mediaprocessing.shared.database.stores.EventStore
import org.springframework.stereotype.Service import org.springframework.stereotype.Service
@ -55,6 +57,11 @@ class SequenceAggregatorService() {
extractTaskStatus = projection.extreactTaskStatus, extractTaskStatus = projection.extreactTaskStatus,
convertTaskStatus = projection.convertTaskStatus, convertTaskStatus = projection.convertTaskStatus,
coverDownloadTaskStatus = projection.coverDownloadTaskStatus, 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 } hasErrors = projection.getTaskStatus().any { it == CollectProjection.TaskStatus.Failed }
) )
} }

6
shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/dto/SequenceSummary.kt
View File

@ -15,6 +15,7 @@ data class SequenceSummary(
val extractTaskStatus: CollectProjection.TaskStatus, val extractTaskStatus: CollectProjection.TaskStatus,
val convertTaskStatus: CollectProjection.TaskStatus, val convertTaskStatus: CollectProjection.TaskStatus,
val coverDownloadTaskStatus: CollectProjection.TaskStatus, val coverDownloadTaskStatus: CollectProjection.TaskStatus,
val mode: Mode,
val hasErrors: Boolean, val hasErrors: Boolean,
) )
@ -22,3 +23,8 @@ enum class ContextType {
Content, Content,
Metadata Metadata
} }
enum class Mode {
Auto,
Manual
}