diff options
| author | Till <2353100+S7evinK@users.noreply.github.com> | 2022-09-20 11:32:03 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-09-20 11:32:03 +0200 |
| commit | e007b8038f677b6578a65cfe2cbd8a7192ae69b0 (patch) | |
| tree | 27157dc3e229c2a2b6fcf190d4d94a1a0ba17621 /syncapi/syncapi.go | |
| parent | 47af4bff5b930c86630c7879e14f5b07b9d08497 (diff) | |
Mark device list as stale, if we don't have the requesting device (#2728)
This hopefully makes E2EE chats a little bit more reliable by re-syncing
devices if we don't have the `requesting_device_id` in our database. (As
seen in
[Synapse](https://github.com/matrix-org/synapse/blob/c52abc1cfdd9e5480cdb4a03d626fe61cacc6573/synapse/handlers/devicemessage.py#L157-L201))
Diffstat (limited to 'syncapi/syncapi.go')
| -rw-r--r-- | syncapi/syncapi.go | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/syncapi/syncapi.go b/syncapi/syncapi.go index 92db18d5..68537bc4 100644 --- a/syncapi/syncapi.go +++ b/syncapi/syncapi.go @@ -17,9 +17,10 @@ package syncapi import ( "context" - "github.com/matrix-org/dendrite/internal/caching" "github.com/sirupsen/logrus" + "github.com/matrix-org/dendrite/internal/caching" + keyapi "github.com/matrix-org/dendrite/keyserver/api" "github.com/matrix-org/dendrite/roomserver/api" "github.com/matrix-org/dendrite/setup/base" @@ -126,7 +127,7 @@ func AddPublicRoutes( } sendToDeviceConsumer := consumers.NewOutputSendToDeviceEventConsumer( - base.ProcessContext, cfg, js, syncDB, notifier, streams.SendToDeviceStreamProvider, + base.ProcessContext, cfg, js, syncDB, keyAPI, notifier, streams.SendToDeviceStreamProvider, ) if err = sendToDeviceConsumer.Start(); err != nil { logrus.WithError(err).Panicf("failed to start send-to-device consumer") |