diff options
author | Erik Johnston <erik@matrix.org> | 2018-07-26 13:31:59 +0100 |
---|---|---|
committer | Erik Johnston <erik@matrix.org> | 2018-08-06 15:23:38 +0100 |
commit | 62ace05c4521caeed023e5b9dadd993afe5c154f (patch) | |
tree | 3b4cce70711b187077a266fac08243fb0739ef58 /synapse/storage/room.py | |
parent | Import all functions from TransactionStore (diff) | |
download | synapse-62ace05c4521caeed023e5b9dadd993afe5c154f.tar.xz |
Move necessary storage functions to worker classes
Diffstat (limited to '')
-rw-r--r-- | synapse/storage/room.py | 32 |
1 files changed, 16 insertions, 16 deletions
diff --git a/synapse/storage/room.py b/synapse/storage/room.py index 3147fb6827..3378fc77d1 100644 --- a/synapse/storage/room.py +++ b/synapse/storage/room.py @@ -41,6 +41,22 @@ RatelimitOverride = collections.namedtuple( class RoomWorkerStore(SQLBaseStore): + def get_room(self, room_id): + """Retrieve a room. + + Args: + room_id (str): The ID of the room to retrieve. + Returns: + A namedtuple containing the room information, or an empty list. + """ + return self._simple_select_one( + table="rooms", + keyvalues={"room_id": room_id}, + retcols=("room_id", "is_public", "creator"), + desc="get_room", + allow_none=True, + ) + def get_public_room_ids(self): return self._simple_select_onecol( table="rooms", @@ -215,22 +231,6 @@ class RoomStore(RoomWorkerStore, SearchStore): logger.error("store_room with room_id=%s failed: %s", room_id, e) raise StoreError(500, "Problem creating room.") - def get_room(self, room_id): - """Retrieve a room. - - Args: - room_id (str): The ID of the room to retrieve. - Returns: - A namedtuple containing the room information, or an empty list. - """ - return self._simple_select_one( - table="rooms", - keyvalues={"room_id": room_id}, - retcols=("room_id", "is_public", "creator"), - desc="get_room", - allow_none=True, - ) - @defer.inlineCallbacks def set_room_is_public(self, room_id, is_public): def set_room_is_public_txn(txn, next_id): |