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

bop

Browse Source
This commit is contained in:
Brage 2024-01-18 09:14:39 +01:00
parent 3d798a13fb
commit f3d42c06d2
1 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/ffmpeg/FfmpegWorker.kt
View File

@ -3,19 +3,19 @@ package no.iktdev.mediaprocessing.processer.ffmpeg
import com.github.pgreze.process.Redirect import com.github.pgreze.process.Redirect
import com.github.pgreze.process.process import com.github.pgreze.process.process
import com.google.gson.Gson import com.google.gson.Gson
import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.withContext
import no.iktdev.exfl.coroutines.Coroutines import no.iktdev.exfl.coroutines.Coroutines
import no.iktdev.exfl.using import no.iktdev.exfl.using
import no.iktdev.mediaprocessing.shared.kafka.dto.events_result.FfmpegWorkRequestCreated
import no.iktdev.mediaprocessing.processer.ProcesserEnv import no.iktdev.mediaprocessing.processer.ProcesserEnv
import java.io.BufferedWriter import no.iktdev.mediaprocessing.shared.kafka.dto.events_result.FfmpegWorkRequestCreated
import java.io.File import java.io.File
import java.io.FileWriter
class FfmpegWorker(val referenceId: String, val eventId: String, val info: FfmpegWorkRequestCreated, val listener: FfmpegWorkerEvents, val logDir: File) { class FfmpegWorker(val referenceId: String, val eventId: String, val info: FfmpegWorkRequestCreated, val listener: FfmpegWorkerEvents, val logDir: File) {
val scope = Coroutines.io() val scope = Coroutines.io()
val decoder = FfmpegProgressDecoder() val decoder = FfmpegProgressDecoder()
private val outputCache = mutableListOf<String>() private val outputCache = mutableListOf<String>()
val logFile = logDir.using("$eventId-${File(info.outFile).nameWithoutExtension}.log") val logFile = logDir.using("$eventId-=-${File(info.outFile).nameWithoutExtension}.log")
val getOutputCache = outputCache.toList() val getOutputCache = outputCache.toList()
@ -53,6 +53,9 @@ class FfmpegWorker(val referenceId: String, val eventId: String, val info: Ffmpe
} }
private suspend fun execute(args: List<String>) { private suspend fun execute(args: List<String>) {
withContext(Dispatchers.IO) {
logFile.createNewFile()
}
listener.onStarted(info) listener.onStarted(info)
val processOp = process( val processOp = process(
ProcesserEnv.ffmpeg, *args.toTypedArray(), ProcesserEnv.ffmpeg, *args.toTypedArray(),
@ -65,6 +68,11 @@ class FfmpegWorker(val referenceId: String, val eventId: String, val info: Ffmpe
val result = processOp val result = processOp
println(Gson().toJson(result)) println(Gson().toJson(result))
if (outputCache.isEmpty()) {
result.output.forEach {
onOutputChanged(it)
}
}
onOutputChanged("Received exit code: ${result.resultCode}") onOutputChanged("Received exit code: ${result.resultCode}")
if (result.resultCode != 0) { if (result.resultCode != 0) {
listener.onError(info, result.output.joinToString("\n")) listener.onError(info, result.output.joinToString("\n"))