updated prefix for va in datasources json to be accessible

app/main.py

@@ -24,6 +24,7 @@ from fastapi.responses import JSONResponse
 from contextlib import asynccontextmanager
 
 # ─── Router Imports ───────────────────────────────────────────────────────────
+# Import ALL routers
 from app.routers import (
     health,          # Health & monitoring
     datasources,     # Data ingestion
@@ -31,7 +32,7 @@ from app.routers import (
     flags,           # Feature flags
     scheduler,       # Background jobs
     run,             # Analytics execution
-    
+    socket,          # Real-time updates
 )
 
 # ─── Dependencies ─────────────────────────────────────────────────────────────
@@ -135,7 +136,7 @@ app = FastAPI(
         "email": "enterprise@mutsynchub.com"
     },
     license_info={
-        "name": "Enterprise License",
+        "name": "MIT License",
     }
 )
 
@@ -238,12 +239,12 @@ PUBLIC_ROUTERS = [
 
 # Protected routers (require X-API-KEY)
 PROTECTED_ROUTERS = [
-    (datasources.router, "/api/datasources"),
-    (reports.router, "/api/reports"),
-    (flags.router, "/api/flags"),
-    (scheduler.router, "/api/scheduler"),
-    (run.router, "/api/run"),
-    
+    (datasources.router, "/api/v1/datasources"),   
+    (reports.router, "/api/v1/reports"),
+    (flags.router, "/api/v1/flags"),
+    (scheduler.router, "/api/v1/scheduler"),
+    (run.router, "/api/v1/run"),
+    (socket.router, "/api/v1/socket"),
 ]
 
 # Register routers with tags for OpenAPI

app/routers/datasources.py

@@ -10,7 +10,7 @@ from app.routers.socket import sio
 import pandas as pd
 import json
 
-router = APIRouter(prefix="/api/v1", tags=["datasources"])
+router = APIRouter(tags=["datasources"])  # Remove 
 
 
 # =======================================================================

app/routers/ingress.py

@@ -1,16 +0,0 @@
-# from fastapi import APIRouter, Depends
-# from pydantic import BaseModel
-# from app.deps import verify_key
-
-# router = APIRouter(prefix="/api/v1", tags=["datasources"])
-
-# class NewSource(BaseModel):
-#     orgId: str
-#     sourceId: str
-#     type: str
-#     config: dict
-
-# @router.post("/datasources")
-# def create_source(payload: NewSource, _: str = Depends(verify_key)):
-#     print("[analytics] new source", payload)
-#     return {"id": payload.sourceId, "status": "sync_queued"}