Upload 6 files

app.py

@@ -0,0 +1,27 @@
+from fastapi import FastAPI
+from server.utils import config
+from getNode import router as GetNodeRouter
+from randomSubscribeUrl import router as randomSubscribeUrlRouter
+from validSubCount import router as validSubCountRouter
+import uvicorn
+app = FastAPI()
+fileName = "subscribeLink.txt"
+randomSubscribeUrlRouter.fileName = fileName
+validSubCountRouter.fileName = fileName
+GetNodeRouter.fileName = fileName
+
+
+
+@app.get("/uu.json", tags=["Root"])
+async def read_root() -> dict:
+    return config
+
+#全局路由
+app.include_router(GetNodeRouter, prefix="/getNode")
+app.include_router(randomSubscribeUrlRouter, prefix="/randomSubscribeUrl")
+app.include_router(validSubCountRouter, prefix="/validSubCount")
+
+#这个是部署hf上
+if __name__ == '__main__':
+    uvicorn.run(app, host='0.0.0.0', port=7860)
+

getNode.py

@@ -0,0 +1,38 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+import requests
+from server.decoder import decode_url_to_configs
+from server.utils import config,headers
+import random
+from fastapi import APIRouter,BackgroundTasks
+from randomSubscribeUrl import subscription_link_list,getRandomSubscribeUrl,delete_invalid_url_in_txt
+
+
+router = APIRouter()
+@router.get('/')
+def getNode(background_tasks: BackgroundTasks)->str:
+    # 返回一个可用的订阅链接信息
+    SubscribeUrlList = subscription_link_list(router.fileName)
+    # 直接用现成的认为可用然后直接返回，之后再删不可用的
+    randomSubscribeUrl= getRandomSubscribeUrl(SubscribeUrlList)
+    NodeList = dump_configs(randomSubscribeUrl)
+    for i in NodeList:
+        print("nodelist包含"+i)
+    NodeStr = RandomNode(NodeList)
+
+    background_tasks.add_task(delete_invalid_url_in_txt, router.fileName)
+    return NodeStr
+
+def RandomNode(NodeList:list)->str:
+    #返回一个节点信息
+    return random.choice(NodeList)
+
+
+def dump_configs(url:str)->list:
+    #返回全部节点信息的列表
+    configs = decode_url_to_configs(url)
+    return configs
+
+
+
+

randomSubscribeUrl.py

@@ -0,0 +1,108 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+import requests
+import random
+from fastapi import APIRouter, BackgroundTasks
+
+
+
+
+# 添加headers模拟浏览器访问（针对juzi等特殊订阅）
+headers = {
+    'accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.7',
+    'accept-language': 'zh-CN,zh;q=0.9',
+    'cache-control': 'max-age=0',
+    'priority': 'u=0, i',
+    'sec-ch-ua': '"Chromium";v="128", "Not;A=Brand";v="24", "Google Chrome";v="128"',
+    'sec-ch-ua-mobile': '?0',
+    'sec-ch-ua-platform': '"macOS"',
+    'sec-fetch-dest': 'document',
+    'sec-fetch-mode': 'navigate',
+    'sec-fetch-site': 'none',
+    'sec-fetch-user': '?1',
+    'upgrade-insecure-requests': '1',
+    'user-agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/128.0.0.0 Safari/537.36'
+}
+
+
+def is_subscription_link_valid(subscribeUrl: str) -> bool:
+    try:
+        result = requests.get(subscribeUrl,headers=headers).text
+        if "error" in result:
+            return False
+        return True
+    except Exception as e:
+        #这里如果只是请求超时那么认为正常返回true，比如juzi sub判断时候连接超时
+        print('判断sub link是否有效时候发生错误:',e)
+        return True
+
+
+def delete_invalid_url_in_txt(fileName: str) -> "void":
+    valid_lines = []
+    with open(fileName, "r") as file:
+        lines = file.readlines()
+    for line in lines:
+        email = line.strip().split(",")[0]
+        subscription_url = line.strip().split(",")[1]
+        if is_subscription_link_valid(subscription_url):
+            valid_lines.append(line)
+        else:
+            print(email + "订阅已经不可用")
+    # 将有效行重新写回文件
+    with open(fileName, "w") as file:
+        file.writelines(valid_lines)
+
+
+def subscription_link_list(fileName: str) -> list:
+    SubscribeUrlList = []
+    with open(fileName, "r") as f:
+        lines = f.readlines()
+    for line in lines:
+        subscription_url = line.strip().split(",")[1]
+        SubscribeUrlList.append(subscription_url)
+    return SubscribeUrlList
+
+
+def subscription_link_valid_list(SubscribeUrlList: list) -> list:
+    valid_link_list = list(filter(lambda f: is_subscription_link_valid(f), SubscribeUrlList))
+    ##返回可用订阅链接前对原始文件进行删除不可用链接操作:
+    return valid_link_list
+
+
+def read_random_line(fileName: str) -> str:
+    with open(fileName, "r") as file:
+        lines = file.readlines()
+    return random.choice(lines)
+
+
+def getRandomSubscribeUrl(validSubscribeUrlList: list) -> str:
+    # 返回一个可用的订阅链接信息
+    return random.choice(validSubscribeUrlList)
+
+
+router = APIRouter()
+
+#此接口目前唯一作用是方便调试查看订阅剩余状态
+@router.get('/')
+def returnRandomSubscribeUrl(background_tasks: BackgroundTasks) -> str:
+    # 返回一个可用的订阅链接信息
+    SubscribeUrlList = subscription_link_list(router.fileName)
+    #直接用现成的认为可用然后直接返回，之后再删不可用的
+    result = getRandomSubscribeUrl(SubscribeUrlList)
+    background_tasks.add_task(delete_invalid_url_in_txt, router.fileName)
+    return result
+
+    # return hf_test()
+
+
+
+
+if __name__ == "__main__":
+    print()
+
+    ##思路是随机选取一行订阅检测，如果没问题就返回
+    # 1订阅有问题，那么
+    ##1->对全部订阅扫描，删除不可用的，然后重新随机一个返回,此返回时不用检测
+    ##2->如果扫描后没有可用的，那么不做处理让vercel报错
+
+    # 1订阅一个都没有，那么vercel错误提醒(不做处理考虑就行)

requirements.txt

@@ -0,0 +1,8 @@
+#gradio
+uvicorn[standard]==0.17.*
+requests==2.31.0
+aiohttp==3.7.3
+fastapi==0.95.0
+urllib3==2.0.7
+uvicorn
+#这个适用hf和windows

subscribeLink.txt

@@ -0,0 +1,2 @@
+hanryr,https://s.juzicloud.vip/link/3Dv3anqm7fBcTxcT?sub=3
+971,http://sub2.cutecloud.net/link/cDNGUOivouRigbSc?sub=3

validSubCount.py

@@ -0,0 +1,18 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+import requests
+from fastapi import APIRouter,BackgroundTasks
+
+
+def ValidSubCount(fileName:str)->int:
+    with open(fileName, "r") as f:
+        lines = f.readlines()
+    return len(lines)
+
+
+router = APIRouter()
+
+@router.get('/')
+def returnValidSubCount():
+    # 获取当前剩余的有效订阅数量 (方便随时检测)
+    return ValidSubCount(router.fileName)