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

ren

Browse Source
This commit is contained in:
bskjon 2025-02-21 22:54:12 +01:00
parent f8a69ee620
commit ac227f075f
3 changed files with 4 additions and 5 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/EventsDatabase.kt
View File

@ -11,7 +11,7 @@ class EventsDatabase() {
allEvents,
tasks,
runners,
processedFile,
filesProcessed,
files
)

5
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasksV2/mapping/store/ProcessedFileStore.kt
View File

@ -2,11 +2,10 @@ package no.iktdev.mediaprocessing.coordinator.tasksV2.mapping.store
import com.google.gson.Gson
import mu.KotlinLogging
import no.iktdev.eventi.data.isSuccessful
import no.iktdev.mediaprocessing.coordinator.eventDatabase
import no.iktdev.mediaprocessing.shared.common.contract.data.*
import no.iktdev.mediaprocessing.shared.common.contract.dto.EventSummary
import no.iktdev.mediaprocessing.shared.common.database.tables.processedFile
import no.iktdev.mediaprocessing.shared.common.database.tables.filesProcessed
import no.iktdev.mediaprocessing.shared.common.getChecksum
import no.iktdev.streamit.library.db.withTransaction
import org.jetbrains.exposed.sql.insert
@ -20,7 +19,7 @@ object ProcessedFileStore {
withTransaction(eventDatabase.database.database, block = {
processedFile.insert {
filesProcessed.insert {
it[this.title] = title
it[this.inputFile] = inputFilePath
it[this.data] = Gson().toJson(summary)

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

@ -6,7 +6,7 @@ import org.jetbrains.exposed.sql.javatime.CurrentDateTime
import org.jetbrains.exposed.sql.javatime.datetime
import java.time.LocalDateTime
object processedFile: IntIdTable() {
object filesProcessed: IntIdTable() {
val title: Column<String> = varchar("title", 256)
val inputFile: Column<String> = varchar("fileName", 512)
val data: Column<String> = text("data")