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

Minor fix

Browse Source
This commit is contained in:
bskjon 2024-04-16 17:50:37 +02:00
parent d82488405f
commit f847a0669c
3 changed files with 22 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/coordinator/build.gradle.kts
View File

@ -37,7 +37,7 @@ dependencies {
implementation("org.json:json:20210307") implementation("org.json:json:20210307")
implementation("no.iktdev:exfl:0.0.13-SNAPSHOT") implementation("no.iktdev:exfl:0.0.13-SNAPSHOT")
implementation("no.iktdev.streamit.library:streamit-library-db:0.0.6-alpha26") implementation("no.iktdev.streamit.library:streamit-library-db:0.0.6-alpha27")
implementation("org.jetbrains.kotlinx:kotlinx-coroutines-core:1.7.1") implementation("org.jetbrains.kotlinx:kotlinx-coroutines-core:1.7.1")

3
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/CoordinatorApplication.kt
View File

@ -82,7 +82,8 @@ fun main(args: Array<String>) {
progress, progress,
data_audio, data_audio,
data_video, data_video,
cast_errors cast_errors,
titles
) )
storeDatabase.createTables(*tables) storeDatabase.createTables(*tables)

15
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CollectAndStoreTask.kt
View File

@ -74,7 +74,7 @@ class CollectAndStoreTask(@Autowired override var coordinator: Coordinator) : Ta
mapped.metadata?.let { mapped.metadata?.let {
storeMetadata(catalogId = catalogId, metadata = it) storeMetadata(catalogId = catalogId, metadata = it)
storeTitles(it.title, contentTitles = it.titles) storeTitles(it.collection, it.title, contentTitles = it.titles)
} }
return SimpleMessageData(Status.COMPLETED, derivedFromEventId = event.eventId) return SimpleMessageData(Status.COMPLETED, derivedFromEventId = event.eventId)
@ -109,12 +109,18 @@ class CollectAndStoreTask(@Autowired override var coordinator: Coordinator) : Ta
} }
} }
private fun storeTitles(usedTitle: String, contentTitles: List<String>) { private fun storeTitles(collection: String, usedTitle: String, contentTitles: List<String>) {
try {
withTransaction(getStoreDatabase()) { withTransaction(getStoreDatabase()) {
titles.insertIgnore {
it[titles.masterTitle] = collection
it[titles.title] = NameHelper.normalize(usedTitle)
it[titles.type] = 1
}
titles.insertIgnore { titles.insertIgnore {
it[titles.masterTitle] = usedTitle it[titles.masterTitle] = usedTitle
it[titles.title] = NameHelper.normalize(usedTitle) it[titles.title] = NameHelper.normalize(usedTitle)
it[titles.type] = 1 it[titles.type] = 2
} }
contentTitles.forEach { title -> contentTitles.forEach { title ->
titles.insertIgnore { titles.insertIgnore {
@ -123,6 +129,9 @@ class CollectAndStoreTask(@Autowired override var coordinator: Coordinator) : Ta
} }
} }
} }
} catch (e: Exception) {
e.printStackTrace()
}
} }
private fun storeAndGetGenres(genres: List<String>): String? { private fun storeAndGetGenres(genres: List<String>): String? {