Purge History¶
Edpoints¶
PurgeHistory¶
The purge history API allows server admins to purge historic events from their database, reclaiming disk space.
Depending on the amount of history being purged a call to the API may take several minutes or longer. During this period users will not be able to paginate further back in the room from the point being purged from.
Source code in matrix_admin_sdk/endpoints/v1/purge_history.py
class PurgeHistory(Endpoint):
"""
The purge history API allows server admins to purge historic events from
their database, reclaiming disk space.
Depending on the amount of history being purged a call to the API may take
several minutes or longer. During this period users will not be able to paginate
further back in the room from the point being purged from.
"""
async def purge_room_history(
self,
room_id: str,
event_id: str,
delete_local_events: bool = False,
purge_up_to_event_id: Optional[str] = None,
purge_up_to_ts: Optional[int] = None,
) -> Dict[str, str]:
"""
By default, events sent by local users are not deleted, as they may
represent the only copies of this content in existence. (Events sent by
remote users are deleted.)
Room state data (such as joins, leaves, topic) is always preserved.
To delete local message events as well, set delete_local_events in the body
The caller must specify the point in the room to purge up to. This can be
specified by including an event_id in the URI, or by setting
a purge_up_to_event_id or purge_up_to_ts in the request body.
If an event id is given, that event (and others at the same graph depth)
will be retained. If purge_up_to_ts is given, it should be a timestamp since
the unix epoch, in milliseconds.
The API starts the purge running, and returns immediately with a
JSON body with a purge id
Args:
room_id: room id to purge history for
event_id: event id
delete_local_events: To delete local message events, Default: False
purge_up_to_event_id
purge_up_to_ts
Returns: {"purge_id": "<opaque id>"}
"""
url = self.url(f"purge_history/{room_id}/{event_id}")
data: Dict[str, Any] = {
"delete_local_events": delete_local_events,
}
if purge_up_to_event_id is not None:
data["purge_up_to_event_id"] = purge_up_to_event_id
if purge_up_to_ts is not None:
data["purge_up_to_ts"] = purge_up_to_ts
result = await self.request(RequestMethods.POST, url, json=data)
return result
async def purge_status_query(self, purge_id: str) -> Dict[str, str]:
"""
It is possible to poll for updates on recent purges
Args:
purge_id:
Returns: {"status": "active"}. The status will be one of active,
complete, or failed. If status is failed there will be a string
error with the error message.
"""
url = self.url(f"purge_history_status/{purge_id}")
result = await self.request(RequestMethods.GET, url)
return result
purge_room_history(self, room_id, event_id, delete_local_events=False, purge_up_to_event_id=None, purge_up_to_ts=None)
async
¶
By default, events sent by local users are not deleted, as they may represent the only copies of this content in existence. (Events sent by remote users are deleted.)
Room state data (such as joins, leaves, topic) is always preserved.
To delete local message events as well, set delete_local_events in the body
The caller must specify the point in the room to purge up to. This can be specified by including an event_id in the URI, or by setting a purge_up_to_event_id or purge_up_to_ts in the request body. If an event id is given, that event (and others at the same graph depth) will be retained. If purge_up_to_ts is given, it should be a timestamp since the unix epoch, in milliseconds.
The API starts the purge running, and returns immediately with a JSON body with a purge id
Parameters:
| Name | Type | Description | Default |
|---|---|---|---|
room_id |
str |
room id to purge history for |
required |
event_id |
str |
event id |
required |
delete_local_events |
bool |
To delete local message events, Default: False |
False |
Source code in matrix_admin_sdk/endpoints/v1/purge_history.py
async def purge_room_history(
self,
room_id: str,
event_id: str,
delete_local_events: bool = False,
purge_up_to_event_id: Optional[str] = None,
purge_up_to_ts: Optional[int] = None,
) -> Dict[str, str]:
"""
By default, events sent by local users are not deleted, as they may
represent the only copies of this content in existence. (Events sent by
remote users are deleted.)
Room state data (such as joins, leaves, topic) is always preserved.
To delete local message events as well, set delete_local_events in the body
The caller must specify the point in the room to purge up to. This can be
specified by including an event_id in the URI, or by setting
a purge_up_to_event_id or purge_up_to_ts in the request body.
If an event id is given, that event (and others at the same graph depth)
will be retained. If purge_up_to_ts is given, it should be a timestamp since
the unix epoch, in milliseconds.
The API starts the purge running, and returns immediately with a
JSON body with a purge id
Args:
room_id: room id to purge history for
event_id: event id
delete_local_events: To delete local message events, Default: False
purge_up_to_event_id
purge_up_to_ts
Returns: {"purge_id": "<opaque id>"}
"""
url = self.url(f"purge_history/{room_id}/{event_id}")
data: Dict[str, Any] = {
"delete_local_events": delete_local_events,
}
if purge_up_to_event_id is not None:
data["purge_up_to_event_id"] = purge_up_to_event_id
if purge_up_to_ts is not None:
data["purge_up_to_ts"] = purge_up_to_ts
result = await self.request(RequestMethods.POST, url, json=data)
return result
purge_status_query(self, purge_id)
async
¶
It is possible to poll for updates on recent purges
Parameters:
| Name | Type | Description | Default |
|---|---|---|---|
purge_id |
str |
required |
{"status": "active"}. The status will be one of active,
complete, or failed. If status is failed there will be a string error with the error message.
Source code in matrix_admin_sdk/endpoints/v1/purge_history.py
async def purge_status_query(self, purge_id: str) -> Dict[str, str]:
"""
It is possible to poll for updates on recent purges
Args:
purge_id:
Returns: {"status": "active"}. The status will be one of active,
complete, or failed. If status is failed there will be a string
error with the error message.
"""
url = self.url(f"purge_history_status/{purge_id}")
result = await self.request(RequestMethods.GET, url)
return result