Вы не можете выбрать более 25 тем Темы должны начинаться с буквы или цифры, могут содержать дефисы(-) и должны содержать не более 35 символов.
 
 
 
 
 
 

210 строки
7.6 KiB

  1. # Copyright 2016 OpenMarket Ltd
  2. #
  3. # Licensed under the Apache License, Version 2.0 (the "License");
  4. # you may not use this file except in compliance with the License.
  5. # You may obtain a copy of the License at
  6. #
  7. # http://www.apache.org/licenses/LICENSE-2.0
  8. #
  9. # Unless required by applicable law or agreed to in writing, software
  10. # distributed under the License is distributed on an "AS IS" BASIS,
  11. # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12. # See the License for the specific language governing permissions and
  13. # limitations under the License.
  14. import logging
  15. import re
  16. from typing import TYPE_CHECKING, Dict, Iterable, Optional
  17. from synapse.api.constants import EventTypes, Membership
  18. from synapse.events import EventBase
  19. from synapse.types import StateMap
  20. if TYPE_CHECKING:
  21. from synapse.storage.databases.main import DataStore
  22. logger = logging.getLogger(__name__)
  23. # intentionally looser than what aliases we allow to be registered since
  24. # other HSes may allow aliases that we would not
  25. ALIAS_RE = re.compile(r"^#.*:.+$")
  26. ALL_ALONE = "Empty Room"
  27. async def calculate_room_name(
  28. store: "DataStore",
  29. room_state_ids: StateMap[str],
  30. user_id: str,
  31. fallback_to_members: bool = True,
  32. fallback_to_single_member: bool = True,
  33. ) -> Optional[str]:
  34. """
  35. Works out a user-facing name for the given room as per Matrix
  36. spec recommendations.
  37. Does not yet support internationalisation.
  38. Args:
  39. store: The data store to query.
  40. room_state_ids: Dictionary of the room's state IDs.
  41. user_id: The ID of the user to whom the room name is being presented
  42. fallback_to_members: If False, return None instead of generating a name
  43. based on the room's members if the room has no
  44. title or aliases.
  45. fallback_to_single_member: If False, return None instead of generating a
  46. name based on the user who invited this user to the room if the room
  47. has no title or aliases.
  48. Returns:
  49. A human readable name for the room, if possible.
  50. """
  51. # does it have a name?
  52. if (EventTypes.Name, "") in room_state_ids:
  53. m_room_name = await store.get_event(
  54. room_state_ids[(EventTypes.Name, "")], allow_none=True
  55. )
  56. if m_room_name and m_room_name.content and m_room_name.content.get("name"):
  57. return m_room_name.content["name"]
  58. # does it have a canonical alias?
  59. if (EventTypes.CanonicalAlias, "") in room_state_ids:
  60. canon_alias = await store.get_event(
  61. room_state_ids[(EventTypes.CanonicalAlias, "")], allow_none=True
  62. )
  63. if (
  64. canon_alias
  65. and canon_alias.content
  66. and canon_alias.content.get("alias")
  67. and _looks_like_an_alias(canon_alias.content["alias"])
  68. ):
  69. return canon_alias.content["alias"]
  70. if not fallback_to_members:
  71. return None
  72. my_member_event = None
  73. if (EventTypes.Member, user_id) in room_state_ids:
  74. my_member_event = await store.get_event(
  75. room_state_ids[(EventTypes.Member, user_id)], allow_none=True
  76. )
  77. if (
  78. my_member_event is not None
  79. and my_member_event.content.get("membership") == Membership.INVITE
  80. ):
  81. if (EventTypes.Member, my_member_event.sender) in room_state_ids:
  82. inviter_member_event = await store.get_event(
  83. room_state_ids[(EventTypes.Member, my_member_event.sender)],
  84. allow_none=True,
  85. )
  86. if inviter_member_event:
  87. if fallback_to_single_member:
  88. return "Invite from %s" % (
  89. name_from_member_event(inviter_member_event),
  90. )
  91. else:
  92. return None
  93. else:
  94. return "Room Invite"
  95. # at this point we're going to need to search the state by all state keys
  96. # for an event type, so rearrange the data structure
  97. room_state_bytype_ids = _state_as_two_level_dict(room_state_ids)
  98. # we're going to have to generate a name based on who's in the room,
  99. # so find out who is in the room that isn't the user.
  100. if EventTypes.Member in room_state_bytype_ids:
  101. member_events = await store.get_events(
  102. list(room_state_bytype_ids[EventTypes.Member].values())
  103. )
  104. all_members = [
  105. ev
  106. for ev in member_events.values()
  107. if ev.content.get("membership") == Membership.JOIN
  108. or ev.content.get("membership") == Membership.INVITE
  109. ]
  110. # Sort the member events oldest-first so the we name people in the
  111. # order the joined (it should at least be deterministic rather than
  112. # dictionary iteration order)
  113. all_members.sort(key=lambda e: e.origin_server_ts)
  114. other_members = [m for m in all_members if m.state_key != user_id]
  115. else:
  116. other_members = []
  117. all_members = []
  118. if len(other_members) == 0:
  119. if len(all_members) == 1:
  120. # self-chat, peeked room with 1 participant,
  121. # or inbound invite, or outbound 3PID invite.
  122. if all_members[0].sender == user_id:
  123. if EventTypes.ThirdPartyInvite in room_state_bytype_ids:
  124. third_party_invites = room_state_bytype_ids[
  125. EventTypes.ThirdPartyInvite
  126. ].values()
  127. if len(third_party_invites) > 0:
  128. # technically third party invite events are not member
  129. # events, but they are close enough
  130. # FIXME: no they're not - they look nothing like a member;
  131. # they have a great big encrypted thing as their name to
  132. # prevent leaking the 3PID name...
  133. # return "Inviting %s" % (
  134. # descriptor_from_member_events(third_party_invites)
  135. # )
  136. return "Inviting email address"
  137. else:
  138. return ALL_ALONE
  139. else:
  140. return name_from_member_event(all_members[0])
  141. else:
  142. return ALL_ALONE
  143. elif len(other_members) == 1 and not fallback_to_single_member:
  144. return None
  145. return descriptor_from_member_events(other_members)
  146. def descriptor_from_member_events(member_events: Iterable[EventBase]) -> str:
  147. """Get a description of the room based on the member events.
  148. Args:
  149. member_events: The events of a room.
  150. Returns:
  151. The room description
  152. """
  153. member_events = list(member_events)
  154. if len(member_events) == 0:
  155. return "nobody"
  156. elif len(member_events) == 1:
  157. return name_from_member_event(member_events[0])
  158. elif len(member_events) == 2:
  159. return "%s and %s" % (
  160. name_from_member_event(member_events[0]),
  161. name_from_member_event(member_events[1]),
  162. )
  163. else:
  164. return "%s and %d others" % (
  165. name_from_member_event(member_events[0]),
  166. len(member_events) - 1,
  167. )
  168. def name_from_member_event(member_event: EventBase) -> str:
  169. if member_event.content and member_event.content.get("displayname"):
  170. return member_event.content["displayname"]
  171. return member_event.state_key
  172. def _state_as_two_level_dict(state: StateMap[str]) -> Dict[str, Dict[str, str]]:
  173. ret: Dict[str, Dict[str, str]] = {}
  174. for k, v in state.items():
  175. ret.setdefault(k[0], {})[k[1]] = v
  176. return ret
  177. def _looks_like_an_alias(string: str) -> bool:
  178. return ALIAS_RE.match(string) is not None