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:54:10 +02:00
parent e560824b26
commit 412e2ef0b7
3 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
CommonCode/src/main/java/no/iktdev/streamit/content/common/dto/reader/SubtitleInfo.kt
View File

@ -1,4 +1,9 @@
package no.iktdev.streamit.content.common.dto.reader
class SubtitleInfo {
}
import java.io.File
data class SubtitleInfo(
val inputFile: File,
val collection: String,
val language: String
)

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

@ -7,6 +7,7 @@ import no.iktdev.library.subtitle.export.Export
import no.iktdev.library.subtitle.reader.BaseReader
import no.iktdev.library.subtitle.reader.Reader
import no.iktdev.streamit.content.common.dto.reader.work.ConvertWork
import no.iktdev.streamit.content.common.dto.reader.work.ExtractWork
import java.io.File
class ConvertRunner(val referenceId: String, val listener: IConvertListener) {
@ -26,7 +27,7 @@ class ConvertRunner(val referenceId: String, val listener: IConvertListener) {
}
withContext(Dispatchers.Default) {
listener.onStarted(referenceId, subtitleInfo)
listener.onStarted(referenceId)
}
val syncedDialogs = Syncro().sync(dialogs)
@ -50,7 +51,7 @@ class ConvertRunner(val referenceId: String, val listener: IConvertListener) {
}
interface IConvertListener {
fun onStarted(referenceId: String, info: SubtitleInfo)
fun onStarted(referenceId: String)
fun onError(referenceId: String, info: SubtitleInfo, message: String)
fun onEnded(referenceId: String, info: SubtitleInfo, work: ConvertWork)
}

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

@ -54,8 +54,8 @@ class SubtitleConsumer: DefaultKafkaReader("convertHandlerSubtitle"), IConvertLi
listener.listen()
}
override fun onStarted(referenceId: String, info: SubtitleInfo) {
produceMessage(KafkaEvents.EVENT_CONVERTER_STARTED_SUBTITLE_FILE, Message(referenceId = referenceId, Status(statusType = StatusType.SUCCESS)), info)
override fun onStarted(referenceId: String) {
produceMessage(KafkaEvents.EVENT_CONVERTER_STARTED_SUBTITLE_FILE, Message(referenceId = referenceId, Status(statusType = StatusType.SUCCESS)), null)
}
override fun onError(referenceId: String, info: SubtitleInfo, message: String) {