diff --git a/web/assets/js/subscription.js b/web/assets/js/subscription.js
index c7627837..b79d361c 100644
--- a/web/assets/js/subscription.js
+++ b/web/assets/js/subscription.js
@@ -138,14 +138,14 @@
return `streisand://import/${encodeURIComponent(this.app.subUrl)}`;
},
v2raytunUrl() {
- return this.app.subUrl;
+ return this.app.subUrl;
},
npvtunUrl() {
- return this.app.subUrl;
+ return this.app.subUrl;
},
- happUrl() {
- return `happ://add/${encodeURIComponent(this.app.subUrl)}`;
- }
+ happUrl() {
+ return `happ://add/${encodeURIComponent(this.app.subUrl)}`;
+ }
},
methods: {
renderLink,
diff --git a/web/html/common/page.html b/web/html/common/page.html
index 0af63afb..058682d5 100644
--- a/web/html/common/page.html
+++ b/web/html/common/page.html
@@ -24,6 +24,40 @@
body {
font-family: system-ui, -apple-system, BlinkMacSystemFont, 'Vazirmatn', 'Segoe UI', Roboto, Oxygen, Ubuntu, Cantarell, 'Open Sans', 'Helvetica Neue', sans-serif;
}
+
+ /* mobile touch scrolling for tabs */
+ @media (max-width: 576px) {
+ .ant-tabs-nav-container {
+ overflow-x: auto !important;
+ -webkit-overflow-scrolling: touch;
+ scroll-behavior: smooth;
+ overscroll-behavior-x: contain;
+ white-space: nowrap;
+ max-width: 100%;
+ padding: 0 !important; /* Remove padding for arrows */
+ }
+ .ant-tabs-nav-wrap {
+ overflow: visible !important;
+ padding: 0 !important;
+ }
+ .ant-tabs-nav-scroll {
+ overflow: visible !important;
+ box-shadow: none !important;
+ }
+ .ant-tabs-nav {
+ display: flex !important;
+ transform: none !important; /* Disable JS transform */
+ width: auto !important;
+ margin: 0 !important;
+ }
+ .ant-tabs-tab-prev,
+ .ant-tabs-tab-next {
+ display: none !important; /* Hide arrows */
+ }
+ .ant-tabs-nav-container::-webkit-scrollbar {
+ display: none;
+ }
+ }
{{ .host }} – {{ i18n .title}}
{{ end }}
diff --git a/web/html/form/protocol/vless.html b/web/html/form/protocol/vless.html
index bdf75be3..fc9c3852 100644
--- a/web/html/form/protocol/vless.html
+++ b/web/html/form/protocol/vless.html
@@ -1,6 +1,5 @@
{{define "form/vless"}}
-
+
{{template "form/client"}}
@@ -22,115 +21,103 @@
-
-
-
- X25519 (not
- Post-Quantum)
- ML-KEM-768
- (Post-Quantum)
-
-
-
-
-
-
-
-
-
-
- Get New
- keys
- Clear
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+ X25519 (not
+ Post-Quantum)
+ ML-KEM-768
+ (Post-Quantum)
+
+
+
+
+
+
+
+
+
+
+ Get New
+ keys
+ Clear
+
+
+
+
+
+
+
+
+
+
+
-
-
- Fallback [[ index + 1 ]]
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- Rand
-
-
- Reset
-
-
-
-
-
-
+
+
+ Fallback [[ index + 1 ]]
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ Rand
+
+
+ Reset
+
+
+
+
+
+
{{end}}
\ No newline at end of file
diff --git a/web/html/inbounds.html b/web/html/inbounds.html
index 4e1149ae..eeffd98d 100644
--- a/web/html/inbounds.html
+++ b/web/html/inbounds.html
@@ -1608,24 +1608,9 @@
// Listen for traffic updates
window.wsClient.on('traffic', (payload) => {
- if (payload && payload.clientTraffics && Array.isArray(payload.clientTraffics)) {
- // Update client traffic statistics
- payload.clientTraffics.forEach(clientTraffic => {
- const dbInbound = this.dbInbounds.find(ib => {
- if (!ib) return false;
- const clients = this.getInboundClients(ib);
- return clients && Array.isArray(clients) && clients.some(c => c && c.email === clientTraffic.email);
- });
- if (dbInbound && dbInbound.clientStats && Array.isArray(dbInbound.clientStats)) {
- const stats = dbInbound.clientStats.find(s => s && s.email === clientTraffic.email);
- if (stats) {
- stats.up = clientTraffic.up || stats.up;
- stats.down = clientTraffic.down || stats.down;
- stats.total = clientTraffic.total || stats.total;
- }
- }
- });
- }
+ // Note: Do NOT update total consumed traffic (stats.up, stats.down) from this event
+ // because clientTraffics contains delta/incremental values, not total accumulated values.
+ // Total traffic is updated via the 'inbounds' event which contains accumulated values from database.
// Update online clients list in real-time
if (payload && Array.isArray(payload.onlineClients)) {
@@ -1645,8 +1630,6 @@
}
});
- // Notifications disabled - white notifications are not needed
-
// Fallback to polling if WebSocket fails
window.wsClient.on('error', () => {
console.warn('WebSocket connection failed, falling back to polling');
diff --git a/web/html/settings/panel/subscription/subpage.html b/web/html/settings/panel/subscription/subpage.html
index 0043d0d2..222352ff 100644
--- a/web/html/settings/panel/subscription/subpage.html
+++ b/web/html/settings/panel/subscription/subpage.html
@@ -20,28 +20,20 @@
-
{{ i18n "pages.settings.language"
}}
-
-
-
-
+
+
+
@@ -53,42 +45,31 @@
-
-
+
+
-
+
{{ i18n
"pages.settings.subSettings"}}
-
-
-
+
-
+
{{ i18n
"pages.settings.subSettings"}}
Json
-
-
@@ -100,45 +81,36 @@
- [[
+ [[
app.sId
]]
-
+
{{ i18n
"subscription.unlimited" }}
- [[
+ [[
isActive ? '{{ i18n
"subscription.active" }}' : '{{ i18n
"subscription.inactive" }}'
]]
- [[
+ [[
app.download
]]
- [[
+ [[
app.upload
]]
- [[ app.used
+ [[ app.used
]]
- [[
+ [[
app.total
]]
- [[
+ [[
app.remained ]]
-
+
[[ IntlUtil.formatDate(app.lastOnlineMs) ]]
@@ -146,8 +118,7 @@
-
-
+
{{ i18n "subscription.noExpiry" }}
@@ -160,32 +131,48 @@
-
-
-
-
[[ linkName(link, idx)
- ]]
+
+
+
+ [[ linkName(link, idx) ]]
+
+
+ [[ link ]]
-
-
+
+
+
-
-
+
+
+ :style="{ marginTop: isMobile ? '6px' : 0 }" size="large" type="primary">
Android
-
+
V2Box
Sing-box
V2RayTun
- NPV
+ NPV
Tunnel
- Happ
+ Happ
-
+
+ :style="{ marginTop: isMobile ? '6px' : 0 }" size="large" type="primary">
iOS
-
+
Shadowrocket
- V2Box
+ V2Box
Streisand
V2RayTun
- NPV
+ NPV
Tunnel
- Happ
+ Happ
@@ -240,17 +220,12 @@
-
-
{{template "component/aThemeSwitch" .}}
diff --git a/web/html/settings/xray/outbounds.html b/web/html/settings/xray/outbounds.html
index a5211fca..1c099308 100644
--- a/web/html/settings/xray/outbounds.html
+++ b/web/html/settings/xray/outbounds.html
@@ -3,8 +3,8 @@
-
- {{ i18n "pages.xray.outbound.addOutbound" }}
+
+ {{ i18n "pages.xray.outbound.addOutbound" }}
WARP
diff --git a/web/html/xray.html b/web/html/xray.html
index ce5e1ab7..186156ff 100644
--- a/web/html/xray.html
+++ b/web/html/xray.html
@@ -269,7 +269,7 @@
tag: "direct",
protocol: "freedom"
},
- routingDomainStrategies: ["AsIs", "IpIfNonMatch", "IpOnDemand"],
+ routingDomainStrategies: ["AsIs", "IPIfNonMatch", "IPOnDemand"],
log: {
loglevel: ["none", "debug", "info", "warning", "error"],
access: ["none", "./access.log"],
@@ -968,6 +968,17 @@
await this.getXraySetting();
await this.getXrayResult();
await this.getOutboundsTraffic();
+
+ if (window.wsClient) {
+ window.wsClient.connect();
+ window.wsClient.on('outbounds', (payload) => {
+ if (payload) {
+ this.outboundsTraffic = payload;
+ this.$forceUpdate();
+ }
+ });
+ }
+
while (true) {
await PromiseUtil.sleep(800);
this.saveBtnDisable = this.oldXraySetting === this.xraySetting;
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) {
diff --git a/web/service/inbound.go b/web/service/inbound.go
index 66e87a4f..469fa561 100644
--- a/web/service/inbound.go
+++ b/web/service/inbound.go
@@ -1010,12 +1010,12 @@ func (s *InboundService) addClientTraffic(tx *gorm.DB, traffics []*xray.ClientTr
if len(traffics) == 0 {
// Empty onlineUsers
if p != nil {
- p.SetOnlineClients(nil)
+ p.SetOnlineClients(make([]string, 0))
}
return nil
}
- var onlineClients []string
+ onlineClients := make([]string, 0)
emails := make([]string, 0, len(traffics))
for _, traffic := range traffics {
diff --git a/web/websocket/hub.go b/web/websocket/hub.go
index 187ebb6f..7ee93405 100644
--- a/web/websocket/hub.go
+++ b/web/websocket/hub.go
@@ -20,6 +20,7 @@ const (
MessageTypeInbounds MessageType = "inbounds" // Inbounds list update
MessageTypeNotification MessageType = "notification" // System notification
MessageTypeXrayState MessageType = "xray_state" // Xray state change
+ MessageTypeOutbounds MessageType = "outbounds" // Outbounds list update
)
// Message represents a WebSocket message
diff --git a/web/websocket/notifier.go b/web/websocket/notifier.go
index cedf56f2..416adaff 100644
--- a/web/websocket/notifier.go
+++ b/web/websocket/notifier.go
@@ -48,6 +48,14 @@ func BroadcastInbounds(inbounds interface{}) {
}
}
+// BroadcastOutbounds broadcasts outbounds list update to all connected clients
+func BroadcastOutbounds(outbounds interface{}) {
+ hub := GetHub()
+ if hub != nil {
+ hub.Broadcast(MessageTypeOutbounds, outbounds)
+ }
+}
+
// BroadcastNotification broadcasts a system notification to all connected clients
func BroadcastNotification(title, message, level string) {
hub := GetHub()