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-23 22:14:07 +02:00
parent b57ea20e3a
commit 64eeda69fc
4 changed files with 32 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Encode/build.gradle.kts
View File

@ -23,7 +23,7 @@ repositories {
dependencies { dependencies {
implementation(project(":CommonCode")) implementation(project(":CommonCode"))
implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha63") implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha69")
implementation("no.iktdev:exfl:0.0.12-SNAPSHOT") implementation("no.iktdev:exfl:0.0.12-SNAPSHOT")
implementation("org.jetbrains.kotlinx:kotlinx-coroutines-core:1.7.1") implementation("org.jetbrains.kotlinx:kotlinx-coroutines-core:1.7.1")

4
Encode/src/main/kotlin/no/iktdev/streamit/content/encode/runner/EncodeDaemon.kt
View File

@ -14,11 +14,15 @@ class EncodeDaemon(val referenceId: String, val work: EncodeWork, val daemonInte
var outputCache = observableListOf<String>() var outputCache = observableListOf<String>()
private val decoder = ProgressDecoder() private val decoder = ProgressDecoder()
private fun produceProgress(items: List<String>) { private fun produceProgress(items: List<String>) {
try {
val progress = decoder.parseVideoProgress(items) val progress = decoder.parseVideoProgress(items)
if (progress != null) { if (progress != null) {
daemonInterface.onProgress(referenceId, work, progress) daemonInterface.onProgress(referenceId, work, progress)
outputCache.clear() outputCache.clear()
} }
} catch (e: Exception) {
e.message
}
} }
init { init {

9
Encode/src/main/kotlin/no/iktdev/streamit/content/encode/runner/RunnerCoordinator.kt
View File

@ -40,6 +40,7 @@ class RunnerCoordinator {
fun addEncodeMessageToQueue(message: Message) { fun addEncodeMessageToQueue(message: Message) {
encodeExecutor.execute { encodeExecutor.execute {
try {
runBlocking { runBlocking {
if (message.data is EncodeWork) { if (message.data is EncodeWork) {
val data: EncodeWork = message.data as EncodeWork val data: EncodeWork = message.data as EncodeWork
@ -49,6 +50,10 @@ class RunnerCoordinator {
producer.sendMessage(KafkaEvents.EVENT_ENCODER_STARTED_VIDEO_FILE.event, message.withNewStatus(Status(StatusType.ERROR, "Data is not an instance of EncodeWork"))) producer.sendMessage(KafkaEvents.EVENT_ENCODER_STARTED_VIDEO_FILE.event, message.withNewStatus(Status(StatusType.ERROR, "Data is not an instance of EncodeWork")))
} }
} }
} catch (e: Exception) {
producer.sendMessage(KafkaEvents.EVENT_ENCODER_ENDED_VIDEO_FILE.event, message.withNewStatus(Status(StatusType.ERROR, e.message)))
}
} }
producer.sendMessage(KafkaEvents.EVENT_ENCODER_STARTED_VIDEO_FILE.event, message.withNewStatus(Status(StatusType.PENDING))) producer.sendMessage(KafkaEvents.EVENT_ENCODER_STARTED_VIDEO_FILE.event, message.withNewStatus(Status(StatusType.PENDING)))
} }
@ -56,6 +61,7 @@ class RunnerCoordinator {
fun addExtractMessageToQueue(message: Message) { fun addExtractMessageToQueue(message: Message) {
extractExecutor.execute { extractExecutor.execute {
runBlocking { runBlocking {
try {
if (message.data is ExtractWork) { if (message.data is ExtractWork) {
val data: ExtractWork = message.data as ExtractWork val data: ExtractWork = message.data as ExtractWork
val extractDaemon = ExtractDaemon(message.referenceId, data, extractListener) val extractDaemon = ExtractDaemon(message.referenceId, data, extractListener)
@ -63,6 +69,9 @@ class RunnerCoordinator {
} else { } else {
producer.sendMessage(KafkaEvents.EVENT_ENCODER_STARTED_SUBTITLE_FILE.event, message.withNewStatus(Status(StatusType.ERROR, "Data is not an instance of ExtractWork"))) producer.sendMessage(KafkaEvents.EVENT_ENCODER_STARTED_SUBTITLE_FILE.event, message.withNewStatus(Status(StatusType.ERROR, "Data is not an instance of ExtractWork")))
} }
} catch (e: Exception) {
producer.sendMessage(KafkaEvents.EVENT_ENCODER_ENDED_SUBTITLE_FILE.event, message.withNewStatus(Status(StatusType.ERROR, e.message)))
}
} }
} }
producer.sendMessage(KafkaEvents.EVENT_ENCODER_STARTED_SUBTITLE_FILE.event, message.withNewStatus(Status(StatusType.PENDING))) producer.sendMessage(KafkaEvents.EVENT_ENCODER_STARTED_SUBTITLE_FILE.event, message.withNewStatus(Status(StatusType.PENDING)))

2
Reader/build.gradle.kts
View File

@ -23,7 +23,7 @@ repositories {
} }
dependencies { dependencies {
implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha68") implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha69")
implementation("no.iktdev:exfl:0.0.12-SNAPSHOT") implementation("no.iktdev:exfl:0.0.12-SNAPSHOT")
implementation("no.iktdev.streamit.library:streamit-library-db:0.0.6-alpha7") implementation("no.iktdev.streamit.library:streamit-library-db:0.0.6-alpha7")