mirror of https://gitlab.com/litecord/litecord.git
27 lines
761 B
Python
27 lines
761 B
Python
from .dispatcher import Dispatcher
|
|
|
|
|
|
class MemberDispatcher(Dispatcher):
|
|
"""Member backend for Pub/Sub."""
|
|
KEY_TYPE = tuple
|
|
|
|
async def dispatch(self, key, event, data):
|
|
"""Dispatch a single event to a member.
|
|
|
|
This is shard-aware.
|
|
"""
|
|
# we don't keep any state on this dispatcher, so the key
|
|
# is just (guild_id, user_id)
|
|
guild_id, user_id = key
|
|
|
|
# fetch shards
|
|
states = self.sm.fetch_states(user_id, guild_id)
|
|
|
|
# if no states were found, we should
|
|
# unsub the user from the GUILD channel
|
|
if not states:
|
|
await self.main_dispatcher.unsub('guild', guild_id, user_id)
|
|
return
|
|
|
|
return await self._dispatch_states(states, event, data)
|