diff options
| author |  tobi <31960611+tsmethurst@users.noreply.github.com> | 2021-09-04 13:29:56 +0200 |
|---|---|---|
| committer |  GitHub <noreply@github.com> | 2021-09-04 13:29:56 +0200 |
| commit | ff05046df7c0ce21f70b0dd8dce59dd5e01771de (patch) | |
| tree | 227720dc9ca30da106e508108eba08426e8bd2ee /internal/processing/processor.go | |
| parent | Merge pull request #186 from superseriousbusiness/struct_validation (diff) | |
| download | gotosocial-ff05046df7c0ce21f70b0dd8dce59dd5e01771de.tar.xz | |
tests + announce notification fix (#193)
Diffstat (limited to 'internal/processing/processor.go')
| -rw-r--r-- | internal/processing/processor.go | 8 |
1 files changed, 6 insertions, 2 deletions
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) } }() |