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

Storing processed files

Browse Source
This commit is contained in:
bskjon 2025-02-02 16:38:35 +01:00
parent 4638560c30
commit afa0900755
3 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasksV2/listeners/ReadMediaFileStreamsTaskListener.kt
View File

@ -86,7 +86,7 @@ class ReadMediaFileStreamsTaskListener() : CoordinatorEventListener() {
val joined = result.output.joinToString(" ") val joined = result.output.joinToString(" ")
Gson().fromJson(joined, JsonObject::class.java) Gson().fromJson(joined, JsonObject::class.java)
} else { } 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 } log.error { it }
} }
throw RuntimeException(message) throw RuntimeException(message)

12
shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/contract/data/Event.kt
View File

@ -1,7 +1,6 @@
package no.iktdev.mediaprocessing.shared.common.contract.data package no.iktdev.mediaprocessing.shared.common.contract.data
import no.iktdev.eventi.data.EventImpl import no.iktdev.eventi.data.EventImpl
import no.iktdev.eventi.data.EventMetadata
import no.iktdev.mediaprocessing.shared.common.contract.Events import no.iktdev.mediaprocessing.shared.common.contract.Events
abstract class Event: EventImpl() { abstract class Event: EventImpl() {
@ -14,3 +13,14 @@ inline fun <reified T: Event> Event.az(): T? {
null null
} else this } else this
} }
inline fun <reified T: Event> List<Event>.findFirstEventOf(): T? {
val first = this.firstOrNull { it is T }
return if (first != null) {
first as T
} else null
}
inline fun <reified T: Event> List<Event>.findEventsOf(): List<T> {
return this.filterIsInstance<T>().map { it }
}

2
shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/database/tables/processed.kt
View File

@ -9,7 +9,9 @@ import org.jetbrains.exposed.sql.javatime.datetime
import java.time.LocalDateTime import java.time.LocalDateTime
object processed: IntIdTable() { object processed: IntIdTable() {
val title: Column<String> = varchar("title", 256)
val fileName: Column<String> = varchar("fileName", 256) val fileName: Column<String> = varchar("fileName", 256)
val processedFiles: Column<String> = text("processedFilesJson")
val encoded: Column<Boolean> = bool("encoded").default(false) val encoded: Column<Boolean> = bool("encoded").default(false)
val extracted: Column<Boolean> = bool("extracted").default(false) val extracted: Column<Boolean> = bool("extracted").default(false)
val created: Column<LocalDateTime> = datetime("created").defaultExpression(CurrentDateTime) val created: Column<LocalDateTime> = datetime("created").defaultExpression(CurrentDateTime)