diff --git a/.github/workflows/.DS_Store b/.github/workflows/.DS_Store new file mode 100644 index 0000000..5008ddf Binary files /dev/null and b/.github/workflows/.DS_Store differ diff --git a/.github/workflows/zip_flows.yml b/.github/workflows/zip_flows.yml new file mode 100644 index 0000000..d9999e0 --- /dev/null +++ b/.github/workflows/zip_flows.yml @@ -0,0 +1,29 @@ +name: zip_flows # 工作流程的名称 + +on: + workflow_dispatch: # 手动触发 + push: + paths: + - '_worker.js' # 当 _worker.js 文件发生变动时触发 + +permissions: + contents: write + +jobs: + package-and-commit: + runs-on: ubuntu-latest # 运行环境,这里使用最新版本的 Ubuntu + steps: + - name: Checkout Repository # 检出代码 + uses: actions/checkout@v2 + + - name: Zip the worker file # 将 _worker.js 文件打包成 worker.js.zip + run: zip _worker.js.zip _worker.js + + - name: Commit and push the packaged file # 提交并推送打包后的文件 + uses: EndBug/add-and-commit@v7 + with: + add: '_worker.js.zip' + message: 'Automatically package and commit _worker.js.zip' + author_name: github-actions[bot] + author_email: actions[bot]@users.noreply.github.com + token: ${{ secrets.GH_TOKEN }} diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..caa19dc --- /dev/null +++ b/.gitignore @@ -0,0 +1,137 @@ +# Logs +logs +*.log +npm-debug.log* +yarn-debug.log* +yarn-error.log* +lerna-debug.log* +.pnpm-debug.log* + +# Diagnostic reports (https://nodejs.org/api/report.html) +report.[0-9]*.[0-9]*.[0-9]*.[0-9]*.json + +# Runtime data +pids +*.pid +*.seed +*.pid.lock + +# Directory for instrumented libs generated by jscoverage/JSCover +lib-cov + +# Coverage directory used by tools like istanbul +coverage +*.lcov +.DS_Store + +# nyc test coverage +.nyc_output + +# Grunt intermediate storage (https://gruntjs.com/creating-plugins#storing-task-files) +.grunt + +# Bower dependency directory (https://bower.io/) +bower_components + +# node-waf configuration +.lock-wscript + +# Compiled binary addons (https://nodejs.org/api/addons.html) +build/Release + +# Dependency directories +node_modules/ +jspm_packages/ + +# Snowpack dependency directory (https://snowpack.dev/) +web_modules/ + +# TypeScript cache +*.tsbuildinfo + +# Optional npm cache directory +.npm + +# Optional eslint cache +.eslintcache + +# Optional stylelint cache +.stylelintcache + +# Microbundle cache +.rpt2_cache/ +.rts2_cache_cjs/ +.rts2_cache_es/ +.rts2_cache_umd/ + +# Optional REPL history +.node_repl_history + +# Output of 'npm pack' +*.tgz + +# Yarn Integrity file +.yarn-integrity + +# dotenv environment variable files +.env +.env.development.local +.env.test.local +.env.production.local +.env.local + +# parcel-bundler cache (https://parceljs.org/) +.cache +.parcel-cache + +# Next.js build output +.next +out + +# Nuxt.js build / generate output +.nuxt +dist + +# Gatsby files +.cache/ +# Comment in the public line in if your project uses Gatsby and not Next.js +# https://nextjs.org/blog/next-9-1#public-directory-support +# public + +# vuepress build output +.vuepress/dist + +# vuepress v2.x temp and cache directory +.temp +.cache + +# Docusaurus cache and generated files +.docusaurus + +# Serverless directories +.serverless/ + +# FuseBox cache +.fusebox/ + +# DynamoDB Local files +.dynamodb/ + +# TernJS port file +.tern-port + +# Stores VSCode versions used for testing VSCode extensions +.vscode-test + +# yarn v2 +.yarn/cache +.yarn/unplugged +.yarn/build-state.yml +.yarn/install-state.gz +.pnp.* + +.DS_Store +.vscode +package-lock.json +yarn.lock + diff --git a/LICENSE b/LICENSE new file mode 100644 index 0000000..261eeb9 --- /dev/null +++ b/LICENSE @@ -0,0 +1,201 @@ + Apache License + Version 2.0, January 2004 + http://www.apache.org/licenses/ + + TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION + + 1. Definitions. + + "License" shall mean the terms and conditions for use, reproduction, + and distribution as defined by Sections 1 through 9 of this document. + + "Licensor" shall mean the copyright owner or entity authorized by + the copyright owner that is granting the License. + + "Legal Entity" shall mean the union of the acting entity and all + other entities that control, are controlled by, or are under common + control with that entity. For the purposes of this definition, + "control" means (i) the power, direct or indirect, to cause the + direction or management of such entity, whether by contract or + otherwise, or (ii) ownership of fifty percent (50%) or more of the + outstanding shares, or (iii) beneficial ownership of such entity. + + "You" (or "Your") shall mean an individual or Legal Entity + exercising permissions granted by this License. + + "Source" form shall mean the preferred form for making modifications, + including but not limited to software source code, documentation + source, and configuration files. + + "Object" form shall mean any form resulting from mechanical + transformation or translation of a Source form, including but + not limited to compiled object code, generated documentation, + and conversions to other media types. + + "Work" shall mean the work of authorship, whether in Source or + Object form, made available under the License, as indicated by a + copyright notice that is included in or attached to the work + (an example is provided in the Appendix below). + + "Derivative Works" shall mean any work, whether in Source or Object + form, that is based on (or derived from) the Work and for which the + editorial revisions, annotations, elaborations, or other modifications + represent, as a whole, an original work of authorship. For the purposes + of this License, Derivative Works shall not include works that remain + separable from, or merely link (or bind by name) to the interfaces of, + the Work and Derivative Works thereof. + + "Contribution" shall mean any work of authorship, including + the original version of the Work and any modifications or additions + to that Work or Derivative Works thereof, that is intentionally + submitted to Licensor for inclusion in the Work by the copyright owner + or by an individual or Legal Entity authorized to submit on behalf of + the copyright owner. For the purposes of this definition, "submitted" + means any form of electronic, verbal, or written communication sent + to the Licensor or its representatives, including but not limited to + communication on electronic mailing lists, source code control systems, + and issue tracking systems that are managed by, or on behalf of, the + Licensor for the purpose of discussing and improving the Work, but + excluding communication that is conspicuously marked or otherwise + designated in writing by the copyright owner as "Not a Contribution." + + "Contributor" shall mean Licensor and any individual or Legal Entity + on behalf of whom a Contribution has been received by Licensor and + subsequently incorporated within the Work. + + 2. Grant of Copyright License. Subject to the terms and conditions of + this License, each Contributor hereby grants to You a perpetual, + worldwide, non-exclusive, no-charge, royalty-free, irrevocable + copyright license to reproduce, prepare Derivative Works of, + publicly display, publicly perform, sublicense, and distribute the + Work and such Derivative Works in Source or Object form. + + 3. Grant of Patent License. Subject to the terms and conditions of + this License, each Contributor hereby grants to You a perpetual, + worldwide, non-exclusive, no-charge, royalty-free, irrevocable + (except as stated in this section) patent license to make, have made, + use, offer to sell, sell, import, and otherwise transfer the Work, + where such license applies only to those patent claims licensable + by such Contributor that are necessarily infringed by their + Contribution(s) alone or by combination of their Contribution(s) + with the Work to which such Contribution(s) was submitted. If You + institute patent litigation against any entity (including a + cross-claim or counterclaim in a lawsuit) alleging that the Work + or a Contribution incorporated within the Work constitutes direct + or contributory patent infringement, then any patent licenses + granted to You under this License for that Work shall terminate + as of the date such litigation is filed. + + 4. Redistribution. You may reproduce and distribute copies of the + Work or Derivative Works thereof in any medium, with or without + modifications, and in Source or Object form, provided that You + meet the following conditions: + + (a) You must give any other recipients of the Work or + Derivative Works a copy of this License; and + + (b) You must cause any modified files to carry prominent notices + stating that You changed the files; and + + (c) You must retain, in the Source form of any Derivative Works + that You distribute, all copyright, patent, trademark, and + attribution notices from the Source form of the Work, + excluding those notices that do not pertain to any part of + the Derivative Works; and + + (d) If the Work includes a "NOTICE" text file as part of its + distribution, then any Derivative Works that You distribute must + include a readable copy of the attribution notices contained + within such NOTICE file, excluding those notices that do not + pertain to any part of the Derivative Works, in at least one + of the following places: within a NOTICE text file distributed + as part of the Derivative Works; within the Source form or + documentation, if provided along with the Derivative Works; or, + within a display generated by the Derivative Works, if and + wherever such third-party notices normally appear. The contents + of the NOTICE file are for informational purposes only and + do not modify the License. You may add Your own attribution + notices within Derivative Works that You distribute, alongside + or as an addendum to the NOTICE text from the Work, provided + that such additional attribution notices cannot be construed + as modifying the License. + + You may add Your own copyright statement to Your modifications and + may provide additional or different license terms and conditions + for use, reproduction, or distribution of Your modifications, or + for any such Derivative Works as a whole, provided Your use, + reproduction, and distribution of the Work otherwise complies with + the conditions stated in this License. + + 5. Submission of Contributions. Unless You explicitly state otherwise, + any Contribution intentionally submitted for inclusion in the Work + by You to the Licensor shall be under the terms and conditions of + this License, without any additional terms or conditions. + Notwithstanding the above, nothing herein shall supersede or modify + the terms of any separate license agreement you may have executed + with Licensor regarding such Contributions. + + 6. Trademarks. This License does not grant permission to use the trade + names, trademarks, service marks, or product names of the Licensor, + except as required for reasonable and customary use in describing the + origin of the Work and reproducing the content of the NOTICE file. + + 7. Disclaimer of Warranty. Unless required by applicable law or + agreed to in writing, Licensor provides the Work (and each + Contributor provides its Contributions) on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or + implied, including, without limitation, any warranties or conditions + of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A + PARTICULAR PURPOSE. You are solely responsible for determining the + appropriateness of using or redistributing the Work and assume any + risks associated with Your exercise of permissions under this License. + + 8. Limitation of Liability. In no event and under no legal theory, + whether in tort (including negligence), contract, or otherwise, + unless required by applicable law (such as deliberate and grossly + negligent acts) or agreed to in writing, shall any Contributor be + liable to You for damages, including any direct, indirect, special, + incidental, or consequential damages of any character arising as a + result of this License or out of the use or inability to use the + Work (including but not limited to damages for loss of goodwill, + work stoppage, computer failure or malfunction, or any and all + other commercial damages or losses), even if such Contributor + has been advised of the possibility of such damages. + + 9. Accepting Warranty or Additional Liability. While redistributing + the Work or Derivative Works thereof, You may choose to offer, + and charge a fee for, acceptance of support, warranty, indemnity, + or other liability obligations and/or rights consistent with this + License. However, in accepting such obligations, You may act only + on Your own behalf and on Your sole responsibility, not on behalf + of any other Contributor, and only if You agree to indemnify, + defend, and hold each Contributor harmless for any liability + incurred by, or claims asserted against, such Contributor by reason + of your accepting any such warranty or additional liability. + + END OF TERMS AND CONDITIONS + + APPENDIX: How to apply the Apache License to your work. + + To apply the Apache License to your work, attach the following + boilerplate notice, with the fields enclosed by brackets "[]" + replaced with your own identifying information. (Don't include + the brackets!) The text should be enclosed in the appropriate + comment syntax for the file format. We also recommend that a + file or class name and description of purpose be included on the + same "printed page" as the copyright notice for easier + identification within third-party archives. + + Copyright [yyyy] [name of copyright owner] + + Licensed under the Apache License, Version 2.0 (the "License"); + you may not use this file except in compliance with the License. + You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. diff --git a/README.md b/README.md new file mode 100644 index 0000000..1aad87d --- /dev/null +++ b/README.md @@ -0,0 +1,121 @@ +# [am-cf-sub-rss](https://github.com/amclubs/am-cf-sub-rss) +通过Cloudflare Workers & Pages 搭建,将你任意节点与多个订阅聚合成专属于你的订阅链接,完成定制汇聚订阅 + + +▶️ **新人[YouTube](https://youtube.com/@AM_CLUB)** 需要您的支持,请务必帮我**点赞**、**关注**、**打开小铃铛**,***十分感谢!!!*** ✅ +
🎁 不要只是下载或Fork。请 **follow** 我的GitHub、给我所有项目一个 **Star** 星星(拜托了)!你的支持是我不断前进的动力! 💖 +
✅**解锁更多技术请访问[【个人博客】](https://am.809098.xyz)** +# + + +# 定制聚合订阅 + +## Pages 部署方法 [视频教程](https://youtu.be/YBO2hf96150) +### 1. 部署 Cloudflare Pages: + - 在 Github 上先 Fork 本项目,并点上 Star !!! + - 在 Cloudflare Pages 控制台中选择 `连接到 Git`后,选中 `am-cf-sub-rss`项目后点击 `开始设置`。 + +### 2. 给 Pages绑定 自定义域: + - 在 Pages控制台的 `自定义域`选项卡,下方点击 `设置自定义域`。 + - 填入你的自定义次级域名,注意不要使用你的根域名,例如: + 您分配到的域名是 `fuck.google.com`,则添加自定义域填入 `sub.fuck.google.com`即可; + - 按照 Cloudflare 的要求将返回你的域名DNS服务商,添加 该自定义域 `sub`的 CNAME记录 `am-cf-sub-rss.pages.dev` 后,点击 `激活域`即可。 + +### 3. 修改 快速订阅入口 : + + 例如您的pages项目域名为:`sub.fuck.google.com`; + - 添加 `TOKEN` 变量,快速订阅访问入口,默认值为: `auto` ,获取订阅器默认节点订阅地址即 `/auto` ,例如 `https://sub.fuck.google.com/auto` + +### 4. 添加你的节点和订阅链接: + - 添加 `SUB` 变量,节点相关配置连接,确保每行一个链接,例如: + ``` + vless://866853eb-5293-4f09-bf00-e13eb237c655@icook.tw:443?encryption=none&security=tls&sni=worker.amcloud.filegear-sg.me&fp=random&type=ws&host=worker.amcloud.filegear-sg.me#t.me%2FAM_CLUBS vless://866853eb-5293-4f09-bf00-e13eb237c655@visa.com:443?encryption=none&security=tls&sni=worker.amcloud.filegear-sg.me&fp=random&type=ws&host=worker.amcloud.filegear-sg.me#youtube.com%2F%40AM_CLUB + ``` + - 添加 `SUB_LINK` 变量,添加你的自建节点链接和机场订阅链接,确保每行一个链接,例如: + ``` + https://trojan.amcloud.filegear-sg.me/auto + https://worker.amcloud.filegear-sg.me/bestip/866853eb-5293-4f09-bf00-e13eb237c655?uuid=866853eb-5293-4f09-bf00-e13eb237c655 + ``` + +## Workers 部署方法 +### 1. 部署 Cloudflare Worker: + + - 在 Cloudflare Worker 控制台中创建一个新的 Worker。 + - 将 [worker.js](https://github.com/amclubs/am-cf-sub-rss/blob/main/_worker.js) 的内容粘贴到 Worker 编辑器中。 + + +### 2. 修改 订阅入口 : + + 例如您的workers项目域名为:`sub.am.workers.dev`; + - 通过修改 `mytoken` 赋值内容,达到修改你专属订阅的入口,避免订阅泄漏。 + ``` + let mytoken = 'auto'; + ``` + 如上所示,你的订阅地址则如下: + ```url + https://sub.am.workers.dev/auto + 或 + https://sub.am.workers.dev/?token=auto + ``` + + +### 3. 添加你的节点或订阅链接: + +**3.1 修改 MainData 参数示例** + + - 修改 `mainData` 参数添加你的自建节点,例如: + + ```js + const mainData = ` + vless://866853eb-5293-4f09-bf00-e13eb237c655@icook.tw:443?encryption=none&security=tls&sni=worker.amcloud.filegear-sg.me&fp=random&type=ws&host=worker.amcloud.filegear-sg.me#t.me%2FAM_CLUBS + vless://866853eb-5293-4f09-bf00-e13eb237c655@visa.com:443?encryption=none&security=tls&sni=worker.amcloud.filegear-sg.me&fp=random&type=ws&host=worker.amcloud.filegear-sg.me#youtube.com%2F%40AM_CLUB + ` + ``` +注意!`mainData`参数的特殊引号必须保留,否则代码异常。 + + + + **3.2 修改 urls 参数示例** + + - 修改 `urls` 参数,在脚本中设置 `urls` 变量为 你的订阅链接 的 URL。例如: + + ```js + const urls = [ + 'https://trojan.amcloud.filegear-sg.me/auto', + 'https://hy2sub.pages.dev', + ]; + ``` +注意!订阅链接内容必须为`base64`格式。 + + +## 变量说明 +| 变量名 | 示例 | 必填 | 备注 | YT | +|-----|-----|-----|-----|-----| +| TOKEN | auto |❌| 你专属订阅的入口,避免订阅泄漏 | | +| SUB | vless://b7a39... vmess://ew0K... |❌| 节点相关配置连接,确保每行一个链接 | | +| SUB_LINK | https://sub... |❌| 添加你的自建节点链接和机场订阅链接,确保每行一个链接 | | +| SUB_CONFIG | [https://raw.github.../ACL4SSR_Online_Mini.ini](https://raw.githubusercontent.com/amclubs/ACL4SSR/main/Clash/config/ACL4SSR_Online_Full_MultiMode.ini) |❌| clash、singbox等 订阅转换配置文件 | | +| SUB_CONVERTER | https://url.v1.mk |❌| clash、singbox等 订阅转换后端的api地址 | | +| SUB_NAME | @AM_CLUB |❌| 订阅名称 | | +| TG_TOKEN | 6894123456:XXXXXXXXXX0qXXXXqWXgBA |❌| 发送TG通知的机器人token | | +| TG_ID | 6946912345 |❌| 接收TG通知的账户数字ID | | + + +## 注意事项 +项目中,TG_TOKEN和TG_ID在使用时需要先到Telegram注册并获取。其中,TG_TOKEN是telegram bot的凭证,TG_ID是用来接收通知的telegram用户或者组的id。 + + + # +
[点击展开] 赞赏支持 ~🧧 + *我非常感谢您的赞赏和支持,它们将极大地激励我继续创新,持续产生有价值的工作。* + + - **USDT-TRC20:** `TWTxUyay6QJN3K4fs4kvJTT8Zfa2mWTwDD` + +
+ + # + 免责声明: + - 1、该项目设计和开发仅供学习、研究和安全测试目的。使用者在下载和使用该项目时,必须遵守当地法律和规定。使用者有责任确保他们的行为符合其所在地区的法律、规章以及其他适用的规定。 + - 2、作者对任何人或团体使用该项目进行的任何非法活动不承担责任。使用者使用该项目时产生的任何后果由使用者本人承担。 + - 3、作者不对使用该项目可能引起的任何直接或间接损害负责。作者保留随时更新本免责声明的权利,且不另行通知。 + \ No newline at end of file diff --git a/_worker.js b/_worker.js new file mode 100644 index 0000000..6e7d663 --- /dev/null +++ b/_worker.js @@ -0,0 +1,270 @@ +let myToken = 'auto'; +let botToken = ''; +let chatID = ''; +let enableTG = 0; +let fileName = 'am-cf-sub-rss'; +let subUpdateTime = 6; +let timestamp = 4102329600000; +let total = 99 * 1125899906842624; +let download = Math.floor(Math.random() * 1099511627776); +let upload = download; + +//vless://866853eb-5293-4f09-bf00-e13eb237c655@visa.com:443?encryption=none&security=tls&sni=worker.amcloud.filegear-sg.me&fp=random&type=ws&host=worker.amcloud.filegear-sg.me#youtube.com%2F%40AM_CLUB +let mainData = ` + +`; + +//'https://trojan.amcloud.filegear-sg.me/auto' +let urls = []; + +let subConverter = "url.v1.mk"; +let subConfig = "https://raw.githubusercontent.com/amclubs/ACL4SSR/main/Clash/config/ACL4SSR_Online_Full_MultiMode.ini"; +let subProtocol = 'https'; + +export default { + async fetch(request, env) { + const userAgent = request.headers.get('User-Agent')?.toLowerCase() || "null"; + const url = new URL(request.url); + const token = url.searchParams.get('token'); + + myToken = env.TOKEN || myToken; + botToken = env.TG_TOKEN || botToken; + chatID = env.TG_ID || chatID; + enableTG = env.TG_ENABLE || enableTG; + subConverter = env.SUB_CONVERTER || subConverter; + subConfig = env.SUB_CONFIG || subConfig; + fileName = env.SUB_NAME || fileName; + mainData = env.SUB || mainData; + urls = env.SUB_LINK ? await addIpText(env.SUB_LINK) : []; + + const currentDate = new Date(); + currentDate.setHours(0, 0, 0, 0); + const timeTemp = Math.ceil(currentDate.getTime() / 1000); + const fakeToken = await MD5MD5(`${myToken}${timeTemp}`); + + download = Math.floor(((timestamp - Date.now()) / timestamp * total * 1099511627776) / 2); + total *= 1099511627776; + let expire = Math.floor(timestamp / 1000); + subUpdateTime = env.SUBUPTIME || subUpdateTime; + + let combinedLinks = await addIpText(`${mainData}\n${urls.join('\n')}`); + let { selfBuiltNodes, subscriptionLinks } = splitLinks(combinedLinks); + + if (!isValidToken(token, fakeToken, url.pathname)) { + await handleInvalidAccess(request, url, userAgent, enableTG); + return new Response(await nginx(), { status: 200, headers: { 'Content-Type': 'text/html; charset=UTF-8' } }); + } else { + await sendMessage(`获取订阅 ${fileName}`, request.headers.get('CF-Connecting-IP'), `UA: ${userAgent}`); + const subscriptionFormat = determineSubscriptionFormat(userAgent, url); + const subscriptionConversionURL = `${url.origin}/${await MD5MD5(fakeToken)}?token=${fakeToken}`; + + const reqData = await fetchUrls(urls, subscriptionConversionURL, userAgent); + const uniqueResult = getUniqueLines(reqData); + + const response = await handleSubscriptionFormat(subscriptionFormat, uniqueResult, subscriptionConversionURL, expire); + return response; + } + } +}; + +function splitLinks(links) { + let selfBuiltNodes = "", subscriptionLinks = ""; + for (let link of links) { + if (link.toLowerCase().startsWith('http')) { + subscriptionLinks += `${link}\n`; + } else { + selfBuiltNodes += `${link}\n`; + } + } + return { selfBuiltNodes, subscriptionLinks }; +} + +function isValidToken(token, fakeToken, pathname) { + return token === myToken || token === fakeToken || pathname === `/${myToken}` || pathname.includes(`/${myToken}?`); +} + +async function handleInvalidAccess(request, url, userAgent, enableTG) { + if (enableTG == 1 && url.pathname !== "/" && url.pathname !== "/favicon.ico") { + await sendMessage(`#异常访问 ${fileName}`, request.headers.get('CF-Connecting-IP'), `UA: ${userAgent}`); + } +} + +function determineSubscriptionFormat(userAgent, url) { + if (userAgent.includes('null') || userAgent.includes('subconverter') || userAgent.includes('nekobox') || userAgent.includes('CF-FAKE-UA')) { + return 'base64'; + } else if (userAgent.includes('clash') || (url.searchParams.has('clash') && !userAgent.includes('subconverter'))) { + return 'clash'; + } else if (userAgent.includes('sing-box') || ((url.searchParams.has('sb') || url.searchParams.has('singbox')) && !userAgent.includes('subconverter'))) { + return 'singbox'; + } else if (userAgent.includes('surge') || (url.searchParams.has('surge') && !userAgent.includes('subconverter'))) { + return 'surge'; + } +} + +async function fetchUrls(urls, subscriptionConversionURL, userAgent) { + const reqData = ""; + const controller = new AbortController(); + const timeout = setTimeout(() => controller.abort(), 2000); + + const responses = await Promise.allSettled(urls.map(url => + fetch(url, { + method: 'get', + headers: { 'Accept': 'text/html,application/xhtml+xml,application/xml;', 'User-Agent': `ansoncloud8/am-cf-sub-rss ${userAgent}` }, + signal: controller.signal + }).then(response => response.ok ? response.text() : "") + )); + + clearTimeout(timeout); + return responses + .filter(response => response.status === 'fulfilled' && response.value) + .map(response => base64Decode(response.value)) + .join('\n'); +} + +function getUniqueLines(data) { + const uniqueLines = new Set(data.split('\n')); + return [...uniqueLines].join('\n'); +} + +async function handleSubscriptionFormat(format, result, subscriptionConversionURL, expire) { + const base64Data = btoa(result); + const headers = { + "content-type": "text/plain; charset=utf-8", + "Profile-Update-Interval": `${subUpdateTime}`, + "Subscription-Userinfo": `upload=${download}; download=${download}; total=${total}; expire=${expire}`, + }; + + if (format === 'base64') { + return new Response(base64Data, { headers }); + } else { + const subconverterUrl = getSubconverterUrl(format, subscriptionConversionURL); + const subconverterResponse = await fetch(subconverterUrl); + if (!subconverterResponse.ok) { + return new Response(base64Data, { headers }); + } + let subconverterContent = await subconverterResponse.text(); + if (format === 'clash') subconverterContent = await clashFix(subconverterContent); + return new Response(subconverterContent, { + headers: { + "Content-Disposition": `attachment; filename*=utf-8''${encodeURIComponent(fileName)}; filename=${fileName}`, + ...headers, + }, + }); + } +} + +function getSubconverterUrl(format, subscriptionConversionURL) { + return `${subProtocol}://${subConverter}/sub?target=${format}&url=${encodeURIComponent(subscriptionConversionURL)}&insert=false&config=${encodeURIComponent(subConfig)}&emoji=true&list=false&tfo=false&scv=true&fdn=false&sort=false&new_name=true`; +} + +async function sendMessage(type, ip, additionalData = "") { + if (botToken !== '' && chatID !== '') { + let msg = ""; + const response = await fetch(`http://ip-api.com/json/${ip}?lang=zh-CN`); + if (response.status == 200) { + const ipInfo = await response.json(); + msg = `${type}\nIP: ${ip}\n国家: ${ipInfo.country}\n城市: ${ipInfo.city}\n组织: ${ipInfo.org}\nASN: ${ipInfo.as}\n${additionalData}`; + } else { + msg = `${type}\nIP: ${ip}\n${additionalData}`; + } + + let url = `https://api.telegram.org/bot${botToken}/sendMessage?chat_id=${chatID}&parse_mode=HTML&text=${encodeURIComponent(msg)}`; + return fetch(url, { + method: 'get', + headers: { + 'Accept': 'text/html,application/xhtml+xml,application/xml;', + 'Accept-Encoding': 'gzip, deflate, br', + 'User-Agent': 'Mozilla/5.0 Chrome/90.0.4430.72' + } + }); + } +} + +function clashFix(content) { + if (content.includes('wireguard') && !content.includes('remote-dns-resolve')) { + let lines; + if (content.includes('\r\n')) { + lines = content.split('\r\n'); + } else { + lines = content.split('\n'); + } + + let result = ""; + for (let line of lines) { + if (line.includes('type: wireguard')) { + const modifiedContent = `, mtu: 1280, udp: true`; + const correctContent = `, mtu: 1280, remote-dns-resolve: true, udp: true`; + result += line.replace(new RegExp(modifiedContent, 'g'), correctContent) + '\n'; + } else { + result += line + '\n'; + } + } + + content = result; + } + return content; +} + +async function addIpText(envadd) { + 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); + const add = addtext.split(','); + //console.log(add); + return add; +} + + + + +function base64Decode(str) { + const bytes = new Uint8Array(atob(str).split('').map(c => c.charCodeAt(0))); + const decoder = new TextDecoder('utf-8'); + return decoder.decode(bytes); +} + +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(''); + + 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(); +} + +async function nginx() { + const text = ` + + + + Welcome to nginx! + + + +

Welcome to nginx!

+

If you see this page, the nginx web server is successfully installed and + working. Further configuration is required.

+ +

For online documentation and support please refer to + nginx.org.
+ Commercial support is available at + nginx.com.

+ +

Thank you for using nginx.

+ + + ` + return text; +} \ No newline at end of file