Peter Mutwiri commited on
Commit Β·
6b41c9e
1
Parent(s): 784ea15
fixed datasource api endpoint
Browse files- app/main.py +9 -47
app/main.py
CHANGED
|
@@ -25,16 +25,7 @@ from contextlib import asynccontextmanager
|
|
| 25 |
|
| 26 |
# βββ Router Imports βββββββββββββββββββββββββββββββββββββββββββββββββββββββββββ
|
| 27 |
# Import ALL routers
|
| 28 |
-
from app.routers import
|
| 29 |
-
health, # Health & monitoring
|
| 30 |
-
datasources, # Data ingestion
|
| 31 |
-
reports, # Report generation
|
| 32 |
-
flags, # Feature flags
|
| 33 |
-
scheduler, # Background jobs
|
| 34 |
-
run, # Analytics execution
|
| 35 |
-
socket, # Real-time updates
|
| 36 |
-
)
|
| 37 |
-
|
| 38 |
# βββ Dependencies βββββββββββββββββββββββββββββββββββββββββββββββββββββββββββββ
|
| 39 |
from app.deps import verify_api_key, check_all_services
|
| 40 |
|
|
@@ -232,40 +223,11 @@ async def global_exception_handler(request: Request, exc: Exception):
|
|
| 232 |
)
|
| 233 |
|
| 234 |
# βββ Router Registration βββββββββββββββββββββββββββββββββββββββββββββββββββββββ
|
| 235 |
-
#
|
| 236 |
-
|
| 237 |
-
|
| 238 |
-
]
|
| 239 |
-
|
| 240 |
-
|
| 241 |
-
|
| 242 |
-
|
| 243 |
-
(reports.router, "/api/v1/reports"),
|
| 244 |
-
(flags.router, "/api/v1/flags"),
|
| 245 |
-
(scheduler.router, "/api/v1/scheduler"),
|
| 246 |
-
(run.router, "/api/v1/run"),
|
| 247 |
-
(socket.router, "/api/v1/socket"),
|
| 248 |
-
]
|
| 249 |
-
|
| 250 |
-
# Register routers with tags for OpenAPI
|
| 251 |
-
for router, prefix in PUBLIC_ROUTERS:
|
| 252 |
-
app.include_router(router, prefix=prefix)
|
| 253 |
-
|
| 254 |
-
for router, prefix in PROTECTED_ROUTERS:
|
| 255 |
-
app.include_router(
|
| 256 |
-
router,
|
| 257 |
-
prefix=prefix,
|
| 258 |
-
dependencies=[Depends(verify_api_key)],
|
| 259 |
-
tags=[prefix.split("/")[-1].title()]
|
| 260 |
-
)
|
| 261 |
-
|
| 262 |
-
# Log router registration
|
| 263 |
-
if __name__ == "__main__":
|
| 264 |
-
logger.info("=" * 60)
|
| 265 |
-
logger.info("π ROUTER REGISTRATION SUMMARY")
|
| 266 |
-
logger.info("=" * 60)
|
| 267 |
-
for router, prefix in PROTECTED_ROUTERS:
|
| 268 |
-
logger.info(f"π {prefix:30} β PROTECTED")
|
| 269 |
-
for router, prefix in PUBLIC_ROUTERS:
|
| 270 |
-
logger.info(f"π {prefix:30} β PUBLIC")
|
| 271 |
-
logger.info("=" * 60)
|
|
|
|
| 25 |
|
| 26 |
# βββ Router Imports βββββββββββββββββββββββββββββββββββββββββββββββββββββββββββ
|
| 27 |
# Import ALL routers
|
| 28 |
+
from app.routers import health, datasources, reports, flags, scheduler, run, socket
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 29 |
# βββ Dependencies βββββββββββββββββββββββββββββββββββββββββββββββββββββββββββββ
|
| 30 |
from app.deps import verify_api_key, check_all_services
|
| 31 |
|
|
|
|
| 223 |
)
|
| 224 |
|
| 225 |
# βββ Router Registration βββββββββββββββββββββββββββββββββββββββββββββββββββββββ
|
| 226 |
+
# Register EXPLICITLY (no variables, no loops)
|
| 227 |
+
app.include_router(health.router, prefix="/api")
|
| 228 |
+
app.include_router(datasources.router, prefix="/api/v1/datasources", dependencies=[Depends(verify_api_key)])
|
| 229 |
+
app.include_router(reports.router, prefix="/api/v1/reports", dependencies=[Depends(verify_api_key)])
|
| 230 |
+
app.include_router(flags.router, prefix="/api/v1/flags", dependencies=[Depends(verify_api_key)])
|
| 231 |
+
app.include_router(scheduler.router, prefix="/api/v1/scheduler", dependencies=[Depends(verify_api_key)])
|
| 232 |
+
app.include_router(run.router, prefix="/api/v1/run", dependencies=[Depends(verify_api_key)])
|
| 233 |
+
app.include_router(socket.router, prefix="/api/v1/socket", dependencies=[Depends(verify_api_key)])
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|