From 942491cef49c7a8550ec47f6fadc54e01a5f1599 Mon Sep 17 00:00:00 2001 From: Kegan Dougal Date: Thu, 11 Jun 2020 18:20:30 +0100 Subject: [PATCH] Only include adds not the current event --- federationsender/consumers/roomserver.go | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/federationsender/consumers/roomserver.go b/federationsender/consumers/roomserver.go index adca255f7..ff5230161 100644 --- a/federationsender/consumers/roomserver.go +++ b/federationsender/consumers/roomserver.go @@ -131,9 +131,7 @@ func (s *OutputRoomEventConsumer) onMessage(msg *sarama.ConsumerMessage) error { // processMessage updates the list of currently joined hosts in the room // and then sends the event to the hosts that were joined before the event. func (s *OutputRoomEventConsumer) processMessage(ore api.OutputNewRoomEvent) error { - addStateEvents := []gomatrixserverlib.HeaderedEvent{ore.Event} - addStateEvents = append(addStateEvents, ore.AddStateEvents...) - addsJoinedHosts, err := joinedHostsFromEvents(gomatrixserverlib.UnwrapEventHeaders(addStateEvents)) + addsJoinedHosts, err := joinedHostsFromEvents(gomatrixserverlib.UnwrapEventHeaders(ore.AddStateEvents)) if err != nil { return err }