deblan-mirror/mautrix-go
1
0
Fork 0
mirror of https://mau.dev/mautrix/go.git synced 2026-03-14 14:25:53 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

Add device ID to appservice OTK count map

Browse source
This commit is contained in:
Tulir Asokan 2022-08-05 18:08:44 +03:00
commit d2fcc50f2d
2 changed files with 21 additions and 15 deletions
Download patch file Download diff file Expand all files Collapse all files

17
appservice/http.go
View file

@ -161,13 +161,16 @@ func (as *AppService) handleTransaction(id string, txn *Transaction) {
as.txnIDC.MarkProcessed(id)
}
func (as *AppService) handleOTKCounts(otks map[id.UserID]mautrix.OTKCount) {
for userID, otkCounts := range otks {
otkCounts.UserID = userID
select {
case as.OTKCounts <- &otkCounts:
default:
as.Log.Warnfln("Dropped OTK count update for %s because channel is full", userID)
func (as *AppService) handleOTKCounts(otks OTKCountMap) {
for userID, devices := range otks {
for deviceID, otkCounts := range devices {
otkCounts.UserID = userID
otkCounts.DeviceID = deviceID
select {
case as.OTKCounts <- &otkCounts:
default:
as.Log.Warnfln("Dropped OTK count update for %s because channel is full", userID)
}
}
}
}