From 195abfe7a5ec3b0d52812a3d7a04264f97376771 Mon Sep 17 00:00:00 2001
From: Erik Johnston <erik@matrix.org>
Date: Fri, 27 Oct 2017 09:58:13 +0100
Subject: Remove incorrect attestations

---
 synapse/storage/group_server.py | 18 ++++++++++++++++++
 1 file changed, 18 insertions(+)

(limited to 'synapse/storage')

diff --git a/synapse/storage/group_server.py b/synapse/storage/group_server.py
index 9e63db5c6c..ed2ee61ad2 100644
--- a/synapse/storage/group_server.py
+++ b/synapse/storage/group_server.py
@@ -1086,6 +1086,24 @@ class GroupServerStore(SQLBaseStore):
             desc="update_remote_attestion",
         )
 
+    def remove_attestation_renewal(self, group_id, user_id):
+        """Remove an attestation that we thought we should renew, but actually
+        shouldn't. Ideally this would never get called as we would never
+        incorrectly try and do attestations for local users on local groups.
+
+        Args:
+            group_id (str)
+            user_id (str)
+        """
+        return self._simple_update_one(
+            table="_simple_delete",
+            keyvalues={
+                "group_id": group_id,
+                "user_id": user_id,
+            },
+            desc="remove_attestation_renewal",
+        )
+
     @defer.inlineCallbacks
     def get_remote_attestation(self, group_id, user_id):
         """Get the attestation that proves the remote agrees that the user is
-- 
cgit 1.5.1


From 82d8c1bacb085588b59021d21cd4df56b0d8411a Mon Sep 17 00:00:00 2001
From: Erik Johnston <erik@matrix.org>
Date: Fri, 27 Oct 2017 10:30:21 +0100
Subject: Fixup

---
 synapse/groups/attestations.py  | 6 +++---
 synapse/storage/group_server.py | 4 ++--
 2 files changed, 5 insertions(+), 5 deletions(-)

(limited to 'synapse/storage')

diff --git a/synapse/groups/attestations.py b/synapse/groups/attestations.py
index 0bd73b6a61..4656e854f0 100644
--- a/synapse/groups/attestations.py
+++ b/synapse/groups/attestations.py
@@ -128,11 +128,9 @@ class GroupAttestionRenewer(object):
 
         @defer.inlineCallbacks
         def _renew_attestation(group_id, user_id):
-            attestation = self.attestations.create_attestation(group_id, user_id)
-
             if not self.is_mine_id(group_id):
                 destination = get_domain_from_id(group_id)
-            else not self.is_mine_id(user_id):
+            elif not self.is_mine_id(user_id):
                 destination = get_domain_from_id(user_id)
             else:
                 logger.warn(
@@ -142,6 +140,8 @@ class GroupAttestionRenewer(object):
                 yield self.store.remove_attestation_renewal(group_id, user_id)
                 return
 
+            attestation = self.attestations.create_attestation(group_id, user_id)
+
             yield self.transport_client.renew_group_attestation(
                 destination, group_id, user_id,
                 content={"attestation": attestation},
diff --git a/synapse/storage/group_server.py b/synapse/storage/group_server.py
index ed2ee61ad2..ba3f5617fa 100644
--- a/synapse/storage/group_server.py
+++ b/synapse/storage/group_server.py
@@ -1095,8 +1095,8 @@ class GroupServerStore(SQLBaseStore):
             group_id (str)
             user_id (str)
         """
-        return self._simple_update_one(
-            table="_simple_delete",
+        return self._simple_delete(
+            table="group_attestations_renewals",
             keyvalues={
                 "group_id": group_id,
                 "user_id": user_id,
-- 
cgit 1.5.1