mirror of
https://github.com/matrix-org/dendrite.git
synced 2026-01-09 15:13:12 -06:00
Tweak state before processing
This commit is contained in:
parent
4be38f6dd2
commit
c69c189a64
|
|
@ -300,13 +300,14 @@ func (r *Inputer) processRoomEvent(
|
||||||
// bother doing this if the event was already rejected as it just ends up
|
// bother doing this if the event was already rejected as it just ends up
|
||||||
// burning CPU time.
|
// burning CPU time.
|
||||||
historyVisibility := gomatrixserverlib.HistoryVisibilityJoined // Default to restrictive.
|
historyVisibility := gomatrixserverlib.HistoryVisibilityJoined // Default to restrictive.
|
||||||
if rejectionErr == nil && !isRejected && !softfail {
|
if !isCreateEvent && rejectionErr == nil && !isRejected && !softfail {
|
||||||
var err error
|
var err error
|
||||||
historyVisibility, rejectionErr, err = r.processStateBefore(ctx, input, missingPrev)
|
historyVisibility, rejectionErr, err = r.processStateBefore(ctx, input, missingPrev)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("r.processStateBefore: %w", err)
|
return fmt.Errorf("r.processStateBefore: %w", err)
|
||||||
}
|
}
|
||||||
if rejectionErr != nil {
|
if rejectionErr != nil {
|
||||||
|
rejectionErr = fmt.Errorf("rejected by state before event: %w", rejectionErr)
|
||||||
isRejected = true
|
isRejected = true
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue