kurbezz/discord-bot
1
0
Fork 0
mirror of https://github.com/kurbezz/discord-bot.git synced 2025-12-06 07:05:36 +01:00
Code Issues Packages Projects Releases Wiki Activity

Fix

Browse Source
This commit is contained in:
Bulat Kurbanov
2024-11-17 23:10:54 +01:00
parent fc3ce27c51
commit 4adcbef8e4
1 changed files with 15 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
src/modules/stream_notifications/twitch/webhook.py
View File

@@ -44,27 +44,25 @@ class TwitchService:
await eventsub.listen_stream_online(str(streamer.twitch.id), self.on_stream_online)
else:
raise ValueError("Unknown method")
except ValueError as e:
raise e
except EventSubSubscriptionConflict:
if method == "listen_channel_update_v2":
sub_type = "channel.update"
elif method == "listen_stream_online":
sub_type = "stream.online"
else:
raise ValueError("Unknown method")
subs = await self.twitch.get_eventsub_subscriptions(
user_id=str(streamer.twitch.id)
)
for sub in subs.data:
if sub.status == "enabled" and sub.type == sub_type:
await self.twitch.delete_eventsub_subscription(sub.id)
except Exception as e:
if retry <= 0:
raise e
if method == "listen_channel_update_v2":
sub_type = "channel.update"
elif method == "listen_stream_online":
sub_type = "stream.online"
else:
raise ValueError("Unknown method")
subs = await self.twitch.get_eventsub_subscriptions(
user_id=str(streamer.twitch.id)
)
for sub in subs.data:
if sub.status == "enabled" and sub.type == sub_type:
await self.twitch.delete_eventsub_subscription(sub.id)
await sleep(1)
await self.subscribe_with_retry(method, eventsub, streamer, retry - 1)