From f4555b870f163acbb6495ef8500811dde31477f9 Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Wed, 9 Sep 2020 17:45:33 +0100 Subject: [PATCH] Process events actually --- syncapi/consumers/roomserver.go | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) diff --git a/syncapi/consumers/roomserver.go b/syncapi/consumers/roomserver.go index d6d99e098..5ca1be118 100644 --- a/syncapi/consumers/roomserver.go +++ b/syncapi/consumers/roomserver.go @@ -129,11 +129,6 @@ 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) @@ -155,7 +150,7 @@ func (s *OutputRoomEventConsumer) onNewRoomEvent( msg.AddsStateEventIDs, msg.RemovesStateEventIDs, msg.TransactionID, - false, + msg.Type == api.OutputRoomState, ) if err != nil { // panic rather than continue with an inconsistent database