diff --git a/syncapi/streams/stream_pdu.go b/syncapi/streams/stream_pdu.go index d5def30dd..fcf7a72ab 100644 --- a/syncapi/streams/stream_pdu.go +++ b/syncapi/streams/stream_pdu.go @@ -257,7 +257,7 @@ func (p *PDUStreamProvider) addRoomDeltaToResponse( // or not, it needs the m.room.create event which may be chronologically outside // the filter limit. if !delta.NewlyJoined { - delta.StateEvents = removeDuplicates(delta.StateEvents, recentEvents) // roll back + delta.StateEvents = removeDuplicates(delta.StateEvents, recentEvents) } prevBatch, err := snapshot.GetBackwardTopologyPos(ctx, recentStreamEvents) if err != nil {