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
---
 testrig/processor.go | 4 ++--
 testrig/util.go      | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

(limited to 'testrig')

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)
-- 
cgit v1.3