mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-17 03:43:11 -06:00
Code Issues Packages Projects Releases Wiki Activity

Limit prev_events and auth_events

Browse source
This commit is contained in:
Neil Alexander 2020-04-01 10:30:47 +01:00
parent b4c84be802
commit 942b2db448
1 changed files with 15 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
common/events.go
View file

@ -105,17 +105,32 @@ func AddPrevEventsToEvent(
return err return err
} }
// The limits here feel a bit arbitrary but they are currently here
// because of https://github.com/matrix-org/matrix-doc/issues/2307
// and because Synapse will just drop events that don't comply.
switch eventFormat { switch eventFormat {
case gomatrixserverlib.EventFormatV1: case gomatrixserverlib.EventFormatV1:
builder.AuthEvents = refs builder.AuthEvents = refs
builder.PrevEvents = queryRes.LatestEvents builder.PrevEvents = queryRes.LatestEvents
if len(builder.AuthEvents) > 10 {
builder.AuthEvents = builder.AuthEvents[:10]
}
if len(builder.PrevEvents) > 20 {
builder.PrevEvents = builder.PrevEvents[:20]
}
case gomatrixserverlib.EventFormatV2: case gomatrixserverlib.EventFormatV2:
v2AuthRefs := []string{} v2AuthRefs := []string{}
v2PrevRefs := []string{} v2PrevRefs := []string{}
for _, ref := range refs { for _, ref := range refs {
if len(v2AuthRefs) == 10 {
break
}
v2AuthRefs = append(v2AuthRefs, ref.EventID) v2AuthRefs = append(v2AuthRefs, ref.EventID)
} }
for _, ref := range queryRes.LatestEvents { for _, ref := range queryRes.LatestEvents {
if len(v2PrevRefs) == 20 {
break
}
v2PrevRefs = append(v2PrevRefs, ref.EventID) v2PrevRefs = append(v2PrevRefs, ref.EventID)
} }
builder.AuthEvents = v2AuthRefs builder.AuthEvents = v2AuthRefs