Peter Mutwiri commited on
Commit
1e5d7a4
Β·
1 Parent(s): ae09122

added routers on main app router

Browse files
Files changed (1) hide show
  1. app/main.py +7 -5
app/main.py CHANGED
@@ -23,7 +23,7 @@ from app.redis_client import redis
23
  from app.deps import get_current_user, rate_limit_org, verify_api_key, check_all_services
24
  from app.tasks.analytics_worker import redis_listener
25
  from app.services.vector_service import cleanup_expired_vectors
26
- from app.routers import health, datasources, reports, flags, scheduler, run, socket, analytics_stream
27
 
28
  # ─── Logger Configuration ───────────────────────────────────────────────────────
29
  logging.basicConfig(
@@ -194,11 +194,12 @@ async def add_request_tracking(request: Request, call_next):
194
 
195
  return response
196
 
 
197
  # ─── KPI Computation Endpoint ──────────────────────────────────────────────────
198
  @app.post("/api/v1/kpi/compute")
199
  async def compute_kpis(
 
200
  source_id: str = Query(..., description="Data source ID"),
201
- background_tasks: BackgroundTasks,
202
  current_user: dict = Depends(get_current_user),
203
  limited_org: str = Depends(rate_limit_org(max_requests=50))
204
  ):
@@ -217,13 +218,12 @@ async def compute_kpis(
217
  "org_id": org_id,
218
  "data": json.loads(cached),
219
  "rate_limit": {
220
- "remaining": 50, # Simplified - get from actual rate limiter
221
  "reset_in": 60
222
  }
223
  }
224
 
225
  # Trigger background computation
226
- # NOTE: Make sure trigger_kpi_computation is defined in deps or imported
227
  background_tasks.add_task(trigger_kpi_computation, org_id, source_id)
228
 
229
  return {
@@ -339,4 +339,6 @@ app.include_router(flags.router, prefix="/api/v1/flags", dependencies=[Depends(v
339
  app.include_router(scheduler.router, prefix="/api/v1/scheduler", dependencies=[Depends(verify_api_key)])
340
  app.include_router(run.router, prefix="/api/v1/run", dependencies=[Depends(verify_api_key)])
341
  app.include_router(socket.router, prefix="/api/v1/socket", dependencies=[Depends(verify_api_key)])
342
- app.include_router(analytics_stream.router, prefix="/api/v1/analytics", tags=["analytics"])
 
 
 
23
  from app.deps import get_current_user, rate_limit_org, verify_api_key, check_all_services
24
  from app.tasks.analytics_worker import redis_listener
25
  from app.services.vector_service import cleanup_expired_vectors
26
+ from app.routers import health, datasources, reports, flags, scheduler, run, socket, analytics_stream,ai_query,schema
27
 
28
  # ─── Logger Configuration ───────────────────────────────────────────────────────
29
  logging.basicConfig(
 
194
 
195
  return response
196
 
197
+ # ─── KPI Computation Endpoint ──────────────────────────────────────────────────
198
  # ─── KPI Computation Endpoint ──────────────────────────────────────────────────
199
  @app.post("/api/v1/kpi/compute")
200
  async def compute_kpis(
201
+ background_tasks: BackgroundTasks, # βœ… First parameter, no default needed
202
  source_id: str = Query(..., description="Data source ID"),
 
203
  current_user: dict = Depends(get_current_user),
204
  limited_org: str = Depends(rate_limit_org(max_requests=50))
205
  ):
 
218
  "org_id": org_id,
219
  "data": json.loads(cached),
220
  "rate_limit": {
221
+ "remaining": 50,
222
  "reset_in": 60
223
  }
224
  }
225
 
226
  # Trigger background computation
 
227
  background_tasks.add_task(trigger_kpi_computation, org_id, source_id)
228
 
229
  return {
 
339
  app.include_router(scheduler.router, prefix="/api/v1/scheduler", dependencies=[Depends(verify_api_key)])
340
  app.include_router(run.router, prefix="/api/v1/run", dependencies=[Depends(verify_api_key)])
341
  app.include_router(socket.router, prefix="/api/v1/socket", dependencies=[Depends(verify_api_key)])
342
+ app.include_router(analytics_stream.router, prefix="/api/v1/analytics", tags=["analytics"])
343
+ app.include_router(ai_query.router, prefix="/api/v1/ai-query", dependencies=[Depends(verify_api_key)])
344
+ app.include_router(schema.router, prefix="/api/v1/schema", dependencies=[Depends(verify_api_key)])