mirror of
https://git.anonymousland.org/anonymousland/synapse-product.git
synced 2024-12-29 18:36:12 -05:00
Remove sync stuff
This commit is contained in:
parent
6e9f147faa
commit
508460f240
@ -783,26 +783,6 @@ class GroupServerStore(SQLBaseStore):
|
|||||||
"content": json.dumps(content),
|
"content": json.dumps(content),
|
||||||
},
|
},
|
||||||
)
|
)
|
||||||
self._simple_delete_txn(
|
|
||||||
txn,
|
|
||||||
table="local_group_updates",
|
|
||||||
keyvalues={
|
|
||||||
"group_id": group_id,
|
|
||||||
"user_id": user_id,
|
|
||||||
"type": "membership",
|
|
||||||
},
|
|
||||||
)
|
|
||||||
self._simple_insert_txn(
|
|
||||||
txn,
|
|
||||||
table="local_group_updates",
|
|
||||||
values={
|
|
||||||
"stream_id": next_id,
|
|
||||||
"group_id": group_id,
|
|
||||||
"user_id": user_id,
|
|
||||||
"type": "membership",
|
|
||||||
"content": json.dumps({"membership": membership, "content": content}),
|
|
||||||
}
|
|
||||||
)
|
|
||||||
self._group_updates_stream_cache.entity_has_changed(user_id, next_id)
|
self._group_updates_stream_cache.entity_has_changed(user_id, next_id)
|
||||||
|
|
||||||
# TODO: Insert profile to ensuer it comes down stream if its a join.
|
# TODO: Insert profile to ensuer it comes down stream if its a join.
|
||||||
|
@ -144,6 +144,7 @@ CREATE INDEX group_attestations_remote_u_idx ON group_attestations_remote(user_i
|
|||||||
CREATE INDEX group_attestations_remote_v_idx ON group_attestations_remote(valid_until_ms);
|
CREATE INDEX group_attestations_remote_v_idx ON group_attestations_remote(valid_until_ms);
|
||||||
|
|
||||||
|
|
||||||
|
-- The group membership for the HS's users
|
||||||
CREATE TABLE local_group_membership (
|
CREATE TABLE local_group_membership (
|
||||||
group_id TEXT NOT NULL,
|
group_id TEXT NOT NULL,
|
||||||
user_id TEXT NOT NULL,
|
user_id TEXT NOT NULL,
|
||||||
@ -154,12 +155,3 @@ CREATE TABLE local_group_membership (
|
|||||||
|
|
||||||
CREATE INDEX local_group_membership_u_idx ON local_group_membership(user_id, group_id);
|
CREATE INDEX local_group_membership_u_idx ON local_group_membership(user_id, group_id);
|
||||||
CREATE INDEX local_group_membership_g_idx ON local_group_membership(group_id);
|
CREATE INDEX local_group_membership_g_idx ON local_group_membership(group_id);
|
||||||
|
|
||||||
|
|
||||||
CREATE TABLE local_group_updates (
|
|
||||||
stream_id BIGINT NOT NULL,
|
|
||||||
group_id TEXT NOT NULL,
|
|
||||||
user_id TEXT NOT NULL,
|
|
||||||
type TEXT NOT NULL,
|
|
||||||
content TEXT NOT NULL
|
|
||||||
);
|
|
||||||
|
Loading…
Reference in New Issue
Block a user