From 6fd84594475230c0a000fec5d8d1790060ead6de Mon Sep 17 00:00:00 2001 From: Eric Eastwood Date: Sat, 16 Jan 2021 01:07:52 -0600 Subject: [PATCH] Try fix unit tests --- syncapi/notifier/notifier_test.go | 2 +- syncapi/streams/stream_pdu.go | 8 ++++++++ 2 files changed, 9 insertions(+), 1 deletion(-) diff --git a/syncapi/notifier/notifier_test.go b/syncapi/notifier/notifier_test.go index 8b9425e3..1d988eb4 100644 --- a/syncapi/notifier/notifier_test.go +++ b/syncapi/notifier/notifier_test.go @@ -367,7 +367,7 @@ func newTestSyncRequest(userID, deviceID string, since types.StreamingToken) typ Timeout: 1 * time.Minute, Since: since, WantFullState: false, - Limit: 20, + Filter: gomatrixserverlib.DefaultFilter(), Log: util.GetLogger(context.TODO()), Context: context.TODO(), } diff --git a/syncapi/streams/stream_pdu.go b/syncapi/streams/stream_pdu.go index c0bcdc4d..b453e7b6 100644 --- a/syncapi/streams/stream_pdu.go +++ b/syncapi/streams/stream_pdu.go @@ -142,6 +142,14 @@ func (p *PDUStreamProvider) IncrementalSync( } } + logrus.WithFields(logrus.Fields{ + "stateFilter": fmt.Sprintf("%+v", stateFilter), + "from": from, + "to": to, + "req.WantFullState": req.WantFullState, + "stateDeltas": stateDeltas, + }).Info("IncrementalSync") + for _, roomID := range joinedRooms { req.Rooms[roomID] = gomatrixserverlib.Join }