diff options
| author | Neil Alexander <neilalexander@users.noreply.github.com> | 2020-12-18 14:04:17 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-12-18 14:04:17 +0000 |
| commit | 4fe4c180e638985cbb88beb764da9a2c3273069a (patch) | |
| tree | 0bd8f95ace37bf58d99f9a998f8ee63ffb4ae374 | |
| parent | fac71edc62508e517b188e00fb64651910761ff0 (diff) | |
Ensure we wake for our own device list updates (#1661)
* Make sure we wake up for our own key changes
* Whitelist 'Users receive device_list updates for their own devices'
| -rw-r--r-- | syncapi/consumers/keychange.go | 3 | ||||
| -rw-r--r-- | sytest-whitelist | 1 |
2 files changed, 3 insertions, 1 deletions
diff --git a/syncapi/consumers/keychange.go b/syncapi/consumers/keychange.go index 128f6011..59cd583d 100644 --- a/syncapi/consumers/keychange.go +++ b/syncapi/consumers/keychange.go @@ -112,7 +112,8 @@ func (s *OutputKeyChangeEventConsumer) onMessage(msg *sarama.ConsumerMessage) er log.WithError(err).Error("syncapi: failed to QuerySharedUsers for key change event from key server") return err } - // TODO: f.e queryRes.UserIDsToCount : notify users by waking up streams + // make sure we get our own key updates too! + queryRes.UserIDsToCount[output.UserID] = 1 posUpdate := types.StreamingToken{ DeviceListPosition: types.LogPosition{ Offset: msg.Offset, diff --git a/sytest-whitelist b/sytest-whitelist index 4ef2304a..cfbe5443 100644 --- a/sytest-whitelist +++ b/sytest-whitelist @@ -500,3 +500,4 @@ Can forget room you've been kicked from /whois /joined_members return joined members A next_batch token can be used in the v1 messages API +Users receive device_list updates for their own devices |