mirror of
https://github.com/doms9/iptv.git
synced 2026-06-05 02:33:08 +02:00
Compare commits
35 commits
60b56d20ff
...
0e1e69c9d7
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
0e1e69c9d7 | ||
|
|
d618cc7731 | ||
|
|
aa44a1787a | ||
|
|
855ed92069 | ||
|
|
00000d9b2c | ||
|
|
46b7e9985e | ||
|
|
6454724f7e | ||
|
|
3eb8fb9b83 | ||
|
|
79e43a1d47 | ||
|
|
2de592a580 | ||
|
|
fe543ca0e4 | ||
|
|
ea8ab4dab8 | ||
|
|
c96b05abf3 | ||
|
|
63da5b6066 | ||
|
|
825624a03f | ||
|
|
2d96869c42 | ||
|
|
e631c2bce1 | ||
|
|
e1e56f486d | ||
|
|
80fc620bff | ||
|
|
6bc6d50c20 | ||
|
|
3f783c4090 | ||
|
|
98af6befbb | ||
|
|
f5eee37d1b | ||
|
|
0f11ceac8b | ||
|
|
9f1150ee1c | ||
|
|
3833ffde8a | ||
|
|
204ba1e24c | ||
|
|
187b2e5767 | ||
|
|
27364eac9b | ||
|
|
719236183c | ||
|
|
8c53db5b8b | ||
|
|
930a16fe45 | ||
|
|
8dc677dd04 | ||
|
|
bfae4796b3 | ||
|
|
78412942c0 |
9 changed files with 118980 additions and 114932 deletions
1206
M3U8/TV.m3u8
1206
M3U8/TV.m3u8
File diff suppressed because it is too large
Load diff
231317
M3U8/TV.xml
231317
M3U8/TV.xml
File diff suppressed because one or more lines are too long
1206
M3U8/events.m3u8
1206
M3U8/events.m3u8
File diff suppressed because it is too large
Load diff
|
|
@ -8,6 +8,7 @@ from scrapers import (
|
||||||
cdnlivetv,
|
cdnlivetv,
|
||||||
embedhd,
|
embedhd,
|
||||||
fawa,
|
fawa,
|
||||||
|
footfast,
|
||||||
fsports,
|
fsports,
|
||||||
istreameast,
|
istreameast,
|
||||||
mainportal,
|
mainportal,
|
||||||
|
|
@ -59,6 +60,7 @@ async def main() -> None:
|
||||||
|
|
||||||
pw_tasks = [
|
pw_tasks = [
|
||||||
asyncio.create_task(embedhd.scrape(hdl_brwsr)),
|
asyncio.create_task(embedhd.scrape(hdl_brwsr)),
|
||||||
|
asyncio.create_task(footfast.scrape(xtrnl_brwsr)),
|
||||||
asyncio.create_task(fsports.scrape(xtrnl_brwsr)),
|
asyncio.create_task(fsports.scrape(xtrnl_brwsr)),
|
||||||
asyncio.create_task(roxie.scrape(hdl_brwsr)),
|
asyncio.create_task(roxie.scrape(hdl_brwsr)),
|
||||||
# asyncio.create_task(streamhub.scrape(xtrnl_brwsr)),
|
# asyncio.create_task(streamhub.scrape(xtrnl_brwsr)),
|
||||||
|
|
@ -95,6 +97,7 @@ async def main() -> None:
|
||||||
cdnlivetv.urls
|
cdnlivetv.urls
|
||||||
| embedhd.urls
|
| embedhd.urls
|
||||||
| fawa.urls
|
| fawa.urls
|
||||||
|
| footfast.urls
|
||||||
| fsports.urls
|
| fsports.urls
|
||||||
| istreameast.urls
|
| istreameast.urls
|
||||||
| mainportal.urls
|
| mainportal.urls
|
||||||
|
|
|
||||||
|
|
@ -99,7 +99,7 @@ async def scrape(browser: Browser) -> None:
|
||||||
if events := await get_events(cached_urls.keys()):
|
if events := await get_events(cached_urls.keys()):
|
||||||
log.info(f"Processing {len(events)} new URL(s)")
|
log.info(f"Processing {len(events)} new URL(s)")
|
||||||
|
|
||||||
async with network.event_context(browser) as context:
|
async with network.event_context(browser, stealth=False) as context:
|
||||||
for i, ev in enumerate(events, start=1):
|
for i, ev in enumerate(events, start=1):
|
||||||
async with network.event_page(context) as page:
|
async with network.event_page(context) as page:
|
||||||
handler = partial(
|
handler = partial(
|
||||||
|
|
|
||||||
160
M3U8/scrapers/footfast.py
Normal file
160
M3U8/scrapers/footfast.py
Normal file
|
|
@ -0,0 +1,160 @@
|
||||||
|
from functools import partial
|
||||||
|
from urllib.parse import urljoin
|
||||||
|
|
||||||
|
from playwright.async_api import Browser
|
||||||
|
|
||||||
|
from .utils import Cache, Time, get_logger, leagues, network
|
||||||
|
|
||||||
|
log = get_logger(__name__)
|
||||||
|
|
||||||
|
urls: dict[str, dict[str, str | float]] = {}
|
||||||
|
|
||||||
|
TAG = "FOOTFAST"
|
||||||
|
|
||||||
|
CACHE_FILE = Cache(TAG, exp=5_400)
|
||||||
|
|
||||||
|
API_FILE = Cache(f"{TAG}-api", exp=28_800)
|
||||||
|
|
||||||
|
BASE_URL = "https://footfast.cc"
|
||||||
|
|
||||||
|
CATEGORIES = {
|
||||||
|
1: "Soccer",
|
||||||
|
3: "NBA",
|
||||||
|
6: "UFC/MMA",
|
||||||
|
8: "NHL",
|
||||||
|
13: "Live Event",
|
||||||
|
17: "MLB",
|
||||||
|
10: "Racing",
|
||||||
|
21: "Basketball",
|
||||||
|
#: "American Football",
|
||||||
|
#: "Boxing",
|
||||||
|
#: "Rugby",
|
||||||
|
#: "Tennis",
|
||||||
|
#: "Golf",
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
async def get_events(cached_keys: list[str]) -> list[dict[str, str]]:
|
||||||
|
now = Time.clean(Time.now())
|
||||||
|
|
||||||
|
if not (api_data := API_FILE.load(per_entry=False)):
|
||||||
|
log.info("Refreshing API cache")
|
||||||
|
|
||||||
|
api_data = {"timestamp": now.timestamp()}
|
||||||
|
|
||||||
|
if r := await network.request(urljoin(BASE_URL, "api/public/catalog"), log=log):
|
||||||
|
api_data: dict[str, list[dict]] = r.json()
|
||||||
|
|
||||||
|
api_data["timestamp"] = now.timestamp()
|
||||||
|
|
||||||
|
API_FILE.write(api_data)
|
||||||
|
|
||||||
|
events = []
|
||||||
|
|
||||||
|
start_ts = now.delta(hours=-3).timestamp()
|
||||||
|
|
||||||
|
for event_info in api_data.get("events", []):
|
||||||
|
event_name: str = event_info.get("name")
|
||||||
|
category_id: int = event_info.get("category_id")
|
||||||
|
|
||||||
|
event_ts: int = event_info.get("start")
|
||||||
|
|
||||||
|
if not (event_name and category_id and event_ts):
|
||||||
|
continue
|
||||||
|
|
||||||
|
if not start_ts <= event_ts <= now.timestamp():
|
||||||
|
continue
|
||||||
|
|
||||||
|
# if not (sources := event_info.get("source")):
|
||||||
|
# continue
|
||||||
|
|
||||||
|
# elif not (source_id := sources[0].get("id")):
|
||||||
|
# continue
|
||||||
|
|
||||||
|
if not (sport := CATEGORIES.get(category_id)):
|
||||||
|
continue
|
||||||
|
|
||||||
|
if f"[{sport}] {event_name} ({TAG})" in cached_keys:
|
||||||
|
continue
|
||||||
|
|
||||||
|
embed_id: str = event_info["embedId"]
|
||||||
|
|
||||||
|
events.append(
|
||||||
|
{
|
||||||
|
"sport": sport,
|
||||||
|
"event": event_name,
|
||||||
|
# "link": f"https://aerastora.com/event/{embed_id}?source={source_id}",
|
||||||
|
"link": urljoin(BASE_URL, f"event/{embed_id}"),
|
||||||
|
"timestamp": event_ts,
|
||||||
|
}
|
||||||
|
)
|
||||||
|
|
||||||
|
return events
|
||||||
|
|
||||||
|
|
||||||
|
async def scrape(browser: Browser) -> None:
|
||||||
|
cached_urls = CACHE_FILE.load()
|
||||||
|
|
||||||
|
valid_urls = {k: v for k, v in cached_urls.items() if v["url"]}
|
||||||
|
|
||||||
|
valid_count = cached_count = len(valid_urls)
|
||||||
|
|
||||||
|
urls.update(valid_urls)
|
||||||
|
|
||||||
|
log.info(f"Loaded {cached_count} event(s) from cache")
|
||||||
|
|
||||||
|
log.info(f'Scraping from "{BASE_URL}"')
|
||||||
|
|
||||||
|
if events := await get_events(cached_urls.keys()):
|
||||||
|
log.info(f"Processing {len(events)} new URL(s)")
|
||||||
|
|
||||||
|
async with network.event_context(browser, stealth=False) as context:
|
||||||
|
for i, ev in enumerate(events, start=1):
|
||||||
|
async with network.event_page(context) as page:
|
||||||
|
handler = partial(
|
||||||
|
network.process_event,
|
||||||
|
url=(link := ev["link"]),
|
||||||
|
url_num=i,
|
||||||
|
page=page,
|
||||||
|
log=log,
|
||||||
|
)
|
||||||
|
|
||||||
|
url = await network.safe_process(
|
||||||
|
handler,
|
||||||
|
url_num=i,
|
||||||
|
semaphore=network.PW_S,
|
||||||
|
log=log,
|
||||||
|
)
|
||||||
|
|
||||||
|
sport, event, ts = (
|
||||||
|
ev["sport"],
|
||||||
|
ev["event"],
|
||||||
|
ev["timestamp"],
|
||||||
|
)
|
||||||
|
|
||||||
|
tvg_id, logo = leagues.get_tvg_info(sport, event)
|
||||||
|
|
||||||
|
key = f"[{sport}] {event} ({TAG})"
|
||||||
|
|
||||||
|
entry = {
|
||||||
|
"url": url,
|
||||||
|
"logo": logo,
|
||||||
|
"base": "https://aerastora.com/ ",
|
||||||
|
"timestamp": ts,
|
||||||
|
"id": tvg_id or "Live.Event.us",
|
||||||
|
"link": link,
|
||||||
|
}
|
||||||
|
|
||||||
|
cached_urls[key] = entry
|
||||||
|
|
||||||
|
if url:
|
||||||
|
valid_count += 1
|
||||||
|
|
||||||
|
urls[key] = entry
|
||||||
|
|
||||||
|
log.info(f"Collected and cached {valid_count - cached_count} new event(s)")
|
||||||
|
|
||||||
|
else:
|
||||||
|
log.info("No new events found")
|
||||||
|
|
||||||
|
CACHE_FILE.write(cached_urls)
|
||||||
|
|
@ -14,7 +14,7 @@ TAG = "OVO"
|
||||||
|
|
||||||
CACHE_FILE = Cache(TAG, exp=28_800)
|
CACHE_FILE = Cache(TAG, exp=28_800)
|
||||||
|
|
||||||
BASE_URL = "https://ovogoaal.com"
|
BASE_URL = "https://ovogoalz.top"
|
||||||
|
|
||||||
|
|
||||||
async def process_event(url: str, url_num: int) -> tuple[str | None, str | None]:
|
async def process_event(url: str, url_num: int) -> tuple[str | None, str | None]:
|
||||||
|
|
|
||||||
|
|
@ -184,7 +184,7 @@ async def scrape(browser: Browser) -> None:
|
||||||
if events := await get_events():
|
if events := await get_events():
|
||||||
log.info(f"Processing {len(events)} new URL(s)")
|
log.info(f"Processing {len(events)} new URL(s)")
|
||||||
|
|
||||||
async with network.event_context(browser) as context:
|
async with network.event_context(browser, stealth=False) as context:
|
||||||
for i, ev in enumerate(events, start=1):
|
for i, ev in enumerate(events, start=1):
|
||||||
async with network.event_page(context) as page:
|
async with network.event_page(context) as page:
|
||||||
|
|
||||||
|
|
|
||||||
14
readme.md
14
readme.md
|
|
@ -1,11 +1,19 @@
|
||||||
## Base Log @ 2026-05-18 17:17 UTC
|
## Base Log @ 2026-05-19 17:25 UTC
|
||||||
|
|
||||||
### ✅ Working Streams: 158<br>❌ Dead Streams: 2
|
### ✅ Working Streams: 150<br>❌ Dead Streams: 10
|
||||||
|
|
||||||
| Channel | Error (Code) | Link |
|
| Channel | Error (Code) | Link |
|
||||||
| ------- | ------------ | ---- |
|
| ------- | ------------ | ---- |
|
||||||
|
| FDSN Florida | HTTP Error (403) | `http://realsport.scalecdn.co:8080/live/supersonicstreams/cUewZolveU8Jh18jk34BDJ/663186.ts` |
|
||||||
|
| FDSN Midwest | HTTP Error (403) | `http://realsport.scalecdn.co:8080/live/supersonicstreams/cUewZolveU8Jh18jk34BDJ/3784.ts` |
|
||||||
|
| FDSN Ohio | HTTP Error (403) | `http://realsport.scalecdn.co:8080/live/supersonicstreams/cUewZolveU8Jh18jk34BDJ/663237.ts` |
|
||||||
|
| FDSN SoCal | HTTP Error (403) | `http://realsport.scalecdn.co:8080/live/supersonicstreams/cUewZolveU8Jh18jk34BDJ/663253.ts` |
|
||||||
|
| FDSN South | HTTP Error (403) | `http://realsport.scalecdn.co:8080/live/supersonicstreams/cUewZolveU8Jh18jk34BDJ/2513.ts` |
|
||||||
| FDSN Southeast | HTTP Error (403) | `http://realsport.scalecdn.co:8080/live/supersonicstreams/cUewZolveU8Jh18jk34BDJ/663159.ts` |
|
| FDSN Southeast | HTTP Error (403) | `http://realsport.scalecdn.co:8080/live/supersonicstreams/cUewZolveU8Jh18jk34BDJ/663159.ts` |
|
||||||
| MSG | HTTP Error (404) | `http://23.237.104.106:8080/USA_MSG/index.m3u8` |
|
| FDSN Southwest | HTTP Error (403) | `http://realsport.scalecdn.co:8080/live/supersonicstreams/cUewZolveU8Jh18jk34BDJ/663270.ts` |
|
||||||
|
| FDSN Sun | HTTP Error (403) | `http://realsport.scalecdn.co:8080/live/supersonicstreams/cUewZolveU8Jh18jk34BDJ/663153.ts` |
|
||||||
|
| FDSN West | HTTP Error (403) | `http://realsport.scalecdn.co:8080/live/supersonicstreams/cUewZolveU8Jh18jk34BDJ/663285.ts` |
|
||||||
|
| FDSN Wisconsin | HTTP Error (403) | `http://realsport.scalecdn.co:8080/live/supersonicstreams/cUewZolveU8Jh18jk34BDJ/3787.ts` |
|
||||||
---
|
---
|
||||||
#### Base Channels URL
|
#### Base Channels URL
|
||||||
```
|
```
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue