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/db/bundb/list_test.go | 21 +++++++++++++++++++++
 1 file changed, 21 insertions(+)

(limited to 'internal/db/bundb/list_test.go')

diff --git a/internal/db/bundb/list_test.go b/internal/db/bundb/list_test.go
index 296ab7c1a..ca078d086 100644
--- a/internal/db/bundb/list_test.go
+++ b/internal/db/bundb/list_test.go
@@ -310,6 +310,27 @@ func (suite *ListTestSuite) TestDeleteListEntriesForFollowID() {
 	suite.checkList(testList, dbList)
 }
 
+func (suite *ListTestSuite) TestListIncludesAccount() {
+	ctx := context.Background()
+	testList, _ := suite.testStructs()
+
+	for accountID, expected := range map[string]bool{
+		suite.testAccounts["admin_account"].ID:   true,
+		suite.testAccounts["local_account_1"].ID: false,
+		suite.testAccounts["local_account_2"].ID: true,
+		"01H7074GEZJ56J5C86PFB0V2CT":             false,
+	} {
+		includes, err := suite.db.ListIncludesAccount(ctx, testList.ID, accountID)
+		if err != nil {
+			suite.FailNow(err.Error())
+		}
+
+		if includes != expected {
+			suite.FailNow("", "expected %t for accountID %s got %t", expected, accountID, includes)
+		}
+	}
+}
+
 func TestListTestSuite(t *testing.T) {
 	suite.Run(t, new(ListTestSuite))
 }
-- 
cgit v1.2.3