summary refs log tree commit diff
path: root/synapse/storage/registration.py
diff options
context:
space:
mode:
authorDavid Baker <dave@matrix.org>2016-03-11 14:29:01 +0000
committerDavid Baker <dave@matrix.org>2016-03-11 14:29:01 +0000
commitf523177850df7fbe480086b281f09815f3d5c656 (patch)
tree5e19b61ef6649410c08fbea6160cd36c388e5dcf /synapse/storage/registration.py
parentDear PyCharm, please indent sensibly for me. Thx. (diff)
downloadsynapse-f523177850df7fbe480086b281f09815f3d5c656.tar.xz
Delete old, unused methods and rename new one to just be `user_delete_access_tokens` with an `except_token_ids` argument doing what it says on the tin.
Diffstat (limited to 'synapse/storage/registration.py')
-rw-r--r--synapse/storage/registration.py17
1 files changed, 2 insertions, 15 deletions
diff --git a/synapse/storage/registration.py b/synapse/storage/registration.py
index d3d84c9b94..266e29f5bc 100644
--- a/synapse/storage/registration.py
+++ b/synapse/storage/registration.py
@@ -195,20 +195,7 @@ class RegistrationStore(SQLBaseStore):
         })
 
     @defer.inlineCallbacks
-    def user_delete_access_tokens(self, user_id):
-        yield self.runInteraction(
-            "user_delete_access_tokens",
-            self._user_delete_access_tokens, user_id
-        )
-
-    def _user_delete_access_tokens(self, txn, user_id):
-        txn.execute(
-            "DELETE FROM access_tokens WHERE user_id = ?",
-            (user_id, )
-        )
-
-    @defer.inlineCallbacks
-    def user_delete_access_tokens_except(self, user_id, except_token_ids):
+    def user_delete_access_tokens(self, user_id, except_token_ids):
         def f(txn):
             txn.execute(
                 "SELECT id, token FROM access_tokens WHERE user_id = ? LIMIT 50",
@@ -226,7 +213,7 @@ class RegistrationStore(SQLBaseStore):
                 ), [r[0] for r in rows]
             )
             return len(rows) == 50
-        while (yield self.runInteraction("user_delete_access_tokens_except", f)):
+        while (yield self.runInteraction("user_delete_access_tokens", f)):
             pass
 
     @cached()