From 3f0b31294cffec0cf419e741c3103d5bd74cb98e Mon Sep 17 00:00:00 2001 From: crutoboy Date: Fri, 29 May 2026 09:32:39 +0000 Subject: [PATCH] add Subscription-Userinfo support --- .env.example | 5 +++ config.py | 3 ++ main.py | 117 +++++++++++++++++++++++++++++++++++++++++---------- 3 files changed, 103 insertions(+), 22 deletions(-) diff --git a/.env.example b/.env.example index 848147b..df7c0f5 100644 --- a/.env.example +++ b/.env.example @@ -23,6 +23,11 @@ ANNOUNCE=Это объявление # Как часто клиенты должны обновлять подписку (в часах) UPDATE_INTERVAL=12 +# Информация об использовании трафика по умолчанию +# Используются при отсутствии настоящих данных +# Формат: upload=XXX; download=YYY; total=ZZZ; expire=UNIX_TIMESTAMP +SUBSCRIPTION_USERINFO=upload=0; download=0; total=0; expire=0 + # Ссылка на импорт маршрутизации для клиента Happ (happ://routing/add/...) # Скопируй полную ссылку из Happ или сгенерируй самостоятельно HAPP_ROUTING_LINK=happ://routing/add/eyJibG9ja2lwIjpbXSwiYmxvY2tzaXRlcyI6W10sImRpcmVjdGlwIjpbIjEwLjAuMC4wLzgiLCIxNzIuMTYuMC4wLzEyIiwiMTkyLjE2OC4wLjAvMTYiLCIxNjkuMjU0LjAuMC8xNiIsIjIyNC4wLjAuMC80IiwiMjU1LjI1NS4yNTUuMjU1IiwiZ2VvaXA6cnUiXSwiZGlyZWN0c2l0ZXMiOlsiZ2Vvc2l0ZTpjYXRlZ29yeS1ydSIsIioubG9jYWwiXSwiZG5zaG9zdHMiOnsiY2xvdWRmbGFyZS1kbnMuY29tIjoiMS4xLjEuMSIsImRucy5nb29nbGUiOiI4LjguOC44In0sImRvbWFpbnN0cmF0ZWd5IjoiSVBJZk5vbk1hdGNoIiwiZG9tZXN0aWNkbnNkb21haW4iOiJodHRwczovL2Rucy5nb29nbGUvZG5zLXF1ZXJ5IiwiZG9tZXN0aWNkbnNpcCI6IjguOC44LjgiLCJkb21lc3RpY2Ruc3R5cGUiOiJEb0giLCJmYWtlZG5zIjpmYWxzZSwiZ2VvaXB1cmwiOiJodHRwczovL2dpdGh1Yi5jb20vTG95YWxzb2xkaWVyL3YycmF5LXJ1bGVzLWRhdGEvcmVsZWFzZXMvbGF0ZXN0L2Rvd25sb2FkL2dlb2lwLmRhdCIsImdlb3NpdGV1cmwiOiJodHRwczovL2dpdGh1Yi5jb20vTG95YWxzb2xkaWVyL3YycmF5LXJ1bGVzLWRhdGEvcmVsZWFzZXMvbGF0ZXN0L2Rvd25sb2FkL2dlb3NpdGUuZGF0IiwiZ2xvYmFscHJveHkiOnRydWUsIm5hbWUiOiJydSwgbG9jYWwiLCJwcm94eWlwIjpbXSwicHJveHlzaXRlcyI6W10sInJlbW90ZWRuc2RvbWFpbiI6Imh0dHBzOi8vY2xvdWRmbGFyZS1kbnMuY29tL2Rucy1xdWVyeSIsInJlbW90ZWRuc2lwIjoiMS4xLjEuMSIsInJlbW90ZWRuc3R5cGUiOiJEb0giLCJyb3V0ZW9yZGVyIjoiYmxvY2stZGlyZWN0LXByb3h5In0= diff --git a/config.py b/config.py index ebfaa11..8b71dbf 100644 --- a/config.py +++ b/config.py @@ -21,3 +21,6 @@ PROFILE_WEB_PAGE_URL = os.getenv('PROFILE_WEB_PAGE_URL', '') ANNOUNCE = os.getenv('ANNOUNCE', '') UPDATE_INTERVAL = int(os.getenv('UPDATE_INTERVAL', '12')) # в часах HAPP_ROUTING_LINK = os.getenv('HAPP_ROUTING_LINK', '') # полный happ://routing/add/... + +# Fallback значение Subscription-Userinfo, если ни одна внешняя подписка не вернула свои данные +SUBSCRIPTION_USERINFO = os.getenv('SUBSCRIPTION_USERINFO', '') diff --git a/main.py b/main.py index fde1906..017884b 100644 --- a/main.py +++ b/main.py @@ -20,45 +20,118 @@ def index(): # Кеш внешних подписок с TTL (по умолчанию 1 час) _subs_cache = TTLCache(maxsize=256, ttl=c.SUBSCRIPTION_CACHE_TTL) @cached(_subs_cache) -def get_subs_from_server(link: str) -> List[str]: +def get_subs_from_server(link: str): """ - Получает и декодирует внешнюю подписку по HTTPS ссылке. - Результат кешируется на SUBSCRIPTION_CACHE_TTL секунд. + Получает внешнюю подписку. + Возвращает кортеж: (список нод, Subscription-Userinfo из заголовка или None) """ try: sub_response = requests.get(link, timeout=10) - decoded = base64.b64decode(sub_response.text).decode('utf-8') - res = decoded.split('\n') - res = list(filter(None, res)) - return res - except Exception: - # В случае ошибки не кешируем результат (попробуем снова при следующем запросе) - # Для этого очищаем кеш для данного ключа - _subs_cache.pop(link, None) - return [] + userinfo = sub_response.headers.get('Subscription-Userinfo') or \ + sub_response.headers.get('subscription-userinfo') + + decoded = base64.b64decode(sub_response.text).decode('utf-8') + nodes = [line for line in decoded.split('\n') if line.strip()] + + return nodes, userinfo + except Exception: + # При ошибке не кешируем и пробуем заново в следующий раз + _subs_cache.pop(link, None) + return [], None + +def format_urls(urls: List[str], user: str): + """ + Возвращает (список всех нод, список найденных Subscription-Userinfo из внешних подписок) + """ + all_nodes = [] + userinfos = [] -def format_urls(urls: List[str], user: str) -> List[str]: - res = [] for url in urls: url = url.strip().format(user) if url.startswith('https://'): - subs = get_subs_from_server(url) - res += subs - else: - res.append(url) - return res + nodes, userinfo = get_subs_from_server(url) + all_nodes += nodes + if userinfo: + userinfos.append(userinfo) + else: + all_nodes.append(url) + + return all_nodes, userinfos + +def _parse_userinfo(s: str) -> dict: + """Парсит строку вида 'upload=123; download=456; total=789; expire=1234567890'""" + data = {} + for part in s.split(';'): + part = part.strip() + if '=' in part: + k, v = part.split('=', 1) + try: + data[k.strip().lower()] = int(v.strip()) + except ValueError: + pass + return data + + +def _merge_userinfo(infos: list[str]) -> str | None: + """Объединяет несколько Subscription-Userinfo (суммирует трафик, берёт минимальные лимиты).""" + if not infos: + return None + + total_upload = 0 + total_download = 0 + min_total = None + min_expire = None + + for info in infos: + parsed = _parse_userinfo(info) + total_upload += parsed.get('upload', 0) + total_download += parsed.get('download', 0) + + t = parsed.get('total') + if t is not None and t > 0: + min_total = t if min_total is None else min(min_total, t) + + e = parsed.get('expire') + if e is not None and e > 0: + min_expire = e if min_expire is None else min(min_expire, e) + + parts = [ + f"upload={total_upload}", + f"download={total_download}", + ] + + if min_total is not None: + parts.append(f"total={min_total}") + else: + parts.append("total=0") + + if min_expire is not None: + parts.append(f"expire={min_expire}") + else: + parts.append("expire=0") + + return '; '.join(parts) + @app.route(f'{c.URI_PATH}') def get_subs(user: str): - urls = format_urls(c.URLS.get(user, []) + c.URLS.get('all', []), user) - urls_text = '\n'.join(urls) + nodes, upstream_userinfos = format_urls( + c.URLS.get(user, []) + c.URLS.get('all', []), user + ) + urls_text = '\n'.join(nodes) encoded = base64.b64encode(bytes(urls_text, 'utf-8')) - # Создаём ответ и добавляем заголовки resp = make_response(encoded) resp.headers['Content-Type'] = 'text/plain; charset=utf-8' + # === Динамический Userinfo из внешних подписок === + dynamic_userinfo = _merge_userinfo(upstream_userinfos) + if dynamic_userinfo: + resp.headers['Subscription-Userinfo'] = dynamic_userinfo + elif c.SUBSCRIPTION_USERINFO: # fallback на статическое значение, если есть + resp.headers['Subscription-Userinfo'] = c.SUBSCRIPTION_USERINFO + if c.UPDATE_INTERVAL: resp.headers['Profile-Update-Interval'] = str(c.UPDATE_INTERVAL)