doms/iptv
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 3

update M3U8

Browse source
This commit is contained in:
GitHub Actions Bot 2025-11-18 12:03:46 -05:00
parent 6eaf99470d
commit 424ca1c807
4 changed files with 1209 additions and 441 deletions
Download patch file Download diff file Expand all files Collapse all files

822
M3U8/TV.m3u8
View file

File diff suppressed because it is too large Load diff

822
M3U8/events.m3u8
View file

File diff suppressed because it is too large Load diff

3
M3U8/scrapers/streameast.py
View file

@ -1,4 +1,3 @@
import random
from functools import partial from functools import partial
from urllib.parse import urljoin from urllib.parse import urljoin
@ -114,8 +113,6 @@ async def scrape(client: httpx.AsyncClient) -> None:
log.info(f"Loaded {cached_count} event(s) from cache") log.info(f"Loaded {cached_count} event(s) from cache")
random.shuffle(MIRRORS)
if not (base_url := await network.get_base(MIRRORS)): if not (base_url := await network.get_base(MIRRORS)):
log.warning("No working Streameast mirrors") log.warning("No working Streameast mirrors")
CACHE_FILE.write(cached_urls) CACHE_FILE.write(cached_urls)

3
M3U8/scrapers/utils/webwork.py
View file

@ -1,5 +1,6 @@
import asyncio import asyncio
import logging import logging
import random
import re import re
from collections.abc import Awaitable, Callable from collections.abc import Awaitable, Callable
from functools import partial from functools import partial
@ -40,6 +41,8 @@ class Network:
return False return False
async def get_base(self, mirrors: list[str]) -> str | None: async def get_base(self, mirrors: list[str]) -> str | None:
random.shuffle(mirrors)
tasks = [self.check_status(link) for link in mirrors] tasks = [self.check_status(link) for link in mirrors]
results = await asyncio.gather(*tasks, return_exceptions=True) results = await asyncio.gather(*tasks, return_exceptions=True)