From ec670487f69bb1f6ecda0e2be55e7362ef07c873 Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Wed, 9 Sep 2020 17:36:14 +0100 Subject: [PATCH] Sync API don't consume state events --- syncapi/consumers/roomserver.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) 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