feat: enhance billing dashboard with historical data & security hardening

- Fix usage tracking zero-value bug with self-healing logic
- Add month selector for historical usage views
- Implement start-of-month graceful initialization
- Merge PR #372: Harden user-scoped access in subscription routes
- Fix UI bugs in UsageDashboard component

backend/api/agents_api.py

@@ -555,7 +555,10 @@ async def get_agent_huddle_feed_endpoint(
     try:
         user_id = str(current_user.get("id"))
         service = AgentActivityService(db, user_id)
-        feed = service.get_huddle_feed(
+        
+        # Use run_in_threadpool to execute the blocking service call in a separate thread
+        feed = await run_in_threadpool(
+            service.get_huddle_feed,
             since=since,
             cursor=cursor,
             runs_limit=runs_limit,

backend/api/today_workflow.py

@@ -48,15 +48,19 @@ async def get_today_workflow(
     current_user: dict = Depends(get_current_user),
     db: Session = Depends(get_db),
 ) -> Dict[str, Any]:
+    from starlette.concurrency import run_in_threadpool
     user_id = str(current_user.get("id"))
     plan, created = await get_or_create_daily_workflow_plan(db, user_id, date=date)
 
-    tasks = (
-        db.query(DailyWorkflowTask)
-        .filter(DailyWorkflowTask.plan_id == plan.id, DailyWorkflowTask.user_id == user_id)
-        .order_by(DailyWorkflowTask.created_at.asc())
-        .all()
-    )
+    def _fetch_tasks():
+        return (
+            db.query(DailyWorkflowTask)
+            .filter(DailyWorkflowTask.plan_id == plan.id, DailyWorkflowTask.user_id == user_id)
+            .order_by(DailyWorkflowTask.created_at.asc())
+            .all()
+        )
+
+    tasks = await run_in_threadpool(_fetch_tasks)
 
     response_tasks = []
     for t in tasks:
@@ -100,18 +104,26 @@ async def get_today_workflow(
             from datetime import date as date_type, timedelta
 
             y_str = (date_type.fromisoformat(plan.date) - timedelta(days=1)).isoformat()
-            y_plan = (
-                db.query(DailyWorkflowPlan)
-                .filter(DailyWorkflowPlan.user_id == user_id, DailyWorkflowPlan.date == y_str)
-                .first()
-            )
-            if y_plan:
-                y_tasks = (
-                    db.query(DailyWorkflowTask)
-                    .filter(DailyWorkflowTask.plan_id == y_plan.id, DailyWorkflowTask.user_id == user_id)
-                    .order_by(DailyWorkflowTask.created_at.asc())
-                    .all()
+            
+            def _fetch_yesterday():
+                y_plan = (
+                    db.query(DailyWorkflowPlan)
+                    .filter(DailyWorkflowPlan.user_id == user_id, DailyWorkflowPlan.date == y_str)
+                    .first()
                 )
+                if y_plan:
+                    y_tasks = (
+                        db.query(DailyWorkflowTask)
+                        .filter(DailyWorkflowTask.plan_id == y_plan.id, DailyWorkflowTask.user_id == user_id)
+                        .order_by(DailyWorkflowTask.created_at.asc())
+                        .all()
+                    )
+                    return y_tasks
+                return []
+
+            y_tasks = await run_in_threadpool(_fetch_yesterday)
+            
+            if y_tasks:
                 y_response = []
                 for t in y_tasks:
                     y_response.append(