From ff05046df7c0ce21f70b0dd8dce59dd5e01771de Mon Sep 17 00:00:00 2001 From: tobi <31960611+tsmethurst@users.noreply.github.com> Date: Sat, 4 Sep 2021 13:29:56 +0200 Subject: tests + announce notification fix (#193) --- internal/processing/processor.go | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) (limited to 'internal/processing/processor.go') diff --git a/internal/processing/processor.go b/internal/processing/processor.go index 38076123f..5dcdca152 100644 --- a/internal/processing/processor.go +++ b/internal/processing/processor.go @@ -56,6 +56,10 @@ type Processor interface { Start(ctx context.Context) error // Stop stops the processor cleanly, finishing handling any remaining messages before closing down. Stop() error + // ProcessFromClientAPI processes one message coming from the clientAPI channel, and triggers appropriate side effects. + ProcessFromClientAPI(ctx context.Context, clientMsg messages.FromClientAPI) error + // ProcessFromFederator processes one message coming from the federator channel, and triggers appropriate side effects. + ProcessFromFederator(ctx context.Context, federatorMsg messages.FromFederator) error /* CLIENT API-FACING PROCESSING FUNCTIONS @@ -290,14 +294,14 @@ func (p *processor) Start(ctx context.Context) error { case clientMsg := <-p.fromClientAPI: p.log.Tracef("received message FROM client API: %+v", clientMsg) go func() { - if err := p.processFromClientAPI(ctx, clientMsg); err != nil { + if err := p.ProcessFromClientAPI(ctx, clientMsg); err != nil { p.log.Error(err) } }() case federatorMsg := <-p.fromFederator: p.log.Tracef("received message FROM federator: %+v", federatorMsg) go func() { - if err := p.processFromFederator(ctx, federatorMsg); err != nil { + if err := p.ProcessFromFederator(ctx, federatorMsg); err != nil { p.log.Error(err) } }() -- cgit v1.2.3