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

Notify account data without advancing PDU position in notifier

Browse source
This commit is contained in:
Neil Alexander 2021-01-08 13:39:12 +00:00
parent d70ebaa1b9
commit 95e2e4d668
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
2 changed files with 10 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
syncapi/consumers/clientapi.go
View file

@ -97,7 +97,7 @@ func (s *OutputClientDataConsumer) onMessage(msg *sarama.ConsumerMessage) error
} }
s.streams.AccountDataStreamProvider.Advance(pduPos) s.streams.AccountDataStreamProvider.Advance(pduPos)
s.notifier.OnNewEvent(nil, "", []string{string(msg.Key)}, types.StreamingToken{AccountDataPosition: pduPos}) s.notifier.OnNewAccountData(string(msg.Key), types.StreamingToken{AccountDataPosition: pduPos})
return nil return nil
} }

9
syncapi/notifier/notifier.go
View file

@ -124,6 +124,15 @@ func (n *Notifier) OnNewEvent(
} }
} }
func (n *Notifier) OnNewAccountData(
userID string, posUpdate types.StreamingToken,
) {
n.streamLock.Lock()
defer n.streamLock.Unlock()
n.wakeupUsers([]string{userID}, nil, posUpdate)
}
func (n *Notifier) OnNewPeek( func (n *Notifier) OnNewPeek(
roomID, userID, deviceID string, roomID, userID, deviceID string,
) { ) {