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

Performing filter on waits

Browse Source
This commit is contained in:
Brage 2024-03-24 01:01:55 +01:00
parent 3d872a7488
commit c7bad81bd9
2 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/mapping/ProcessMapping.kt
View File

@ -4,6 +4,7 @@ import no.iktdev.mediaprocessing.shared.common.persistance.PersistentMessage
import no.iktdev.mediaprocessing.shared.kafka.core.KafkaEvents import no.iktdev.mediaprocessing.shared.kafka.core.KafkaEvents
import no.iktdev.mediaprocessing.shared.kafka.dto.events_result.ProcessStarted import no.iktdev.mediaprocessing.shared.kafka.dto.events_result.ProcessStarted
import no.iktdev.mediaprocessing.shared.contract.reader.MediaProcessedDto import no.iktdev.mediaprocessing.shared.contract.reader.MediaProcessedDto
import no.iktdev.mediaprocessing.shared.kafka.dto.isSuccess
class ProcessMapping(val events: List<PersistentMessage>) { class ProcessMapping(val events: List<PersistentMessage>) {
@ -38,7 +39,8 @@ class ProcessMapping(val events: List<PersistentMessage>) {
} }
fun waitsForExtract(): Boolean { fun waitsForExtract(): Boolean {
val arguments = events.filter { it.event == KafkaEvents.EVENT_MEDIA_EXTRACT_PARAMETER_CREATED } // Check if message is declared as skipped with statis
val arguments = events.filter { it.event == KafkaEvents.EVENT_MEDIA_EXTRACT_PARAMETER_CREATED }.filter { it.data.isSuccess() }
val created = events.filter { it.event == KafkaEvents.EVENT_WORK_EXTRACT_CREATED } val created = events.filter { it.event == KafkaEvents.EVENT_WORK_EXTRACT_CREATED }
val performed = events.filter { it.event == KafkaEvents.EVENT_WORK_EXTRACT_PERFORMED } val performed = events.filter { it.event == KafkaEvents.EVENT_WORK_EXTRACT_PERFORMED }

4
shared/kafka/src/main/kotlin/no/iktdev/mediaprocessing/shared/kafka/dto/MessageDataWrapper.kt
View File

@ -17,3 +17,7 @@ data class SimpleMessageData(
fun MessageDataWrapper?.isSuccess(): Boolean { fun MessageDataWrapper?.isSuccess(): Boolean {
return this != null && this.status != Status.ERROR return this != null && this.status != Status.ERROR
} }
fun MessageDataWrapper?.isSkipped(): Boolean {
return this != null && this.status != Status.SKIPPED
}