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

Check membership of room

Browse source
This commit is contained in:
Will Hunt 2021-01-04 12:49:38 +00:00
parent 597350a67f
commit 6ca7fa8a4d
1 changed files with 28 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

28
appservice/consumers/roomserver.go
View file

@ -159,5 +159,33 @@ func (s *OutputRoomEventConsumer) appserviceIsInterestedInEvent(ctx context.Cont
}).WithError(err).Errorf("Unable to get aliases for room")
}
// Check if any of the members in the room match the appservice
// TODO: appserviceIsInterestedInEvent should be wrapped in a cache
// as this part can involve a lot of DB lookups
membershipReq := api.QueryMembershipsForRoomRequest{
JoinedOnly: true,
RoomID: event.RoomID(),
}
var membershipRes api.QueryMembershipsForRoomResponse
// XXX: This should be membership at the time of the event, not current membership. I'm not sure
// how to extract this though, help?!
// TODO: We also don't need to get all the members. Could we query the DB directly with a set of
// regex to limit the cost involved?
log.WithFields(log.Fields{
"room_id": event.RoomID(),
"membership_count": len(membershipRes.JoinEvents),
}).Infof("Got membership")
if err := s.rsAPI.QueryMembershipsForRoom(ctx, &membershipReq, &membershipRes); err == nil {
for _, ev := range membershipRes.JoinEvents {
if appservice.IsInterestedInUserID(*ev.StateKey) {
return true
}
}
} else {
log.WithFields(log.Fields{
"room_id": event.RoomID(),
}).WithError(err).Errorf("Unable to get membership for room")
}
return false
}