mirror of
https://github.com/dalbodeule/chibot-chzzk-bot.git
synced 2025-06-09 07:18:22 +00:00
debug some errors.
- ChzzkHandler.runStreamInfo debugs with startThread functions.
This commit is contained in:
parent
f994972fac
commit
910886f8b5
@ -3,6 +3,7 @@ package space.mori.chzzk_bot.chatbot.chzzk
|
|||||||
import kotlinx.coroutines.CoroutineScope
|
import kotlinx.coroutines.CoroutineScope
|
||||||
import kotlinx.coroutines.Dispatchers
|
import kotlinx.coroutines.Dispatchers
|
||||||
import kotlinx.coroutines.delay
|
import kotlinx.coroutines.delay
|
||||||
|
import kotlinx.coroutines.future.await
|
||||||
import kotlinx.coroutines.launch
|
import kotlinx.coroutines.launch
|
||||||
import org.koin.java.KoinJavaComponent.inject
|
import org.koin.java.KoinJavaComponent.inject
|
||||||
import org.slf4j.Logger
|
import org.slf4j.Logger
|
||||||
@ -215,15 +216,15 @@ class UserHandler(
|
|||||||
|
|
||||||
internal fun isActive(value: Boolean, status: IData<IStreamInfo?>) {
|
internal fun isActive(value: Boolean, status: IData<IStreamInfo?>) {
|
||||||
if(value) {
|
if(value) {
|
||||||
logger.info("${user.username} is live.")
|
|
||||||
|
|
||||||
logger.info("ChzzkChat connecting... ${channel.channelName} - ${channel.channelId}")
|
|
||||||
listener.connectBlocking()
|
|
||||||
|
|
||||||
streamStartTime = status.content?.openDate?.let { convertChzzkDateToLocalDateTime(it) }
|
|
||||||
|
|
||||||
CoroutineScope(Dispatchers.Default).launch {
|
CoroutineScope(Dispatchers.Default).launch {
|
||||||
if(!_isActive) {
|
if(!_isActive) {
|
||||||
|
logger.info("${user.username} is live.")
|
||||||
|
|
||||||
|
logger.info("ChzzkChat connecting... ${channel.channelName} - ${channel.channelId}")
|
||||||
|
listener.connectAsync().await()
|
||||||
|
|
||||||
|
streamStartTime = status.content?.openDate?.let { convertChzzkDateToLocalDateTime(it) }
|
||||||
|
|
||||||
_isActive = true
|
_isActive = true
|
||||||
when(TimerConfigService.getConfig(UserService.getUser(channel.channelId)!!)?.option) {
|
when(TimerConfigService.getConfig(UserService.getUser(channel.channelId)!!)?.option) {
|
||||||
TimerType.UPTIME.value -> dispatcher.post(
|
TimerType.UPTIME.value -> dispatcher.post(
|
||||||
|
Loading…
x
Reference in New Issue
Block a user