mirror of
https://github.com/MHSanaei/3x-ui.git
synced 2026-04-22 15:35:52 +00:00
* feat: implement real-time traffic monitoring and UI updates using a high-performance WebSocket hub and background job system * feat: add bulk client management support and improve inbound data handling * Fix bug * **Fixes & Changes:** 1. **Fixed XPadding Placement Dropdown**: - Added the missing `cookie` and `query` options to `xPaddingPlacement` (`stream_xhttp.html`). - *Why:* Previously, users wanting `cookie` obfuscation were forced to use the `header` placement string. This caused Xray-core to blindly intercept the entire monolithic HTTP Cookie header, failing internal padding-length validations and causing the inbound to silently drop the connection. 2. **Fixed Uplink Data Placement Validation**: - Replaced the unsupported `query` option with `cookie` in `uplinkDataPlacement`. - *Why:* Xray-core's `transport_internet.go` explicitly forbids `query` as an uplink placement option. Selecting it from the UI previously sent a payload that would cause Xray-core to instantly throw an `unsupported uplink data placement: query` panic. Adding `cookie` perfectly aligns the UI with Xray-core restrictions. ### Related Issues - Resolves #3992 * This commit fixes structural payload issues preventing XHTTP from functioning correctly and eliminates WebSocket log spam. - **[Fix X-Padding UI]** Added missing `cookie` and `query` options to X-Padding Placement. Fixes the issue where using Cookie fallback triggers whole HTTP Cookie header interception and silent drop in Xray-core. (Resolves [#3992](https://github.com/MHSanaei/3x-ui/issues/3992)) - **[Fix Uplink Data Options]** Replaced the invalid `query` option with `cookie` in Uplink Data Placement dropdown to prevent Xray-core backend panic `unsupported uplink data placement: query`. - **[Fix WebSockets Spam]** Boosted `maxMessageSize` boundary to 100MB and gracefully handled fallback fetch signals via `broadcastInvalidate` to avoid buffer dropping spam. (Resolves [#3984](https://github.com/MHSanaei/3x-ui/issues/3984)) * Fix * gofmt * fix(websocket): resolve channel race condition and graceful shutdown deadlock * Fix: inbounds switch * Change max quantity from 10000 to 500 * fix
174 lines
No EOL
4.2 KiB
JavaScript
174 lines
No EOL
4.2 KiB
JavaScript
class DBInbound {
|
|
|
|
constructor(data) {
|
|
this.id = 0;
|
|
this.userId = 0;
|
|
this.up = 0;
|
|
this.down = 0;
|
|
this.total = 0;
|
|
this.allTime = 0;
|
|
this.remark = "";
|
|
this.enable = true;
|
|
this.expiryTime = 0;
|
|
this.trafficReset = "never";
|
|
this.lastTrafficResetTime = 0;
|
|
|
|
this.listen = "";
|
|
this.port = 0;
|
|
this.protocol = "";
|
|
this.settings = "";
|
|
this.streamSettings = "";
|
|
this.tag = "";
|
|
this.sniffing = "";
|
|
this.clientStats = ""
|
|
if (data == null) {
|
|
return;
|
|
}
|
|
ObjectUtil.cloneProps(this, data);
|
|
}
|
|
|
|
get totalGB() {
|
|
return NumberFormatter.toFixed(this.total / SizeFormatter.ONE_GB, 2);
|
|
}
|
|
|
|
set totalGB(gb) {
|
|
this.total = NumberFormatter.toFixed(gb * SizeFormatter.ONE_GB, 0);
|
|
}
|
|
|
|
get isVMess() {
|
|
return this.protocol === Protocols.VMESS;
|
|
}
|
|
|
|
get isVLess() {
|
|
return this.protocol === Protocols.VLESS;
|
|
}
|
|
|
|
get isTrojan() {
|
|
return this.protocol === Protocols.TROJAN;
|
|
}
|
|
|
|
get isSS() {
|
|
return this.protocol === Protocols.SHADOWSOCKS;
|
|
}
|
|
|
|
get isMixed() {
|
|
return this.protocol === Protocols.MIXED;
|
|
}
|
|
|
|
get isHTTP() {
|
|
return this.protocol === Protocols.HTTP;
|
|
}
|
|
|
|
get isWireguard() {
|
|
return this.protocol === Protocols.WIREGUARD;
|
|
}
|
|
|
|
get address() {
|
|
let address = location.hostname;
|
|
if (!ObjectUtil.isEmpty(this.listen) && this.listen !== "0.0.0.0") {
|
|
address = this.listen;
|
|
}
|
|
return address;
|
|
}
|
|
|
|
get _expiryTime() {
|
|
if (this.expiryTime === 0) {
|
|
return null;
|
|
}
|
|
return moment(this.expiryTime);
|
|
}
|
|
|
|
set _expiryTime(t) {
|
|
if (t == null) {
|
|
this.expiryTime = 0;
|
|
} else {
|
|
this.expiryTime = t.valueOf();
|
|
}
|
|
}
|
|
|
|
get isExpiry() {
|
|
return this.expiryTime < new Date().getTime();
|
|
}
|
|
|
|
invalidateCache() {
|
|
this._cachedInbound = null;
|
|
this._clientStatsMap = null;
|
|
}
|
|
|
|
toInbound() {
|
|
if (this._cachedInbound) {
|
|
return this._cachedInbound;
|
|
}
|
|
|
|
let settings = {};
|
|
if (!ObjectUtil.isEmpty(this.settings)) {
|
|
settings = JSON.parse(this.settings);
|
|
}
|
|
|
|
let streamSettings = {};
|
|
if (!ObjectUtil.isEmpty(this.streamSettings)) {
|
|
streamSettings = JSON.parse(this.streamSettings);
|
|
}
|
|
|
|
let sniffing = {};
|
|
if (!ObjectUtil.isEmpty(this.sniffing)) {
|
|
sniffing = JSON.parse(this.sniffing);
|
|
}
|
|
|
|
const config = {
|
|
port: this.port,
|
|
listen: this.listen,
|
|
protocol: this.protocol,
|
|
settings: settings,
|
|
streamSettings: streamSettings,
|
|
tag: this.tag,
|
|
sniffing: sniffing,
|
|
clientStats: this.clientStats,
|
|
};
|
|
|
|
this._cachedInbound = Inbound.fromJson(config);
|
|
return this._cachedInbound;
|
|
}
|
|
|
|
getClientStats(email) {
|
|
if (!this._clientStatsMap) {
|
|
this._clientStatsMap = new Map();
|
|
if (this.clientStats && Array.isArray(this.clientStats)) {
|
|
for (const stats of this.clientStats) {
|
|
this._clientStatsMap.set(stats.email, stats);
|
|
}
|
|
}
|
|
}
|
|
return this._clientStatsMap.get(email);
|
|
}
|
|
|
|
isMultiUser() {
|
|
switch (this.protocol) {
|
|
case Protocols.VMESS:
|
|
case Protocols.VLESS:
|
|
case Protocols.TROJAN:
|
|
return true;
|
|
case Protocols.SHADOWSOCKS:
|
|
return this.toInbound().isSSMultiUser;
|
|
default:
|
|
return false;
|
|
}
|
|
}
|
|
|
|
hasLink() {
|
|
switch (this.protocol) {
|
|
case Protocols.VMESS:
|
|
case Protocols.VLESS:
|
|
case Protocols.TROJAN:
|
|
case Protocols.SHADOWSOCKS:
|
|
return true;
|
|
default:
|
|
return false;
|
|
}
|
|
}
|
|
|
|
genInboundLinks(remarkModel) {
|
|
const inbound = this.toInbound();
|
|
return inbound.genInboundLinks(this.remark, remarkModel);
|
|
}
|
|
} |