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

Fixes + new version

Browse Source
This commit is contained in:
Brage 2023-07-26 18:01:08 +02:00
parent 7b06ca5637
commit a6c4e3a399
2 changed files with 13 additions and 5 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-alpha11") implementation("no.iktdev.streamit.library:streamit-library-db:0.0.6-alpha12")
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")

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

@ -18,6 +18,7 @@ import org.jetbrains.exposed.sql.insert
import org.jetbrains.exposed.sql.transactions.transaction import org.jetbrains.exposed.sql.transactions.transaction
import org.springframework.stereotype.Service import org.springframework.stereotype.Service
import java.io.File import java.io.File
import kotlin.math.log
private val logger = KotlinLogging.logger {} private val logger = KotlinLogging.logger {}
@ -63,11 +64,18 @@ class VideoConsumer: DefaultKafkaReader("collectorConsumerEncodedVideo"), IColle
val videoFileNameWithExtension = File(encodeWork.outFile).name val videoFileNameWithExtension = File(encodeWork.outFile).name
val iid = transaction { val iid = transaction {
val serieStatus = if (serieData != null) { if (serieData != null) {
getSerieQueryInstance(serieData, videoFileNameWithExtension)?.insertAndGetStatus() ?: false val serieInsertStatus = getSerieQueryInstance(serieData, videoFileNameWithExtension)?.insertAndGetStatus()
} else true if (serieInsertStatus == false) {
logger.warn { "Failed to insert episode $videoFileNameWithExtension" }
}
}
if (serieData == null || metadata?.type == "movie") { if (serieData == null || metadata?.type == "movie") {
MovieQuery(videoFileNameWithExtension).insertAndGetId() val iid = MovieQuery(videoFileNameWithExtension).insertAndGetId()
if (iid == null) {
logger.warn { "Failed to insert movie and get id for it $videoFileNameWithExtension" }
}
iid
} else null } else null
} }