diff options
| author | Neil Alexander <neilalexander@users.noreply.github.com> | 2020-12-15 15:09:10 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-12-15 15:09:10 +0000 |
| commit | 38318b0f162a41ac9d1aa60dc3b7693eae033851 (patch) | |
| tree | 9c032fc27d8b06e1b747da410789d572ac8aa790 /syncapi/consumers | |
| parent | 98ebbd01e552aa00c37abbc635fca61b91c40683 (diff) | |
De-map device list positions in streaming tokens (#1642)
* De-map device list positions in streaming tokens
* Fix lint error
* Tweak toOffset
Diffstat (limited to 'syncapi/consumers')
| -rw-r--r-- | syncapi/consumers/keychange.go | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/syncapi/consumers/keychange.go b/syncapi/consumers/keychange.go index 0d82f7a5..128f6011 100644 --- a/syncapi/consumers/keychange.go +++ b/syncapi/consumers/keychange.go @@ -23,7 +23,6 @@ import ( "github.com/matrix-org/dendrite/internal" "github.com/matrix-org/dendrite/keyserver/api" roomserverAPI "github.com/matrix-org/dendrite/roomserver/api" - syncinternal "github.com/matrix-org/dendrite/syncapi/internal" "github.com/matrix-org/dendrite/syncapi/storage" syncapi "github.com/matrix-org/dendrite/syncapi/sync" "github.com/matrix-org/dendrite/syncapi/types" @@ -115,11 +114,9 @@ func (s *OutputKeyChangeEventConsumer) onMessage(msg *sarama.ConsumerMessage) er } // TODO: f.e queryRes.UserIDsToCount : notify users by waking up streams posUpdate := types.StreamingToken{ - Logs: map[string]*types.LogPosition{ - syncinternal.DeviceListLogName: { - Offset: msg.Offset, - Partition: msg.Partition, - }, + DeviceListPosition: types.LogPosition{ + Offset: msg.Offset, + Partition: msg.Partition, }, } for userID := range queryRes.UserIDsToCount { |