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

Fixes to db and new names

Browse Source
This commit is contained in:
Brage 2023-07-26 18:42:21 +02:00
parent a6c4e3a399
commit 64f2bfba76
3 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Reader/build.gradle.kts
View File

@ -27,7 +27,7 @@ dependencies {
implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha75") implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha75")
implementation("no.iktdev:exfl:0.0.12-SNAPSHOT") implementation("no.iktdev:exfl:0.0.12-SNAPSHOT")
implementation("no.iktdev.streamit.library:streamit-library-db:0.0.6-alpha12") implementation("no.iktdev.streamit.library:streamit-library-db:0.0.6-alpha13")
implementation("org.jetbrains.exposed:exposed-core:$exposedVersion") implementation("org.jetbrains.exposed:exposed-core:$exposedVersion")
implementation("org.jetbrains.exposed:exposed-dao:$exposedVersion") implementation("org.jetbrains.exposed:exposed-dao:$exposedVersion")

10
Reader/src/main/kotlin/no/iktdev/streamit/content/reader/collector/SubtitleConsumer.kt
View File

@ -75,10 +75,11 @@ class SubtitleConsumer : DefaultKafkaReader("collectorConsumerExtractedSubtitle"
val of = File(work.outFile) val of = File(work.outFile)
val status = transaction { val status = transaction {
SubtitleQuery( SubtitleQuery(
title = of.nameWithoutExtension, associatedWithVideo = of.nameWithoutExtension,
language = work.language, language = work.language,
collection = work.collection, collection = work.collection,
format = of.extension.uppercase() format = of.extension.uppercase(),
file = File(work.outFile).name
) )
.insertAndGetStatus() .insertAndGetStatus()
} }
@ -89,10 +90,11 @@ class SubtitleConsumer : DefaultKafkaReader("collectorConsumerExtractedSubtitle"
val of = File(work.outFile) val of = File(work.outFile)
val status = transaction { val status = transaction {
SubtitleQuery( SubtitleQuery(
title = of.nameWithoutExtension, associatedWithVideo = of.nameWithoutExtension,
language = work.language, language = work.language,
collection = work.collection, collection = work.collection,
format = of.extension.uppercase() format = of.extension.uppercase(),
file = File(work.outFile).name
) )
.insertAndGetStatus() .insertAndGetStatus()
} }

2
Reader/src/main/kotlin/no/iktdev/streamit/content/reader/collector/VideoConsumer.kt
View File

@ -142,7 +142,7 @@ class VideoConsumer: DefaultKafkaReader("collectorConsumerEncodedVideo"), IColle
fun getSerieQueryInstance(data: EpisodeInfo?, baseName: String?): SerieQuery? { fun getSerieQueryInstance(data: EpisodeInfo?, baseName: String?): SerieQuery? {
if (data == null || baseName == null) return null if (data == null || baseName == null) return null
return SerieQuery(data.title, data.episode, data.season, data.title, baseName) return SerieQuery(data.episodeTitle, data.episode, data.season, data.title, baseName)
} }
} }