apps/streamctl
1
0
Fork 0
mirror of https://github.com/xaionaro-go/streamctl.git synced 2025-09-27 03:45:52 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Don't panic in Kick chat handler

Browse Source
This commit is contained in:
Dmitrii Okunev
2025-07-27 13:05:16 +01:00
parent 316eeaca5c
commit d7325ef61b
2 changed files with 11 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
cmd/streampanel/context.go
View File

@@ -51,6 +51,7 @@ func getContext(
ll := xlogrus.DefaultLogrusLogger() ll := xlogrus.DefaultLogrusLogger()
ll.Formatter.(*logrus.TextFormatter).ForceColors = true ll.Formatter.(*logrus.TextFormatter).ForceColors = true
ll.ReportCaller = true
logPreHooks := logger.PreHooks{ logPreHooks := logger.PreHooks{
&observability.LogLevelFilter, &observability.LogLevelFilter,

11
pkg/streamcontrol/kick/kick.go
View File

@@ -134,7 +134,16 @@ func (k *Kick) keepAliveLoop(
t := time.NewTicker(time.Minute) t := time.NewTicker(time.Minute)
defer t.Stop() defer t.Stop()
for { for {
_, err := k.GetClient().GetLivestreams(k.CloseCtx, gokick.NewLivestreamListFilter().SetBroadcasterUserIDs(int(k.Channel.UserID))) if k.Channel == nil { // TODO: fix non-atomicity
logger.Warnf(ctx, "channel info is not set, yet")
continue
}
client := k.GetClient()
if client == nil {
logger.Errorf(ctx, "client is not initialized")
continue
}
_, err := client.GetLivestreams(k.CloseCtx, gokick.NewLivestreamListFilter().SetBroadcasterUserIDs(int(k.Channel.UserID)))
if err != nil { if err != nil {
logger.Errorf(ctx, "unable to get my stream status: %v", err) logger.Errorf(ctx, "unable to get my stream status: %v", err)
continue continue