From d0fae0dd6bc235d54a8a0c3863764fb6123cb960 Mon Sep 17 00:00:00 2001 From: cmliu Date: Sat, 20 Dec 2025 18:28:34 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E7=A7=BB=E9=99=A4forwardataTCP=E5=87=BD?= =?UTF-8?q?=E6=95=B0=E4=B8=AD=E7=9A=84=E6=8E=92=E5=BA=8F=E7=A7=98=E9=92=A5?= =?UTF-8?q?=E5=8F=82=E6=95=B0=EF=BC=8C=E7=AE=80=E5=8C=96TCP=E8=BD=AC?= =?UTF-8?q?=E5=8F=91=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- _worker.js | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/_worker.js b/_worker.js index a957c10..4e76bf1 100644 --- a/_worker.js +++ b/_worker.js @@ -383,7 +383,7 @@ async function 处理WS请求(request, yourUUID) { if (判断是否是木马) { const { port, hostname, rawClientData } = 解析木马请求(chunk, yourUUID); if (isSpeedTestSite(hostname)) throw new Error('Speedtest site is blocked'); - await forwardataTCP(hostname, port, rawClientData, serverSock, null, remoteConnWrapper, yourUUID); + await forwardataTCP(hostname, port, rawClientData, serverSock, null, remoteConnWrapper); } else { const { port, hostname, rawIndex, version, isUDP } = 解析魏烈思请求(chunk, yourUUID); if (isSpeedTestSite(hostname)) throw new Error('Speedtest site is blocked'); @@ -394,7 +394,7 @@ async function 处理WS请求(request, yourUUID) { const respHeader = new Uint8Array([version[0], 0]); const rawData = chunk.slice(rawIndex); if (isDnsQuery) return forwardataudp(rawData, serverSock, respHeader); - await forwardataTCP(hostname, port, rawData, serverSock, respHeader, remoteConnWrapper, yourUUID); + await forwardataTCP(hostname, port, rawData, serverSock, respHeader, remoteConnWrapper); } }, })).catch((err) => { @@ -498,7 +498,7 @@ function 解析魏烈思请求(chunk, token) { if (!hostname) return { hasError: true, message: `Invalid address: ${addressType}` }; return { hasError: false, addressType, port, hostname, isUDP, rawIndex: addrValIdx + addrLen, version }; } -async function forwardataTCP(host, portNum, rawData, ws, respHeader, remoteConnWrapper, 排序秘钥) { +async function forwardataTCP(host, portNum, rawData, ws, respHeader, remoteConnWrapper) { console.log(`[TCP转发] 目标: ${host}:${portNum} | 反代IP: ${反代IP} | 反代类型: ${启用SOCKS5反代 || 'proxyip'} | 全局: ${启用SOCKS5全局反代 ? '是' : '否'}`); async function connectDirect(address, port, data, 所有反代数组 = null) { let remoteSock; @@ -539,7 +539,7 @@ async function forwardataTCP(host, portNum, rawData, ws, respHeader, remoteConnW } else if (启用SOCKS5反代 === 'http' || 启用SOCKS5反代 === 'https') { newSocket = await httpConnect(host, portNum, rawData); } else { - const 所有反代数组 = await 解析地址端口(反代IP, 排序秘钥); + const 所有反代数组 = await 解析地址端口(反代IP); newSocket = await connectDirect(atob('UFJPWFlJUC50cDEuMDkwMjI3Lnh5eg=='), 1, rawData, 所有反代数组); } remoteConnWrapper.socket = newSocket;