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

Setting failed to consumed to prevent spamming

Browse Source
This commit is contained in:
Brage 2024-03-25 00:22:16 +01:00
parent c7bad81bd9
commit d4d0f6f0fb
2 changed files with 4 additions and 0 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/services/EncodeService.kt
View File

@ -86,6 +86,8 @@ class EncodeService(@Autowired override var coordinator: Coordinator): TaskCreat
runner = FfmpegWorker(event.referenceId, event.eventId, info = ffwrc, logDir = logDir, listener = ffmpegWorkerEvents ) runner = FfmpegWorker(event.referenceId, event.eventId, info = ffwrc, logDir = logDir, listener = ffmpegWorkerEvents )
if (File(ffwrc.outFile).exists() && ffwrc.arguments.firstOrNull() != "-y") { if (File(ffwrc.outFile).exists() && ffwrc.arguments.firstOrNull() != "-y") {
ffmpegWorkerEvents.onError(ffwrc, "${this::class.java.simpleName} identified the file as already existing, either allow overwrite or delete the offending file: ${ffwrc.outFile}") ffmpegWorkerEvents.onError(ffwrc, "${this::class.java.simpleName} identified the file as already existing, either allow overwrite or delete the offending file: ${ffwrc.outFile}")
// Setting consumed to prevent spamming
PersistentDataStore().setProcessEventCompleted(event.referenceId, event.eventId, serviceId)
return return
} }
runnerJob = scope.launch { runnerJob = scope.launch {

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

@ -91,6 +91,8 @@ class ExtractService(@Autowired override var coordinator: Coordinator): TaskCrea
if (File(ffwrc.outFile).exists() && ffwrc.arguments.firstOrNull() != "-y") { if (File(ffwrc.outFile).exists() && ffwrc.arguments.firstOrNull() != "-y") {
ffmpegWorkerEvents.onError(ffwrc, "${this::class.java.simpleName} identified the file as already existing, either allow overwrite or delete the offending file: ${ffwrc.outFile}") ffmpegWorkerEvents.onError(ffwrc, "${this::class.java.simpleName} identified the file as already existing, either allow overwrite or delete the offending file: ${ffwrc.outFile}")
// Setting consumed to prevent spamming
PersistentDataStore().setProcessEventCompleted(event.referenceId, event.eventId, serviceId)
return return
} }
runnerJob = scope.launch { runnerJob = scope.launch {