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

Bulk fetch events for restricted room join members

Browse source
This commit is contained in:
Devon Hudson 2023-05-15 13:00:13 -06:00
parent faa0aa0744
commit 9742cbfe78
No known key found for this signature in database
GPG key ID: CD06B18E77F6A628
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
roomserver/internal/query/query.go
View file

@ -882,15 +882,15 @@ func (r *Queryer) GetLocallyJoinedUsers(ctx context.Context, roomVersion gomatri
return nil, err return nil, err
} }
events, err := r.DB.Events(ctx, roomVersion, joinNIDs)
if err != nil {
return nil, err
}
// For each of the joined users, let's see if we can get a valid // For each of the joined users, let's see if we can get a valid
// membership event. // membership event.
joinedUsers := []gomatrixserverlib.PDU{} joinedUsers := []gomatrixserverlib.PDU{}
for _, joinNID := range joinNIDs { for _, event := range events {
events, err := r.DB.Events(ctx, roomVersion, []types.EventNID{joinNID})
if err != nil || len(events) != 1 {
continue
}
event := events[0]
if event.Type() != spec.MRoomMember || event.StateKey() == nil { if event.Type() != spec.MRoomMember || event.StateKey() == nil {
continue // shouldn't happen continue // shouldn't happen
} }