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

Limit room state events

Browse source 
Signed-off-by: Thibaut CHARLES cromfr@gmail.com
This commit is contained in:
Crom (Thibaut CHARLES) 2018-01-15 00:08:21 +01:00
parent cc56e0b88e
commit 97a5882d81
No known key found for this signature in database
GPG key ID: 45A3D5F880B9E6D0
1 changed files with 5 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
src/github.com/matrix-org/dendrite/syncapi/storage/current_room_state_table.go
View file

@ -72,7 +72,8 @@ const selectCurrentStateSQL = "" +
" AND ( $2::text[] IS NULL OR sender = ANY($2) )" + " AND ( $2::text[] IS NULL OR sender = ANY($2) )" +
" AND ( $3::text[] IS NULL OR NOT(sender = ANY($3)) )" + " AND ( $3::text[] IS NULL OR NOT(sender = ANY($3)) )" +
" AND ( $4::text[] IS NULL OR type LIKE ANY($4) )" + " AND ( $4::text[] IS NULL OR type LIKE ANY($4) )" +
" AND ( $5::text[] IS NULL OR NOT(type LIKE ANY($5)) )" " AND ( $5::text[] IS NULL OR NOT(type LIKE ANY($5)) )" +
" LIMIT $6"
const selectJoinedUsersSQL = "" + const selectJoinedUsersSQL = "" +
"SELECT room_id, state_key FROM syncapi_current_room_state WHERE type = 'm.room.member' AND membership = 'join'" "SELECT room_id, state_key FROM syncapi_current_room_state WHERE type = 'm.room.member' AND membership = 'join'"
@ -188,7 +189,9 @@ func (s *currentRoomStateStatements) selectCurrentState(
pq.StringArray(filter.Senders), pq.StringArray(filter.Senders),
pq.StringArray(filter.NotSenders), pq.StringArray(filter.NotSenders),
pq.StringArray(filterConvertWildcardToSQL(filter.Types)), pq.StringArray(filterConvertWildcardToSQL(filter.Types)),
pq.StringArray(filterConvertWildcardToSQL(filter.NotTypes))) pq.StringArray(filterConvertWildcardToSQL(filter.NotTypes)),
stateFilter.Limit,
)
if err != nil { if err != nil {
return nil, err return nil, err
} }