mirrors/gotosocial
1
0
Fork 0
mirror of https://github.com/superseriousbusiness/gotosocial.git synced 2025-12-24 08:56:14 -06:00
Code Issues Projects Releases Packages Wiki Activity Actions

remove tryUntil

Browse source
This commit is contained in:
tobi 2025-03-05 17:07:56 +01:00
commit be85a5b642
7 changed files with 30 additions and 43 deletions
Download patch file Download diff file Expand all files Collapse all files

4
cmd/gotosocial/action/admin/account/account.go
View file

@ -38,7 +38,9 @@ import (
func initState(ctx context.Context) (*state.State, error) {
var state state.State
state.Caches.Init()
state.Caches.Start()
if err := state.Caches.Start(); err != nil {
return nil, fmt.Errorf("error starting caches: %w", err)
}
// Only set state DB connection.
// Don't need Actions or Workers for this (yet).

4
cmd/gotosocial/action/admin/media/list.go
View file

@ -125,7 +125,9 @@ func setupList(ctx context.Context) (*list, error) {
}
state.Caches.Init()
state.Caches.Start()
if err := state.Caches.Start(); err != nil {
return nil, fmt.Errorf("error starting caches: %w", err)
}
// Only set state DB connection.
// Don't need Actions or Workers for this.

4
cmd/gotosocial/action/admin/media/prune/common.go
View file

@ -42,7 +42,9 @@ func setupPrune(ctx context.Context) (*prune, error) {
var state state.State
state.Caches.Init()
state.Caches.Start()
if err := state.Caches.Start(); err != nil {
return nil, fmt.Errorf("error starting caches: %w", err)
}
// Scheduler is required for the
// cleaner, but no other workers

13
cmd/gotosocial/action/server/server.go
View file

@ -118,11 +118,10 @@ var Start action.GTSAction = func(ctx context.Context) error {
)
defer func() {
if state.Caches.Inited() {
// We reached a point where caches
// were initialized. Stop them.
state.Caches.Stop()
}
// Stop any started caches.
//
// Noop if never started.
state.Caches.Stop()
if route != nil {
// We reached a point where the API router
@ -207,7 +206,9 @@ var Start action.GTSAction = func(ctx context.Context) error {
// Initialize caches
state.Caches.Init()
state.Caches.Start()
if err := state.Caches.Start(); err != nil {
return fmt.Errorf("error starting caches: %w", err)
}
// Open connection to the database now caches started.
dbService, err := bundb.NewBunDBService(ctx, state)