From 4800f8fb706a092a38255ee70904227238b2a6f6 Mon Sep 17 00:00:00 2001 From: lolka1333 Date: Mon, 5 Jan 2026 05:50:40 +0100 Subject: feat: Real-time Outbound Traffic, UI Improvements & Fix (#3629) * Refactor HTML and JavaScript for improved UI and functionality - Cleaned up JavaScript methods in subscription.js for better readability. - Updated inbounds.html to clarify traffic update handling and removed unnecessary comments. - Enhanced xray.html by correcting casing in routingDomainStrategies. - Added mobile touch scrolling styles in page.html for better tab navigation on small screens. - Streamlined vless.html by removing redundant line breaks and improving form layout. - Refined subscription subpage.html for better structure and user experience. - Adjusted outbounds.html to improve button visibility and functionality. - Updated xray_traffic_job.go to ensure accurate traffic updates and real-time UI refresh. * Refactor client traffic handling in InboundService - Updated addClientTraffic method to initialize onlineClients as an empty slice instead of nil. - Improved clarity and consistency in handling empty onlineUsers scenario. * Add WebSocket support for outbounds traffic updates - Implemented WebSocket connection in xray.html to handle real-time updates for outbounds traffic. - Enhanced xray_traffic_job.go to retrieve and broadcast outbounds traffic updates. - Introduced MessageTypeOutbounds in hub.go for managing outbounds messages. - Added BroadcastOutbounds function in notifier.go to facilitate broadcasting outbounds updates to connected clients. --------- Co-authored-by: lolka1333 --- web/job/xray_traffic_job.go | 24 +++++++++++++++++++++++- 1 file changed, 23 insertions(+), 1 deletion(-) (limited to 'web/job') diff --git a/web/job/xray_traffic_job.go b/web/job/xray_traffic_job.go index 2f331cd6..33a432b5 100644 --- a/web/job/xray_traffic_job.go +++ b/web/job/xray_traffic_job.go @@ -58,7 +58,19 @@ func (j *XrayTrafficJob) Run() { lastOnlineMap = make(map[string]int64) } - // Broadcast traffic update via WebSocket + // Fetch updated inbounds from database with accumulated traffic values + // This ensures frontend receives the actual total traffic, not just delta values + updatedInbounds, err := j.inboundService.GetAllInbounds() + if err != nil { + logger.Warning("get all inbounds for websocket failed:", err) + } + + updatedOutbounds, err := j.outboundService.GetOutboundsTraffic() + if err != nil { + logger.Warning("get all outbounds for websocket failed:", err) + } + + // Broadcast traffic update via WebSocket with accumulated values from database trafficUpdate := map[string]interface{}{ "traffics": traffics, "clientTraffics": clientTraffics, @@ -66,6 +78,16 @@ func (j *XrayTrafficJob) Run() { "lastOnlineMap": lastOnlineMap, } websocket.BroadcastTraffic(trafficUpdate) + + // Broadcast full inbounds update for real-time UI refresh + if updatedInbounds != nil { + websocket.BroadcastInbounds(updatedInbounds) + } + + if updatedOutbounds != nil { + websocket.BroadcastOutbounds(updatedOutbounds) + } + } func (j *XrayTrafficJob) informTrafficToExternalAPI(inboundTraffics []*xray.Traffic, clientTraffics []*xray.ClientTraffic) { -- cgit v1.2.3