diff --git a/M3U8/scrapers/ppv.py b/M3U8/scrapers/ppv.py index fd810e0..d626ae0 100644 --- a/M3U8/scrapers/ppv.py +++ b/M3U8/scrapers/ppv.py @@ -130,7 +130,13 @@ async def get_events( cached_keys: set[str], ) -> list[dict[str, str]]: if not (api_data := API_FILE.load(per_entry=False)): - api_data = await refresh_api_cache(client, urljoin(base_url, "api/streams")) + api_data = await refresh_api_cache( + client, + urljoin( + base_url, + "api/streams", + ), + ) API_FILE.write(api_data) diff --git a/M3U8/scrapers/strmd.py b/M3U8/scrapers/strmd.py index d77534a..c14290f 100644 --- a/M3U8/scrapers/strmd.py +++ b/M3U8/scrapers/strmd.py @@ -141,7 +141,11 @@ async def get_events( ) -> list[dict[str, str]]: if not (api_data := API_FILE.load(per_entry=False, index=True)): api_data = await refresh_api_cache( - client, urljoin(base_url, "api/matches/all-today") + client, + urljoin( + base_url, + "api/matches/all-today", + ), ) API_FILE.write(api_data) @@ -180,18 +184,17 @@ async def get_events( if not start_dt <= event_dt <= end_dt: continue - source: list[dict[str, str]] = event["sources"] + sources: list[dict[str, str]] = event["sources"] - for s in source: - source_type = s.get("source") + if not sources: + continue - stream_id = s.get("id") + first_source = sources[0] + source_type = first_source.get("source") + stream_id = first_source.get("id") - if not source_type: - continue - - if not stream_id: - continue + if not (source_type and stream_id): + continue events.append( {