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

Update

Browse Source
This commit is contained in:
Brage 2023-07-25 00:46:01 +02:00
parent 1ba7142045
commit e560824b26
3 changed files with 16 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
Convert/src/main/kotlin/no/iktdev/streamit/content/convert/ConvertRunner.kt
View File

@ -1,5 +1,7 @@
package no.iktdev.streamit.content.convert
import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.withContext
import no.iktdev.library.subtitle.Syncro
import no.iktdev.library.subtitle.export.Export
import no.iktdev.library.subtitle.reader.BaseReader
@ -17,10 +19,15 @@ class ConvertRunner(val referenceId: String, val listener: IConvertListener) {
val reader = getReade(subtitleInfo.inputFile)
val dialogs = reader?.read()
if (dialogs.isNullOrEmpty()) {
listener.onError(referenceId, subtitleInfo, "Dialogs read from file is null or empty!")
withContext(Dispatchers.Default) {
listener.onError(referenceId, subtitleInfo, "Dialogs read from file is null or empty!")
}
return
}
listener.onStarted(referenceId, subtitleInfo)
withContext(Dispatchers.Default) {
listener.onStarted(referenceId, subtitleInfo)
}
val syncedDialogs = Syncro().sync(dialogs)
@ -32,7 +39,9 @@ class ConvertRunner(val referenceId: String, val listener: IConvertListener) {
language = subtitleInfo.language,
outFile = it.absolutePath
)
listener.onEnded(referenceId, subtitleInfo, work = item)
withContext(Dispatchers.Default) {
listener.onEnded(referenceId, subtitleInfo, work = item)
}
}
}

2
Convert/src/main/kotlin/no/iktdev/streamit/content/convert/kafka/SubtitleConsumer.kt
View File

@ -34,11 +34,13 @@ class SubtitleConsumer: DefaultKafkaReader("convertHandlerSubtitle"), IConvertLi
val workResult = data.value().dataAs(ExtractWork::class.java)
if (workResult?.produceConvertEvent == true) {
logger.info { "Using ${data.value().referenceId} ${workResult.outFile} as it is a convert candidate" }
val convertWork = SubtitleInfo(
inputFile = File(workResult.outFile),
collection = workResult.collection,
language = workResult.language,
)
produceMessage(KafkaEvents.EVENT_CONVERTER_STARTED_SUBTITLE_FILE, Message(referenceId = referenceId, Status(statusType = StatusType.PENDING)), convertWork)
Coroutines.io().launch {
ConvertRunner(referenceId, this@SubtitleConsumer).readAndConvert(convertWork)
}

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

@ -10,8 +10,10 @@ import no.iktdev.streamit.library.kafka.dto.Message
import no.iktdev.streamit.library.kafka.listener.SimpleMessageListener
import no.iktdev.streamit.library.kafka.listener.deserializer.IMessageDataDeserialization
import org.apache.kafka.clients.consumer.ConsumerRecord
import org.springframework.stereotype.Service
import java.io.File
@Service
class ConvertedSubtitleConsumer : DefaultKafkaReader("collectorConsumerConvertedSubtitle") {
private val listener = object: SimpleMessageListener(