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

More limiting

Browse source
This commit is contained in:
Till Faelligen 2022-04-27 21:30:30 +02:00
parent 9f7ab9c608
commit 0c9d1cfe18
3 changed files with 5 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
syncapi/storage/postgres/presence_table.go
View file

@ -72,7 +72,7 @@ const selectMaxPresenceSQL = "" +
const selectPresenceAfter = "" +
" SELECT id, user_id, presence, status_msg, last_active_ts" +
" FROM syncapi_presence" +
" WHERE id > $1 ORDER BY last_active_ts DESC LIMIT $2"
" WHERE id > $1 ORDER BY id DESC, last_active_ts DESC LIMIT $2"
type presenceStatements struct {
upsertPresenceStmt *sql.Stmt

2
syncapi/storage/sqlite3/presence_table.go
View file

@ -71,7 +71,7 @@ const selectMaxPresenceSQL = "" +
const selectPresenceAfter = "" +
" SELECT id, user_id, presence, status_msg, last_active_ts" +
" FROM syncapi_presence" +
" WHERE id > $1 ORDER BY last_active_ts DESC LIMIT $2"
" WHERE id > $1 ORDER BY id DESC, last_active_ts DESC LIMIT $2"
type presenceStatements struct {
db *sql.DB

3
syncapi/streams/stream_presence.go
View file

@ -135,6 +135,9 @@ func (p *PresenceStreamProvider) IncrementalSync(
if presence.StreamPos > lastPos {
lastPos = presence.StreamPos
}
if len(req.Response.Presence.Events) == req.Filter.Presence.Limit {
break
}
p.cache.Store(cacheKey, presence)
}