From 2ceff09003a366ac70f141e294a95e447f05f8f1 Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Wed, 31 Aug 2022 15:09:52 +0100 Subject: [PATCH] Rename function --- appservice/consumers/roomserver.go | 11 ++++------- 1 file changed, 4 insertions(+), 7 deletions(-) diff --git a/appservice/consumers/roomserver.go b/appservice/consumers/roomserver.go index 2df694440..5d969301e 100644 --- a/appservice/consumers/roomserver.go +++ b/appservice/consumers/roomserver.go @@ -147,7 +147,7 @@ func (s *OutputRoomEventConsumer) onMessage( } // Send event to any relevant application services - if err := s.filterRoomserverEvents(ctx, state, events); err != nil { + if err := s.sendEvents(ctx, state, events); err != nil { log.WithField("appservice", state.ID).WithError(err).Errorf("Appservice failed to filter events") return false } @@ -155,12 +155,9 @@ func (s *OutputRoomEventConsumer) onMessage( return true } -// filterRoomserverEvents takes in events and decides whether any of them need -// to be passed on to an external application service. It does this by checking -// each namespace of each registered application service, and if there is a -// match, adds the event to the queue for events to be sent to a particular -// application service. -func (s *OutputRoomEventConsumer) filterRoomserverEvents( +// sendEvents passes events to the appservice by using the transactions +// endpoint. It will block for the backoff period if necessary. +func (s *OutputRoomEventConsumer) sendEvents( ctx context.Context, state *appserviceState, events []*gomatrixserverlib.HeaderedEvent, ) error {