Add avatar and topic settings for server notice room
parent
b0ed14d815
commit
3bcfe96888
|
|
@ -0,0 +1 @@
|
|||
Add a way to set the avatar and the topic of the server notices room.
|
||||
|
|
@ -46,11 +46,13 @@ server_notices:
|
|||
system_mxid_display_name: "Server Notices"
|
||||
system_mxid_avatar_url: "mxc://server.com/oumMVlgDnLYFaPVkExemNVVZ"
|
||||
room_name: "Server Notices"
|
||||
room_avatar_url: "mxc://server.com/oumMVlgDnLYFaPVkExemNVVZ"
|
||||
room_topic: "Room used by your server admin to notice you of important information"
|
||||
```
|
||||
|
||||
The only compulsory setting is `system_mxid_localpart`, which defines the user
|
||||
id of the Server Notices user, as above. `room_name` defines the name of the
|
||||
room which will be created.
|
||||
room which will be created, `room_avatar_url` its avatar and `room_topic` its topic.
|
||||
|
||||
`system_mxid_display_name` and `system_mxid_avatar_url` can be used to set the
|
||||
displayname and avatar of the Server Notices user.
|
||||
|
|
|
|||
|
|
@ -3815,6 +3815,8 @@ Sub-options for this setting include:
|
|||
* `system_mxid_display_name`: set the display name of the "notices" user
|
||||
* `system_mxid_avatar_url`: set the avatar for the "notices" user
|
||||
* `room_name`: set the room name of the server notices room
|
||||
* `room_avatar_url`: set the room avatar URL of the server notices room
|
||||
* `room_topic`: set the room topic of the server notices room
|
||||
|
||||
Example configuration:
|
||||
```yaml
|
||||
|
|
@ -3823,6 +3825,8 @@ server_notices:
|
|||
system_mxid_display_name: "Server Notices"
|
||||
system_mxid_avatar_url: "mxc://server.com/oumMVlgDnLYFaPVkExemNVVZ"
|
||||
room_name: "Server Notices"
|
||||
room_avatar_url: "mxc://server.com/oumMVlgDnLYFaPVkExemNVVZ"
|
||||
room_topic: "Room used by your server admin to notice you of important information"
|
||||
```
|
||||
---
|
||||
### `enable_room_list_search`
|
||||
|
|
|
|||
|
|
@ -38,6 +38,14 @@ class ServerNoticesConfig(Config):
|
|||
server_notices_room_name (str|None):
|
||||
The name to use for the server notices room.
|
||||
None if server notices are not enabled.
|
||||
|
||||
server_notices_room_avatar_url (str|None):
|
||||
The avatar URL to use for the server notices room.
|
||||
None if server notices are not enabled.
|
||||
|
||||
server_notices_room_topic (str|None):
|
||||
The topic to use for the server notices room.
|
||||
None if server notices are not enabled.
|
||||
"""
|
||||
|
||||
section = "servernotices"
|
||||
|
|
@ -48,6 +56,8 @@ class ServerNoticesConfig(Config):
|
|||
self.server_notices_mxid_display_name: Optional[str] = None
|
||||
self.server_notices_mxid_avatar_url: Optional[str] = None
|
||||
self.server_notices_room_name: Optional[str] = None
|
||||
self.server_notices_room_avatar_url: Optional[str] = None
|
||||
self.server_notices_room_topic: Optional[str] = None
|
||||
|
||||
def read_config(self, config: JsonDict, **kwargs: Any) -> None:
|
||||
c = config.get("server_notices")
|
||||
|
|
@ -62,3 +72,5 @@ class ServerNoticesConfig(Config):
|
|||
self.server_notices_mxid_avatar_url = c.get("system_mxid_avatar_url", None)
|
||||
# todo: i18n
|
||||
self.server_notices_room_name = c.get("room_name", "Server Notices")
|
||||
self.server_notices_room_avatar_url = c.get("room_avatar_url", None)
|
||||
self.server_notices_room_topic = c.get("room_topic", None)
|
||||
|
|
|
|||
|
|
@ -160,6 +160,27 @@ class ServerNoticesManager:
|
|||
self._config.servernotices.server_notices_mxid_display_name,
|
||||
self._config.servernotices.server_notices_mxid_avatar_url,
|
||||
)
|
||||
await self._update_room_info(
|
||||
requester,
|
||||
room_id,
|
||||
EventTypes.Name,
|
||||
"name",
|
||||
self._config.servernotices.server_notices_room_name,
|
||||
)
|
||||
await self._update_room_info(
|
||||
requester,
|
||||
room_id,
|
||||
EventTypes.RoomAvatar,
|
||||
"url",
|
||||
self._config.servernotices.server_notices_room_avatar_url,
|
||||
)
|
||||
await self._update_room_info(
|
||||
requester,
|
||||
room_id,
|
||||
EventTypes.Topic,
|
||||
"topic",
|
||||
self._config.servernotices.server_notices_room_topic,
|
||||
)
|
||||
return room_id
|
||||
|
||||
# apparently no existing notice room: create a new one
|
||||
|
|
@ -178,20 +199,36 @@ class ServerNoticesManager:
|
|||
"avatar_url": self._config.servernotices.server_notices_mxid_avatar_url,
|
||||
}
|
||||
|
||||
# `ignore_forced_encryption` is used to bypass `encryption_enabled_by_default_for_room_type`
|
||||
# setting if it set, since the server notices will not be encrypted anyway.
|
||||
room_config = {
|
||||
"preset": RoomCreationPreset.PRIVATE_CHAT,
|
||||
"power_level_content_override": {"users_default": -10},
|
||||
}
|
||||
|
||||
if self._config.servernotices.server_notices_room_name:
|
||||
room_config["name"] = self._config.servernotices.server_notices_room_name
|
||||
if self._config.servernotices.server_notices_room_topic:
|
||||
room_config["topic"] = self._config.servernotices.server_notices_room_topic
|
||||
|
||||
room_id, _, _ = await self._room_creation_handler.create_room(
|
||||
requester,
|
||||
config={
|
||||
"preset": RoomCreationPreset.PRIVATE_CHAT,
|
||||
"name": self._config.servernotices.server_notices_room_name,
|
||||
"power_level_content_override": {"users_default": -10},
|
||||
},
|
||||
config=room_config,
|
||||
ratelimit=False,
|
||||
creator_join_profile=join_profile,
|
||||
ignore_forced_encryption=True,
|
||||
)
|
||||
|
||||
# Room avatar can't be set at creation time so let's just send an event for that
|
||||
if self._config.servernotices.server_notices_room_avatar_url:
|
||||
await self._update_room_info(
|
||||
requester,
|
||||
room_id,
|
||||
EventTypes.RoomAvatar,
|
||||
"url",
|
||||
self._config.servernotices.server_notices_room_avatar_url,
|
||||
# Since we just created the room there is no need to check current value
|
||||
if_changed=False,
|
||||
)
|
||||
|
||||
self.maybe_get_notice_room_for_user.invalidate((user_id,))
|
||||
|
||||
max_id = await self._account_data_handler.add_tag_to_room(
|
||||
|
|
@ -275,3 +312,51 @@ class ServerNoticesManager:
|
|||
ratelimit=False,
|
||||
content={"displayname": display_name, "avatar_url": avatar_url},
|
||||
)
|
||||
|
||||
async def _update_room_info(
|
||||
self,
|
||||
requester: Requester,
|
||||
room_id: str,
|
||||
info_event_type: str,
|
||||
info_content_key: str,
|
||||
info_value: Optional[str],
|
||||
if_changed: Optional[bool] = True,
|
||||
) -> None:
|
||||
"""
|
||||
Updates a specific notice room's info if it's different from what is set.
|
||||
|
||||
Args:
|
||||
requester: The user who is performing the update.
|
||||
room_id: The ID of the server notice room
|
||||
info_event_type: The event type holding the specific info
|
||||
info_content_key: The key containing the specific info in the event's content
|
||||
info_value: The expected value for the specific info
|
||||
if_changed: Try to read the info first and does not send the event if it's already the same
|
||||
"""
|
||||
if if_changed:
|
||||
room_info_event = await self._message_handler.get_room_data(
|
||||
requester,
|
||||
room_id,
|
||||
info_event_type,
|
||||
"",
|
||||
)
|
||||
|
||||
if room_info_event and room_info_event.get(info_content_key) == info_value:
|
||||
return
|
||||
|
||||
if info_value is None:
|
||||
info_value = ""
|
||||
|
||||
room_info_event_dict = {
|
||||
"type": info_event_type,
|
||||
"room_id": room_id,
|
||||
"sender": requester.user.to_string(),
|
||||
"state_key": "",
|
||||
"content": {
|
||||
info_content_key: info_value,
|
||||
},
|
||||
}
|
||||
|
||||
event, _ = await self._event_creation_handler.create_and_send_nonmember_event(
|
||||
requester, room_info_event_dict, ratelimit=False
|
||||
)
|
||||
|
|
|
|||
|
|
@ -569,6 +569,115 @@ class ServerNoticeTestCase(unittest.HomeserverTestCase):
|
|||
)
|
||||
self.assertEqual(notice_user_state["avatar_url"], new_avatar_url)
|
||||
|
||||
@override_config(
|
||||
{
|
||||
"server_notices": {
|
||||
"system_mxid_localpart": "notices",
|
||||
"room_avatar_url": "test/url",
|
||||
"room_topic": "Test Topic",
|
||||
}
|
||||
}
|
||||
)
|
||||
def test_notice_room_avatar_and_topic(self) -> None:
|
||||
"""
|
||||
Tests that using `room_avatar_url` and `room_topic` config properly sets
|
||||
those properties for the created notice rooms.
|
||||
"""
|
||||
server_notice_request_content = {
|
||||
"user_id": self.other_user,
|
||||
"content": {"msgtype": "m.text", "body": "test msg one"},
|
||||
}
|
||||
|
||||
self.make_request(
|
||||
"POST",
|
||||
self.url,
|
||||
access_token=self.admin_user_tok,
|
||||
content=server_notice_request_content,
|
||||
)
|
||||
|
||||
invited_rooms = self._check_invite_and_join_status(self.other_user, 1, 0)
|
||||
notice_room_id = invited_rooms[0].room_id
|
||||
self.helper.join(
|
||||
room=notice_room_id, user=self.other_user, tok=self.other_user_token
|
||||
)
|
||||
|
||||
room_avatar_state = self.helper.get_state(
|
||||
notice_room_id,
|
||||
"m.room.avatar",
|
||||
self.other_user_token,
|
||||
state_key="",
|
||||
)
|
||||
self.assertEqual(room_avatar_state["url"], "test/url")
|
||||
|
||||
room_topic_state = self.helper.get_state(
|
||||
notice_room_id,
|
||||
"m.room.topic",
|
||||
self.other_user_token,
|
||||
state_key="",
|
||||
)
|
||||
self.assertEqual(room_topic_state["topic"], "Test Topic")
|
||||
|
||||
@override_config(
|
||||
{
|
||||
"server_notices": {
|
||||
"system_mxid_localpart": "notices",
|
||||
"room_avatar_url": "test/url",
|
||||
}
|
||||
}
|
||||
)
|
||||
def test_update_room_avatar_when_changed(self) -> None:
|
||||
"""
|
||||
Tests that existing server notices room avatar is updated when it is
|
||||
different from the one in homeserver config.
|
||||
"""
|
||||
server_notice_request_content = {
|
||||
"user_id": self.other_user,
|
||||
"content": {"msgtype": "m.text", "body": "test msg one"},
|
||||
}
|
||||
|
||||
self.make_request(
|
||||
"POST",
|
||||
self.url,
|
||||
access_token=self.admin_user_tok,
|
||||
content=server_notice_request_content,
|
||||
)
|
||||
|
||||
invited_rooms = self._check_invite_and_join_status(self.other_user, 1, 0)
|
||||
notice_room_id = invited_rooms[0].room_id
|
||||
self.helper.join(
|
||||
room=notice_room_id, user=self.other_user, tok=self.other_user_token
|
||||
)
|
||||
|
||||
room_avatar_state = self.helper.get_state(
|
||||
notice_room_id,
|
||||
"m.room.avatar",
|
||||
self.other_user_token,
|
||||
state_key="",
|
||||
)
|
||||
self.assertEqual(room_avatar_state["url"], "test/url")
|
||||
|
||||
# simulate a change in server config after a server restart.
|
||||
new_avatar_url = "test/new-url"
|
||||
self.server_notices_manager._config.servernotices.server_notices_room_avatar_url = (
|
||||
new_avatar_url
|
||||
)
|
||||
self.server_notices_manager.get_or_create_notice_room_for_user.cache.invalidate_all()
|
||||
|
||||
self.make_request(
|
||||
"POST",
|
||||
self.url,
|
||||
access_token=self.admin_user_tok,
|
||||
content=server_notice_request_content,
|
||||
)
|
||||
|
||||
room_avatar_state = self.helper.get_state(
|
||||
notice_room_id,
|
||||
"m.room.avatar",
|
||||
self.other_user_token,
|
||||
state_key="",
|
||||
)
|
||||
self.assertEqual(room_avatar_state["url"], new_avatar_url)
|
||||
|
||||
def _check_invite_and_join_status(
|
||||
self, user_id: str, expected_invites: int, expected_memberships: int
|
||||
) -> Sequence[RoomsForUser]:
|
||||
|
|
|
|||
Loading…
Reference in New Issue