diff options
| author | Neil Alexander <neilalexander@users.noreply.github.com> | 2022-06-15 14:27:07 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-06-15 14:27:07 +0100 |
| commit | 7120eb6bc943af6f725b0c61cfd110330f04064a (patch) | |
| tree | a7e278689e44b36eeefe01cd7b8ecb247119c940 /federationapi/routing | |
| parent | 1b90cc95367947fa00616b4426d0c894b33c9862 (diff) | |
Add `InputDeviceListUpdate` to the keyserver, remove old input API (#2536)
* Add `InputDeviceListUpdate` to the keyserver, remove old input API
* Fix copyright
* Log more information when a device list update fails
Diffstat (limited to 'federationapi/routing')
| -rw-r--r-- | federationapi/routing/send.go | 8 |
1 files changed, 2 insertions, 6 deletions
diff --git a/federationapi/routing/send.go b/federationapi/routing/send.go index c25dabce..43003be3 100644 --- a/federationapi/routing/send.go +++ b/federationapi/routing/send.go @@ -501,11 +501,7 @@ func (t *txnReq) processDeviceListUpdate(ctx context.Context, e gomatrixserverli } else if serverName != t.Origin { return } - var inputRes keyapi.InputDeviceListUpdateResponse - t.keyAPI.InputDeviceListUpdate(context.Background(), &keyapi.InputDeviceListUpdateRequest{ - Event: payload, - }, &inputRes) - if inputRes.Error != nil { - util.GetLogger(ctx).WithError(inputRes.Error).WithField("user_id", payload.UserID).Error("failed to InputDeviceListUpdate") + if err := t.producer.SendDeviceListUpdate(ctx, &payload); err != nil { + util.GetLogger(ctx).WithError(err).WithField("user_id", payload.UserID).Error("failed to InputDeviceListUpdate") } } |