Skip to content
This repository was archived by the owner on Apr 26, 2024. It is now read-only.

Improvements to bundling aggregations #11815

Merged
merged 12 commits into from
Jan 26, 2022
Merged

Improvements to bundling aggregations #11815

Changes from 1 commit
Commits
Show all changes
12 commits
Select commit Hold shift + click to select a range
de8a4bc
Do not mutate result dictionaries.
clokep Jan 20, 2022
42e1817
Fetch all bundled aggregations at once.
clokep Jan 20, 2022
12e8832
Create a BundledAggregations attrs.
clokep Jan 24, 2022
9f3d783
Newsfragment
clokep Jan 24, 2022
0d3b625
Merge remote-tracking branch 'origin/develop' into clokep/bundled-agg…
clokep Jan 25, 2022
1777831
Convert retun type of get_events_around to attrs.
clokep Jan 25, 2022
4a91ae8
Merge remote-tracking branch 'origin/develop' into clokep/bundled-agg…
clokep Jan 25, 2022
067d4bc
Add missing assert in tests.
clokep Jan 25, 2022
d976be7
Do not include empty bundled aggregations.
clokep Jan 25, 2022
5d635bf
Merge remote-tracking branch 'origin/develop' into clokep/bundled-agg…
clokep Jan 25, 2022
ca89fb6
Merge remote-tracking branch 'origin/develop' into clokep/bundled-agg…
clokep Jan 25, 2022
10cb9d5
Merge remote-tracking branch 'origin/develop' into clokep/bundled-agg…
clokep Jan 26, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
15 changes: 4 additions & 11 deletions synapse/handlers/room.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1195,17 +1195,10 @@ async def filter_evts(events: List[EventBase]) -> List[EventBase]:

# Fetch the aggregations.
aggregations = await self.store.get_bundled_aggregations(
[event], user.to_string()
)
aggregations.update(
await self.store.get_bundled_aggregations(
results["events_before"], user.to_string()
)
)
aggregations.update(
await self.store.get_bundled_aggregations(
results["events_after"], user.to_string()
)
itertools.chain(
results["events_before"], (event,), results["events_after"]
),
user.to_string(),
)

if results["events_after"]:
Expand Down