mirror of https://gitlab.com/litecord/litecord.git
pubsub.lazy_guild: add dummy impl for chan_update
This commit is contained in:
parent
bb36d7e669
commit
49edad8573
|
|
@ -162,6 +162,17 @@ def _to_simple_group(presence: dict) -> str:
|
||||||
return 'offline' if presence['status'] == 'offline' else 'online'
|
return 'offline' if presence['status'] == 'offline' else 'online'
|
||||||
|
|
||||||
|
|
||||||
|
async def everyone_allow(gml) -> bool:
|
||||||
|
everyone_perms = await role_permissions(
|
||||||
|
gml.guild_id,
|
||||||
|
gml.guild_id,
|
||||||
|
gml.channel_id,
|
||||||
|
storage=gml.storage
|
||||||
|
)
|
||||||
|
|
||||||
|
return everyone_perms.bits.read_messages
|
||||||
|
|
||||||
|
|
||||||
def display_name(member_nicks: Dict[str, str], presence: Presence) -> str:
|
def display_name(member_nicks: Dict[str, str], presence: Presence) -> str:
|
||||||
"""Return the display name of a presence.
|
"""Return the display name of a presence.
|
||||||
|
|
||||||
|
|
@ -284,7 +295,7 @@ class GuildMemberList:
|
||||||
if g.gid in roles)
|
if g.gid in roles)
|
||||||
except StopIteration:
|
except StopIteration:
|
||||||
# no group was found, so we fallback
|
# no group was found, so we fallback
|
||||||
# to simple group"
|
# to simple group
|
||||||
group_id = _to_simple_group({'status': status})
|
group_id = _to_simple_group({'status': status})
|
||||||
|
|
||||||
return group_id
|
return group_id
|
||||||
|
|
@ -1275,6 +1286,27 @@ class GuildMemberList:
|
||||||
|
|
||||||
return await self.resync(sess_ids_resync, role_item_index)
|
return await self.resync(sess_ids_resync, role_item_index)
|
||||||
|
|
||||||
|
async def chan_update(self):
|
||||||
|
"""Called then a channel's data has been updated."""
|
||||||
|
await self._fetch_overwrites()
|
||||||
|
|
||||||
|
# TODO: recreate groups
|
||||||
|
|
||||||
|
# self.list.data = dict()
|
||||||
|
# await self._list_fill_groups()
|
||||||
|
# await self._sort_groups()
|
||||||
|
|
||||||
|
if self.list_id == 'everyone':
|
||||||
|
return
|
||||||
|
|
||||||
|
# we are on a non-everyone gml, time to check everyone perms
|
||||||
|
ev_read = await everyone_allow(self)
|
||||||
|
|
||||||
|
if ev_read:
|
||||||
|
# we became the everyone list right now, so we MUST
|
||||||
|
# move our current state.
|
||||||
|
pass
|
||||||
|
|
||||||
def close(self):
|
def close(self):
|
||||||
"""Remove data."""
|
"""Remove data."""
|
||||||
log.info('closing GML gid={} cid={}, {} subscribers',
|
log.info('closing GML gid={} cid={}, {} subscribers',
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue