chuan/CLIProxyAPI
1
0
Fork 0
mirror of https://github.com/router-for-me/CLIProxyAPI.git synced 2026-02-18 20:30:51 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor(watcher): Filter irrelevant file system events early

Browse Source
This commit is contained in:
hkfires
2025-09-18 20:25:06 +08:00
parent 56b2dabcca
commit 8f0a345e2a
1 changed files with 11 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
internal/watcher/watcher.go
View File

@@ -137,11 +137,19 @@ func (w *Watcher) processEvents(ctx context.Context) {
// handleEvent processes individual file system events // handleEvent processes individual file system events
func (w *Watcher) handleEvent(event fsnotify.Event) { func (w *Watcher) handleEvent(event fsnotify.Event) {
// Filter only relevant events: config file or auth-dir JSON files.
isConfigEvent := event.Name == w.configPath && (event.Op&fsnotify.Write == fsnotify.Write || event.Op&fsnotify.Create == fsnotify.Create)
isAuthJSON := strings.HasPrefix(event.Name, w.authDir) && strings.HasSuffix(event.Name, ".json")
if !isConfigEvent && !isAuthJSON {
// Ignore unrelated files (e.g., cookie snapshots *.cookies) and other noise.
return
}
now := time.Now() now := time.Now()
log.Debugf("file system event detected: %s %s", event.Op.String(), event.Name) log.Debugf("file system event detected: %s %s", event.Op.String(), event.Name)
// Handle config file changes // Handle config file changes
if event.Name == w.configPath && (event.Op&fsnotify.Write == fsnotify.Write || event.Op&fsnotify.Create == fsnotify.Create) { if isConfigEvent {
log.Debugf("config file change details - operation: %s, timestamp: %s", event.Op.String(), now.Format("2006-01-02 15:04:05.000")) log.Debugf("config file change details - operation: %s, timestamp: %s", event.Op.String(), now.Format("2006-01-02 15:04:05.000"))
data, err := os.ReadFile(w.configPath) data, err := os.ReadFile(w.configPath)
if err != nil { if err != nil {
@@ -172,8 +180,8 @@ func (w *Watcher) handleEvent(event fsnotify.Event) {
return return
} }
// Handle auth directory changes incrementally // Handle auth directory changes incrementally (.json only)
if strings.HasPrefix(event.Name, w.authDir) && strings.HasSuffix(event.Name, ".json") { if isAuthJSON {
log.Infof("auth file changed (%s): %s, processing incrementally", event.Op.String(), filepath.Base(event.Name)) log.Infof("auth file changed (%s): %s, processing incrementally", event.Op.String(), filepath.Base(event.Name))
if event.Op&fsnotify.Create == fsnotify.Create || event.Op&fsnotify.Write == fsnotify.Write { if event.Op&fsnotify.Create == fsnotify.Create || event.Op&fsnotify.Write == fsnotify.Write {
w.addOrUpdateClient(event.Name) w.addOrUpdateClient(event.Name)