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

Might as well do all events this way

Browse source
This commit is contained in:
Neil Alexander 2022-08-16 16:31:46 +01:00
parent c2df0b3efa
commit 1f15cfc6a3
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 8 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
roomserver/internal/input/input_events.go
View file

@ -107,19 +107,17 @@ func (r *Inputer) processRoomEvent(
}) })
} }
// If we already know about this outlier and it hasn't been rejected // If we already know about this event and it hasn't been rejected
// then we won't attempt to reprocess it. If it was rejected then we // then we won't attempt to reprocess it. If it was rejected then we
// can attempt to reprocess, in case we have learned something new // can attempt to reprocess, in case we have learned something new
// that will allow us to accept the event this time. // that will allow us to accept the event this time.
if input.Kind == api.KindOutlier { wasRejected, werr := r.DB.IsEventRejected(ctx, event.EventID())
rejected, err := r.DB.IsEventRejected(ctx, event.EventID()) if werr != nil && werr != sql.ErrNoRows {
if err != nil && err != sql.ErrNoRows { return werr
return err }
} if !wasRejected {
if !rejected { logger.Debugf("Already processed event %q, ignoring", event.EventID())
logger.Debugf("Already processed event %q, ignoring", event.EventID()) return nil
return nil
}
} }
// Don't waste time processing the event if the room doesn't exist. // Don't waste time processing the event if the room doesn't exist.