fetch news from redis

routes.py

@@ -1,54 +1,30 @@
 import os
-import requests
-from fastapi import APIRouter, Query
+from fastapi import APIRouter
 from dotenv import load_dotenv
+from redis_client import redis_client as r
 
 load_dotenv()
 
-
 router = APIRouter()
 
-GNEWS_API_KEY = os.getenv("GNEWS_API_KEY")
-
 @router.get("/news/category/{category}")
-def get_news_by_category(category: str, limit: int = 5):
-    base_url = "https://gnews.io/api/v4/top-headlines"
-    params = {
-        "topic": category,
-        "lang": "en",
-        "max": limit,
-        "expand": "content",
-        "token": GNEWS_API_KEY
-    }
-
+def get_cached_articles_by_category(category: str, limit: int = 5):
     try:
-        response = requests.get(base_url, params=params, timeout=10)
-        response.raise_for_status()  # raise exception for non-200 responses
-        data = response.json()
-
+        article_ids = list(r.smembers(f"category:{category}"))[:limit]
         articles = []
-        for article in data.get("articles", []):
-            articles.append({
-                "title": article["title"],
-                "url": article["url"],
-                "description": article.get("description"),
-                "content": article.get("content"),
-                "publishedAt": article["publishedAt"],
-                "image": article.get("image"),
-                "source": article["source"]["name"]
-            })
 
-        return articles
+        for article_id in article_ids:
+            article_data = r.hgetall(f"article:{article_id}")
+            if article_data:
+                articles.append(article_data)
 
-    except requests.exceptions.RequestException as e:
-        print(f"[ERROR] Failed to fetch news: {e}")
-        return {"error": "Failed to fetch news from GNews API."}
+        return articles
 
     except Exception as e:
-        print(f"[ERROR] Unexpected error: {e}")
-        return {"error": "An unexpected error occurred."}
+        print(f"[ERROR] Failed to fetch cached articles: {e}")
+        return {"error": "Failed to fetch articles from cache."}
 
 
 @router.get("/")
 async def root():
-    return {"message": "LucidFeed backend is up and running!"}
+    return {"message": "LucidFeed backend is up and running!"}