diff --git a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasksV2/listeners/ReadMediaFileStreamsTaskListener.kt b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasksV2/listeners/ReadMediaFileStreamsTaskListener.kt index e4c1784f..f2b23e09 100644 --- a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasksV2/listeners/ReadMediaFileStreamsTaskListener.kt +++ b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasksV2/listeners/ReadMediaFileStreamsTaskListener.kt @@ -86,7 +86,7 @@ class ReadMediaFileStreamsTaskListener() : CoordinatorEventListener() { val joined = result.output.joinToString(" ") Gson().fromJson(joined, JsonObject::class.java) } else { - val message = "File in data is not a file or does not exist".also { + val message = "File in data is not a file or does not exist: ${file.absolutePath}".also { log.error { it } } throw RuntimeException(message) diff --git a/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/contract/data/Event.kt b/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/contract/data/Event.kt index d5526365..75b9437d 100644 --- a/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/contract/data/Event.kt +++ b/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/contract/data/Event.kt @@ -1,7 +1,6 @@ package no.iktdev.mediaprocessing.shared.common.contract.data import no.iktdev.eventi.data.EventImpl -import no.iktdev.eventi.data.EventMetadata import no.iktdev.mediaprocessing.shared.common.contract.Events abstract class Event: EventImpl() { @@ -14,3 +13,14 @@ inline fun Event.az(): T? { null } else this } + +inline fun List.findFirstEventOf(): T? { + val first = this.firstOrNull { it is T } + return if (first != null) { + first as T + } else null +} + +inline fun List.findEventsOf(): List { + return this.filterIsInstance().map { it } +} \ No newline at end of file diff --git a/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/database/tables/processed.kt b/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/database/tables/processed.kt index e39e246b..efc8b464 100644 --- a/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/database/tables/processed.kt +++ b/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/database/tables/processed.kt @@ -9,7 +9,9 @@ import org.jetbrains.exposed.sql.javatime.datetime import java.time.LocalDateTime object processed: IntIdTable() { + val title: Column = varchar("title", 256) val fileName: Column = varchar("fileName", 256) + val processedFiles: Column = text("processedFilesJson") val encoded: Column = bool("encoded").default(false) val extracted: Column = bool("extracted").default(false) val created: Column = datetime("created").defaultExpression(CurrentDateTime)