File tree Expand file tree Collapse file tree 1 file changed +6
-32
lines changed Expand file tree Collapse file tree 1 file changed +6
-32
lines changed Original file line number Diff line number Diff line change @@ -1738,39 +1738,13 @@ async def get_new_events(
1738
1738
user .to_string (), from_key , to_key
1739
1739
)
1740
1740
1741
- < << << << HEAD
1742
- room_to_events = await self .store .get_room_events_stream_for_rooms (
1743
- room_ids = room_ids ,
1744
- from_key = from_key ,
1745
- to_key = to_key ,
1746
- limit = limit or 10 ,
1747
- direction = Direction .FORWARDS ,
1748
- )
1749
-
1750
- events = list (room_events )
1751
- events .extend (e for evs , _ , _ in room_to_events .values () for e in evs )
1752
-
1753
- # We know stream_ordering must be not None here, as its been
1754
- # persisted, but mypy doesn't know that
1755
- events .sort (key = lambda e : cast (int , e .internal_metadata .stream_ordering ))
1756
-
1757
- if limit :
1758
- events [:] = events [:limit ]
1759
-
1760
- if events :
1761
- last_event = events [- 1 ]
1762
- assert last_event .internal_metadata .stream_ordering
1763
- end_key = RoomStreamToken (
1764
- stream = last_event .internal_metadata .stream_ordering ,
1765
- == == == =
1766
1741
room_to_events = await self .store .get_room_events_stream_for_rooms (
1767
- room_ids = room_ids ,
1768
- from_key = from_key ,
1769
- to_key = to_key ,
1770
- limit = limit or 10 ,
1771
- order = "ASC" ,
1772
- >> >> >> > d55b9dfb58 (fix / sync for application services )
1773
- )
1742
+ room_ids = room_ids ,
1743
+ from_key = from_key ,
1744
+ to_key = to_key ,
1745
+ limit = limit or 10 ,
1746
+ direction = Direction .FORWARDS ,
1747
+ )
1774
1748
1775
1749
events = list (room_events )
1776
1750
events .extend (e for evs , _ in room_to_events .values () for e in evs )
You can’t perform that action at this time.
0 commit comments