diff options
Diffstat (limited to 'testrig/processor.go')
| -rw-r--r-- | testrig/processor.go | 7 |
1 files changed, 1 insertions, 6 deletions
diff --git a/testrig/processor.go b/testrig/processor.go index e8a871422..a1bab4f9a 100644 --- a/testrig/processor.go +++ b/testrig/processor.go @@ -31,10 +31,5 @@ import ( // The passed in state will have its worker functions set appropriately, // but the state will not be initialized. func NewTestProcessor(state *state.State, federator *federation.Federator, emailSender email.Sender, mediaManager *media.Manager) *processing.Processor { - p := processing.NewProcessor(cleaner.New(state), typeutils.NewConverter(state), federator, NewTestOauthServer(state.DB), mediaManager, state, emailSender) - state.Workers.EnqueueClientAPI = p.Workers().EnqueueClientAPI - state.Workers.EnqueueFediAPI = p.Workers().EnqueueFediAPI - state.Workers.ProcessFromClientAPI = p.Workers().ProcessFromClientAPI - state.Workers.ProcessFromFediAPI = p.Workers().ProcessFromFediAPI - return p + return processing.NewProcessor(cleaner.New(state), typeutils.NewConverter(state), federator, NewTestOauthServer(state.DB), mediaManager, state, emailSender) } |