From 68575526aca1f4f105ed1e2d35aaceec46fd5ff0 Mon Sep 17 00:00:00 2001
From: Till Faelligen <tfaelligen@gmail.com>
Date: Thu, 28 Apr 2022 14:46:35 +0200
Subject: [PATCH] Get 1000 presence events, they are filtered later

---
 syncapi/streams/stream_presence.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/syncapi/streams/stream_presence.go b/syncapi/streams/stream_presence.go
index bd3251ffa..675a7a178 100644
--- a/syncapi/streams/stream_presence.go
+++ b/syncapi/streams/stream_presence.go
@@ -53,7 +53,8 @@ func (p *PresenceStreamProvider) IncrementalSync(
 	req *types.SyncRequest,
 	from, to types.StreamPosition,
 ) types.StreamPosition {
-	presences, err := p.DB.PresenceAfter(ctx, from, req.Filter.Presence)
+	// We pull out a larger number than the filter asks for, since we're filtering out events later
+	presences, err := p.DB.PresenceAfter(ctx, from, gomatrixserverlib.EventFilter{Limit: 1000})
 	if err != nil {
 		req.Log.WithError(err).Error("p.DB.PresenceAfter failed")
 		return from