mirror of
https://github.com/MHSanaei/3x-ui.git
synced 2026-01-11 00:11:27 +00:00
4800f8fb70
* 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 <test123@gmail.com>
82 lines
2 KiB
Go
82 lines
2 KiB
Go
// Package websocket provides WebSocket hub for real-time updates and notifications.
|
|
package websocket
|
|
|
|
import (
|
|
"github.com/mhsanaei/3x-ui/v2/logger"
|
|
"github.com/mhsanaei/3x-ui/v2/web/global"
|
|
)
|
|
|
|
// GetHub returns the global WebSocket hub instance
|
|
func GetHub() *Hub {
|
|
webServer := global.GetWebServer()
|
|
if webServer == nil {
|
|
return nil
|
|
}
|
|
hub := webServer.GetWSHub()
|
|
if hub == nil {
|
|
return nil
|
|
}
|
|
wsHub, ok := hub.(*Hub)
|
|
if !ok {
|
|
logger.Warning("WebSocket hub type assertion failed")
|
|
return nil
|
|
}
|
|
return wsHub
|
|
}
|
|
|
|
// BroadcastStatus broadcasts server status update to all connected clients
|
|
func BroadcastStatus(status interface{}) {
|
|
hub := GetHub()
|
|
if hub != nil {
|
|
hub.Broadcast(MessageTypeStatus, status)
|
|
}
|
|
}
|
|
|
|
// BroadcastTraffic broadcasts traffic statistics update to all connected clients
|
|
func BroadcastTraffic(traffic interface{}) {
|
|
hub := GetHub()
|
|
if hub != nil {
|
|
hub.Broadcast(MessageTypeTraffic, traffic)
|
|
}
|
|
}
|
|
|
|
// BroadcastInbounds broadcasts inbounds list update to all connected clients
|
|
func BroadcastInbounds(inbounds interface{}) {
|
|
hub := GetHub()
|
|
if hub != nil {
|
|
hub.Broadcast(MessageTypeInbounds, inbounds)
|
|
}
|
|
}
|
|
|
|
// 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()
|
|
if hub != nil {
|
|
notification := map[string]string{
|
|
"title": title,
|
|
"message": message,
|
|
"level": level, // info, warning, error, success
|
|
}
|
|
hub.Broadcast(MessageTypeNotification, notification)
|
|
}
|
|
}
|
|
|
|
// BroadcastXrayState broadcasts Xray state change to all connected clients
|
|
func BroadcastXrayState(state string, errorMsg string) {
|
|
hub := GetHub()
|
|
if hub != nil {
|
|
stateUpdate := map[string]string{
|
|
"state": state,
|
|
"errorMsg": errorMsg,
|
|
}
|
|
hub.Broadcast(MessageTypeXrayState, stateUpdate)
|
|
}
|
|
}
|