This commit is contained in:
doms9 2025-11-27 03:03:17 -05:00
parent edbed9cd5f
commit 00000d9da5
7 changed files with 70 additions and 39 deletions

View file

@ -52,7 +52,7 @@ async def get_events(
return [] return []
soup = HTMLParser(r.text) soup = HTMLParser(r.content)
valid_event = re.compile(r"\d{1,2}:\d{1,2}") valid_event = re.compile(r"\d{1,2}:\d{1,2}")
clean_event = re.compile(r"\s+-+\s+\w{1,4}") clean_event = re.compile(r"\s+-+\s+\w{1,4}")

View file

@ -29,7 +29,7 @@ async def process_event(
return "", "" return "", ""
soup = HTMLParser(r.text) soup = HTMLParser(r.content)
if category_links := soup.css(".common-list-category .category-item a"): if category_links := soup.css(".common-list-category .category-item a"):
match_name = category_links[-1].text(strip=True) match_name = category_links[-1].text(strip=True)
@ -65,7 +65,7 @@ async def get_events(
return [] return []
soup = HTMLParser(r.text) soup = HTMLParser(r.content)
events = [] events = []

View file

@ -68,7 +68,7 @@ async def refresh_html_cache(
return {} return {}
soup = HTMLParser(r.text) soup = HTMLParser(r.content)
events = {} events = {}

View file

@ -56,7 +56,7 @@ async def refresh_html_cache(
return {} return {}
soup = HTMLParser(r.text) soup = HTMLParser(r.content)
events = {} events = {}

View file

@ -1,3 +1,4 @@
import asyncio
from functools import partial from functools import partial
from urllib.parse import urljoin from urllib.parse import urljoin
@ -16,22 +17,44 @@ CACHE_FILE = Cache("sport9.json", exp=3_600)
BASE_URL = "https://sport9.ru" BASE_URL = "https://sport9.ru"
async def get_html(
client: httpx.AsyncClient,
url: str,
date: str,
) -> bytes:
try:
r = await client.get(url, params={"date": date})
r.raise_for_status()
except Exception as e:
log.error(f'Failed to fetch "{url}": {e}')
return b""
return r.content
async def get_events( async def get_events(
client: httpx.AsyncClient, client: httpx.AsyncClient,
cached_keys: set[str], cached_keys: set[str],
) -> list[dict[str, str]]: ) -> list[dict[str, str]]:
try: now = Time.now()
r = await client.get(BASE_URL)
r.raise_for_status()
except Exception as e:
log.error(f'Failed to fetch "{BASE_URL}": {e}')
return [] tasks = [
get_html(client, BASE_URL, str(d.date()))
for d in [
now.delta(days=-1),
now,
now.delta(days=1),
]
]
soup = HTMLParser(r.text) results = await asyncio.gather(*tasks)
soups = [HTMLParser(html) for html in results]
events = [] events = []
for soup in soups:
for card in soup.css("a.match-card"): for card in soup.css("a.match-card"):
live_badge = card.css_first(".live-badge") live_badge = card.css_first(".live-badge")
@ -41,20 +64,28 @@ async def get_events(
if not (sport_node := card.css_first(".tournament-name")): if not (sport_node := card.css_first(".tournament-name")):
continue continue
team_1_node = card.css_first(".teams-container2 .team1") sport = sport_node.text(strip=True)
team_2_node = card.css_first(".teams-container2 .team2") team_1_node = card.css_first(".team1 .team-name")
team_2_node = card.css_first(".team2 .team-name")
if not (team_1_node and team_2_node): if team_1_node and not team_2_node:
event = team_1_node.text(strip=True)
elif team_2_node and not team_1_node:
event = team_2_node.text(strip=True)
elif team_1_node and team_2_node:
event = (
f"{team_1_node.text(strip=True)} vs {team_2_node.text(strip=True)}"
)
else:
continue continue
if not (href := card.attributes.get("href")): if not (href := card.attributes.get("href")):
continue continue
sport = sport_node.text(strip=True) key = f"[{sport}] {event} (SPRT9)"
team_1 = team_1_node.text(strip=True)
team_2 = team_2_node.text(strip=True)
key = f"[{sport}] {team_1} vs {team_2} (SPRT9)"
if cached_keys & {key}: if cached_keys & {key}:
continue continue
@ -62,7 +93,7 @@ async def get_events(
events.append( events.append(
{ {
"sport": sport, "sport": sport,
"event": f"{team_1} vs {team_2}", "event": event,
"link": urljoin(BASE_URL, href), "link": urljoin(BASE_URL, href),
} }
) )

View file

@ -50,7 +50,7 @@ async def get_events(client: httpx.AsyncClient) -> list[dict[str, str]]:
return [] return []
soup = HTMLParser(r.text) soup = HTMLParser(r.content)
events = [] events = []

View file

@ -49,7 +49,7 @@ async def get_events(
return [] return []
soup = HTMLParser(r.text) soup = HTMLParser(r.content)
events = [] events = []