mirror of
https://github.com/dalbodeule/chibot-chzzk-bot.git
synced 2025-08-08 05:11:12 +00:00
[hotfix] hotfix on some codes.
This commit is contained in:
@@ -199,7 +199,10 @@ val server = embeddedServer(Netty, port = 8080, ) {
|
||||
listOf()
|
||||
)
|
||||
)
|
||||
user?.let { UserService.setRefreshToken(it, tokenResponse.content.accessToken, tokenResponse.content.refreshToken ?: "") }
|
||||
user?.let { UserService.setRefreshToken(it,
|
||||
tokenResponse.content.accessToken,
|
||||
tokenResponse.content.refreshToken ?: ""
|
||||
) }
|
||||
call.respondRedirect(getFrontendURL(""))
|
||||
}
|
||||
} catch (e: Exception) {
|
||||
@@ -427,4 +430,4 @@ suspend fun getChzzkUser(accessToken: String): ChzzkApi<ChzzkMeApi> {
|
||||
|
||||
fun generateSecureRandomState(): String {
|
||||
return BigInteger(130, SecureRandom()).toString(32)
|
||||
}
|
||||
}
|
||||
|
@@ -40,12 +40,16 @@ fun Routing.apiRoutes() {
|
||||
val dispatcher: CoroutinesEventBus by inject(CoroutinesEventBus::class.java)
|
||||
|
||||
suspend fun getChzzkUserWithId(uid: String): ChzzkUserReceiveEvent? {
|
||||
val completableDeferred = CompletableDeferred< ChzzkUserReceiveEvent>()
|
||||
val completableDeferred = CompletableDeferred<ChzzkUserReceiveEvent>()
|
||||
dispatcher.subscribe(ChzzkUserReceiveEvent::class) { event ->
|
||||
if (event.uid == uid) {
|
||||
completableDeferred.complete(event)
|
||||
}
|
||||
}
|
||||
val user = withTimeoutOrNull(5000) {
|
||||
dispatcher.post(ChzzkUserFindEvent(uid))
|
||||
completableDeferred.await()
|
||||
}
|
||||
|
||||
return user
|
||||
}
|
||||
|
||||
|
Reference in New Issue
Block a user