e

edit watchfooty mirrors
misc. edits

M3U8/scrapers/sport9.py

@@ -25,7 +25,7 @@ async def get_events(cached_keys: list[str]) -> list[dict[str, str]]:
         network.request(
             BASE_URL,
             log=log,
-            params={"date": f"{d.date()}"},
+            params={"date": d.date()},
         )
         for d in [
             now.delta(days=-1),

M3U8/scrapers/streamcenter.py

@@ -16,7 +16,6 @@ API_FILE = Cache(f"{TAG.lower()}-api.json", exp=28_800)
 
 BASE_URL = "https://backendstreamcenter.youshop.pro:488/api/Parties"
 
-
 CATEGORIES = {
     4: "Basketball",
     9: "Football",

M3U8/scrapers/streamhub.py

@@ -19,7 +19,6 @@ HTML_CACHE = Cache(f"{TAG.lower()}-html.json", exp=28_800)
 
 BASE_URL = "https://streamhub.pro/"
 
-
 CATEGORIES = {
     "Soccer": "sport_68c02a4464a38",
     "American Football": "sport_68c02a4465113",

M3U8/scrapers/streamsgate.py

@@ -58,7 +58,7 @@ async def refresh_api_cache(now_ts: float) -> list[dict[str, Any]]:
 
     results = await asyncio.gather(*tasks)
 
-    if not (data := list(chain.from_iterable(r.json() for r in results if r))):
+    if not (data := [*chain.from_iterable(r.json() for r in results if r)]):
         return []
 
     for ev in data:
@@ -94,10 +94,10 @@ async def get_events(cached_keys: list[str]) -> list[dict[str, str]]:
         if not (event_ts and sport):
             continue
 
-        if f"[{sport}] {event} ({TAG})" in cached_keys:
+        if "F1 Abu Dhabi" in event:  # api bug
             continue
 
-        if "F1 Abu Dhabi" in event:  # api bug
+        if f"[{sport}] {event} ({TAG})" in cached_keys:
             continue
 
         event_dt = Time.from_ts(event_ts)

M3U8/scrapers/watchfooty.py

@@ -19,11 +19,15 @@ CACHE_FILE = Cache(f"{TAG.lower()}.json", exp=10_800)
 
 API_FILE = Cache(f"{TAG.lower()}-api.json", exp=28_800)
 
-API_MIRRORS = ["https://api.watchfooty.top", "https://api.watchfooty.st"]
+API_URL = "https://api.watchfooty.st"
 
-BASE_MIRRORS = ["https://www.watchfooty.top", "https://www.watchfooty.st"]
+BASE_MIRRORS = [
+    "https://www.watchfooty.top",
+    "https://www.watchfooty.st",
+    "https://www.watchfooty.su",
+]
 
-SPORT_ENDPOINTS = [
+VALID_SPORTS = [
     "american-football",
     # "australian-football",
     # "baseball",
@@ -41,27 +45,27 @@ SPORT_ENDPOINTS = [
 ]
 
 
-async def refresh_api_cache(url: str, now_ts: float) -> list[dict[str, Any]]:
+async def refresh_api_cache(now: Time) -> list[dict[str, Any]]:
     log.info("Refreshing API cache")
 
     tasks = [
         network.request(
-            urljoin(url, f"api/v1/matches/{sport}"),
+            urljoin(API_URL, "api/v1/matches/all"),
             log=log,
-            timeout=5,
+            params={"date": d.date()},
         )
-        for sport in SPORT_ENDPOINTS
+        for d in [now, now.delta(days=1)]
     ]
 
     results = await asyncio.gather(*tasks)
 
-    if not (data := list(chain.from_iterable(r.json() for r in results if r))):
+    if not (data := [*chain.from_iterable(r.json() for r in results if r)]):
         return []
 
     for ev in data:
         ev["ts"] = ev.pop("timestamp")
 
-        data[-1]["timestamp"] = now_ts
+        data[-1]["timestamp"] = now.timestamp()
 
     return data
 
@@ -158,16 +162,11 @@ async def process_event(
         await page.close()
 
 
-async def get_events(
-    base_url: str,
-    api_url: str,
-    cached_keys: list[str],
-) -> list[dict[str, str]]:
-
+async def get_events(base_url: str, cached_keys: list[str]) -> list[dict[str, str]]:
     now = Time.clean(Time.now())
 
     if not (api_data := API_FILE.load(per_entry=False, index=-1)):
-        api_data = await refresh_api_cache(api_url, now.timestamp())
+        api_data = await refresh_api_cache(now)
 
         API_FILE.write(api_data)
 
@@ -188,6 +187,9 @@ async def get_events(
         if not (match_id and name and league):
             continue
 
+        if event["sport"] not in VALID_SPORTS:
+            continue
+
         sport = pattern.split(league, 1)[0].strip()
 
         if f"[{sport}] {name} ({TAG})" in cached_keys:
@@ -203,7 +205,7 @@ async def get_events(
         if not start_dt <= event_dt <= end_dt:
             continue
 
-        logo = urljoin(api_url, poster) if (poster := event.get("poster")) else None
+        logo = urljoin(API_URL, poster) if (poster := event.get("poster")) else None
 
         events.append(
             {
@@ -229,11 +231,7 @@ async def scrape() -> None:
 
     log.info(f"Loaded {cached_count} event(s) from cache")
 
-    base_url = await network.get_base(BASE_MIRRORS)
-
-    api_url = await network.get_base(API_MIRRORS)
-
-    if not (base_url and api_url):
+    if not (base_url := await network.get_base(BASE_MIRRORS)):
         log.warning("No working Watch Footy mirrors")
 
         CACHE_FILE.write(cached_urls)
@@ -242,11 +240,7 @@ async def scrape() -> None:
 
     log.info(f'Scraping from "{base_url}"')
 
-    events = await get_events(
-        base_url,
-        api_url,
-        cached_urls.keys(),
-    )
+    events = await get_events(base_url, cached_urls.keys())
 
     log.info(f"Processing {len(events)} new URL(s)")