From a4b6036da06eb4ae3727b9e056eb704bc77dce59 Mon Sep 17 00:00:00 2001 From: Knut Ahlers Date: Sat, 5 Feb 2022 23:50:30 +0100 Subject: [PATCH] [core] Fix: EventSub messages had misformatted channel Signed-off-by: Knut Ahlers --- twitchWatcher.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/twitchWatcher.go b/twitchWatcher.go index 18fd127..323ea51 100644 --- a/twitchWatcher.go +++ b/twitchWatcher.go @@ -101,7 +101,7 @@ func (t *twitchWatcher) handleEventSubChannelFollow(m json.RawMessage) error { } fields := plugins.FieldCollectionFromData(map[string]interface{}{ - "channel": payload.BroadcasterUserLogin, + "channel": "#" + payload.BroadcasterUserLogin, "followed_at": payload.FollowedAt, "user_id": payload.UserID, "user": payload.UserLogin, @@ -120,7 +120,7 @@ func (t *twitchWatcher) handleEventSubChannelPointCustomRewardRedemptionAdd(m js } fields := plugins.FieldCollectionFromData(map[string]interface{}{ - "channel": payload.BroadcasterUserLogin, + "channel": "#" + payload.BroadcasterUserLogin, "reward_cost": payload.Reward.Cost, "reward_id": payload.Reward.ID, "reward_title": payload.Reward.Title, @@ -335,7 +335,7 @@ func (t *twitchWatcher) triggerUpdate(channel string, title, category *string, o "category": *category, }).Debug("Twitch metadata changed") go handleMessage(ircHdl.Client(), nil, eventTypeTwitchCategoryUpdate, plugins.FieldCollectionFromData(map[string]interface{}{ - "channel": channel, + "channel": "#" + channel, "category": *category, })) } @@ -347,7 +347,7 @@ func (t *twitchWatcher) triggerUpdate(channel string, title, category *string, o "title": *title, }).Debug("Twitch metadata changed") go handleMessage(ircHdl.Client(), nil, eventTypeTwitchTitleUpdate, plugins.FieldCollectionFromData(map[string]interface{}{ - "channel": channel, + "channel": "#" + channel, "title": *title, })) } @@ -365,7 +365,7 @@ func (t *twitchWatcher) triggerUpdate(channel string, title, category *string, o } go handleMessage(ircHdl.Client(), nil, evt, plugins.FieldCollectionFromData(map[string]interface{}{ - "channel": channel, + "channel": "#" + channel, })) } }