enhance(upstream): proxy target parsing from multiple configs

Author: 0xJacky

api/analytic/nodes.go

@@ -65,8 +65,6 @@ func GetNodeStat(c *gin.Context) {
 					NodeInfo: nodeInfo,
 					NodeStat: stat,
 				}
-
-				logger.Debugf("Sending complete node info including version: %s", ver.Version)
 			}
 		} else {
 			// Send only stat information for performance

internal/cron/upstream_availability.go

@@ -3,7 +3,6 @@ package cron
 import (
 	"time"
 
-	apiUpstream "github.com/0xJacky/Nginx-UI/api/upstream"
 	"github.com/0xJacky/Nginx-UI/internal/upstream"
 	"github.com/go-co-op/gocron/v2"
 	"github.com/uozi-tech/cosy/logger"
@@ -41,13 +40,6 @@ func executeUpstreamAvailabilityTest() {
 		return
 	}
 
-	// Check if we should skip this test due to active WebSocket connections
-	// (WebSocket connections trigger more frequent checks)
-	if hasActiveWebSocketConnections() {
-		logger.Debug("Skipping scheduled test due to active WebSocket connections")
-		return
-	}
-
 	start := time.Now()
 	logger.Debug("Starting scheduled upstream availability test for", targetCount, "targets")
 
@@ -57,11 +49,6 @@ func executeUpstreamAvailabilityTest() {
 	logger.Debug("Upstream availability test completed in", duration)
 }
 
-// hasActiveWebSocketConnections checks if there are active WebSocket connections
-func hasActiveWebSocketConnections() bool {
-	return apiUpstream.HasActiveWebSocketConnections()
-}
-
 // RestartUpstreamAvailabilityJob restarts the upstream availability job
 func RestartUpstreamAvailabilityJob() error {
 	logger.Info("Restarting upstream availability job...")

internal/site/index.go

@@ -220,6 +220,13 @@ func scanForSite(configPath string, content []byte) error {
 		siteIndex.Urls = append(siteIndex.Urls, url)
 	}
 
+	// Ensure upstream service has the latest global upstream definitions
+	upstreamService := upstream.GetUpstreamService()
+	if upstreamService != nil {
+		// Force a rescan of all upstream definitions to ensure we have the latest global state
+		upstreamService.RefreshGlobalUpstreams()
+	}
+
 	// Parse proxy targets from the configuration content
 	siteIndex.ProxyTargets = upstream.ParseProxyTargetsFromRawContent(string(content))
 

internal/stream/index.go

@@ -41,6 +41,13 @@ func scanForStream(configPath string, content []byte) error {
 		ProxyTargets: []upstream.ProxyTarget{},
 	}
 
+	// Ensure upstream service has the latest global upstream definitions
+	upstreamService := upstream.GetUpstreamService()
+	if upstreamService != nil {
+		// Force a rescan of all upstream definitions to ensure we have the latest global state
+		upstreamService.RefreshGlobalUpstreams()
+	}
+
 	// Parse proxy targets from the configuration content
 	streamIndex.ProxyTargets = upstream.ParseProxyTargetsFromRawContent(string(content))
 	// Only store if we found proxy targets