PLUS: логи запросов и диагностика

plus/diag.py

@@ -8,6 +8,7 @@ import argparse
 import io
 import json
 import math
+import pathlib
 import struct
 import sys
 import time
@@ -16,6 +17,45 @@ import urllib.request
 import uuid
 import wave
 
+LINKS = "muscriptor_links.txt"
+
+
+def read_link() -> tuple[str, int, int]:
+    """Достать ссылку и порты из файла, который пишет пускач."""
+    path = pathlib.Path(LINKS)
+    if not path.exists():
+        return "", 8222, 8223
+    url, server, proxy = "", 8222, 8223
+    for line in path.read_text(encoding="utf-8").splitlines():
+        low = line.lower()
+        if low.startswith("ссылка:"):
+            url = line.split(":", 1)[1].strip()
+        elif low.startswith("локально через прокси:") or low.startswith("локально:"):
+            tail = line.rsplit(":", 1)[-1].strip()
+            if tail.isdigit():
+                if "прокси" in low:
+                    proxy = int(tail)
+                else:
+                    server = int(tail)
+    return url, server, proxy
+
+
+def clean_url(value: str) -> str:
+    """Проверить адрес: пустой, кириллица и заглушки отсекаются."""
+    text = (value or "").strip()
+    if not text:
+        return ""
+    if not text.isascii():
+        print("! в адресе не-латинские символы: %r — это заглушка, отбрасываю" % text)
+        return ""
+    if "твоя" in text or "link" in text.replace(".serveo.net", "").replace(".life", ""):
+        return ""
+    if not text.startswith(("http://", "https://")):
+        print("! адрес должен начинаться с http:// или https://")
+        return ""
+    return text
+
+
 BYPASS = {"serveo-skip-browser-warning": "true"}
 
 
@@ -83,17 +123,25 @@ def post(base, audio, timeout=300):
 
 def main():
     parser = argparse.ArgumentParser(description="Диагностика POST /transcribe через туннель")
-    parser.add_argument("--url", default="", help="публичная ссылка туннеля")
-    parser.add_argument("--proxy", type=int, default=8223, help="локальный порт прокси")
+    parser.add_argument("--url", default="", help="публичная ссылка; иначе беру из " + LINKS)
+    parser.add_argument("--proxy", type=int, default=0, help="порт прокси; 0 = из файла")
+    parser.add_argument("--server", type=int, default=0, help="порт сервера; 0 = из файла")
     parser.add_argument("--seconds", type=float, default=2.0)
     args = parser.parse_args()
 
+    url_from_file, server_port, proxy_port = read_link()
+    url = clean_url(args.url) or clean_url(url_from_file)
+    proxy_port = args.proxy or proxy_port
+    if not url and not args.url:
+        print("адрес не задан и в %s его нет — проверю только локально" % LINKS)
+
     audio = probe_wav(args.seconds)
-    print("проба: %.0f КБ WAV\n" % (len(audio) / 1024))
+    print("проба: %.0f КБ WAV" % (len(audio) / 1024))
+    print("цели: туннель %s | локальный прокси :%d\n" % (url or "нет", proxy_port))
 
-    targets = [("локально :%d" % args.proxy, "http://127.0.0.1:%d" % args.proxy)]
-    if args.url:
-        targets.insert(0, ("через туннель", args.url))
+    targets = [("локально :%d" % proxy_port, "http://127.0.0.1:%d" % proxy_port)]
+    if url:
+        targets.insert(0, ("через туннель", url))
 
     verdict = {}
     for label, base in targets:
@@ -104,12 +152,16 @@ def main():
             print("  дошло и ответило: первый байт %s с | всего %.1f с | нот %d | пульсов %d"
                   % (round(result["first"], 2) if result["first"] else "-",
                      result["total"], result["notes"], result["pings"]))
+            if result["events"] == 0:
+                print("  но событий SSE нет: похоже, ответила заглушка провайдера,"
+                      " а не MuScriptor")
+                result["ok"] = False
         else:
             print("  ОШИБКА за %.1f с: %s" % (result["total"], result.get("error")))
 
-    if args.url and "локально :%d" % args.proxy in verdict:
+    if url and "локально :%d" % proxy_port in verdict:
         remote = verdict["через туннель"]
-        local = verdict["локально :%d" % args.proxy]
+        local = verdict["локально :%d" % proxy_port]
         print("\nвывод:")
         if local["ok"] and not remote["ok"]:
             print("  локально работает, снаружи нет → рвёт туннель, не сервер")
@@ -119,7 +171,22 @@ def main():
         elif local["ok"] and remote["ok"]:
             print("  и локально, и снаружи работает: туннель держит POST")
         elif not local["ok"]:
-            print("  локально тоже ошибка → смотри muscriptor_proxy.log и сервер")
+            print("  локально тоже ошибка: скорее всего пускач не работает в этом ядре")
+            print("  проверь, что ячейка запуска жива и на :%d кто-то слушает" % proxy_port)
+            print("  если портов нет, запусти пускач заново — он перезапишет %s" % LINKS)
+    if not url and verdict:
+        only = list(verdict.values())[0]
+        if not only["ok"]:
+            print("\nвывод:")
+            print("  локальный прокси не отвечает: пускач не работает в этом ядре")
+            print("  запусти ячейку запуска заново, она запишет %s и порты" % LINKS)
+        elif only.get("events", 0) == 0:
+            print("\nвывод:")
+            print("  прокси ответил, но событий SSE нет: смотри muscriptor_server.log")
+        else:
+            print("\nвывод:")
+            print("  локально всё работает: %d нот, %d пульсов"
+                  % (only["notes"], only["pings"]))
     return 0