Add a .runInteraction() method on SQLBaseStore itself to wrap the .db_pool

1 files changed, 5 insertions, 0 deletions

diff --git a/synapse/storage/roommember.py b/synapse/storage/roommember.py

index b357dc3058..8cbc15356d 100644
--- a/synapse/storage/roommember.py
+++ b/synapse/storage/roommember.py
@@ -71,6 +71,11 @@ class RoomMemberStore(SQLBaseStore):
 
             txn.execute(sql, (room_id, domain))
 
+    def store_room_member(self, user_id, room_id, event_id, membership):
+        return self.runInteraction(self._store_room_member_txn,
+            user_id, user_id, room_id, event_id, membership
+        )
+
     @defer.inlineCallbacks
     def get_room_member(self, user_id, room_id):
         """Retrieve the current state of a room member.