diff --git a/syncapi/consumers/roomserver.go b/syncapi/consumers/roomserver.go index 5ca1be118..d6d99e098 100644 --- a/syncapi/consumers/roomserver.go +++ b/syncapi/consumers/roomserver.go @@ -129,6 +129,11 @@ func (s *OutputRoomEventConsumer) onNewRoomEvent( ctx context.Context, msg api.OutputNewRoomEvent, ) error { ev := msg.Event + if msg.Type == api.OutputRoomState { + s.notifyKeyChanges(&ev) + return nil + } + addsStateEvents := msg.AddsState() ev, err := s.updateStateEvent(ev) @@ -150,7 +155,7 @@ func (s *OutputRoomEventConsumer) onNewRoomEvent( msg.AddsStateEventIDs, msg.RemovesStateEventIDs, msg.TransactionID, - msg.Type == api.OutputRoomState, + false, ) if err != nil { // panic rather than continue with an inconsistent database