dalbodeule/chibot-chzzk-bot
1
0
Fork 0
mirror of https://github.com/dalbodeule/chibot-chzzk-bot.git synced 2025-06-09 07:18:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #97 from dalbodeule/develop

Browse Source 
apiDiscordRoutes add.
This commit is contained in:
JinU Choi 2024-08-15 13:50:47 +09:00 committed by GitHub
commit ec0d811dbc
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 32 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
webserver/src/main/kotlin/space/mori/chzzk_bot/webserver/routes/ApiDiscordRoutes.kt
View File

@ -2,9 +2,11 @@ package space.mori.chzzk_bot.webserver.routes
import io.ktor.http.* import io.ktor.http.*
import io.ktor.server.application.* import io.ktor.server.application.*
import io.ktor.server.request.*
import io.ktor.server.response.* import io.ktor.server.response.*
import io.ktor.server.routing.* import io.ktor.server.routing.*
import io.ktor.server.sessions.* import io.ktor.server.sessions.*
import kotlinx.serialization.Serializable
import org.koin.java.KoinJavaComponent.inject import org.koin.java.KoinJavaComponent.inject
import space.mori.chzzk_bot.common.events.CoroutinesEventBus import space.mori.chzzk_bot.common.events.CoroutinesEventBus
import space.mori.chzzk_bot.common.services.UserService import space.mori.chzzk_bot.common.services.UserService
@ -15,7 +17,7 @@ fun Route.apiDiscordRoutes() {
val dispatcher: CoroutinesEventBus by inject(CoroutinesEventBus::class.java) val dispatcher: CoroutinesEventBus by inject(CoroutinesEventBus::class.java)
route("/discord") { route("/discord") {
get("{uid}") { get("/{uid}") {
val uid = call.parameters["uid"] val uid = call.parameters["uid"]
val session = call.sessions.get<UserSession>() val session = call.sessions.get<UserSession>()
if(uid == null) { if(uid == null) {
@ -32,14 +34,29 @@ fun Route.apiDiscordRoutes() {
call.respond(HttpStatusCode.NotFound) call.respond(HttpStatusCode.NotFound)
return@get return@get
} }
val guild = DiscordGuildCache.getCachedGuilds(user.liveAlertGuild.toString()) call.respond(HttpStatusCode.OK, GuildSettings(
if(guild == null) { user.liveAlertGuild,
call.respond(HttpStatusCode.NotFound) user.liveAlertChannel,
return@get user.liveAlertMessage
} ))
call.respond(HttpStatusCode.OK, guild)
return@get return@get
} }
post("/{uid}") {
val uid = call.parameters["uid"]
val session = call.sessions.get<UserSession>()
val body: GuildSettings = call.receive()
if(uid == null) {
call.respond(HttpStatusCode.BadRequest, "UID is required")
return@post
}
val user = UserService.getUser(uid)
if(user == null || user.naverId != session?.id || user.token == null) {
call.respond(HttpStatusCode.BadRequest, "User does not exist")
return@post
}
UserService.updateLiveAlert(user, body.guildId ?: 0L, body.channelId ?: 0L, body.message)
call.respond(HttpStatusCode.OK)
}
get("/guild/{gid}") { get("/guild/{gid}") {
val gid = call.parameters["gid"] val gid = call.parameters["gid"]
val session = call.sessions.get<UserSession>() val session = call.sessions.get<UserSession>()
@ -81,4 +98,11 @@ fun Route.apiDiscordRoutes() {
return@get return@get
} }
} }
} }
@Serializable
data class GuildSettings(
val guildId: Long?,
val channelId: Long?,
val message: String? = null,
)