refactor!: ConnectionState & Event Handling

discord/abc.py

@@ -90,7 +90,7 @@
     from .member import Member
     from .message import Message, MessageReference, PartialMessage
     from .poll import Poll
-    from .state import ConnectionState
+    from .app.state import ConnectionState
     from .threads import Thread
     from .types.channel import Channel as ChannelPayload
     from .types.channel import GuildChannel as GuildChannelPayload
@@ -345,7 +345,7 @@ def __str__(self) -> str:
     def _sorting_bucket(self) -> int:
         raise NotImplementedError
 
-    def _update(self, guild: Guild, data: dict[str, Any]) -> None:
+    async def _update(self, data: dict[str, Any]) -> None:
         raise NotImplementedError
 
     async def _move(
@@ -595,8 +595,7 @@ def overwrites_for(self, obj: Role | User) -> PermissionOverwrite:
 
         return PermissionOverwrite()
 
-    @property
-    def overwrites(self) -> dict[Role | Member, PermissionOverwrite]:
+    async def get_overwrites(self) -> dict[Role | Member, PermissionOverwrite]:
         """Returns all of the channel's overwrites.
 
         This is returned as a dictionary where the key contains the target which
@@ -618,7 +617,7 @@ def overwrites(self) -> dict[Role | Member, PermissionOverwrite]:
             if ow.is_role():
                 target = self.guild.get_role(ow.id)
             elif ow.is_member():
-                target = self.guild.get_member(ow.id)
+                target = await self.guild.get_member(ow.id)
 
             # TODO: There is potential data loss here in the non-chunked
             # case, i.e. target is None because get_member returned nothing.
@@ -1226,7 +1225,7 @@ async def create_invite(
             target_user_id=target_user.id if target_user else None,
             target_application_id=target_application_id,
         )
-        invite = Invite.from_incomplete(data=data, state=self._state)
+        invite = await Invite.from_incomplete(data=data, state=self._state)
         if target_event:
             invite.set_scheduled_event(target_event)
         return invite
@@ -1611,7 +1610,7 @@ async def send(
         ret = state.create_message(channel=channel, data=data)
         if view:
             if view.is_dispatchable():
-                state.store_view(view, ret.id)
+                await state.store_view(view, ret.id)
             view.message = ret
             view.refresh(ret.components)