summary refs log tree commit diff
path: root/synapse
diff options
context:
space:
mode:
Diffstat (limited to 'synapse')
-rw-r--r--synapse/storage/group_server.py20
-rw-r--r--synapse/storage/schema/delta/43/group_server.sql10
2 files changed, 1 insertions, 29 deletions
diff --git a/synapse/storage/group_server.py b/synapse/storage/group_server.py
index 2dcdcbfdfc..bff2324cc7 100644
--- a/synapse/storage/group_server.py
+++ b/synapse/storage/group_server.py
@@ -783,26 +783,6 @@ class GroupServerStore(SQLBaseStore):
                     "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)
 
             # TODO: Insert profile to ensuer it comes down stream if its a join.
diff --git a/synapse/storage/schema/delta/43/group_server.sql b/synapse/storage/schema/delta/43/group_server.sql
index f9e11c9146..e1fd47aa7f 100644
--- a/synapse/storage/schema/delta/43/group_server.sql
+++ b/synapse/storage/schema/delta/43/group_server.sql
@@ -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);
 
 
+-- The group membership for the HS's users
 CREATE TABLE local_group_membership (
     group_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_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
-);