summaryrefslogtreecommitdiff
path: root/cmd/gotosocial/action/admin/media/prune/common.go
diff options
context:
space:
mode:
Diffstat (limited to 'cmd/gotosocial/action/admin/media/prune/common.go')
-rw-r--r--cmd/gotosocial/action/admin/media/prune/common.go17
1 files changed, 8 insertions, 9 deletions
diff --git a/cmd/gotosocial/action/admin/media/prune/common.go b/cmd/gotosocial/action/admin/media/prune/common.go
index 07b9c13bb..bd759a0d4 100644
--- a/cmd/gotosocial/action/admin/media/prune/common.go
+++ b/cmd/gotosocial/action/admin/media/prune/common.go
@@ -38,21 +38,24 @@ type prune struct {
func setupPrune(ctx context.Context) (*prune, error) {
var state state.State
state.Caches.Init()
+ state.Workers.Start()
dbService, err := bundb.NewBunDBService(ctx, &state)
if err != nil {
return nil, fmt.Errorf("error creating dbservice: %w", err)
}
- storage, err := gtsstorage.AutoConfig() //nolint:contextcheck
+ //nolint:contextcheck
+ storage, err := gtsstorage.AutoConfig()
if err != nil {
return nil, fmt.Errorf("error creating storage backend: %w", err)
}
- manager, err := media.NewManager(dbService, storage) //nolint:contextcheck
- if err != nil {
- return nil, fmt.Errorf("error instantiating mediamanager: %w", err)
- }
+ state.DB = dbService
+ state.Storage = storage
+
+ //nolint:contextcheck
+ manager := media.NewManager(&state)
return &prune{
dbService: dbService,
@@ -70,9 +73,5 @@ func (p *prune) shutdown(ctx context.Context) error {
return fmt.Errorf("error closing dbservice: %w", err)
}
- if err := p.manager.Stop(); err != nil {
- return fmt.Errorf("error closing media manager: %w", err)
- }
-
return nil
}