From 2eb12900b9012551485e926ea0af9ad7101b6d8c Mon Sep 17 00:00:00 2001 From: Knut Ahlers Date: Thu, 2 Sep 2021 17:40:38 +0200 Subject: [PATCH] Fix: Do not send update when not asked to Signed-off-by: Knut Ahlers --- twitchWatcher.go | 66 +++++++++++++++++++++++------------------------- 1 file changed, 32 insertions(+), 34 deletions(-) diff --git a/twitchWatcher.go b/twitchWatcher.go index 53ecb00..15333dd 100644 --- a/twitchWatcher.go +++ b/twitchWatcher.go @@ -90,42 +90,40 @@ func (r *twitchWatcher) updateChannelFromAPI(channel string, sendUpdate bool) er return nil } - if r.ChannelStatus[channel] == nil { - r.ChannelStatus[channel] = &status - } - - if r.ChannelStatus[channel].Category != status.Category { - log.WithFields(log.Fields{ - "channel": channel, - "category": status.Category, - }).Debug("Twitch metadata changed") - go handleMessage(nil, nil, eventTypeTwitchCategoryUpdate, map[string]interface{}{ - "category": status.Category, - }) - } - - if r.ChannelStatus[channel].Title != status.Title { - log.WithFields(log.Fields{ - "channel": channel, - "title": status.Title, - }).Debug("Twitch metadata changed") - go handleMessage(nil, nil, eventTypeTwitchTitleUpdate, map[string]interface{}{ - "title": status.Title, - }) - } - - if r.ChannelStatus[channel].IsLive != status.IsLive { - log.WithFields(log.Fields{ - "channel": channel, - "isLive": status.IsLive, - }).Debug("Twitch metadata changed") - - evt := eventTypeTwitchStreamOnline - if !status.IsLive { - evt = eventTypeTwitchStreamOffline + if sendUpdate && r.ChannelStatus[channel] != nil { + if r.ChannelStatus[channel].Category != status.Category { + log.WithFields(log.Fields{ + "channel": channel, + "category": status.Category, + }).Debug("Twitch metadata changed") + go handleMessage(nil, nil, eventTypeTwitchCategoryUpdate, map[string]interface{}{ + "category": status.Category, + }) } - go handleMessage(nil, nil, evt, nil) + if r.ChannelStatus[channel].Title != status.Title { + log.WithFields(log.Fields{ + "channel": channel, + "title": status.Title, + }).Debug("Twitch metadata changed") + go handleMessage(nil, nil, eventTypeTwitchTitleUpdate, map[string]interface{}{ + "title": status.Title, + }) + } + + if r.ChannelStatus[channel].IsLive != status.IsLive { + log.WithFields(log.Fields{ + "channel": channel, + "isLive": status.IsLive, + }).Debug("Twitch metadata changed") + + evt := eventTypeTwitchStreamOnline + if !status.IsLive { + evt = eventTypeTwitchStreamOffline + } + + go handleMessage(nil, nil, evt, nil) + } } r.ChannelStatus[channel] = &status