aboutsummaryrefslogtreecommitdiff
path: root/roomserver/internal
diff options
context:
space:
mode:
authorNeil Alexander <neilalexander@users.noreply.github.com>2022-02-17 13:53:48 +0000
committerGitHub <noreply@github.com>2022-02-17 13:53:48 +0000
commit7dfc7c3d7067c0f247f79f299e80e100244f5121 (patch)
treee6db1e027ffecb06cbce4a3bea0d8fa86db5ecaf /roomserver/internal
parent353168a9e93803bc9c5608d2e0ec55ba7fc581d9 (diff)
Don't re-send sent events in `add_state_events` (#2195)
* Only add events to `add_state_events` that haven't already been sent to the roomserver output before * Filter on event NIDs instead, hopefully bring joy to SQLite * UnsentFilter, review comments
Diffstat (limited to 'roomserver/internal')
-rw-r--r--roomserver/internal/input/input_latest_events.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/roomserver/internal/input/input_latest_events.go b/roomserver/internal/input/input_latest_events.go
index 5173d3ab..ae28ebef 100644
--- a/roomserver/internal/input/input_latest_events.go
+++ b/roomserver/internal/input/input_latest_events.go
@@ -405,7 +405,7 @@ func (u *latestEventsUpdater) extraEventsForIDs(roomVersion gomatrixserverlib.Ro
if len(extraEventIDs) == 0 {
return nil, nil
}
- extraEvents, err := u.updater.EventsFromIDs(u.ctx, extraEventIDs)
+ extraEvents, err := u.updater.UnsentEventsFromIDs(u.ctx, extraEventIDs)
if err != nil {
return nil, err
}