diff options
| author | Sean Quah <8349537+squahtx@users.noreply.github.com> | 2021-09-22 14:43:26 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-09-22 14:43:26 +0100 |
| commit | 9391de3f373454aeec5b5c2f01b3c576528e76fe (patch) | |
| tree | 95f961f52c47f8636d840a1b96967d627e6bb35d /synapse/storage/databases | |
| parent | Add documentation for experimental feature flags. (#10865) (diff) | |
| download | synapse-9391de3f373454aeec5b5c2f01b3c576528e76fe.tar.xz | |
Fix /initialSync error due to unhashable `RoomStreamToken` (#10827)
The deprecated /initialSync endpoint maintains a cache of responses, using parameter values as part of the cache key. When a `from` or `to` parameter is specified, it gets converted into a `StreamToken`, which contains a `RoomStreamToken` and forms part of the cache key. `RoomStreamToken`s need to be made hashable for this to work.
Diffstat (limited to 'synapse/storage/databases')
| -rw-r--r-- | synapse/storage/databases/main/stream.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/synapse/storage/databases/main/stream.py b/synapse/storage/databases/main/stream.py index 959f13de47..9a3b6f4acf 100644 --- a/synapse/storage/databases/main/stream.py +++ b/synapse/storage/databases/main/stream.py @@ -39,6 +39,8 @@ import logging from collections import namedtuple from typing import TYPE_CHECKING, Collection, Dict, List, Optional, Set, Tuple +from frozendict import frozendict + from twisted.internet import defer from synapse.api.filtering import Filter @@ -379,7 +381,7 @@ class StreamWorkerStore(EventsWorkerStore, SQLBaseStore, metaclass=abc.ABCMeta): if p > min_pos } - return RoomStreamToken(None, min_pos, positions) + return RoomStreamToken(None, min_pos, frozendict(positions)) async def get_room_events_stream_for_rooms( self, |