From f4b801c773628cbc6a98a320afd679a985263be5 Mon Sep 17 00:00:00 2001
From: "google-labs-jules[bot]"
 <161369871+google-labs-jules[bot]@users.noreply.github.com>
Date: Thu, 10 Sep 2026 09:01:39 +0000
Subject: [PATCH] perf: parallelize fast.com downloads with asyncio.gather

Co-authored-by: Horizontal42 <75383519+Horizontal42@users.noreply.github.com>
---
 src/netsleuth/speed.py | 14 ++++++++++++--
 1 file changed, 12 insertions(+), 2 deletions(-)

diff --git a/src/netsleuth/speed.py b/src/netsleuth/speed.py
index 505e1f0..d32c6e9 100644
--- a/src/netsleuth/speed.py
+++ b/src/netsleuth/speed.py
@@ -183,16 +183,26 @@ async def tier_fastcom(client: httpx.AsyncClient, cfg: Speedtest, timeout: float
     targets = response.json().get("targets") or []
     samples: list[tuple[int, float]] = []
     on_net: bool | None = None
+
+    valid_targets = []
     for target in targets:
         url = target.get("url")
         if not url:
             continue
         location = (target.get("location") or {}).get("country")
         on_net = on_net or bool(location)
-        began = time.perf_counter()
+        valid_targets.append(url)
+
+    async def _fetch(url: str) -> int:
         body = await client.get(url, timeout=timeout)
         body.raise_for_status()
-        samples.append((len(body.content), time.perf_counter() - began))
+        return len(body.content)
+
+    if valid_targets:
+        began = time.perf_counter()
+        results = await asyncio.gather(*(_fetch(url) for url in valid_targets))
+        samples.append((sum(results), time.perf_counter() - began))
+
     return SpeedResult(
         method="fastcom",
         download_mbps=throughput_from_samples(samples),