From 26c9570bf3fb3cc3c25b6d0dcac03a83d916b36e Mon Sep 17 00:00:00 2001 From: Brage Date: Thu, 27 Jul 2023 02:03:32 +0200 Subject: [PATCH] Update --- .../streamit/content/reader/collector/VideoConsumer.kt | 9 +-------- 1 file changed, 1 insertion(+), 8 deletions(-) diff --git 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 index d963d401..0bb884e1 100644 --- 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