diff options
| author | Olivier Wilkinson (reivilibre) <olivier@librepush.net> | 2019-08-30 16:57:19 +0100 |
|---|---|---|
| committer | Olivier Wilkinson (reivilibre) <olivier@librepush.net> | 2019-08-30 16:57:19 +0100 |
| commit | a04f01eb156abdbc10a6c0a920e80a8b19d748e6 (patch) | |
| tree | 7395efdae76ef54394a76ce5375495af0daa126b /synapse | |
| parent | Use async/await syntax. (diff) | |
| download | synapse-a04f01eb156abdbc10a6c0a920e80a8b19d748e6.tar.xz | |
Adapt for new separated statistics.
Signed-off-by: Olivier Wilkinson (reivilibre) <olivier@librepush.net>
Diffstat (limited to 'synapse')
| -rw-r--r-- | synapse/storage/room.py | 18 |
1 files changed, 10 insertions, 8 deletions
diff --git a/synapse/storage/room.py b/synapse/storage/room.py index fa730e06fc..732352a731 100644 --- a/synapse/storage/room.py +++ b/synapse/storage/room.py @@ -164,7 +164,8 @@ class RoomWorkerStore(SQLBaseStore): def count_public_rooms(self): """ - Counts the number of public rooms as tracked in the room_stats and room_state + Counts the number of public rooms as tracked in the room_stats_current + and room_stats_state table. A public room is one who has is_public set AND is publicly-joinable and/or world-readable. @@ -176,8 +177,8 @@ class RoomWorkerStore(SQLBaseStore): def _count_public_rooms_txn(txn): sql = """ SELECT COUNT(*) - FROM room_stats - JOIN room_state USING (room_id) + FROM room_stats_current + JOIN room_stats_state USING (room_id) JOIN rooms USING (room_id) WHERE is_public @@ -201,7 +202,8 @@ class RoomWorkerStore(SQLBaseStore): forwards, fetch_creation_event_ids=False, ): - """TODO doc this + """Gets the largest public rooms (where largest is in terms of joined + members, as tracked in the statistics table). Args: network_tuple (ThirdPartyInstanceID|None): @@ -219,7 +221,7 @@ class RoomWorkerStore(SQLBaseStore): """ - # TODO probably want to use ts_… on Postgres? + # TODO we probably want to use full text search on Postgres? sql = """ SELECT @@ -234,8 +236,8 @@ class RoomWorkerStore(SQLBaseStore): sql += """ FROM - room_stats - JOIN room_state USING (room_id) + room_stats_current + JOIN room_stats_state USING (room_id) JOIN rooms USING (room_id) """ query_args = [] @@ -267,7 +269,7 @@ class RoomWorkerStore(SQLBaseStore): if pagination_token: pt_joined = yield self._simple_select_one_onecol( - table="room_stats", + table="room_stats_current", keyvalues={"room_id": pagination_token}, retcol="joined_members", desc="get_largest_public_rooms", |