Function NewLifecycleManager

internal/processing/manager.go:85–115

(addFunc AddDownloadFunc, addWithIDFunc AddDownloadWithIDFunc, isNameActive ...IsNameActiveFunc)

}

func NewLifecycleManager(addFunc AddDownloadFunc, addWithIDFunc AddDownloadWithIDFunc, isNameActive ...IsNameActiveFunc) *LifecycleManager {
	// Snapshot settings once so enqueue can still make routing decisions even if
	// a later disk read fails or the caller never opens the settings UI.
	settings, err := config.LoadSettings()
	if err != nil {
		settings = config.DefaultSettings()
	}

	var activeCheck IsNameActiveFunc
	if len(isNameActive) > 0 {
		activeCheck = isNameActive[0]
	}

	probeCap := defaultMaxConcurrentProbes
	if settings != nil && config.Resolve[int](settings.Network.MaxConcurrentProbes) > 0 {
		probeCap = config.Resolve[int](settings.Network.MaxConcurrentProbes)
	}
	sem := make(chan struct{}, probeCap)
	for i := 0; i < probeCap; i++ {
		sem <- struct{}{}
	}

	return &LifecycleManager{
		settings:            settings,
		settingsRefreshedAt: time.Now(),
		addFunc:             addFunc,
		addWithIDFunc:       addWithIDFunc,
		isNameActive:        activeCheck,
		probeSem:            sem,
	}
}

// SetEngineHooks injects dependencies the manager needs to interact with the broader system
// (like the download worker pool or the event system) without causing cyclic dependency graphs.