death916/deathclock
1
0
Fork 0
mirror of https://github.com/Death916/deathclock.git synced 2026-04-10 03:04:40 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions

started news

Browse source
This commit is contained in:
Death916 2025-04-22 04:18:48 -07:00
parent 732e030169
commit 27367934eb
1 changed files with 27 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

28
deathclock/deathclock.py
View file

@ -9,7 +9,7 @@ from rxconfig import config
from utils.weather import Weather from utils.weather import Weather
# from utils.scores import NBAScores, mlbScores # from utils.scores import NBAScores, mlbScores
# from utils.news import News from utils.news import News
# from utils.alarm import Alarm # from utils.alarm import Alarm
import logging import logging
@ -42,6 +42,7 @@ class State(rx.State):
try: try:
self._weather_client = Weather() self._weather_client = Weather()
self._news_client = News()
logging.info("Weather client initialized successfully.") logging.info("Weather client initialized successfully.")
except Exception as e: except Exception as e:
logging.error(f"Failed to initialize Weather client: {e}", exc_info=True) logging.error(f"Failed to initialize Weather client: {e}", exc_info=True)
@ -58,6 +59,31 @@ class State(rx.State):
logging.info("Triggering background tasks: Weather") logging.info("Triggering background tasks: Weather")
# *** FIX: Return a list containing the handler reference *** # *** FIX: Return a list containing the handler reference ***
return [State.fetch_weather] return [State.fetch_weather]
@rx.event(background=True)
async def fetch_news(self):
"""Fetches news periodically."""
# Placeholder for the actual news fetching logic
while True:
try:
logging.info("Fetching news...")
news_items = await self._news_client.get_news() # This now comes from utils/news.py
if not news_items:
logging.warning("No news items fetched.")
async with self:
self.news = []
yield # Update frontend
else:
logging.info(f"Fetched {len(news_items)} news items.")
async with self:
self.news = news_items
yield
except Exception as e:
logging.error(f"Error in fetch_news background task: {e}", exc_info=True)
await asyncio.sleep(500)
# --- Weather Background Task --- # --- Weather Background Task ---
@rx.event(background=True) @rx.event(background=True)