diff --git a/package.v2.json b/package.v2.json index b066ce8..5dad11d 100644 --- a/package.v2.json +++ b/package.v2.json @@ -390,5 +390,17 @@ "history": { "v1.0": "支持清理QB中已下载的订阅文件" } + }, + "ToBypassTrackers": { + "name": "绕过Trackers", + "description": "提供tracker服务器IP地址列表，帮助IPv6连接绕过OpenClash", + "labels": "工具", + "version": "1.0", + "icon": "Clash_A.png", + "author": "wumode", + "level": 2, + "history": { + "v1.0": "支持自定义Trackers" + } } } \ No newline at end of file diff --git a/plugins.v2/tobypasstrackers/__init__.py b/plugins.v2/tobypasstrackers/__init__.py new file mode 100644 index 0000000..ac7297f --- /dev/null +++ b/plugins.v2/tobypasstrackers/__init__.py @@ -0,0 +1,597 @@ +from typing import Any, List, Dict, Tuple, Optional +from datetime import datetime, timedelta +import pickle +import ipaddress +import socket + +from apscheduler.schedulers.background import BackgroundScheduler +from fastapi import Response +from apscheduler.triggers.cron import CronTrigger +import pytz + +from app.chain.site import SiteChain +from app.core.config import settings +from app.core.event import EventManager, eventmanager +from app.db.site_oper import SiteOper +from app.helper.sites import SitesHelper +from app.log import logger +from app.plugins import _PluginBase +from app.utils.http import RequestUtils +from app.schemas.types import EventType, NotificationType +from app.plugins.tobypasstrackers.dns_helper import DnsHelper + + +class ToBypassTrackers(_PluginBase): + # 插件名称 + plugin_name = "绕过Trackers" + # 插件描述 + plugin_desc = "提供tracker服务器IP地址列表，帮助IPv6连接绕过OpenClash" + # 插件图标 + plugin_icon = "Clash_A.png" + # 插件版本 + plugin_version = "1.0" + # 插件作者 + plugin_author = "wumode" + # 作者主页 + author_url = "https://github.com/wumode" + # 插件配置项ID前缀 + plugin_config_prefix = "tobypasstrackers_" + # 加载顺序 + plugin_order = 21 + # 可使用的用户级别 + auth_level = 2 + + # 私有属性 + sites: SitesHelper = None + site_chain: SiteChain = None + siteoper: SiteOper = None + + + # 事件管理器 + event: EventManager = None + # 定时器 + _scheduler: Optional[BackgroundScheduler] = None + # 开关 + _enabled: bool = False + _cron: str = "" + _notify = False + _onlyonce: bool = False + _custom_trackers: str = "" + _bypassed_sites: list = [] + _china_ip_route: bool = True + _china_ipv6_route: bool = True + _bypass_ipv4: bool = True + _bypass_ipv6: bool = True + _dns_input: str = "" + ipv6_txt: str = "" + ipv4_txt: str = "" + + def init_plugin(self, config: dict = None): + self.sites = SitesHelper() + # self.event = EventManager() + self.site_chain = SiteChain() + self.stop_service() + self.siteoper = SiteOper() + self.trackers = {} + self.ipv6_txt = self.get_data('ipv6_txt') if self.get_data('ipv6_txt') else "" + self.ipv4_txt = self.get_data('ipv4_txt') if self.get_data('ipv4_txt') else "" + try: + with open(f"{settings.ROOT_PATH}/app/plugins/tobypasstrackers/sites/trackers", "rb") as f: + self.trackers = pickle.load(f) + except Exception as e: + logger.error(f"插件加载错误：{e}") + # 配置 + if config: + self._enabled = config.get("enabled") + self._cron = config.get("cron") + self._onlyonce = config.get("onlyonce") + self._notify = config.get("notify") + self._custom_trackers = config.get("custom_trackers") + self._bypassed_sites = config.get("bypassed_sites") or [] + self._bypass_ipv4 = config.get("bypass_ipv4") + self._bypass_ipv6 = config.get("bypass_ipv6") + self._dns_input = config.get("dns_input") + self._china_ipv6_route = config.get("china_ipv6_route") + self._china_ip_route = config.get("china_ip_route") + # 过滤掉已删除的站点 + all_sites = [site.id for site in self.siteoper.list_order_by_pri()] + self._bypassed_sites = [site_id for site_id in all_sites if site_id in self._bypassed_sites] + self.__update_config() + if self._enabled or self._onlyonce: + self._scheduler = BackgroundScheduler(timezone=settings.TZ) + if self._onlyonce: + logger.info(f"立即运行一次") + self._scheduler.add_job(self.update_ips, 'date', + run_date=datetime.now( + tz=pytz.timezone(settings.TZ)) + timedelta(seconds=3) + ) + self._onlyonce = False + self.__update_config() + self._scheduler.print_jobs() + self._scheduler.start() + + def get_state(self) -> bool: + return self._enabled + + def __update_config(self): + # 保存配置 + self.update_config( + { + "enabled": self._enabled, + "cron": self._cron, + "onlyonce": self._onlyonce, + "bypassed_sites": self._bypassed_sites, + "custom_trackers": self._custom_trackers, + "notify": self._notify, + "dns_input": self._dns_input, + "china_ip_route": self._china_ip_route, + "china_ipv6_route": self._china_ipv6_route, + "bypass_ipv6": self._bypass_ipv6, + "bypass_ipv4": self._bypass_ipv4 + } + ) + + @staticmethod + def get_command() -> List[Dict[str, Any]]: + pass + + def get_api(self) -> List[Dict[str, Any]]: + """ + 获取插件API + [{ + "path": "/xx", + "endpoint": self.xxx, + "methods": ["GET", "POST"], + "summary": "API说明" + }] + """ + return [{ + "path": "/bypassed_ips", + "endpoint": self.bypassed_ips, + "methods": ["GET"], + "summary": "绕过的IP", + "description": "绕过Clash核心的IP地址列表", + }] + + def get_form(self) -> Tuple[List[dict], Dict[str, Any]]: + site_options = ([{"title": site.name, "value": site.id} + for site in self.siteoper.list_order_by_pri()] + ) + return [ + { + 'component': 'VForm', + 'content': [ + { + 'component': 'VRow', + 'content': [ + { + 'component': 'VCol', + 'props': { + 'cols': 12, + 'md': 4 + }, + 'content': [ + { + 'component': 'VSwitch', + 'props': { + 'model': 'enabled', + 'label': '启用插件', + } + } + ] + }, + { + 'component': 'VCol', + 'props': { + 'cols': 12, + 'md': 4 + }, + 'content': [ + { + 'component': 'VSwitch', + 'props': { + 'model': 'notify', + 'label': '发送通知', + } + } + ] + }, + { + 'component': 'VCol', + 'props': { + 'cols': 12, + 'md': 4 + }, + 'content': [ + { + 'component': 'VSwitch', + 'props': { + 'model': 'onlyonce', + 'label': '立即运行一次', + } + } + ] + } + ] + }, + { + 'component': 'VRow', + 'content': [ + { + 'component': 'VCol', + 'props': { + 'cols': 12, + 'md': 3 + }, + 'content': [ + { + 'component': 'VSwitch', + 'props': { + 'model': 'bypass_ipv4', + 'label': '绕过 IPv4 Tracker', + } + } + ] + }, + { + 'component': 'VCol', + 'props': { + 'cols': 12, + 'md': 3 + }, + 'content': [ + { + 'component': 'VSwitch', + 'props': { + 'model': 'bypass_ipv6', + 'label': '绕过 IPv6 Tracker', + } + } + ] + }, + { + 'component': 'VCol', + 'props': { + 'cols': 12, + 'md': 3 + }, + 'content': [ + { + 'component': 'VSwitch', + 'props': { + 'model': 'china_ip_route', + 'label': '合并中国大陆IPv4列表', + } + } + ] + }, + { + 'component': 'VCol', + 'props': { + 'cols': 12, + 'md': 3 + }, + 'content': [ + { + 'component': 'VSwitch', + 'props': { + 'model': 'china_ipv6_route', + 'label': '合并中国大陆IPv6列表', + } + } + ] + }, + ] + }, + { + 'component': 'VRow', + 'content': [ + { + 'component': 'VCol', + 'props': { + 'cols': 12, + 'md': 6 + }, + 'content': [ + { + 'component': 'VCronField', + 'props': { + 'model': 'cron', + 'label': '执行周期', + 'placeholder': '0 4 * * *' + } + } + ] + }, + { + 'component': 'VCol', + 'props': { + 'cols': 12, + 'md': 6 + }, + 'content': [ + { + 'component': 'VTextField', + 'props': { + 'model': 'dns_input', + 'label': 'DNS 服务器', + 'placeholder': '留空则使用本地DNS' + } + } + ] + } + ] + }, + { + 'component': 'VRow', + 'content': [ + { + 'component': 'VCol', + 'content': [ + { + 'component': 'VSelect', + 'props': { + 'chips': True, + 'multiple': True, + 'model': 'bypassed_sites', + 'label': '绕过站点', + 'items': site_options + } + } + ] + } + ] + }, + { + 'component': 'VRow', + 'content': [ + { + 'component': 'VCol', + 'props': { + 'cols': 12 + }, + 'content': [ + { + 'component': 'VTextarea', + 'props': { + 'model': 'custom_trackers', + 'label': '自定义Tracker服务器', + 'rows': 3, + 'placeholder': '每行一个域名或IP' + } + } + ] + } + ] + }, + { + 'component': 'VRow', + 'content': [ + { + 'component': 'VCol', + 'props': { + 'cols': 12 + }, + 'content': [ + { + 'component': 'VAlert', + 'props': { + 'type': 'info', + 'variant': 'tonal', + 'text': 'DNS 服务器示例: ' + '1、94.140.14.140;' + '2、94.140.14.140:53;' + '3、[2a10:50c0::1:ff]:53;' + '4、https://unfiltered.adguard-dns.com/dns-query。' + '仅支持UDP和HTTPS方法, 留空使用本地DNS查询。' + } + } + ] + } + ] + }, + { + 'component': 'VRow', + 'content': [ + { + 'component': 'VCol', + 'props': { + 'cols': 12 + }, + 'content': [ + { + 'component': 'VAlert', + 'props': { + 'type': 'info', + 'variant': 'tonal', + 'text': '【订阅URL】' + 'IPv4: {Moviepilot地址}/api/v1/plugin/ToBypassTrackers/bypassed_ips?apikey={apikey}&protocol=4; ' + 'IPv6: {Moviepilot地址}/api/v1/plugin/ToBypassTrackers/bypassed_ips?apikey={apikey}&protocol=6。' + } + } + ] + } + ] + }, + { + 'component': 'VRow', + 'content': [ + { + 'component': 'VCol', + 'props': { + 'cols': 12 + }, + 'content': [ + { + 'component': 'VAlert', + 'props': { + 'type': 'info', + 'variant': 'tonal', + 'text': '【如何使用】' + '在OpenClash->插件设置->中国大陆IP路由 选择 绕过中国大陆; ' + '在OpenClash->插件设置->Chnroute Update 填入订阅URL。' + } + } + ] + } + ] + } + ] + } + ], { + "enabled": False, + "notify": False, + "onlyonce": False, + "cron": "0 4 * * *", + "bypassed_sites": [], + "custom_trackers": "", + "dns_input": "", + "china_ip_route": True, + "china_ipv6_route": True, + "bypass_ipv4": True, + "bypass_ipv6": True + } + + def get_page(self) -> List[dict]: + pass + + def get_dashboard(self, key: str = None, **kwargs) -> Optional[Tuple[Dict[str, Any], Dict[str, Any], List[dict]]]: + """ + 获取插件仪表盘页面，需要返回：1、仪表板col配置字典；2、全局配置（自动刷新等）；3、仪表板页面元素配置json（含数据） + 1、col配置参考： + { + "cols": 12, "md": 6 + } + 2、全局配置参考： + { + "refresh": 10 // 自动刷新时间，单位秒 + } + 3、页面配置使用Vuetify组件拼装，参考：https://vuetifyjs.com/ + """ + pass + + def stop_service(self): + """ + 退出插件 + """ + try: + if self._scheduler: + self._scheduler.remove_all_jobs() + if self._scheduler.running: + self._scheduler.shutdown() + self._scheduler = None + except Exception as e: + logger.error("退出插件失败：%s" % str(e)) + + def get_service(self) -> List[Dict[str, Any]]: + """ + 注册插件公共服务 + [{ + "id": "服务ID", + "name": "服务名称", + "trigger": "触发器：cron/interval/date/CronTrigger.from_crontab()", + "func": self.xxx, + "kwargs": {} # 定时器参数 + }] + """ + if self.get_state(): + return [{ + "id": "ToBypassTrackers", + "name": "绕过Trackers服务", + "trigger": CronTrigger.from_crontab(self._cron), + "func": self.update_ips, + "kwargs": {} + }] + return [] + + def bypassed_ips(self, protocol: str): + if protocol == '6': + return Response(content=self.ipv6_txt, media_type="text/plain") + return Response(content=self.ipv4_txt, media_type="text/plain") + + @eventmanager.register(EventType.PluginAction) + def update_ips(self): + def __is_ip_in_subnet(ip: str, subnet: str) -> bool: + """ + Check if the given IP address is in the specified subnet. + + :param ip: IP address as a string (e.g., '192.168.1.1') + :param subnet: Subnet in CIDR notation (e.g., '192.168.1.0/24') + :return: True if IP is in the subnet, False otherwise + """ + ip_obj = ipaddress.ip_address(ip) + subnet_obj = ipaddress.ip_network(subnet, strict=False) + return ip_obj in subnet_obj + # replacing = data.get('replace') + chnroute6_lists_url = 'https://ispip.clang.cn/all_cn_ipv6.txt' + chnroute_lists_url = 'https://ispip.clang.cn/all_cn.txt' + ipv6_list = [] + ip_list = [] + domains = [] + if self._china_ipv6_route: + # Load Chnroute6 Lists + res = RequestUtils().get_res(url=chnroute6_lists_url) + if res is not None and res.status_code == 200: + chnroute6_lists = res.text[:-1].split('\n') + for ipr in chnroute6_lists: + ipv6_list.append(ipr) + if self._china_ip_route: + # Load Chnroute Lists + res = RequestUtils().get_res(url=chnroute_lists_url) + if res is not None and res.status_code == 200: + chnroute_lists = res.text[:-1].split('\n') + for ipr in chnroute_lists: + ip_list.append(ipr) + do_sites = {site.domain: site.name for site in self.siteoper.list_order_by_pri() if site.id in self._bypassed_sites} + for site in do_sites: + site_domains = self.trackers.get(site) + if site_domains: + domains.extend(site_domains) + else: + logger.warn(f"不支持的站点: {do_sites[site]}({site})") + for custom_tracker in self._custom_trackers.split('\n'): + if custom_tracker: + try: + socket.inet_pton(socket.AF_INET, custom_tracker) + if self._bypass_ipv4: + ip_list.append(f"{custom_tracker}/32") + except socket.error: + try: + socket.inet_pton(socket.AF_INET6, custom_tracker) + if self._bypass_ipv6: + ipv6_list.append(ipaddress.ip_network(f"{custom_tracker}/128", strict=False).compressed) + except socket.error: + domains.append(custom_tracker) + for domain in domains: + if self._bypass_ipv6: + ipv6_addresses = DnsHelper.query_domain(domain, self._dns_input, 'AAAA') + if ipv6_addresses is None: + logger.warn(f"{domain} AAAA 记录查询失败") + continue + for address in ipv6_addresses: + has_flag = False + for subnet in ipv6_list: + if __is_ip_in_subnet(address, subnet): + has_flag = True + break + if not has_flag: + ipv6_list.append(ipaddress.ip_network(f"{address}/128", strict=False).compressed) + logger.info(f"{address} ({domain}) 已被添加") + if self._bypass_ipv4: + ip_addresses = DnsHelper.query_domain(domain,self._dns_input, 'A') + if ip_addresses is None: + logger.warn(f"{domain} A 记录查询失败") + continue + for address in ip_addresses: + has_flag = False + for subnet in ip_list: + if __is_ip_in_subnet(address, subnet): + has_flag = True + break + if not has_flag: + ip_list.append(f"{address}/32") + logger.info(f"{address} ({domain}) 已被添加") + self.ipv4_txt = "\n".join(ip_list) + self.ipv6_txt = "\n".join(ipv6_list) + self.save_data("ipv4_txt", self.ipv4_txt) + self.save_data("ipv6_txt", self.ipv6_txt) diff --git a/plugins.v2/tobypasstrackers/dns_helper.py b/plugins.v2/tobypasstrackers/dns_helper.py new file mode 100644 index 0000000..000b682 --- /dev/null +++ b/plugins.v2/tobypasstrackers/dns_helper.py @@ -0,0 +1,105 @@ +import socket +import re +from typing import Optional + +import dns.resolver + +from app.log import logger +from app.utils.http import RequestUtils + + +class DnsHelper: + + @staticmethod + def query_dns_udp(domain: str, dns_server: str, port: int =53, dns_type: str ='A') -> list[str]: + resolver = dns.resolver.Resolver() + resolver.nameservers = [dns_server] + resolver.port = port + + try: + ip_answer = resolver.resolve(domain, dns_type) + ip_addresses = [record.address for record in ip_answer] + except dns.resolver.NoAnswer: + ip_addresses = [] + except: + return None + return ip_addresses + + @staticmethod + def query_doh(domain: str, doh_url: str, dns_type: str = 'A') -> Optional[list]: + params = { + 'name': domain, + 'type': dns_type, + } + headers = { + 'Accept': 'application/dns-json', + } + response = RequestUtils().get_res(url=doh_url, headers=headers, params=params) + if not response.status_code == 200: + return None + data = response.json() + return [answer['data'] for answer in data.get('Answer', []) if + answer.get('type') == 28 or answer.get('type') == 1] + + @staticmethod + def parse_dns_input(dns_input: str): + if not dns_input: + return 'local', dns_input + # Check if it's a DoH URL (starts with https://) + if dns_input.startswith('https://'): + return 'doh', dns_input + + # Check if it's a UDP DNS with hostname (e.g., udp://unfiltered.adguard-dns.com) + if dns_input.startswith('udp://'): + hostname = dns_input[len('udp://'):] + return 'udp', hostname, 53 + + # Check if it's an IP address with port (e.g., 94.140.14.140:53 or [2a10:50c0::1:ff]:53) + port_match = re.match(r'^(\[?.+?\]?):(\d+)$', dns_input) + if port_match: + dns_server = port_match.group(1).strip('[]') + port = int(port_match.group(2)) + return 'udp', dns_server, port + + # Default to regular DNS over UDP with default port 53 + return 'udp', dns_input, 53 + + @staticmethod + def query_dns_local(domain_name: str, dns_type: str = 'A') -> Optional[list]: + try: + # Get address info for both IPv4 and IPv6 + addr_info = socket.getaddrinfo(domain_name, None, socket.AF_UNSPEC, socket.SOCK_STREAM) + + ipv4_addresses = [] + ipv6_addresses = [] + + # Iterate over the address info + for info in addr_info: + ip_address = info[4][0] + + # Check if the IP address is IPv4 or IPv6 + if '.' in ip_address: + ipv4_addresses.append(ip_address) + elif ':' in ip_address: + ipv6_addresses.append(ip_address) + if dns_type == 'A': + return ipv4_addresses + elif dns_type == 'AAAA': + return ipv6_addresses + + except socket.gaierror as e: + logger.error(f"本地DNS查询错误: {e} {domain_name}") + + @staticmethod + def query_domain(domain: str, dns_input: str, dns_type='A') -> Optional[list]: + method, *args = DnsHelper.parse_dns_input(dns_input) + if method == 'local': + return DnsHelper.query_dns_local(domain, dns_type) + elif method == 'udp': + dns_server, port = args + return DnsHelper.query_dns_udp(domain, dns_server, port, dns_type) + elif method == 'doh': + doh_url = args[0] + return DnsHelper.query_doh(domain, doh_url, dns_type) + else: + logger.error(f'Unknown method {method}') \ No newline at end of file diff --git a/plugins.v2/tobypasstrackers/requirements.txt b/plugins.v2/tobypasstrackers/requirements.txt new file mode 100644 index 0000000..1b7439e --- /dev/null +++ b/plugins.v2/tobypasstrackers/requirements.txt @@ -0,0 +1 @@ +dnspython~=2.7.0 \ No newline at end of file diff --git a/plugins.v2/tobypasstrackers/sites/trackers b/plugins.v2/tobypasstrackers/sites/trackers new file mode 100644 index 0000000..55d8d01 Binary files /dev/null and b/plugins.v2/tobypasstrackers/sites/trackers differ