2014-09-29 13:59:52 +00:00
|
|
|
# -*- coding: utf-8 -*-
|
2016-01-07 04:26:29 +00:00
|
|
|
# Copyright 2014-2016 OpenMarket Ltd
|
2019-05-01 14:32:38 +00:00
|
|
|
# Copyright 2018-2019 New Vector Ltd
|
2021-01-11 21:43:58 +00:00
|
|
|
# Copyright 2020, 2021 The Matrix.org Foundation C.I.C.
|
|
|
|
|
2014-09-29 13:59:52 +00:00
|
|
|
#
|
|
|
|
# Licensed under the Apache License, Version 2.0 (the "License");
|
|
|
|
# you may not use this file except in compliance with the License.
|
|
|
|
# You may obtain a copy of the License at
|
|
|
|
#
|
|
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
#
|
|
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
|
|
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
|
|
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
|
|
# See the License for the specific language governing permissions and
|
|
|
|
# limitations under the License.
|
|
|
|
|
2018-07-09 06:09:20 +00:00
|
|
|
import logging
|
2019-03-01 03:05:47 +00:00
|
|
|
import platform
|
2014-09-29 13:59:52 +00:00
|
|
|
|
2019-03-01 03:05:47 +00:00
|
|
|
import synapse
|
2019-08-13 11:49:28 +00:00
|
|
|
from synapse.api.errors import Codes, NotFoundError, SynapseError
|
2019-05-01 14:18:58 +00:00
|
|
|
from synapse.http.server import JsonResource
|
2019-11-20 11:49:11 +00:00
|
|
|
from synapse.http.servlet import RestServlet, parse_json_object_from_request
|
2020-11-25 21:26:11 +00:00
|
|
|
from synapse.rest.admin._base import admin_patterns, assert_requester_is_admin
|
2020-06-05 12:07:22 +00:00
|
|
|
from synapse.rest.admin.devices import (
|
|
|
|
DeleteDevicesRestServlet,
|
|
|
|
DeviceRestServlet,
|
|
|
|
DevicesRestServlet,
|
|
|
|
)
|
2020-10-26 18:16:37 +00:00
|
|
|
from synapse.rest.admin.event_reports import (
|
|
|
|
EventReportDetailRestServlet,
|
|
|
|
EventReportsRestServlet,
|
|
|
|
)
|
2019-11-20 11:49:11 +00:00
|
|
|
from synapse.rest.admin.groups import DeleteGroupAdminRestServlet
|
2019-09-03 19:35:20 +00:00
|
|
|
from synapse.rest.admin.media import ListMediaInRoom, register_servlets_for_media_repo
|
2019-08-22 09:42:59 +00:00
|
|
|
from synapse.rest.admin.purge_room_servlet import PurgeRoomServlet
|
2020-03-27 19:16:43 +00:00
|
|
|
from synapse.rest.admin.rooms import (
|
2020-07-14 11:36:23 +00:00
|
|
|
DeleteRoomRestServlet,
|
2021-01-07 21:01:59 +00:00
|
|
|
ForwardExtremitiesRestServlet,
|
2020-03-27 19:16:43 +00:00
|
|
|
JoinRoomAliasServlet,
|
|
|
|
ListRoomRestServlet,
|
2020-12-18 15:37:19 +00:00
|
|
|
MakeRoomAdminRestServlet,
|
2021-01-18 14:02:22 +00:00
|
|
|
RoomEventContextServlet,
|
2020-07-16 20:43:23 +00:00
|
|
|
RoomMembersRestServlet,
|
2020-05-07 19:33:07 +00:00
|
|
|
RoomRestServlet,
|
2020-03-27 19:16:43 +00:00
|
|
|
ShutdownRoomRestServlet,
|
|
|
|
)
|
2019-05-02 10:59:16 +00:00
|
|
|
from synapse.rest.admin.server_notice_servlet import SendServerNoticeServlet
|
2020-11-05 18:59:12 +00:00
|
|
|
from synapse.rest.admin.statistics import UserMediaStatisticsRestServlet
|
2019-11-20 11:49:11 +00:00
|
|
|
from synapse.rest.admin.users import (
|
|
|
|
AccountValidityRenewServlet,
|
|
|
|
DeactivateAccountRestServlet,
|
2020-10-28 15:02:42 +00:00
|
|
|
PushersRestServlet,
|
2019-11-20 11:49:11 +00:00
|
|
|
ResetPasswordRestServlet,
|
|
|
|
SearchUsersRestServlet,
|
2021-01-25 19:49:39 +00:00
|
|
|
ShadowBanRestServlet,
|
2019-11-20 11:49:11 +00:00
|
|
|
UserAdminServlet,
|
2020-10-27 14:12:31 +00:00
|
|
|
UserMediaRestServlet,
|
2020-09-18 14:26:36 +00:00
|
|
|
UserMembershipRestServlet,
|
2019-11-20 11:49:11 +00:00
|
|
|
UserRegisterServlet,
|
2020-01-09 13:31:00 +00:00
|
|
|
UserRestServletV2,
|
2019-11-20 11:49:11 +00:00
|
|
|
UsersRestServlet,
|
2019-12-05 18:12:23 +00:00
|
|
|
UsersRestServletV2,
|
2020-11-17 10:51:25 +00:00
|
|
|
UserTokenRestServlet,
|
2019-11-20 11:49:11 +00:00
|
|
|
WhoisRestServlet,
|
|
|
|
)
|
2020-10-05 13:43:14 +00:00
|
|
|
from synapse.types import RoomStreamToken
|
2019-03-01 03:05:47 +00:00
|
|
|
from synapse.util.versionstring import get_version_string
|
2015-01-23 11:47:15 +00:00
|
|
|
|
2014-09-29 13:59:52 +00:00
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
|
|
|
2019-05-01 09:40:33 +00:00
|
|
|
class VersionServlet(RestServlet):
|
2020-09-17 11:04:15 +00:00
|
|
|
PATTERNS = admin_patterns("/server_version$")
|
2019-03-01 03:05:47 +00:00
|
|
|
|
2019-05-01 09:40:33 +00:00
|
|
|
def __init__(self, hs):
|
2019-05-07 08:29:30 +00:00
|
|
|
self.res = {
|
2019-06-20 09:32:02 +00:00
|
|
|
"server_version": get_version_string(synapse),
|
|
|
|
"python_version": platform.python_version(),
|
2019-03-01 03:05:47 +00:00
|
|
|
}
|
|
|
|
|
2019-05-07 08:29:30 +00:00
|
|
|
def on_GET(self, request):
|
|
|
|
return 200, self.res
|
2019-03-01 03:05:47 +00:00
|
|
|
|
|
|
|
|
2019-05-01 09:40:33 +00:00
|
|
|
class PurgeHistoryRestServlet(RestServlet):
|
2020-11-25 21:26:11 +00:00
|
|
|
PATTERNS = admin_patterns(
|
2019-05-01 14:18:58 +00:00
|
|
|
"/purge_history/(?P<room_id>[^/]*)(/(?P<event_id>[^/]+))?"
|
2016-07-05 09:28:51 +00:00
|
|
|
)
|
|
|
|
|
2016-08-12 09:03:19 +00:00
|
|
|
def __init__(self, hs):
|
2018-03-01 23:20:54 +00:00
|
|
|
"""
|
|
|
|
|
|
|
|
Args:
|
|
|
|
hs (synapse.server.HomeServer)
|
|
|
|
"""
|
2018-07-18 14:22:02 +00:00
|
|
|
self.pagination_handler = hs.get_pagination_handler()
|
2018-03-01 23:20:54 +00:00
|
|
|
self.store = hs.get_datastore()
|
2019-05-01 09:40:33 +00:00
|
|
|
self.auth = hs.get_auth()
|
2016-08-12 09:03:19 +00:00
|
|
|
|
2019-10-11 11:05:27 +00:00
|
|
|
async def on_POST(self, request, room_id, event_id):
|
|
|
|
await assert_requester_is_admin(self.auth, request)
|
2016-07-05 09:28:51 +00:00
|
|
|
|
2018-02-08 18:44:52 +00:00
|
|
|
body = parse_json_object_from_request(request, allow_empty_body=True)
|
|
|
|
|
2018-02-13 13:04:41 +00:00
|
|
|
delete_local_events = bool(body.get("delete_local_events", False))
|
2018-02-08 18:44:52 +00:00
|
|
|
|
2018-03-01 23:20:54 +00:00
|
|
|
# establish the topological ordering we should keep events from. The
|
|
|
|
# user can provide an event_id in the URL or the request body, or can
|
|
|
|
# provide a timestamp in the request body.
|
|
|
|
if event_id is None:
|
2019-06-20 09:32:02 +00:00
|
|
|
event_id = body.get("purge_up_to_event_id")
|
2018-03-01 23:20:54 +00:00
|
|
|
|
|
|
|
if event_id is not None:
|
2019-10-11 11:05:27 +00:00
|
|
|
event = await self.store.get_event(event_id)
|
2018-03-01 23:20:54 +00:00
|
|
|
|
|
|
|
if event.room_id != room_id:
|
|
|
|
raise SynapseError(400, "Event is for wrong room.")
|
|
|
|
|
2020-10-05 13:43:14 +00:00
|
|
|
room_token = RoomStreamToken(
|
|
|
|
event.depth, event.internal_metadata.stream_ordering
|
|
|
|
)
|
2020-09-30 19:29:19 +00:00
|
|
|
token = await room_token.to_string(self.store)
|
2018-05-15 15:06:30 +00:00
|
|
|
|
2019-06-20 09:32:02 +00:00
|
|
|
logger.info("[purge] purging up to token %s (event_id %s)", token, event_id)
|
|
|
|
elif "purge_up_to_ts" in body:
|
|
|
|
ts = body["purge_up_to_ts"]
|
2018-03-01 23:20:54 +00:00
|
|
|
if not isinstance(ts, int):
|
|
|
|
raise SynapseError(
|
2019-06-20 09:32:02 +00:00
|
|
|
400, "purge_up_to_ts must be an int", errcode=Codes.BAD_JSON
|
2018-03-01 23:20:54 +00:00
|
|
|
)
|
|
|
|
|
2019-10-11 11:05:27 +00:00
|
|
|
stream_ordering = await self.store.find_first_stream_ordering_after_ts(ts)
|
2018-03-01 23:20:54 +00:00
|
|
|
|
2020-01-16 20:24:17 +00:00
|
|
|
r = await self.store.get_room_event_before_stream_ordering(
|
2019-10-11 11:05:27 +00:00
|
|
|
room_id, stream_ordering
|
2018-03-01 23:20:54 +00:00
|
|
|
)
|
2018-06-06 23:15:49 +00:00
|
|
|
if not r:
|
2019-10-31 10:23:24 +00:00
|
|
|
logger.warning(
|
2018-04-30 12:29:48 +00:00
|
|
|
"[purge] purging events not possible: No event found "
|
|
|
|
"(received_ts %i => stream_ordering %i)",
|
2019-06-20 09:32:02 +00:00
|
|
|
ts,
|
|
|
|
stream_ordering,
|
2018-04-30 12:29:48 +00:00
|
|
|
)
|
|
|
|
raise SynapseError(
|
2019-06-20 09:32:02 +00:00
|
|
|
404, "there is no event to be purged", errcode=Codes.NOT_FOUND
|
2018-04-30 12:29:48 +00:00
|
|
|
)
|
2018-06-06 23:15:49 +00:00
|
|
|
(stream, topo, _event_id) = r
|
|
|
|
token = "t%d-%d" % (topo, stream)
|
2018-03-01 23:20:54 +00:00
|
|
|
logger.info(
|
2018-06-06 23:26:38 +00:00
|
|
|
"[purge] purging up to token %s (received_ts %i => "
|
2018-03-01 23:20:54 +00:00
|
|
|
"stream_ordering %i)",
|
2019-06-20 09:32:02 +00:00
|
|
|
token,
|
|
|
|
ts,
|
|
|
|
stream_ordering,
|
2018-03-01 23:20:54 +00:00
|
|
|
)
|
|
|
|
else:
|
|
|
|
raise SynapseError(
|
|
|
|
400,
|
|
|
|
"must specify purge_up_to_event_id or purge_up_to_ts",
|
|
|
|
errcode=Codes.BAD_JSON,
|
|
|
|
)
|
|
|
|
|
2019-10-11 14:26:09 +00:00
|
|
|
purge_id = self.pagination_handler.start_purge_history(
|
2019-06-20 09:32:02 +00:00
|
|
|
room_id, token, delete_local_events=delete_local_events
|
2018-02-08 18:44:52 +00:00
|
|
|
)
|
2016-07-05 09:28:51 +00:00
|
|
|
|
2019-08-30 15:28:26 +00:00
|
|
|
return 200, {"purge_id": purge_id}
|
2018-03-08 11:47:28 +00:00
|
|
|
|
|
|
|
|
2019-05-01 09:40:33 +00:00
|
|
|
class PurgeHistoryStatusRestServlet(RestServlet):
|
2020-11-25 21:26:11 +00:00
|
|
|
PATTERNS = admin_patterns("/purge_history_status/(?P<purge_id>[^/]+)")
|
2018-03-08 11:47:28 +00:00
|
|
|
|
|
|
|
def __init__(self, hs):
|
|
|
|
"""
|
|
|
|
|
|
|
|
Args:
|
|
|
|
hs (synapse.server.HomeServer)
|
|
|
|
"""
|
2018-07-18 14:22:02 +00:00
|
|
|
self.pagination_handler = hs.get_pagination_handler()
|
2019-05-01 09:40:33 +00:00
|
|
|
self.auth = hs.get_auth()
|
2018-03-08 11:47:28 +00:00
|
|
|
|
2019-10-11 11:05:27 +00:00
|
|
|
async def on_GET(self, request, purge_id):
|
|
|
|
await assert_requester_is_admin(self.auth, request)
|
2018-03-08 11:47:28 +00:00
|
|
|
|
2018-07-18 14:22:02 +00:00
|
|
|
purge_status = self.pagination_handler.get_purge_status(purge_id)
|
2018-03-08 11:47:28 +00:00
|
|
|
if purge_status is None:
|
|
|
|
raise NotFoundError("purge id '%s' not found" % purge_id)
|
|
|
|
|
2019-08-30 15:28:26 +00:00
|
|
|
return 200, purge_status.asdict()
|
2016-07-05 09:28:51 +00:00
|
|
|
|
|
|
|
|
2019-05-02 10:59:16 +00:00
|
|
|
########################################################################################
|
|
|
|
#
|
|
|
|
# please don't add more servlets here: this file is already long and unwieldy. Put
|
|
|
|
# them in separate files within the 'admin' package.
|
|
|
|
#
|
|
|
|
########################################################################################
|
|
|
|
|
2019-04-16 19:13:59 +00:00
|
|
|
|
2019-05-01 14:18:58 +00:00
|
|
|
class AdminRestResource(JsonResource):
|
|
|
|
"""The REST resource which gets mounted at /_synapse/admin"""
|
|
|
|
|
|
|
|
def __init__(self, hs):
|
|
|
|
JsonResource.__init__(self, hs, canonical_json=False)
|
2019-05-29 15:47:16 +00:00
|
|
|
register_servlets(hs, self)
|
2019-05-02 10:59:16 +00:00
|
|
|
|
2019-05-29 15:47:16 +00:00
|
|
|
|
|
|
|
def register_servlets(hs, http_server):
|
|
|
|
"""
|
|
|
|
Register all the admin servlets.
|
|
|
|
"""
|
|
|
|
register_servlets_for_client_rest_resource(hs, http_server)
|
2020-01-22 13:36:43 +00:00
|
|
|
ListRoomRestServlet(hs).register(http_server)
|
2020-05-07 19:33:07 +00:00
|
|
|
RoomRestServlet(hs).register(http_server)
|
2020-07-16 20:43:23 +00:00
|
|
|
RoomMembersRestServlet(hs).register(http_server)
|
2020-07-14 11:36:23 +00:00
|
|
|
DeleteRoomRestServlet(hs).register(http_server)
|
2020-03-27 19:16:43 +00:00
|
|
|
JoinRoomAliasServlet(hs).register(http_server)
|
2019-08-22 09:42:59 +00:00
|
|
|
PurgeRoomServlet(hs).register(http_server)
|
2019-05-29 15:47:16 +00:00
|
|
|
SendServerNoticeServlet(hs).register(http_server)
|
|
|
|
VersionServlet(hs).register(http_server)
|
2019-08-27 09:14:00 +00:00
|
|
|
UserAdminServlet(hs).register(http_server)
|
2020-10-27 14:12:31 +00:00
|
|
|
UserMediaRestServlet(hs).register(http_server)
|
2020-09-18 14:26:36 +00:00
|
|
|
UserMembershipRestServlet(hs).register(http_server)
|
2020-11-17 10:51:25 +00:00
|
|
|
UserTokenRestServlet(hs).register(http_server)
|
2020-01-09 13:31:00 +00:00
|
|
|
UserRestServletV2(hs).register(http_server)
|
2019-12-05 18:12:23 +00:00
|
|
|
UsersRestServletV2(hs).register(http_server)
|
2020-06-05 12:07:22 +00:00
|
|
|
DeviceRestServlet(hs).register(http_server)
|
|
|
|
DevicesRestServlet(hs).register(http_server)
|
|
|
|
DeleteDevicesRestServlet(hs).register(http_server)
|
2020-11-05 18:59:12 +00:00
|
|
|
UserMediaStatisticsRestServlet(hs).register(http_server)
|
2020-10-26 18:16:37 +00:00
|
|
|
EventReportDetailRestServlet(hs).register(http_server)
|
2020-10-28 15:02:42 +00:00
|
|
|
EventReportsRestServlet(hs).register(http_server)
|
|
|
|
PushersRestServlet(hs).register(http_server)
|
2020-12-18 15:37:19 +00:00
|
|
|
MakeRoomAdminRestServlet(hs).register(http_server)
|
2021-01-25 19:49:39 +00:00
|
|
|
ShadowBanRestServlet(hs).register(http_server)
|
2021-01-07 21:01:59 +00:00
|
|
|
ForwardExtremitiesRestServlet(hs).register(http_server)
|
2021-01-18 14:02:22 +00:00
|
|
|
RoomEventContextServlet(hs).register(http_server)
|
2019-05-01 14:18:58 +00:00
|
|
|
|
|
|
|
|
2019-05-02 10:59:16 +00:00
|
|
|
def register_servlets_for_client_rest_resource(hs, http_server):
|
|
|
|
"""Register only the servlets which need to be exposed on /_matrix/client/xxx"""
|
2014-09-29 13:59:52 +00:00
|
|
|
WhoisRestServlet(hs).register(http_server)
|
2018-03-08 11:47:28 +00:00
|
|
|
PurgeHistoryStatusRestServlet(hs).register(http_server)
|
2016-06-30 14:40:58 +00:00
|
|
|
DeactivateAccountRestServlet(hs).register(http_server)
|
2016-07-06 14:56:59 +00:00
|
|
|
PurgeHistoryRestServlet(hs).register(http_server)
|
2017-02-02 13:02:26 +00:00
|
|
|
UsersRestServlet(hs).register(http_server)
|
|
|
|
ResetPasswordRestServlet(hs).register(http_server)
|
|
|
|
SearchUsersRestServlet(hs).register(http_server)
|
2017-06-19 11:36:28 +00:00
|
|
|
ShutdownRoomRestServlet(hs).register(http_server)
|
2018-07-20 12:41:13 +00:00
|
|
|
UserRegisterServlet(hs).register(http_server)
|
2019-04-03 15:07:34 +00:00
|
|
|
DeleteGroupAdminRestServlet(hs).register(http_server)
|
2019-04-16 19:13:59 +00:00
|
|
|
AccountValidityRenewServlet(hs).register(http_server)
|
2019-08-13 11:49:28 +00:00
|
|
|
|
2019-09-03 19:35:20 +00:00
|
|
|
# Load the media repo ones if we're using them. Otherwise load the servlets which
|
|
|
|
# don't need a media repo (typically readonly admin APIs).
|
2019-08-13 11:49:28 +00:00
|
|
|
if hs.config.can_load_media_repo:
|
|
|
|
register_servlets_for_media_repo(hs, http_server)
|
2019-09-03 19:35:20 +00:00
|
|
|
else:
|
|
|
|
ListMediaInRoom(hs).register(http_server)
|
2019-08-13 11:49:28 +00:00
|
|
|
|
2019-05-02 10:59:16 +00:00
|
|
|
# don't add more things here: new servlets should only be exposed on
|
|
|
|
# /_synapse/admin so should not go here. Instead register them in AdminRestResource.
|