mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2026-01-11 08:03:09 -06:00
Code Issues Packages Projects Releases Wiki Activity

Fix ooops

Browse source
This commit is contained in:
Till Faelligen 2023-07-07 13:08:55 +02:00
parent 33c09905dd
commit c8baa399aa
No known key found for this signature in database
GPG key ID: ACCDC9606D472758
1 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
syncapi/streams/stream_pdu.go
View file

@ -370,7 +370,7 @@ func (p *PDUStreamProvider) addRoomDeltaToResponse(
gomatrixserverlib.ToPDUs(removeDuplicates(delta.StateEvents, events)), gomatrixserverlib.ToPDUs(removeDuplicates(delta.StateEvents, events)),
gomatrixserverlib.TopologicalOrderByAuthEvents, gomatrixserverlib.TopologicalOrderByAuthEvents,
) )
delta.StateEvents = make([]*rstypes.HeaderedEvent, 0, len(sEvents)) delta.StateEvents = make([]*rstypes.HeaderedEvent, len(sEvents))
var skipped int var skipped int
for i := range sEvents { for i := range sEvents {
ev := sEvents[i] ev := sEvents[i]
@ -390,6 +390,7 @@ func (p *PDUStreamProvider) addRoomDeltaToResponse(
delta.StateEvents[i-skipped] = &rstypes.HeaderedEvent{PDU: newEvent} delta.StateEvents[i-skipped] = &rstypes.HeaderedEvent{PDU: newEvent}
} }
} }
delta.StateEvents = delta.StateEvents[:len(sEvents)-skipped]
if len(delta.StateEvents) > 0 { if len(delta.StateEvents) > 0 {
if last := delta.StateEvents[len(delta.StateEvents)-1]; last != nil { if last := delta.StateEvents[len(delta.StateEvents)-1]; last != nil {