summaryrefslogtreecommitdiff
path: root/testrig/federator.go
diff options
context:
space:
mode:
Diffstat (limited to 'testrig/federator.go')
-rw-r--r--testrig/federator.go4
1 files changed, 2 insertions, 2 deletions
diff --git a/testrig/federator.go b/testrig/federator.go
index 475ed3346..0546325ab 100644
--- a/testrig/federator.go
+++ b/testrig/federator.go
@@ -20,15 +20,15 @@ package testrig
import (
"codeberg.org/gruf/go-store/kv"
+ "github.com/superseriousbusiness/gotosocial/internal/concurrency"
"github.com/superseriousbusiness/gotosocial/internal/db"
"github.com/superseriousbusiness/gotosocial/internal/federation"
"github.com/superseriousbusiness/gotosocial/internal/media"
"github.com/superseriousbusiness/gotosocial/internal/messages"
"github.com/superseriousbusiness/gotosocial/internal/transport"
- "github.com/superseriousbusiness/gotosocial/internal/worker"
)
// NewTestFederator returns a federator with the given database and (mock!!) transport controller.
-func NewTestFederator(db db.DB, tc transport.Controller, storage *kv.KVStore, mediaManager media.Manager, fedWorker *worker.Worker[messages.FromFederator]) federation.Federator {
+func NewTestFederator(db db.DB, tc transport.Controller, storage *kv.KVStore, mediaManager media.Manager, fedWorker *concurrency.WorkerPool[messages.FromFederator]) federation.Federator {
return federation.NewFederator(db, NewTestFederatingDB(db, fedWorker), tc, NewTestTypeConverter(db), mediaManager)
}