Fix PubSubChannelSubscribe model

PartialUser had incorrect args and self.message needs to be a string, not PubSubChatMessage.

Author: chillymosh

docs/changelog.rst

@@ -11,6 +11,8 @@ Massive documentation updates
     - :func:`Bot.handle_commands` now also invokes on threads / replies
     - Cooldowns are now handled correctly per bucket.
 
+- ext.pubsub
+    - Channel subscription model fixes.
 
 2.2.0
 =====

docs/exts/pubsub.rst

@@ -151,10 +151,6 @@ If the topic requires multiple channel ids, they should be passed as such:
 
 .. function:: channel_subscriptions(oauth_token: str)
 
-    .. warning::
-
-        This does not have a model created yet, and will error when a subscription event is received
-
     This topic listens for subscriptions on the given channel.
     This topic dispatches the ``pubsub_subscription`` client event.
     This topic takes one channel id, the channel to listen on, e.g.:

twitchio/ext/pubsub/models.py

@@ -399,13 +399,11 @@ def __init__(self, client: Client, topic: str, data: dict):
         self.context: str = subscription["context"]
 
         try:
-            self.user = (
-                PartialUser(client._http, subscription["user_name"], int(subscription["user_id"])),
-                subscription["display_name"],
-            )
+            self.user = PartialUser(client._http, int(subscription["user_id"]), subscription["user_name"])
         except KeyError:
             self.user = None
-        self.message = PubSubChatMessage(subscription["sub_message"]["message"])
+
+        self.message: str = subscription["sub_message"]["message"]
 
         try:
             self.emotes = subscription["sub_message"]["emotes"]
@@ -415,9 +413,8 @@ def __init__(self, client: Client, topic: str, data: dict):
         self.is_gift: bool = subscription["is_gift"]
 
         try:
-            self.recipient = (
-                PartialUser(client._http, subscription["recipient_user_name"], int(subscription["recipient_id"])),
-                subscription["recipient_display_name"],
+            self.recipient = PartialUser(
+                client._http, int(subscription["recipient_id"]), subscription["recipient_user_name"]
             )
         except KeyError:
             self.recipient = None