From 9770d54237bea828cab7e50aec7dff452c203138 Mon Sep 17 00:00:00 2001 From: tobi <31960611+tsmethurst@users.noreply.github.com> Date: Wed, 9 Aug 2023 19:14:33 +0200 Subject: [feature] List replies policy, refactor async workers (#2087) * Add/update some DB functions. * move async workers into subprocessor * rename FromFederator -> FromFediAPI * update home timeline check to include check for current status first before moving to parent status * change streamMap to pointer to mollify linter * update followtoas func signature * fix merge * remove errant debug log * don't use separate errs.Combine() check to wrap errs * wrap parts of workers functionality in sub-structs * populate report using new db funcs * embed federator (tiny bit tidier) * flesh out error msg, add continue(!) * fix other error messages to be more specific * better, nicer * give parseURI util function a bit more util * missing headers * use pointers for subprocessors --- internal/workers/workers.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'internal/workers/workers.go') diff --git a/internal/workers/workers.go b/internal/workers/workers.go index aa8e40e1c..965cf1d2a 100644 --- a/internal/workers/workers.go +++ b/internal/workers/workers.go @@ -43,7 +43,7 @@ type Workers struct { // these are pointers to Processor{}.Enqueue___() msg functions. // This prevents dependency cycling as Processor depends on Workers. EnqueueClientAPI func(context.Context, ...messages.FromClientAPI) - EnqueueFederator func(context.Context, ...messages.FromFederator) + EnqueueFediAPI func(context.Context, ...messages.FromFediAPI) // Media manager worker pools. Media runners.WorkerPool -- cgit v1.2.3