UI

Author: itsmeakhil

apps/backend/app/api/routes/analytics/api.py

@@ -2,13 +2,14 @@
 
 from app.api.routes.analytics import services as analytics_svc
 from app.api.routes.auth.services import get_current_uid
+from app.api.routes.workspaces.middleware import WorkspaceContext, get_workspace_ctx
 
 router = APIRouter(prefix="/analytics", tags=["analytics"])
 
 
 @router.get("/summary", summary="Dashboard analytics counts")
-async def dashboard_summary(uid: str = Depends(get_current_uid)):
-    return await analytics_svc.get_dashboard_analytics(uid)
+async def dashboard_summary(ctx: WorkspaceContext = Depends(get_workspace_ctx)):
+    return await analytics_svc.get_dashboard_analytics(ctx)
 
 
 @router.get("/top-tools", summary="Top tools by usage (global, cached 5 min)")

apps/backend/app/api/routes/analytics/services.py

@@ -18,6 +18,7 @@
     PROJECTS,
 )
 from app.api.routes.analytics.schema import DashboardAnalyticsOut
+from app.api.routes.workspaces.middleware import WorkspaceContext, apply_legacy_or_filter
 from app.database import db_manager
 
 
@@ -59,13 +60,9 @@ async def get_activity_buckets(*, days: int = 7) -> list[dict]:
     return await db_manager.aggregate(AUDIT_LOG, pipeline)
 
 
-async def get_dashboard_analytics(uid: str) -> DashboardAnalyticsOut:
-    base = {"created_by": uid}
-    nosql_filter = {
-        **base,
-        "encryptedData": {"$exists": True},
-        "iv": {"$exists": True},
-    }
+async def get_dashboard_analytics(ctx: WorkspaceContext) -> DashboardAnalyticsOut:
+    flt = lambda base=None: apply_legacy_or_filter(ctx, base or {}, user_field="created_by")
+    nosql_filter = flt({"encryptedData": {"$exists": True}, "iv": {"$exists": True}})
     (
         task_stats,
         password_entries,
@@ -80,18 +77,18 @@ async def get_dashboard_analytics(uid: str) -> DashboardAnalyticsOut:
         json_docs,
         code_snippets,
     ) = await asyncio.gather(
-        task_svc.get_task_stats(uid=uid),
-        db_manager.count_documents(PASSWORD_ENTRIES, base),
-        db_manager.count_documents(BOOKMARKS, base),
-        db_manager.count_documents(BOOKMARK_FOLDERS, base),
-        db_manager.count_documents(PROJECTS, base),
+        task_svc.get_task_stats(ctx=ctx),
+        db_manager.count_documents(PASSWORD_ENTRIES, flt()),
+        db_manager.count_documents(BOOKMARKS, flt()),
+        db_manager.count_documents(BOOKMARK_FOLDERS, flt()),
+        db_manager.count_documents(PROJECTS, flt()),
         db_manager.count_documents(NOSQL_CONNECTIONS, nosql_filter),
-        db_manager.count_documents(NOTES, base),
-        db_manager.count_documents(API_CLIENT_COLLECTIONS, base),
-        db_manager.count_documents(API_CLIENT_ENVIRONMENTS, base),
-        db_manager.count_documents(API_CLIENT_HISTORY, base),
-        db_manager.count_documents(JSON_FORMATTER_DOCUMENTS, base),
-        db_manager.count_documents(CODE_SNIPPETS, base),
+        db_manager.count_documents(NOTES, flt()),
+        db_manager.count_documents(API_CLIENT_COLLECTIONS, flt()),
+        db_manager.count_documents(API_CLIENT_ENVIRONMENTS, flt()),
+        db_manager.count_documents(API_CLIENT_HISTORY, flt()),
+        db_manager.count_documents(JSON_FORMATTER_DOCUMENTS, flt()),
+        db_manager.count_documents(CODE_SNIPPETS, flt()),
     )
 
     return DashboardAnalyticsOut(