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

Logging

Browse Source
This commit is contained in:
bskjon 2025-02-24 01:38:47 +01:00
parent b8737fb687
commit 3216212c43
1 changed files with 28 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasksV2/listeners/CompletedTaskListener.kt
View File

@ -1,7 +1,9 @@
package no.iktdev.mediaprocessing.coordinator.tasksV2.listeners package no.iktdev.mediaprocessing.coordinator.tasksV2.listeners
import com.google.gson.GsonBuilder
import mu.KotlinLogging import mu.KotlinLogging
import no.iktdev.eventi.core.ConsumableEvent import no.iktdev.eventi.core.ConsumableEvent
import no.iktdev.eventi.core.LocalDateTimeAdapter
import no.iktdev.eventi.data.* import no.iktdev.eventi.data.*
import no.iktdev.mediaprocessing.coordinator.Coordinator import no.iktdev.mediaprocessing.coordinator.Coordinator
import no.iktdev.mediaprocessing.coordinator.CoordinatorEventListener import no.iktdev.mediaprocessing.coordinator.CoordinatorEventListener
@ -15,6 +17,7 @@ import no.iktdev.mediaprocessing.shared.common.contract.reader.*
import org.springframework.beans.factory.annotation.Autowired import org.springframework.beans.factory.annotation.Autowired
import org.springframework.stereotype.Service import org.springframework.stereotype.Service
import java.io.File import java.io.File
import java.time.LocalDateTime
@Service @Service
class CompletedTaskListener : CoordinatorEventListener() { class CompletedTaskListener : CoordinatorEventListener() {
@ -228,12 +231,7 @@ class CompletedTaskListener : CoordinatorEventListener() {
log.info { "Cant find BaseInfoEvent on ${Events.ReadBaseInfoPerformed}" } log.info { "Cant find BaseInfoEvent on ${Events.ReadBaseInfoPerformed}" }
return null return null
} }
val metadataInfo = val metadataInfo = getMetadata(events)
events.find { it.eventType == Events.MetadataSearchPerformed }?.az<MediaMetadataReceivedEvent>()?.data
?: run {
log.info { "Cant find MediaMetadataReceivedEvent on ${Events.MetadataSearchPerformed}" }
null
}
val mediaInfo: MediaInfo = events.find { it.eventType == Events.ReadOutNameAndType } val mediaInfo: MediaInfo = events.find { it.eventType == Events.ReadOutNameAndType }
?.az<MediaOutInformationConstructedEvent>()?.let { ?.az<MediaOutInformationConstructedEvent>()?.let {
it.data?.toValueObject() it.data?.toValueObject()
@ -263,4 +261,28 @@ class CompletedTaskListener : CoordinatorEventListener() {
} }
private fun getMetadata(events: List<Event>): pyMetadata? {
val referenceId = events.firstNotNullOf { it.referenceId() }
val gson = GsonBuilder()
.registerTypeAdapter(LocalDateTime::class.java, LocalDateTimeAdapter())
.setPrettyPrinting()
.create()
log.info { "Events in complete:\n${gson.toJson(events)}" }
val metadataFound = events.find { it.eventType == Events.MetadataSearchPerformed }
if (metadataFound == null) {
log.warn { "ReferenceId: $referenceId -> ${Events.MetadataSearchPerformed} was not found in events" }
return null
}
val data = metadataFound.az<MediaMetadataReceivedEvent>()
if (data == null) {
log.warn { "ReferenceId: $referenceId -> ${Events.MetadataSearchPerformed} does not contain any data.." }
return null
}
return data.data
}
} }