feat: /api/stories endpoint for landing mosaic

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

src/mediastorm/api.py

@@ -1,8 +1,62 @@
+import json
+from contextlib import asynccontextmanager
+from pathlib import Path
+from typing import Any
+
 from fastapi import FastAPI
 
-app = FastAPI(title="MediaStorm Archive Explorer")
+from mediastorm.config import INGEST_CACHE_DIR
+
+_landing_stories: list[dict[str, Any]] = []
+
+
+def _load_stories_for_landing() -> list[dict[str, Any]]:
+    stories = []
+    cache_dir = Path(INGEST_CACHE_DIR)
+    if not cache_dir.exists():
+        return stories
+    for json_file in sorted(cache_dir.glob("*.json")):
+        try:
+            data = json.loads(json_file.read_text())
+        except (json.JSONDecodeError, OSError):
+            continue
+        name = data.get("name") or ""
+        slug = data.get("slug") or ""
+        if not name or not slug:
+            continue
+        poster_images = data.get("poster_images") or []
+        poster = ""
+        if poster_images:
+            last = poster_images[-1]
+            poster = f"https://www.mediastorm.com{last}" if last.startswith("/") else last
+        awards = data.get("awards") or []
+        stories.append({
+            "uid": data.get("uid", ""),
+            "name": name,
+            "slug": slug,
+            "poster": poster,
+            "year": data.get("published_year"),
+            "media_type": data.get("content_type", ""),
+            "awards_count": len(awards),
+        })
+    return stories
+
+
+@asynccontextmanager
+async def lifespan(app: FastAPI):
+    global _landing_stories
+    _landing_stories = _load_stories_for_landing()
+    yield
+
+
+app = FastAPI(title="MediaStorm Archive Explorer", lifespan=lifespan)
 
 
 @app.get("/api/health")
 async def health():
     return {"status": "ok"}
+
+
+@app.get("/api/stories")
+async def stories():
+    return {"stories": _landing_stories}

src/mediastorm/config.py

@@ -21,3 +21,5 @@ GEMINI_FLASH_MODEL = "gemini-2.5-flash"
 GEMINI_PRO_MODEL = "gemini-2.5-pro"
 
 BM25_INDEX_PATH = Path(os.environ.get("BM25_INDEX_PATH", "./data/bm25_index.pkl"))
+
+INGEST_CACHE_DIR = Path(os.environ.get("INGEST_CACHE_DIR", "./data/ingest_cache"))

tests/test_api.py

@@ -12,3 +12,20 @@ async def test_health():
     data = resp.json()
     assert "status" in data
     assert data["status"] == "ok"
+
+
+@pytest.mark.asyncio
+async def test_stories_returns_list():
+    transport = ASGITransport(app=app)
+    async with AsyncClient(transport=transport, base_url="http://test") as client:
+        resp = await client.get("/api/stories")
+    assert resp.status_code == 200
+    data = resp.json()
+    assert "stories" in data
+    assert isinstance(data["stories"], list)
+    if data["stories"]:
+        story = data["stories"][0]
+        assert "uid" in story
+        assert "name" in story
+        assert "slug" in story
+        assert "poster" in story