Update _worker.js

_worker.js

@@ -73,6 +73,7 @@ let isBase64 = true;
 let botToken = '';
 let chatID = '';
 
+const httpPattern = /^http(s)?:\/\/.+/;
 
 if (!isValidUUID(userID)) {
 	throw new Error('uuid is invalid');
@@ -111,8 +112,28 @@ export default {
 
 			userID = (UUID || userID).toLowerCase();
 			if (PROXYIP) {
-				proxyIPs = await addIpText(PROXYIP);
-				proxyIP = proxyIPs[Math.floor(Math.random() * proxyIPs.length)];
+				if (httpPattern.test(PROXYIP)) {
+					let ipUrlTxtAndCsv;
+					if (PROXYIP.endsWith('.txt')) {
+						ipUrlTxtAndCsv = await getIpUrlTxtAndCsv(noTLS, PROXYIP, null);
+
+					} else if (PROXYIP.endsWith('.csv')) {
+						ipUrlTxtAndCsv = await getIpUrlTxtAndCsv(noTLS, null, PROXYIP);
+
+					} else {
+						return new Response("PROXYIP是无效的文件类型:", {
+							headers: {
+								'Content-Type': 'text/html; charset=UTF-8',
+								'referer': 'https://www.google.com/search?q=AM科技',
+							},
+						});
+					}
+					const uniqueIpTxt = [...new Set([...ipUrlTxtAndCsv.txt, ...ipUrlTxtAndCsv.csv])];
+					proxyIP = uniqueIpTxt[Math.floor(Math.random() * uniqueIpTxt.length)];
+				} else {
+					proxyIPs = await addIpText(PROXYIP);
+					proxyIP = proxyIPs[Math.floor(Math.random() * proxyIPs.length)];
+				}
 				const [ip, port] = proxyIP.split(':');
 				proxyIP = ip;
 				proxyPort = port || proxyPort;
@@ -394,6 +415,7 @@ async function parseSocks5FromUrl(socks5, url) {
 	return null;
 }
 
+
 /** ---------------------Get data------------------------------ */
 
 let subParams = ['sub', 'base64', 'b64', 'clash', 'singbox', 'sb'];
@@ -421,7 +443,7 @@ async function getVLESSConfig(userID, host, userAgent, _url) {
 
 	// Get node information
 	fakeHostName = getFakeHostName(host);
-	const ipUrlTxtAndCsv = await getIpUrlTxtAndCsv(noTLS);
+	const ipUrlTxtAndCsv = await getIpUrlTxtAndCsv(noTLS, ipUrlTxt, ipUrlCsv);
 
 	// console.log(`txt: ${ipUrlTxtAndCsv.txt} \n csv: ${ipUrlTxtAndCsv.csv}`);
 	let content = await getSubscribeNode(userAgent, _url, host, fakeHostName, fakeUserID, noTLS, ipUrlTxtAndCsv.txt, ipUrlTxtAndCsv.csv);
@@ -456,21 +478,21 @@ function getFakeHostName(host) {
 	return `${fakeHostName}.xyz`;
 }
 
-async function getIpUrlTxtAndCsv(noTLS) {
+async function getIpUrlTxtAndCsv(noTLS, urlTxts, urlCsvs) {
 	if (noTLS === 'true') {
 		return {
-			txt: await getIpUrlTxt(ipUrlTxt),
-			csv: await getIpUrlCsv('FALSE')
+			txt: await getIpUrlTxt(urlTxts),
+			csv: await getIpUrlCsv(urlCsvs, 'FALSE')
 		};
 	}
 	return {
-		txt: await getIpUrlTxt(ipUrlTxt),
-		csv: await getIpUrlCsv('TRUE')
+		txt: await getIpUrlTxt(urlTxts),
+		csv: await getIpUrlCsv(urlCsvs, 'TRUE')
 	};
 }
 
-async function getIpUrlTxt(ipUrlTxts) {
-	if (!ipUrlTxts || ipUrlTxts.length === 0) {
+async function getIpUrlTxt(urlTxts) {
+	if (!urlTxts || urlTxts.length === 0) {
 		return [];
 	}
 
@@ -487,7 +509,7 @@ async function getIpUrlTxt(ipUrlTxts) {
 	try {
 		// Use Promise.allSettled to wait for all API requests to complete, regardless of success or failure
 		// Iterate over the api array and send a fetch request to each API URL
-		const responses = await Promise.allSettled(ipUrlTxts.map(apiUrl => fetch(apiUrl, {
+		const responses = await Promise.allSettled(urlTxts.map(apiUrl => fetch(apiUrl, {
 			method: 'GET',
 			headers: {
 				'Accept': 'text/html,application/xhtml+xml,application/xml;',
@@ -520,16 +542,16 @@ async function getIpUrlTxt(ipUrlTxts) {
 	return newIpTxt;
 }
 
-async function getIpUrlCsv(tls) {
+async function getIpUrlCsv(urlCsvs, tls) {
 	// Check if the CSV URLs are valid
-	if (!ipUrlCsv || ipUrlCsv.length === 0) {
+	if (!urlCsvs || urlCsvs.length === 0) {
 		return [];
 	}
 
 	const newAddressesCsv = [];
 
 	// Fetch and process all CSVs concurrently
-	const fetchCsvPromises = ipUrlCsv.map(async (csvUrl) => {
+	const fetchCsvPromises = urlCsvs.map(async (csvUrl) => {
 		try {
 			const response = await fetch(csvUrl);