fix some nitpicks, change the ws subscribe stuff to async

Author: IAmTomahawkx

docs/exts/eventsub.rst

@@ -104,10 +104,32 @@ This is a list of events dispatched by the eventsub ext.
     .. note::
         You generally won't need to interact with this event. The ext will handle responding to the challenge automatically.
 
+.. function:: event_eventsub_keepalive(event: KeepaliveEvent)
+
+    Called when a Twitch sends a keepalive event. You do not need to use this in daily usage.
+    
+    .. note::
+        You generally won't need to interact with this event.
+
+.. function:: event_eventsub_reconnect(event: ReconnectEvent)
+
+    Called when a Twitch wishes for us to reconnect.
+    
+    .. note::
+        You generally won't need to interact with this event. The library will automatically handle reconnecting.
+
 .. function:: event_eventsub_notification_follow(event: ChannelFollowData)
 
     Called when someone creates a follow on a channel you've subscribed to.
 
+    .. warning::
+        Twitch has removed this, please use :func:`event_eventsub_notification_followV2`
+
+
+.. function:: event_eventsub_notification_followV2(event: ChannelFollowData)
+
+    Called when someone creates a follow on a channel you've subscribed to.
+
 .. function:: event_eventsub_notification_subscription(event: ChannelSubscribeData)
 
     Called when someone subscribes to a channel that you've subscribed to.
@@ -235,6 +257,12 @@ API Reference
     :members:
     :inherited-members:
 
+.. attributetable:: WebsocketHeaders
+
+.. autoclass:: WebsocketHeaders
+    :members:
+    :inherited-members:
+
 .. attributetable::: ChannelBanData
 
 .. autoclass:: ChannelBanData

twitchio/ext/eventsub/http.py

@@ -32,15 +32,15 @@ async def create_webhook_subscription(
 
     async def create_websocket_subscription(
         self, event_type: Tuple[str, int, Type[EventData]], condition: Dict[str, str], session_id: str, token: str
-    ):
+    ) -> dict:
         payload = {
             "type": event_type[0],
             "version": str(event_type[1]),
             "condition": condition,
             "transport": {"method": "websocket", "session_id": session_id},
         }
         route = Route("POST", "eventsub/subscriptions", body=payload, token=token)
-        return await self._http.request(route, paginate=False, full_body=True)
+        return await self._http.request(route, paginate=False, full_body=True)  # type: ignore
 
     async def delete_subscription(self, subscription: Union[str, Subscription]):
         if isinstance(subscription, models.Subscription):

twitchio/ext/eventsub/models.py

@@ -236,7 +236,7 @@ class ReconnectEvent(BaseEvent):
     A reconnect event. Called by twitch when the websocket needs to be disconnected for maintenance or other reasons
 
     .. note::
-        These are only dispatched when using :class:`~twitchio.ext.eventsub.EventSubWSClient
+        These are only dispatched when using :class:`~twitchio.ext.eventsub.EventSubWSClient`
 
     Attributes
     -----------
@@ -258,7 +258,7 @@ class KeepAliveEvent(BaseEvent):
     A keep-alive event. Called by twitch when no message has been sent for more than ``keepalive_timeout``
 
     .. note::
-        These are only dispatched when using :class:`~twitchio.ext.eventsub.EventSubWSClient
+        These are only dispatched when using :class:`~twitchio.ext.eventsub.EventSubWSClient`
 
     """