diff options
Diffstat (limited to 'testrig')
| -rw-r--r-- | testrig/processor.go | 4 | ||||
| -rw-r--r-- | testrig/util.go | 2 |
2 files changed, 3 insertions, 3 deletions
diff --git a/testrig/processor.go b/testrig/processor.go index 1839b482a..0c6d97253 100644 --- a/testrig/processor.go +++ b/testrig/processor.go @@ -28,7 +28,7 @@ import ( // NewTestProcessor returns a Processor suitable for testing purposes func NewTestProcessor(state *state.State, federator federation.Federator, emailSender email.Sender, mediaManager *media.Manager) *processing.Processor { p := processing.NewProcessor(NewTestTypeConverter(state.DB), federator, NewTestOauthServer(state.DB), mediaManager, state, emailSender) - state.Workers.EnqueueClientAPI = p.EnqueueClientAPI - state.Workers.EnqueueFederator = p.EnqueueFederator + state.Workers.EnqueueClientAPI = p.Workers().EnqueueClientAPI + state.Workers.EnqueueFediAPI = p.Workers().EnqueueFediAPI return p } diff --git a/testrig/util.go b/testrig/util.go index 4e52d12b5..483064e0a 100644 --- a/testrig/util.go +++ b/testrig/util.go @@ -37,7 +37,7 @@ import ( func StartWorkers(state *state.State) { state.Workers.EnqueueClientAPI = func(context.Context, ...messages.FromClientAPI) {} - state.Workers.EnqueueFederator = func(context.Context, ...messages.FromFederator) {} + state.Workers.EnqueueFediAPI = func(context.Context, ...messages.FromFediAPI) {} _ = state.Workers.Scheduler.Start(nil) _ = state.Workers.ClientAPI.Start(1, 10) |