diff options
Diffstat (limited to 'internal/processing/account/account.go')
| -rw-r--r-- | internal/processing/account/account.go | 39 |
1 files changed, 20 insertions, 19 deletions
diff --git a/internal/processing/account/account.go b/internal/processing/account/account.go index 2a9e5f898..c49df1a1a 100644 --- a/internal/processing/account/account.go +++ b/internal/processing/account/account.go @@ -33,6 +33,7 @@ import ( "github.com/superseriousbusiness/gotosocial/internal/text" "github.com/superseriousbusiness/gotosocial/internal/typeutils" "github.com/superseriousbusiness/gotosocial/internal/visibility" + "github.com/superseriousbusiness/gotosocial/internal/worker" "github.com/superseriousbusiness/oauth2/v4" ) @@ -81,28 +82,28 @@ type Processor interface { } type processor struct { - tc typeutils.TypeConverter - mediaManager media.Manager - fromClientAPI chan messages.FromClientAPI - oauthServer oauth.Server - filter visibility.Filter - formatter text.Formatter - db db.DB - federator federation.Federator - parseMention gtsmodel.ParseMentionFunc + tc typeutils.TypeConverter + mediaManager media.Manager + clientWorker *worker.Worker[messages.FromClientAPI] + oauthServer oauth.Server + filter visibility.Filter + formatter text.Formatter + db db.DB + federator federation.Federator + parseMention gtsmodel.ParseMentionFunc } // New returns a new account processor. -func New(db db.DB, tc typeutils.TypeConverter, mediaManager media.Manager, oauthServer oauth.Server, fromClientAPI chan messages.FromClientAPI, federator federation.Federator, parseMention gtsmodel.ParseMentionFunc) Processor { +func New(db db.DB, tc typeutils.TypeConverter, mediaManager media.Manager, oauthServer oauth.Server, clientWorker *worker.Worker[messages.FromClientAPI], federator federation.Federator, parseMention gtsmodel.ParseMentionFunc) Processor { return &processor{ - tc: tc, - mediaManager: mediaManager, - fromClientAPI: fromClientAPI, - oauthServer: oauthServer, - filter: visibility.NewFilter(db), - formatter: text.NewFormatter(db), - db: db, - federator: federator, - parseMention: parseMention, + tc: tc, + mediaManager: mediaManager, + clientWorker: clientWorker, + oauthServer: oauthServer, + filter: visibility.NewFilter(db), + formatter: text.NewFormatter(db), + db: db, + federator: federator, + parseMention: parseMention, } } |