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

Minor adjustments

Browse Source
This commit is contained in:
Brage 2024-03-29 02:00:31 +01:00
parent 63ead22e49
commit 68f3d05d56
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/mapping/OutputFilesMapping.kt
View File

@ -17,11 +17,19 @@ class OutputFilesMapping(val events: List<PersistentMessage>) {
val subtitleResult = events.filter { it.data is ProcesserExtractWorkPerformed && it.data.isSuccess() }.map { it.data as ProcesserExtractWorkPerformed }.filter { !it.outFile.isNullOrBlank() } val subtitleResult = events.filter { it.data is ProcesserExtractWorkPerformed && it.data.isSuccess() }.map { it.data as ProcesserExtractWorkPerformed }.filter { !it.outFile.isNullOrBlank() }
val convertedSubtitleResult = events.filter { it.data is ConvertWorkPerformed && it.data.isSuccess() }.map { it.data as ConvertWorkPerformed } val convertedSubtitleResult = events.filter { it.data is ConvertWorkPerformed && it.data.isSuccess() }.map { it.data as ConvertWorkPerformed }
val referenceId = events.first().referenceId
val subtitles = try {
toSubtitleList(subtitleResult, convertedSubtitleResult)
} catch (e: Exception) {
System.err.println("Exception of $referenceId")
System.err.print("EventIds:\n" + events.joinToString("\n") { it.eventId })
e.printStackTrace()
throw e
}
return OutputFilesDto( return OutputFilesDto(
video = videoResult.lastOrNull { it.isSuccess() }?.outFile, video = videoResult.lastOrNull { it.isSuccess() }?.outFile,
subtitles = toSubtitleList(subtitleResult, convertedSubtitleResult) subtitles = subtitles
) )
} }