Merge branch 'main' of https://git.tvstart.ru/ychernenko/RFB

get_data.py

@@ -14,7 +14,7 @@ from dotenv import load_dotenv
 from pprint import pprint
 import nasio
 import io, os, platform, time
-import xml.etree.ElementTree as ET
+import xml.etree.ElementTree as ETя
 import re
 from PIL import Image, ImageDraw, ImageFont
 from io import BytesIO
@@ -687,7 +687,12 @@ def results_consumer():
                             "game over",
                         ]
 
-                        # 1) матч ЗАКОНЧЕН → запускаем ОТСРОЧЕННЫЙ переход
+                        # 1) матч ЗАКОНЧЕН → запускаем ОТСРОЧЕННЫЙ переход 
+                        # ##TODO - Усложненый код? Нужен, если статус бывает сложнее, чем "result",
+                        # а что-то в стиле "result 1:0", т.е. слова из finished_markers являются 
+                        # состовной частью настоящего статуса
+                        # В противном случае вполне рабочий вариант: 
+                        # if raw_ls_status_low in finished_markers:
                         if any(m in raw_ls_status_low for m in finished_markers):
                             now_ts = time.time()
                             # если ещё не назначали переход — назначим
@@ -805,6 +810,7 @@ def get_items(data: dict) -> list:
     Многие ручки отдают {"result":[...]} или {"seasons":[...]}.
     Если находим список — возвращаем его.
     Если нет — возвращаем None (значит, нужно брать весь dict).
+    ВНИМАНИЕ: если списков в data несколько - вернет случайный
     """
     for k, v in data.items():
         if isinstance(v, list):
@@ -847,6 +853,8 @@ def pick_game_for_team(calendar_json):
             return game["game"]["id"], gdt, True, cal_status
 
     # 2) если на сегодня нет — берём последнюю прошедшую
+    # TODO - код повторяется почти без изменений.
+    # Можно без сожаления свести в один проход.
     last_id = None
     last_dt = None
     last_status = None
@@ -3229,14 +3237,11 @@ def change_vmix_datasource_urls(xml_data, new_base_url: str) -> bytes:
     root = ET.fromstring(text)
 
     # 4. Меняем URL
-    for ds in root.findall(".//datasource[@friendlyName='JSON']"):
-        for inst in ds.findall(".//instance"):
-            url_tag = inst.find(".//state/xml/url")
-            if url_tag is not None and url_tag.text:
-                old_url = url_tag.text.strip()
-                pattern = r"https?\:\/\/\w+\.\w+\.\w{2,}|https?\:\/\/\d{,3}\.\d{,3}\.\d{,3}\.\d{,3}\:\d*"
-                new_url = re.sub(pattern, new_base_url, old_url, count=0, flags=0)
-                url_tag.text = new_url
+    for url_tag in root.findall(".//datasource[@friendlyName='JSON']//instance//state/xml/url"):
+        old_url = url_tag.text.strip()
+        pattern = r'https?:\/\/[^\/]+'
+        new_url = re.sub(pattern, new_base_url, old_url, count=0, flags=0)
+        url_tag.text = new_url
 
     # 5. Сериализуем обратно в bytes
     new_xml = ET.tostring(root, encoding="utf-8", method="xml")