Fixes

apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/listeners/events/MediaCreateMetadataSearchTaskListener.kt

@@ -30,7 +30,7 @@ class MediaCreateMetadataSearchTaskListener: EventListener() {
 
         val startedEvent = history.filterIsInstance<StartProcessingEvent>().firstOrNull() ?: return null
         if (startedEvent.data.operation.isNotEmpty()) {
-            if (!startedEvent.data.operation.contains(OperationType.Metadata))
+            if (!startedEvent.data.operation.contains(OperationType.MetadataSearch))
                 return null
         }
 

apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/listeners/events/StartedListener.kt

@@ -23,7 +23,7 @@ class StartedListener : EventListener() {
                     OperationType.ExtractSubtitles,
                     OperationType.ConvertSubtitles,
                     OperationType.Encode,
-                    OperationType.Metadata
+                    OperationType.MetadataSearch
                 )
             )
         )

apps/coordinator/src/test/kotlin/no/iktdev/mediaprocessing/TestBase.kt

@@ -46,7 +46,7 @@ open class TestBase {
     fun defaultStartEvent(): StartProcessingEvent {
         val start = StartProcessingEvent(
             data = StartData(
-                operation = setOf(OperationType.Encode, OperationType.ExtractSubtitles, OperationType.ConvertSubtitles, OperationType.Metadata),
+                operation = setOf(OperationType.Encode, OperationType.ExtractSubtitles, OperationType.ConvertSubtitles, OperationType.MetadataSearch),
                 fileUri = "file:///unit/${UUID.randomUUID()}.mkv"
             )
         ).apply { newReferenceId() }

apps/coordinator/src/test/kotlin/no/iktdev/mediaprocessing/coordinator/listeners/events/CollectEventsListenerTest.kt

@@ -78,7 +78,7 @@ class CollectEventsListenerTest : TestBase() {
             ev.copy(
                 data = ev.data.copy(
                     operation = setOf(
-                        OperationType.Metadata,
+                        OperationType.MetadataSearch,
                         OperationType.Encode,
                         OperationType.ExtractSubtitles
                     )
@@ -123,7 +123,7 @@ class CollectEventsListenerTest : TestBase() {
             ev.copy(
                 data = ev.data.copy(
                     operation = setOf(
-                        OperationType.Metadata,
+                        OperationType.MetadataSearch,
                         OperationType.ConvertSubtitles
                     )
                 )

apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/config/FileUtil.kt

@@ -1,16 +1,19 @@
-package no.iktdev.mediaprocessing.processer
+package no.iktdev.mediaprocessing.processer.config
 
 import no.iktdev.exfl.using
-import no.iktdev.mediaprocessing.processer.config.DirectoryProperties
 import no.iktdev.mediaprocessing.shared.common.configs.MediaPaths
 import org.springframework.stereotype.Component
 import java.io.File
 
+@Suppress("SENSELESS_COMPARISON")
 @Component
 class FileUtil(
     private val dirs: DirectoryProperties,
     private val mediaPaths: MediaPaths
 ) {
+    init {
+        assert(dirs.logs != null)
+    }
     fun getTemporaryStoreFile(fileName: String): File =
         File(mediaPaths.cache).using(fileName)
 

apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/listeners/SubtitleTaskListener.kt

@@ -9,7 +9,7 @@ import no.iktdev.eventi.tasks.TaskType
 import no.iktdev.exfl.using
 import no.iktdev.mediaprocessing.ffmpeg.FFmpeg
 import no.iktdev.mediaprocessing.ffmpeg.arguments.MpegArgument
-import no.iktdev.mediaprocessing.processer.FileUtil
+import no.iktdev.mediaprocessing.processer.config.FileUtil
 import no.iktdev.mediaprocessing.processer.config.ExecutablesConfig
 import no.iktdev.mediaprocessing.shared.common.event_task_contract.events.ProcesserExtractResultEvent
 import no.iktdev.mediaprocessing.shared.common.event_task_contract.tasks.ExtractSubtitleTask

apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/listeners/VideoTaskListener.kt

@@ -11,7 +11,7 @@ import no.iktdev.mediaprocessing.ffmpeg.FFmpeg
 import no.iktdev.mediaprocessing.ffmpeg.arguments.MpegArgument
 import no.iktdev.mediaprocessing.ffmpeg.decoder.FfmpegDecodedProgress
 import no.iktdev.mediaprocessing.processer.CoordinatorClient
-import no.iktdev.mediaprocessing.processer.FileUtil
+import no.iktdev.mediaprocessing.processer.config.FileUtil
 import no.iktdev.mediaprocessing.processer.LocalProgressCache
 import no.iktdev.mediaprocessing.processer.config.ExecutablesConfig
 import no.iktdev.mediaprocessing.shared.common.event_task_contract.events.ProcesserEncodeResultEvent

apps/processer/src/main/resources/application.yml

@@ -26,17 +26,17 @@ logging:
 
 
 media:
-  cache: ${DIRECTORY_CONTENT_CACHE:/src/cache}
+  cache: /src/cache
   outgoing: /src/output
   incoming: /src/input
 
 processer:
-  coordinator-url: ${COORDINATOR_URL:http://coordinator:8080}
+  coordinator-url: http://coordinator:8080
   coordinator-ping-on-startup: true
-  allow-overwrite: ${ALLOW_OVERWRITE:false}
+  allow-overwrite: false
 
 executables:
-  ffmpeg: ${SUPPORTING_EXECUTABLE_FFMPEG:ffmpeg}
+  ffmpeg: ffmpeg
 
 directories:
-  logs: ${LOG_DIR:/data/logs}
+  logs: /data/logs

apps/processer/src/test/kotlin/no/iktdev/mediaprocessing/processer/TestUtils.kt

@@ -4,6 +4,7 @@ import no.iktdev.eventi.models.Event
 import no.iktdev.eventi.models.Task
 import no.iktdev.mediaprocessing.processer.config.DirectoryProperties
 import no.iktdev.mediaprocessing.processer.config.ExecutablesConfig
+import no.iktdev.mediaprocessing.processer.config.FileUtil
 import no.iktdev.mediaprocessing.shared.common.configs.MediaPaths
 import org.junit.jupiter.api.Assertions.assertEquals
 

apps/processer/src/test/resources/application.yml

@@ -41,9 +41,9 @@ executables:
   ffmpeg: ffmpeg
 
 processer:
-  coordinator-url: ${COORDINATOR_URL:http://coordinator:8080}
+  coordinator-url: http://coordinator:8080
   coordinator-ping-on-startup: false
-  allow-overwrite: ${ALLOW_OVERWRITE:false}
+  allow-overwrite: false
 
 directories:
   logs: build/test-logs

apps/ui/src/main/kotlin/no/iktdev/mediaprocessing/ui/dto/file/File.kt

@@ -50,6 +50,7 @@ enum class MediaActionType(val label: String) {
     Encode("Encode"),
     ExtractSubtitles("Extract Subtitles"),
     ConvertSubtitle("Convert Subtitle"),
+    MetadataSearch("Search for metadata"),
 }
 
 enum class FileActionType(val label: String) {

apps/ui/src/main/kotlin/no/iktdev/mediaprocessing/ui/service/CoordinatorClient.kt

@@ -178,11 +178,13 @@ class CoordinatorClient(
             MediaActionType.All -> setOf(
                 OperationType.Encode,
                 OperationType.ExtractSubtitles,
-                OperationType.ConvertSubtitles
+                OperationType.ConvertSubtitles,
+                OperationType.MetadataSearch
             )
             MediaActionType.Encode -> setOf(OperationType.Encode)
             MediaActionType.ExtractSubtitles -> setOf(OperationType.ExtractSubtitles)
             MediaActionType.ConvertSubtitle -> setOf(OperationType.ConvertSubtitles)
+            MediaActionType.MetadataSearch -> setOf(OperationType.MetadataSearch)
         }
 
 

apps/ui/src/main/kotlin/no/iktdev/mediaprocessing/ui/service/ExplorerService.kt

@@ -73,7 +73,8 @@ class ExplorerService(
             return listOf(
                 MediaAction(MediaActionType.All),
                 MediaAction(MediaActionType.Encode),
-                MediaAction(MediaActionType.ExtractSubtitles)
+                MediaAction(MediaActionType.ExtractSubtitles),
+                MediaAction(MediaActionType.MetadataSearch),
             )
         }
 

apps/ui/web/src/types/files.ts

@@ -9,6 +9,7 @@ export type MediaActionType =
     | "Encode"
     | "ExtractSubtitles"
     | "ConvertSubtitle"
+    |
 
     export interface MediaAction {
     id: MediaActionType

shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/event_task_contract/events/StartProcessingEvent.kt

@@ -23,5 +23,5 @@ enum class OperationType {
     ExtractSubtitles,
     Encode,
     ConvertSubtitles,
-    Metadata
+    MetadataSearch
 }

shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/projection/CollectProjection.kt

@@ -56,7 +56,7 @@ class CollectProjection(val events: List<Event>) {
             OperationType.Encode to encodeTaskStatus,
             OperationType.ExtractSubtitles to extreactTaskStatus,
             OperationType.ConvertSubtitles to convertTaskStatus,
-            OperationType.Metadata to metadataTaskStatus,
+            OperationType.MetadataSearch to metadataTaskStatus,
         )
 
         return required.map { statusMap[it] ?: TaskStatus.NotInitiated }