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

Fixed Projection

Browse Source
This commit is contained in:
Brage Skjønborg 2026-01-23 03:03:22 +01:00
parent c0de46b41a
commit 29923771fd
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/projection/TaskProjection.kt
View File

@ -16,12 +16,11 @@ class TaskProjection(val events: List<Event>) {
val createdEvent = events.getInstancesOf<C>().ifEmpty { return TaskStatus.NotInitiated } val createdEvent = events.getInstancesOf<C>().ifEmpty { return TaskStatus.NotInitiated }
val resultEvent = events.getInstancesOf<R>().ifEmpty { return TaskStatus.Pending } val resultEvent = events.getInstancesOf<R>().ifEmpty { return TaskStatus.Pending }
if (resultEvent.size != createdEvent.size) return TaskStatus.Pending
val created = createdIds(createdEvent) val created = createdIds(createdEvent)
val results = resultIds(resultEvent) val results = resultIds(resultEvent)
if (!created.all { it in results }) return TaskStatus.Pending val taskIds = results.filter { it in created }
if (!taskIds.containsAll(created) || taskIds.size != created.size) return TaskStatus.Pending
if (resultEvent.any { resultStatus(it) == no.iktdev.eventi.models.store.TaskStatus.Failed }) return TaskStatus.Failed if (resultEvent.any { resultStatus(it) == no.iktdev.eventi.models.store.TaskStatus.Failed }) return TaskStatus.Failed
return TaskStatus.Completed return TaskStatus.Completed