mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-26 00:03:09 -06:00
Code Issues Packages Projects Releases Wiki Activity

Make sure we wake up for our own key changes

Browse source
This commit is contained in:
Neil Alexander 2020-12-18 13:26:49 +00:00
parent 50963b724b
commit a5b25878c7
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
syncapi/consumers/keychange.go
View file

@ -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") log.WithError(err).Error("syncapi: failed to QuerySharedUsers for key change event from key server")
return err 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{ posUpdate := types.StreamingToken{
DeviceListPosition: types.LogPosition{ DeviceListPosition: types.LogPosition{
Offset: msg.Offset, Offset: msg.Offset,