enhance(cache): handle symlinks in file event handler

Author: 0xJacky

api/analytic/analytic.go

@@ -94,6 +94,7 @@ func Analytic(c *gin.Context) {
 
 		select {
 		case <-kernel.Context.Done():
+			logger.Debug("Analytic: Context cancelled, closing WebSocket")
 			return
 		case <-time.After(1 * time.Second):
 		}

api/analytic/nodes.go

@@ -86,6 +86,7 @@ func GetNodeStat(c *gin.Context) {
 
 		select {
 		case <-kernel.Context.Done():
+			logger.Debug("GetNodeStat: Context cancelled, closing WebSocket")
 			return
 		case <-time.After(10 * time.Second):
 		}
@@ -119,6 +120,7 @@ func GetNodesAnalytic(c *gin.Context) {
 
 		select {
 		case <-kernel.Context.Done():
+			logger.Debug("GetNodesAnalytic: Context cancelled, closing WebSocket")
 			return
 		case <-time.After(10 * time.Second):
 		}

api/event/websocket.go

@@ -179,6 +179,7 @@ func (c *Client) writePump() {
 			return
 
 		case <-kernel.Context.Done():
+			logger.Debug("EventBus: Context cancelled, closing WebSocket")
 			return
 		}
 	}

api/nginx/websocket.go

@@ -80,6 +80,7 @@ func (h *NginxPerformanceHub) run() {
 			h.broadcastPerformanceData()
 
 		case <-kernel.Context.Done():
+			logger.Debug("NginxPerformanceHub: Context cancelled, closing WebSocket")
 			// Shutdown all clients
 			h.mutex.Lock()
 			for client := range h.clients {
@@ -200,6 +201,7 @@ func (c *NginxPerformanceClient) writePump() {
 			return
 
 		case <-kernel.Context.Done():
+			logger.Debug("NginxPerformanceClient: Context cancelled, closing WebSocket")
 			return
 		}
 	}

internal/cache/index.go

@@ -216,12 +216,28 @@ func (s *Scanner) handleFileEvent(event fsnotify.Event) {
 		return
 	}
 
-	fi, err := os.Stat(event.Name)
+	// Use Lstat to get symlink info without following it
+	fi, err := os.Lstat(event.Name)
 	if err != nil {
 		return
 	}
 
-	if fi.IsDir() {
+	// If it's a symlink, we need to check what it points to
+	var targetIsDir bool
+	if fi.Mode()&os.ModeSymlink != 0 {
+		// For symlinks, check the target
+		targetFi, err := os.Stat(event.Name)
+		if err != nil {
+			logger.Debug("Symlink target not accessible:", event.Name, err)
+			return
+		}
+		targetIsDir = targetFi.IsDir()
+		logger.Debug("Symlink changed:", event.Name, "-> target is dir:", targetIsDir)
+	} else {
+		targetIsDir = fi.IsDir()
+	}
+
+	if targetIsDir {
 		logger.Debug("Directory changed:", event.Name)
 	} else {
 		logger.Debug("File changed:", event.Name)