Conditions | 1 |
Total Lines | 33 |
Code Lines | 13 |
Lines | 0 |
Ratio | 0 % |
Changes | 0 |
1 | # Copyright Pincer 2021-Present |
||
14 | async def thread_members_update_middleware(self, payload: GatewayDispatch): |
||
15 | """|coro| |
||
16 | |||
17 | Middleware for ``on_thread_members_update`` event. |
||
18 | |||
19 | Parameters |
||
20 | ---------- |
||
21 | payload : :class:`GatewayDispatch` |
||
22 | The data received from the thread members update event. |
||
23 | |||
24 | |||
25 | Returns |
||
26 | ------- |
||
27 | Tuple[:class:`str`, List[:class:`~pincer.objects.events.thread.ThreadMembersUpdateEvent`]] |
||
28 | ``on_thread_members_update`` and an ``ThreadMembersUpdateEvent`` |
||
29 | """ |
||
30 | |||
31 | added_members: List[ThreadMember] = [ |
||
32 | ThreadMember.from_dict(construct_client_dict( |
||
33 | self, |
||
34 | { |
||
35 | "join_timestamp": Timestamp(added_member.pop("join_timestamp")), |
||
36 | **added_member |
||
37 | } |
||
38 | )) |
||
39 | for added_member in payload.data.pop("added_members") |
||
40 | ] |
||
41 | |||
42 | return "on_thread_members_update", [ |
||
43 | ThreadMembersUpdateEvent.from_dict( |
||
44 | { |
||
45 | "added_members": added_members, |
||
46 | **payload.data |
||
47 | } |
||
54 |