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

Put that back

Browse source
This commit is contained in:
Neil Alexander 2022-05-05 13:00:42 +01:00
parent 0a8e6dbbfb
commit 0b50cea0c2
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
syncapi/sync/requestpool.go
View file

@ -229,6 +229,9 @@ func (rp *RequestPool) OnIncomingSyncRequest(req *http.Request, device *userapi.
} }
} }
rp.updateLastSeen(req, device)
rp.updatePresence(req.Context(), rp.db, req.FormValue("set_presence"), device.UserID)
activeSyncRequests.Inc() activeSyncRequests.Inc()
defer activeSyncRequests.Dec() defer activeSyncRequests.Dec()
@ -265,9 +268,6 @@ func (rp *RequestPool) OnIncomingSyncRequest(req *http.Request, device *userapi.
syncReq.Log.WithField("currentPos", currentPos).Debugln("Responding to sync immediately") syncReq.Log.WithField("currentPos", currentPos).Debugln("Responding to sync immediately")
} }
defer rp.updateLastSeen(req, device)
rp.updatePresence(req.Context(), rp.db, req.FormValue("set_presence"), device.UserID)
if syncReq.Since.IsEmpty() { if syncReq.Since.IsEmpty() {
// Complete sync // Complete sync
syncReq.Response.NextBatch = types.StreamingToken{ syncReq.Response.NextBatch = types.StreamingToken{