Invoke command in threads fix join_channels bug

Commands will now be invoked in replies and threads.

Channels prefixed with # in initial_channels will now trigger event_ready correctly.

Author: chillymosh

docs/changelog.rst

@@ -4,6 +4,13 @@ Master
 =======
 Massive documentation updates
 
+- TwitchIO
+    - Fix bug where # prefixed channel names in initial_channels would not trigger :func:`Client.event_ready``
+
+- ext.commands
+    - :func:`Bot.handle_commands` now also invokes on threads / replies
+
+
 2.2.0
 =====
 - ext.sounds
@@ -30,7 +37,7 @@ Massive documentation updates
 - ext.eventsub
     - Add support for the following subscription types
         - :class:`twitchio.ext.eventsub.PollBeginProgressData`
-            - ``channel.poll.begin``: 
+            - ``channel.poll.begin``:
             - ``channel.poll.progress``
         - :class:`twitchio.ext.eventsub.PollEndData`
             - ``channel.poll.end``

twitchio/ext/commands/bot.py

@@ -323,6 +323,21 @@ async def get_context(self, message, *, cls=None):
         return context
 
     async def handle_commands(self, message):
+        """|coro|
+
+        This method handles commands sent from chat and invokes them.
+
+        By default, this coroutine is called within the `event_message` event.
+        If you choose to override `event_message` then you need to invoke this coroutine in order to handle commands.
+
+        Parameters
+        ----------
+        message: :class:`.Message`
+            The message object to get content of and context for.
+
+        """
+        if "reply-parent-msg-id" in message.tags:
+            message.content = message.content.split(" ")[1]
         context = await self.get_context(message)
         await self.invoke(context)
 

twitchio/websocket.py

@@ -352,12 +352,12 @@ async def _code(self, parsed, code: int):
             if parsed["channel"] == "TWITCHIOFAILURE":
                 self._initial_channels.remove(parsed["batches"][0])
 
-            if parsed["channel"] in [c.lower() for c in self._initial_channels] and not self._init:
+            if parsed["channel"] in [c.lower().lstrip("#") for c in self._initial_channels] and not self._init:
                 self._join_load[parsed["channel"]] = None
 
             if len(self._join_load) == len(self._initial_channels):
                 for channel in self._initial_channels:
-                    self._join_load.pop(channel.lower())
+                    self._join_load.pop(channel.lower().lstrip("#"))
                     self._cache_add(parsed)
                 self.is_ready.set()
             else: