mirror of
https://github.com/matrix-org/dendrite
synced 2025-01-10 12:08:52 +00:00
Tweak condition
This commit is contained in:
parent
50518dc058
commit
605d57a24f
1 changed files with 1 additions and 2 deletions
|
@ -114,8 +114,7 @@ func (r *Inputer) processRoomEvent(
|
||||||
wasRejected, werr := r.DB.IsEventRejected(ctx, event.EventID())
|
wasRejected, werr := r.DB.IsEventRejected(ctx, event.EventID())
|
||||||
if werr != nil && werr != sql.ErrNoRows {
|
if werr != nil && werr != sql.ErrNoRows {
|
||||||
return werr
|
return werr
|
||||||
}
|
} else if werr == nil && !wasRejected {
|
||||||
if !wasRejected {
|
|
||||||
logger.Debugf("Already processed event %q, ignoring", event.EventID())
|
logger.Debugf("Already processed event %q, ignoring", event.EventID())
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue