Matrix-Mirrors/anonymousland-synapse
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse.git synced 2025-08-08 07:52:15 -04:00
Code Issues Projects Releases Packages Wiki Activity

Remove groups replication code. (#12900)

Browse source 
The replication logic for groups is no longer used, so the message
passing infrastructure can be removed.
This commit is contained in:
Patrick Cloke 2022-05-31 13:04:08 -04:00 • committed by GitHub
parent 2fc787c341
commit cf05258f76
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
7 changed files with 1 additions and 90 deletions
Download patch file Download diff file Expand all files Collapse all files

3
synapse/replication/tcp/streams/__init__.py
View file

@ -29,7 +29,6 @@ from synapse.replication.tcp.streams._base import (
BackfillStream,
CachesStream,
DeviceListsStream,
GroupServerStream,
PresenceFederationStream,
PresenceStream,
PushersStream,
@ -61,7 +60,6 @@ STREAMS_MAP = {
FederationStream,
TagAccountDataStream,
AccountDataStream,
GroupServerStream,
UserSignatureStream,
)
}
@ -81,6 +79,5 @@ __all__ = [
"ToDeviceStream",
"TagAccountDataStream",
"AccountDataStream",
"GroupServerStream",
"UserSignatureStream",
]

20
synapse/replication/tcp/streams/_base.py
View file

@ -585,26 +585,6 @@ class AccountDataStream(Stream):
return updates, to_token, limited
class GroupServerStream(Stream):
@attr.s(slots=True, frozen=True, auto_attribs=True)
class GroupsStreamRow:
group_id: str
user_id: str
type: str
content: JsonDict
NAME = "groups"
ROW_TYPE = GroupsStreamRow
def __init__(self, hs: "HomeServer"):
store = hs.get_datastores().main
super().__init__(
hs.get_instance_name(),
current_token_without_instance(store.get_group_stream_token),
store.get_all_groups_changes,
)
class UserSignatureStream(Stream):
"""A user has signed their own device with their user-signing key"""