From c4d09e4ff82ed06820b8edee064fe1ace4de8f06 Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Mon, 31 Oct 2022 09:58:53 +0000 Subject: [PATCH] Tweak LL --- syncapi/streams/stream_pdu.go | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/syncapi/streams/stream_pdu.go b/syncapi/streams/stream_pdu.go index d0773f804..90f401481 100644 --- a/syncapi/streams/stream_pdu.go +++ b/syncapi/streams/stream_pdu.go @@ -526,7 +526,7 @@ func (p *PDUStreamProvider) getJoinResponseForCompleteSync( // If we are limited by the filter AND the history visibility filter // didn't "remove" events, return that the response is limited. limited = limited && len(events) == len(recentEvents) - + stateEvents = removeDuplicates(stateEvents, recentEvents) if stateFilter.LazyLoadMembers { if err != nil { return nil, err @@ -546,9 +546,7 @@ func (p *PDUStreamProvider) getJoinResponseForCompleteSync( // If we are limited by the filter AND the history visibility filter // didn't "remove" events, return that the response is limited. jr.Timeline.Limited = limited && len(events) == len(recentEvents) - jr.State.Events = gomatrixserverlib.HeaderedToClientEvents( - removeDuplicates(stateEvents, recentEvents), gomatrixserverlib.FormatSync, - ) + jr.State.Events = gomatrixserverlib.HeaderedToClientEvents(stateEvents, gomatrixserverlib.FormatSync) return jr, nil }