nick12
/
hmn
forked from hmn/hmn
1
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Debugging twitch in beta

This commit is contained in:
Asaf Gartner 2022-03-22 20:52:05 +02:00
parent c8096b0fb7
commit 5ecd5a8a31
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/twitch/twitch.go
View File

@ -212,6 +212,7 @@ func syncWithTwitch(ctx context.Context, dbConn *pgxpool.Pool, updateAll bool) {
return return
} }
p.EndBlock() p.EndBlock()
log.Info().Interface("Subscriptions", subscriptions).Msg("Got subs from twitch")
const ( const (
EventSubNone = 0 // No event of this type found EventSubNone = 0 // No event of this type found
@ -244,7 +245,7 @@ func syncWithTwitch(ctx context.Context, dbConn *pgxpool.Pool, updateAll bool) {
log.Debug().Str("TwitchID", sub.TwitchID).Str("Event Type", sub.Type).Msg("Twitch doesn't like our sub") log.Debug().Str("TwitchID", sub.TwitchID).Str("Event Type", sub.Type).Msg("Twitch doesn't like our sub")
toUnsub = append(toUnsub, unsubEvent{TwitchID: sub.TwitchID, EventID: sub.EventID}) toUnsub = append(toUnsub, unsubEvent{TwitchID: sub.TwitchID, EventID: sub.EventID})
} else { } else {
eventSubs[sub.Type] = true streamerEventSubs[sub.TwitchID][sub.Type] = true
} }
handled = true handled = true
} }
@ -270,6 +271,7 @@ func syncWithTwitch(ctx context.Context, dbConn *pgxpool.Pool, updateAll bool) {
for twitchID, evStatuses := range streamerEventSubs { for twitchID, evStatuses := range streamerEventSubs {
for evType, isSubbed := range evStatuses { for evType, isSubbed := range evStatuses {
if !isSubbed { if !isSubbed {
log.Info().Str("TwitchID", twitchID).Str("Type", evType).Msg("Subscribing")
err = subscribeToEvent(ctx, evType, twitchID) err = subscribeToEvent(ctx, evType, twitchID)
if err != nil { if err != nil {
log.Error().Err(err).Msg("Error while monitoring twitch") log.Error().Err(err).Msg("Error while monitoring twitch")