mirror of
https://github.com/router-for-me/CLIProxyAPI.git
synced 2026-06-23 21:00:29 +08:00
1d0551a991
- Refactored `ConfigReloadHook` to use `reloadConfigFromWatcher` for consistency. - Added async `reloadConfigAfterManagementSaveAsync` to handle post-save operations. - Introduced `ReloadConfigIfChanged` in watcher for manual trigger support. - Enhanced config reload paths to separate auth synthesis from standard updates. - Updated `applyConfigUpdate` logic to allow more granular reload behaviors. Closes: #3235
45 lines
1.2 KiB
Go
45 lines
1.2 KiB
Go
package cliproxy
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/router-for-me/CLIProxyAPI/v7/internal/watcher"
|
|
coreauth "github.com/router-for-me/CLIProxyAPI/v7/sdk/cliproxy/auth"
|
|
"github.com/router-for-me/CLIProxyAPI/v7/sdk/config"
|
|
)
|
|
|
|
func defaultWatcherFactory(configPath, authDir string, reload func(*config.Config)) (*WatcherWrapper, error) {
|
|
w, err := watcher.NewWatcher(configPath, authDir, reload)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return &WatcherWrapper{
|
|
start: func(ctx context.Context) error {
|
|
return w.Start(ctx)
|
|
},
|
|
stop: func() error {
|
|
return w.Stop()
|
|
},
|
|
setConfig: func(cfg *config.Config) {
|
|
w.SetConfig(cfg)
|
|
},
|
|
snapshotAuths: func() []*coreauth.Auth { return w.SnapshotCoreAuths() },
|
|
setUpdateQueue: func(queue chan<- watcher.AuthUpdate) {
|
|
w.SetAuthUpdateQueue(queue)
|
|
},
|
|
dispatchRuntimeUpdate: func(update watcher.AuthUpdate) bool {
|
|
return w.DispatchRuntimeAuthUpdate(update)
|
|
},
|
|
dispatchPersistedAuth: func(update watcher.AuthUpdate) bool {
|
|
return w.DispatchPersistedAuthUpdate(update)
|
|
},
|
|
setPluginAuthParser: func(parser PluginAuthParser) {
|
|
w.SetPluginAuthParser(parser)
|
|
},
|
|
reloadConfigIfChanged: func() {
|
|
w.ReloadConfigIfChanged()
|
|
},
|
|
}, nil
|
|
}
|