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

Filter by membership event

Browse source
This commit is contained in:
Brendan Abolivier 2017-08-23 12:19:56 +01:00
parent 266cb16e61
commit 9a9275559c
No known key found for this signature in database
GPG key ID: 8EF1500759F70623
1 changed files with 9 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/github.com/matrix-org/dendrite/roomserver/storage/storage.go
View file

@ -574,8 +574,10 @@ func (d *Database) getMembershipsBeforeEventNID(eventNID types.EventNID) ([]type
var eventNIDs []types.EventNID var eventNIDs []types.EventNID
for _, entry := range stateEntries { for _, entry := range stateEntries {
if entry.EventStateKeyNID == types.MRoomMemberNID {
eventNIDs = append(eventNIDs, entry.EventNID) eventNIDs = append(eventNIDs, entry.EventNID)
} }
}
// Get all of the events in this state // Get all of the events in this state
stateEvents, err := d.Events(eventNIDs) stateEvents, err := d.Events(eventNIDs)
@ -585,7 +587,6 @@ func (d *Database) getMembershipsBeforeEventNID(eventNID types.EventNID) ([]type
// Filter the events to only keep the "join" membership events // Filter the events to only keep the "join" membership events
for _, event := range stateEvents { for _, event := range stateEvents {
if event.Type() == "m.room.member" {
membership, err := event.Membership() membership, err := event.Membership()
if err != nil { if err != nil {
return nil, err return nil, err
@ -595,7 +596,6 @@ func (d *Database) getMembershipsBeforeEventNID(eventNID types.EventNID) ([]type
events = append(events, event) events = append(events, event)
} }
} }
}
return events, nil return events, nil
} }