added redis streams endpoint

app/main.py

@@ -305,6 +305,30 @@ async def continuous_kpi_refresh():
         
         await asyncio.sleep(300)  # 5 minutes
 
+
+@app.get("/debug/stream-content")
+def debug_stream(
+    org_id: str = Query(...),
+    source_id: str = Query(...),
+    api_key: str = Depends(verify_api_key)
+):
+    """See what's actually in the Redis stream"""
+    stream_key = f"stream:analytics:{org_id}:{source_id}"
+    events = event_hub.read_recent_stream(stream_key, 10)
+    
+    # Also check for entity/industry keys
+    entity_key = f"entity:{org_id}:{source_id}"
+    industry_key = f"industry:{org_id}:{source_id}"
+    
+    return {
+        "stream_key": stream_key,
+        "events_count": len(events),
+        "events": events,
+        "entity_exists": bool(event_hub.get_key(entity_key)),
+        "industry_exists": bool(event_hub.get_key(industry_key)),
+        "entity_data": event_hub.get_key(entity_key),
+        "industry_data": event_hub.get_key(industry_key),
+    }
 # ─── Root Endpoint ─────────────────────────────────────────────────────────────
 @app.get("/", tags=["root"])
 def read_root():