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

Fixed membership not being saved on the right conditions + added membership removal

Browse source
This commit is contained in:
Brendan Abolivier 2017-07-12 19:05:17 +01:00
parent 9120188829
commit 013a0a3732
No known key found for this signature in database
GPG key ID: 8EF1500759F70623
1 changed files with 13 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/github.com/matrix-org/dendrite/clientapi/consumers/roomserver.go
View file

@ -89,9 +89,21 @@ func (s *OutputRoomEvent) onMessage(msg *sarama.ConsumerMessage) error {
if ev.Type() == "m.room.member" && ev.StateKey() != nil { if ev.Type() == "m.room.member" && ev.StateKey() != nil {
localpart := getLocalPart(*ev.StateKey()) localpart := getLocalPart(*ev.StateKey())
roomID := ev.RoomID() roomID := ev.RoomID()
membership, err := ev.Membership()
if err != nil {
return err
}
switch membership {
case "join":
if err := s.db.SaveMembership(localpart, roomID); err != nil { if err := s.db.SaveMembership(localpart, roomID); err != nil {
return err return err
} }
case "leave":
case "ban":
if err := s.db.RemoveMembership(localpart, roomID); err != nil {
return err
}
}
} }
return nil return nil