Cleanup stale bot listeners on Client reinitialisation.

`Client()` now takes a kwarg only parameter, `bot`, which is an instance of <commands.Bot, commands.AutoShardedBot>.

Fix examples inline with new changes.

Bump version (0, 7, 0)

examples/advanced.py

@@ -327,7 +327,7 @@ def __init__(self, bot: commands.Bot):
         self.bot = bot
 
         if not hasattr(bot, 'wavelink'):
-            bot.wavelink = wavelink.Client(bot)
+            bot.wavelink = wavelink.Client(bot=bot)
 
         bot.loop.create_task(self.start_nodes())
 

examples/basic.py

@@ -20,7 +20,7 @@ def __init__(self, bot):
         self.bot = bot
 
         if not hasattr(bot, 'wavelink'):
-            self.bot.wavelink = wavelink.Client(self.bot)
+            self.bot.wavelink = wavelink.Client(bot=self.bot)
 
         self.bot.loop.create_task(self.start_nodes())
 

examples/playlist.py

@@ -85,7 +85,7 @@ def __init__(self, bot):
         self.controllers = {}
 
         if not hasattr(bot, 'wavelink'):
-            self.bot.wavelink = wavelink.Client(self.bot)
+            self.bot.wavelink = wavelink.Client(bot=self.bot)
 
         self.bot.loop.create_task(self.start_nodes())
 

wavelink/__init__.py

@@ -2,7 +2,7 @@
 __author__ = 'EvieePy'
 __license__ = 'MIT'
 __copyright__ = 'Copyright 2019-2020 (c) PythonistaGuild'
-__version__ = '0.6.3'
+__version__ = '0.7.0'
 
 from .client import Client
 from .errors import *

wavelink/client.py

@@ -37,6 +37,28 @@
 class Client:
     """The main WaveLink client."""
 
+    def __new__(cls, *args, **kwargs):
+        try:
+            bot = kwargs['bot']
+        except KeyError:
+            msg = 'wavelink.Client: bot is a required keyword only argument which is missing.'
+            raise WavelinkException(msg)
+
+        if not isinstance(bot, (commands.Bot, commands.AutoShardedBot)):
+            msg = f'wavelink.Client expected type <commands.Bot or commands.AutoShardedBot> not {type(bot)}'
+            raise TypeError(msg)
+
+        try:
+            update_handlers = bot.extra_events['on_socket_response']
+        except KeyError:
+            return super().__new__(cls)
+
+        for handler in update_handlers:
+            if isinstance(handler.__self__.__class__, cls.__class__):
+                bot.remove_listener(handler, 'on_socket_response')
+
+        return super().__new__(cls)
+
     def __init__(self, bot: Union[commands.Bot, commands.AutoShardedBot]):
         self.bot = bot
         self.loop = bot.loop or asyncio.get_event_loop()