startup_recovery.go RawHistoryFolder

1package app
2
3import (
4	"context"
5
6	"github.com/bnema/zerowrap"
7
8	"github.com/bnema/gordon/internal/domain"
9)
10
11// startupConfigService defines the route configuration needed during startup
12// recovery. It intentionally excludes auto-route settings because reboot
13// recovery always works from configured routes.
14type startupConfigService interface {
15	GetRoutes(ctx context.Context) []domain.Route
16}
17
18// startupContainerService defines the container lifecycle operations needed
19// during startup recovery.
20type startupContainerService interface {
21	SyncContainers(ctx context.Context) error
22	AutoStart(ctx context.Context, routes []domain.Route) error
23	StartMonitor(ctx context.Context)
24}
25
26// syncAndRecoverConfiguredRoutes performs best-effort startup recovery for
27// configured routes after listeners are ready.
28func syncAndRecoverConfiguredRoutes(
29	ctx context.Context,
30	configSvc startupConfigService,
31	containerSvc startupContainerService,
32	log zerowrap.Logger,
33) {
34	defer containerSvc.StartMonitor(ctx)
35
36	if err := containerSvc.SyncContainers(ctx); err != nil {
37		log.Warn().Err(err).Msg("failed to sync existing containers")
38	}
39
40	routes := configSvc.GetRoutes(ctx)
41	if err := containerSvc.AutoStart(domain.WithInternalDeploy(ctx), routes); err != nil {
42		log.Warn().Err(err).Msg("failed to auto-start configured routes")
43	}
44}