Function _check_dc

core/telegram_scanner.py:109–144

(display: LiveDisplay)

        return False, None

async def _check_dc(display: LiveDisplay) -> List[dict]:
    spin  = 0
    results = []
    total = len(TELEGRAM_DC_IPS)
    lock  = asyncio.Lock()

    async def _one(ip, label):
        nonlocal spin
        reachable, rtt = await _tcp_ping(ip, TELEGRAM_DC_PORT)

        async with lock:
            results.append({"ip": ip, "label": label, "reachable": reachable, "rtt": rtt})
            spin = (spin + 1) % len(_SPIN)
            ok   = sum(1 for x in results if x["reachable"])
            await display.update(2, f"[dim]{_SPIN[spin]} проверяем {len(results)}/{total}  доступно: {ok}[/dim]")

    await asyncio.gather(*[_one(ip, lbl) for ip, lbl in TELEGRAM_DC_IPS])

    ok    = sum(1 for d in results if d["reachable"])
    parts = []
    for d in sorted(results, key=lambda x: x["label"]):
        rtt_s = f" {d['rtt']*1000:.0f}мс" if d.get("rtt") else ""
        if d["reachable"]:
            parts.append(f"[green]{d['label']}[/green][dim]{rtt_s}[/dim]")
        else:
            parts.append(f"[red]{d['label']}✗[/red]")

    if ok == total:
        st = f"[green]ОК {ok}/{total}[/green]"
    elif ok == 0:
        st = f"[red]НЕДОСТУПНЫ 0/{total}[/red]"
    else:
        st = f"[yellow]{ok}/{total}[/yellow]"

    await display.update(2, f"{st}  {'  '.join(parts)}")
    return results

# ─── Upload ──────────────────────────────────────────────────────────────────
async def _run_upload(display: LiveDisplay) -> dict: