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

Updated code

Browse Source
This commit is contained in:
Brage 2023-07-25 23:32:22 +02:00
parent 0cc9b28591
commit add3d37ff3
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Reader/src/main/kotlin/no/iktdev/streamit/content/reader/collector/EncodedVideoConsumer.kt
View File

@ -56,7 +56,7 @@ class EncodedVideoConsumer: DefaultKafkaReader("collectorConsumerEncodedVideo"),
val encodeWork = collection?.getEncodeWork() val encodeWork = collection?.getEncodeWork()
val serieData = collection?.getSerieInfo() val serieData = collection?.getSerieInfo()
val movieData = collection?.getMovieInfo() val movieData = collection?.getMovieInfo()
logger.info { "Obtained collection: \n\t${collection?.getRecords()?.map { it.key() }?.joinToString("\n\t")}" }
if (fileData == null || encodeWork == null || collection.getReferenceId() == null) { if (fileData == null || encodeWork == null || collection.getReferenceId() == null) {
logger.error { "Required data is null, as it has either status as non successful or simply missing" } logger.error { "Required data is null, as it has either status as non successful or simply missing" }

2
Reader/src/main/kotlin/no/iktdev/streamit/content/reader/collector/ExtractedSubtitleConsumer.kt
View File

@ -43,7 +43,7 @@ class ExtractedSubtitleConsumer : DefaultKafkaReader("collectorConsumerExtracted
val message = Message(referenceId = data.value()?.referenceId ?: "M.I.A", status = Status(statusType = StatusType.SUCCESS)) val message = Message(referenceId = data.value()?.referenceId ?: "M.I.A", status = Status(statusType = StatusType.SUCCESS))
if (status) { if (status) {
produceMessage(KafkaEvents.EVENT_COLLECTOR_VIDEO_STORED, message, null) produceMessage(KafkaEvents.EVENT_COLLECTOR_SUBTITLE_STORED, message, null)
logger.info { "Stored ${File(workResult.outFile).absolutePath} subtitle" } logger.info { "Stored ${File(workResult.outFile).absolutePath} subtitle" }
} else { } else {
produceErrorMessage(KafkaEvents.EVENT_COLLECTOR_SUBTITLE_STORED, message.withNewStatus(status = Status(statusType = StatusType.ERROR)), "Unknown, see log") produceErrorMessage(KafkaEvents.EVENT_COLLECTOR_SUBTITLE_STORED, message.withNewStatus(status = Status(statusType = StatusType.ERROR)), "Unknown, see log")