Update

2023-07-27 02:03:32 +02:00 · 2023-07-27 02:03:32 +02:00 · 26c9570bf3
commit 26c9570bf3
parent 4ede2aaf6a
1 changed files with 1 additions and 8 deletions
--- a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/collector/VideoConsumer.kt
+++ b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/collector/VideoConsumer.kt
@ -110,14 +110,7 @@ class VideoConsumer: DefaultKafkaReader("collectorConsumerEncodedVideo"), IColle
                    genres = genres
                )
                val catalogType = if (serieData == null) "movie" else "serie"
-                catalog.insert {
-                    it[title] = fileData.title
-                    it[cover] =  coverFile?.name
-                    it[type] = catalogType
-                    it[catalog.collection] = fileData.title
-                    it[catalog.iid] = iid
-                    it[catalog.genres] = genres
-                }
+                cq.insertAndGetStatus()

                if (coverFile != null) {
                    val qres = catalog.select { catalog.title eq fileData.title }.andWhere { catalog.type eq  catalogType}.firstOrNull() ?: null