jansel/Feixiao
1
0
Fork 0
Code Issues Actions

Merge branch 'root' into feature/configurable-live-message

Browse Source
This commit is contained in:
Jannik Reimers 2024-11-24 02:40:02 +01:00
commit 4a437b5558
Signed by: jansel
GPG Key ID: 39C62D7D5233CFD0
3 changed files with 13 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
build.gradle.kts
View File

@ -32,12 +32,12 @@ dependencies {
kordEx { kordEx {
kordExVersion = "2.2.1-SNAPSHOT" kordExVersion = "2.2.1-SNAPSHOT"
kordVersion = "0.16.0-SNAPSHOT"
jvmTarget = 21 jvmTarget = 21
bot { bot {
// See https://docs.kordex.dev/data-collection.html // See https://docs.kordex.dev/data-collection.html
dataCollection(DataCollection.Standard) dataCollection(DataCollection.None)
mainClass = "dev.jansel.feixiao.AppKt" mainClass = "dev.jansel.feixiao.AppKt"
} }

1
src/main/kotlin/dev/jansel/feixiao/App.kt
View File

@ -23,7 +23,6 @@ val logger = KotlinLogging.logger { }
suspend fun main() { suspend fun main() {
val bot = ExtensibleBot(token) { val bot = ExtensibleBot(token) {
database(true) database(true)
dataCollectionMode = DataCollection.None
extensions { extensions {
add(::EventHooks) add(::EventHooks)
add(::StreamerCommand) add(::StreamerCommand)

10
src/main/kotlin/dev/jansel/feixiao/extensions/EventHooks.kt
View File

@ -1,11 +1,14 @@
package dev.jansel.feixiao.extensions package dev.jansel.feixiao.extensions
import dev.jansel.feixiao.database.collections.StreamerCollection import dev.jansel.feixiao.database.collections.StreamerCollection
import dev.jansel.feixiao.database.entities.StreamerData
import dev.jansel.feixiao.logger import dev.jansel.feixiao.logger
import dev.jansel.feixiao.twitchClient import dev.jansel.feixiao.twitchClient
import dev.kord.core.event.gateway.ReadyEvent import dev.kord.core.event.gateway.ReadyEvent
import dev.kordex.core.extensions.Extension import dev.kordex.core.extensions.Extension
import dev.kordex.core.extensions.event import dev.kordex.core.extensions.event
import org.litote.kmongo.deleteMany
import org.litote.kmongo.eq
class EventHooks : Extension() { class EventHooks : Extension() {
override val name = "eventhooks" override val name = "eventhooks"
@ -15,10 +18,15 @@ class EventHooks : Extension() {
action { action {
logger.info { "Bot is ready!" } logger.info { "Bot is ready!" }
kord.editPresence { listening("the database") } kord.editPresence { listening("the database") }
// check every entry in the database and enable the stream event listener // check every entry in the database and enable the stream event listener if a server is listening to the streamer
StreamerCollection().collection.find().toList().forEach { StreamerCollection().collection.find().toList().forEach {
if (it.servers.isNotEmpty()) {
twitchClient!!.clientHelper.enableStreamEventListener(it.name) twitchClient!!.clientHelper.enableStreamEventListener(it.name)
logger.info { "Enabled stream event listener for ${it.name}" } logger.info { "Enabled stream event listener for ${it.name}" }
} else {
logger.info { "No servers are listening to ${it.name}, deleting from the database..." }
StreamerCollection().collection.deleteMany(StreamerData::name eq it.name)
}
} }
} }
} }