diff options
| author | Neil Alexander <neilalexander@users.noreply.github.com> | 2022-08-18 10:37:47 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-08-18 10:37:47 +0100 |
| commit | 59bc0a6f4ed0324da0387118e1761b4551aaf103 (patch) | |
| tree | 8a0708cf274aae31cb8cb1a9697adb9f96960e57 /roomserver/storage/shared/storage.go | |
| parent | 8d9c8f11c5c5673d48b8e5308e1f565927bdd341 (diff) | |
Reprocess rejected input events (#2647)
* Reprocess outliers that were previously rejected
* Might as well do all events this way
* More useful errors
* Fix queries
* Tweak condition
* Don't wrap errors
* Report more useful error
* Flatten error on `r.Queryer.QueryStateAfterEvents`
* Some more debug logging
* Flatten error in `QueryRestrictedJoinAllowed`
* Revert "Flatten error in `QueryRestrictedJoinAllowed`"
This reverts commit 1238b4184c30e0c31ffb0f364806fa1275aba483.
* Tweak `QueryStateAfterEvents`
* Handle MissingStateError too
* Scope to room
* Clean up
* Fix the error
* Only apply rejection check to outliers
Diffstat (limited to 'roomserver/storage/shared/storage.go')
| -rw-r--r-- | roomserver/storage/shared/storage.go | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/roomserver/storage/shared/storage.go b/roomserver/storage/shared/storage.go index cbf9c8b2..4f92adf1 100644 --- a/roomserver/storage/shared/storage.go +++ b/roomserver/storage/shared/storage.go @@ -567,6 +567,10 @@ func (d *Database) GetRoomUpdater( return updater, err } +func (d *Database) IsEventRejected(ctx context.Context, roomNID types.RoomNID, eventID string) (bool, error) { + return d.EventsTable.SelectEventRejected(ctx, nil, roomNID, eventID) +} + func (d *Database) StoreEvent( ctx context.Context, event *gomatrixserverlib.Event, authEventNIDs []types.EventNID, isRejected bool, |