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

log append

Browse Source
This commit is contained in:
bskjon 2025-03-19 23:20:54 +01:00
parent fac82f06eb
commit 671b367957
2 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/ProcesserEnv.kt
View File

@ -15,5 +15,7 @@ class ProcesserEnv {
val encodeLogDirectory = logDirectory.using("encode") val encodeLogDirectory = logDirectory.using("encode")
val extractLogDirectory = logDirectory.using("extract") val extractLogDirectory = logDirectory.using("extract")
val fullLogging = System.getenv("FullLogging").toBoolean()
} }
} }

10
apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/ffmpeg/FfmpegRunner.kt
View File

@ -1,5 +1,6 @@
package no.iktdev.mediaprocessing.processer.ffmpeg package no.iktdev.mediaprocessing.processer.ffmpeg
import com.fasterxml.jackson.core.io.UTF8Writer
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 kotlinx.coroutines.* import kotlinx.coroutines.*
@ -9,6 +10,7 @@ import no.iktdev.mediaprocessing.processer.ProcesserEnv
import no.iktdev.mediaprocessing.processer.ffmpeg.progress.FfmpegDecodedProgress import no.iktdev.mediaprocessing.processer.ffmpeg.progress.FfmpegDecodedProgress
import no.iktdev.mediaprocessing.processer.ffmpeg.progress.FfmpegProgressDecoder import no.iktdev.mediaprocessing.processer.ffmpeg.progress.FfmpegProgressDecoder
import java.io.File import java.io.File
import java.io.FileOutputStream
import java.time.LocalDateTime import java.time.LocalDateTime
import java.time.format.DateTimeFormatter import java.time.format.DateTimeFormatter
import java.util.* import java.util.*
@ -72,7 +74,9 @@ class FfmpegRunner(
stdout = Redirect.CAPTURE, stdout = Redirect.CAPTURE,
stderr = Redirect.CAPTURE, stderr = Redirect.CAPTURE,
consumer = { consumer = {
//log.info { it } if (ProcesserEnv.fullLogging) {
log.info { it }
}
onOutputChanged(it) onOutputChanged(it)
}, },
destroyForcibly = true destroyForcibly = true
@ -107,7 +111,7 @@ class FfmpegRunner(
fun onOutputChanged(line: String) { fun onOutputChanged(line: String) {
outputCache.add(line) outputCache.add(line)
writeToLog(line) writeToLog(line)
// toList is needed to prevent mutability.
decoder.parseVideoProgress(outputCache.toList())?.let { decoded -> decoder.parseVideoProgress(outputCache.toList())?.let { decoded ->
try { try {
val _progress = decoder.getProgress(decoded) val _progress = decoder.getProgress(decoded)
@ -123,7 +127,7 @@ class FfmpegRunner(
} }
fun writeToLog(line: String) { fun writeToLog(line: String) {
logFile.printWriter().use { FileOutputStream(logFile, true).bufferedWriter(Charsets.UTF_8).use {
it.appendLine(line) it.appendLine(line)
} }
} }