From 4be8254539fb648a09602ddd027ebaf8923f7f00 Mon Sep 17 00:00:00 2001 From: cmliu Date: Mon, 18 Nov 2024 02:14:09 +0800 Subject: [PATCH] debug --- _worker.js | 194 +++++++++++++++++++++++++++-------------------------- 1 file changed, 100 insertions(+), 94 deletions(-) diff --git a/_worker.js b/_worker.js index dec43f22..5c423aa8 100644 --- a/_worker.js +++ b/_worker.js @@ -30,7 +30,7 @@ export default { mytoken = env.TOKEN || mytoken; BotToken = env.TGTOKEN || BotToken; ChatID = env.TGID || ChatID; - TG = env.TG || TG; + TG = env.TG || TG; subconverter = env.SUBAPI || subconverter; if( subconverter.includes("http://") ){ subconverter = subconverter.split("//")[1]; @@ -199,7 +199,7 @@ export default { }; async function ADD(envadd) { - var addtext = envadd.replace(/[ "'|\r\n]+/g, ',').replace(/,+/g, ','); // 将空格、双引号、单引号和换行符替换为逗号 + var addtext = envadd.replace(/[ "'|\r\n]+/g, ',').replace(/,+/g, ','); // 将空格、双引号、单引号和换行符替换为逗号 //console.log(addtext); if (addtext.charAt(0) == ',') addtext = addtext.slice(1); if (addtext.charAt(addtext.length -1) == ',') addtext = addtext.slice(0, addtext.length - 1); @@ -270,7 +270,7 @@ function base64Decode(str) { async function MD5MD5(text) { const encoder = new TextEncoder(); - + const firstPass = await crypto.subtle.digest('MD5', encoder.encode(text)); const firstPassArray = Array.from(new Uint8Array(firstPass)); const firstHex = firstPassArray.map(b => b.toString(16).padStart(2, '0')).join(''); @@ -278,7 +278,7 @@ async function MD5MD5(text) { const secondPass = await crypto.subtle.digest('MD5', encoder.encode(firstHex.slice(7, 27))); const secondPassArray = Array.from(new Uint8Array(secondPass)); const secondHex = secondPassArray.map(b => b.toString(16).padStart(2, '0')).join(''); - + return secondHex.toLowerCase(); } @@ -348,97 +348,103 @@ async function proxyURL(proxyURL, url) { } async function getSUB(api, request, 追加UA, userAgentHeader) { - if (!api || api.length === 0) { - return []; - } - let newapi = ""; - let 订阅转换URLs = ""; - const controller = new AbortController(); // 创建一个AbortController实例，用于取消请求 - const timeout = setTimeout(() => { - controller.abort(); // 2秒后取消所有请求 - }, 2000); - - try { - // 使用Promise.allSettled等待所有API请求完成，无论成功或失败 - const responses = await Promise.allSettled(api.map(apiUrl => getUrl(request, apiUrl, 追加UA, userAgentHeader).then(response => response.ok ? response.text() : Promise.reject(response)))); - - // 遍历所有响应 - const modifiedResponses = responses.map((response, index) => { - // 检查是否请求成功 - if (response.status === 'rejected') { - const reason = response.reason; - if (reason && reason.name === 'AbortError') { - return { - status: '超时', - value: null, - apiUrl: api[index] // 将原始的apiUrl添加到返回对象中 - }; - } - console.error(`请求失败: ${api[index]}, 错误信息: ${reason.status} ${reason.statusText}`); - return { - status: '请求失败', - value: null, - apiUrl: api[index] // 将原始的apiUrl添加到返回对象中 - }; - } - return { - status: response.status, - value: response.value, - apiUrl: api[index] // 将原始的apiUrl添加到返回对象中 - }; - }); - - console.log(modifiedResponses); // 输出修改后的响应数组 - - for (const response of modifiedResponses) { - // 检查响应状态是否为'fulfilled' - if (response.status === 'fulfilled') { - const content = await response.value || 'null'; // 获取响应的内容 - if (content.includes('proxies') && content.includes('proxy-groups')) { - // Clash 配置 - 订阅转换URLs += "|" + response.apiUrl; - } else if (content.includes('outbounds') && content.includes('inbounds')) { - // Singbox 配置 - 订阅转换URLs += "|" + response.apiUrl; - } else { - if (content.includes('://')) { - newapi += content + '\n'; - } else { - newapi += base64Decode(content) + '\n'; // 解码并追加内容 - } - } - } - } - } catch (error) { - console.error(error); // 捕获并输出错误信息 - } finally { - clearTimeout(timeout); // 清除定时器 - } - - const 订阅内容 = await ADD(newapi); - // 返回处理后的结果 - return [订阅内容, 订阅转换URLs]; + if (!api || api.length === 0) { + return []; + } + let newapi = ""; + let 订阅转换URLs = ""; + let 异常订阅 = ""; + const controller = new AbortController(); // 创建一个AbortController实例，用于取消请求 + const timeout = setTimeout(() => { + controller.abort(); // 2秒后取消所有请求 + }, 2000); + + try { + // 使用Promise.allSettled等待所有API请求完成，无论成功或失败 + const responses = await Promise.allSettled(api.map(apiUrl => getUrl(request, apiUrl, 追加UA, userAgentHeader).then(response => response.ok ? response.text() : Promise.reject(response)))); + + // 遍历所有响应 + const modifiedResponses = responses.map((response, index) => { + // 检查是否请求成功 + if (response.status === 'rejected') { + const reason = response.reason; + if (reason && reason.name === 'AbortError') { + return { + status: '超时', + value: null, + apiUrl: api[index] // 将原始的apiUrl添加到返回对象中 + }; + } + console.error(`请求失败: ${api[index]}, 错误信息: ${reason.status} ${reason.statusText}`); + return { + status: '请求失败', + value: null, + apiUrl: api[index] // 将原始的apiUrl添加到返回对象中 + }; + } + return { + status: response.status, + value: response.value, + apiUrl: api[index] // 将原始的apiUrl添加到返回对象中 + }; + }); + + console.log(modifiedResponses); // 输出修改后的响应数组 + + for (const response of modifiedResponses) { + // 检查响应状态是否为'fulfilled' + if (response.status === 'fulfilled') { + const content = await response.value || 'null'; // 获取响应的内容 + if (content.includes('proxies') && content.includes('proxy-groups')) { + 订阅转换URLs += "|" + response.apiUrl; // Clash 配置 + } else if (content.includes('outbounds') && content.includes('inbounds')) { + 订阅转换URLs += "|" + response.apiUrl; // Singbox 配置 + } else if (content.includes('://')) { + newapi += content + '\n'; // 追加内容 + } else if (isValidBase64(content)){ + newapi += base64Decode(content) + '\n'; // 解码并追加内容 + } else { + const 异常订阅LINK = `trojan://CMLiussss@127.0.0.1:8888?security=tls&allowInsecure=1&type=tcp&headerType=none#%E5%BC%82%E5%B8%B8%E8%AE%A2%E9%98%85%20${response.apiUrl.split('://')[1].split('/')[0]}`; + console.log(异常订阅LINK); + 异常订阅 += `${异常订阅LINK}\n`; + } + } + } + } catch (error) { + console.error(error); // 捕获并输出错误信息 + } finally { + clearTimeout(timeout); // 清除定时器 + } + + const 订阅内容 = await ADD(newapi + 异常订阅); // 将处理后的内容转换为数组 + // 返回处理后的结果 + return [订阅内容, 订阅转换URLs]; } async function getUrl(request, targetUrl, 追加UA, userAgentHeader) { - // 设置自定义 User-Agent - const newHeaders = new Headers(request.headers); - newHeaders.set("User-Agent", `v2rayN/${追加UA} cmliu/CF-Workers-SUB ${userAgentHeader}`); - - // 构建新的请求对象 - const modifiedRequest = new Request(targetUrl, { - method: request.method, - headers: newHeaders, - body: request.method === "GET" ? null : request.body, - redirect: "follow" - }); - - // 输出请求的详细信息 - console.log(`请求URL: ${targetUrl}`); - console.log(`请求头: ${JSON.stringify([...newHeaders])}`); - console.log(`请求方法: ${request.method}`); - console.log(`请求体: ${request.method === "GET" ? null : request.body}`); - - // 发送请求并返回响应 - return fetch(modifiedRequest); + // 设置自定义 User-Agent + const newHeaders = new Headers(request.headers); + newHeaders.set("User-Agent", `v2rayN/${追加UA} cmliu/CF-Workers-SUB ${userAgentHeader}`); + + // 构建新的请求对象 + const modifiedRequest = new Request(targetUrl, { + method: request.method, + headers: newHeaders, + body: request.method === "GET" ? null : request.body, + redirect: "follow" + }); + + // 输出请求的详细信息 + console.log(`请求URL: ${targetUrl}`); + console.log(`请求头: ${JSON.stringify([...newHeaders])}`); + console.log(`请求方法: ${request.method}`); + console.log(`请求体: ${request.method === "GET" ? null : request.body}`); + + // 发送请求并返回响应 + return fetch(modifiedRequest); +} + +function isValidBase64(str) { + const base64Regex = /^[A-Za-z0-9+/=]+$/; + return base64Regex.test(str); } \ No newline at end of file