routes.py 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567
  1. import asyncio
  2. from fastapi import APIRouter, Depends, HTTPException, Query, Request, Response
  3. from sqlalchemy import text
  4. from sqlalchemy.orm import Session
  5. from core_domain import ServiceDescriptor, ServiceHealth
  6. from app.bootstrap.settings import ApiGatewaySettings
  7. from app.db.session import get_db
  8. from app.domain.repositories import ApiKeyRepository, GatewayRequestAuditRepository
  9. from app.infrastructure.api_keys import generate_api_key, get_api_key_prefix, hash_api_key
  10. from app.infrastructure.proxy import ProxyServiceName, ProxyTarget, ServiceProxy
  11. from app.schemas.gateway import (
  12. ApiKeyCreateRequest,
  13. ApiKeyCreateResponse,
  14. ApiKeyResponse,
  15. ApiKeyStatusUpdateRequest,
  16. GatewayRequestAuditResponse,
  17. GatewayAuditServiceStats,
  18. GatewayAuditStatsResponse,
  19. GatewayServicesHealthResponse,
  20. )
  21. router = APIRouter()
  22. @router.get("/health", response_model=ServiceDescriptor)
  23. def health_check(db: Session = Depends(get_db)) -> ServiceDescriptor:
  24. db.execute(text("SELECT 1"))
  25. return ServiceDescriptor(name="api-gateway")
  26. @router.get("/ready", response_model=ServiceHealth)
  27. def readiness_check(db: Session = Depends(get_db)) -> ServiceHealth:
  28. db.execute(text("SELECT 1"))
  29. return ServiceHealth(service="api-gateway", status="ok", database="ok")
  30. @router.post("/gateway/api-keys", response_model=ApiKeyCreateResponse)
  31. def create_api_key(
  32. payload: ApiKeyCreateRequest,
  33. db: Session = Depends(get_db),
  34. ) -> ApiKeyCreateResponse:
  35. api_key = generate_api_key()
  36. entity = ApiKeyRepository(db).create(
  37. tenant_id=payload.tenant_id,
  38. name=payload.name,
  39. key_prefix=get_api_key_prefix(api_key),
  40. key_hash=hash_api_key(api_key),
  41. scopes=payload.scopes,
  42. expires_time=payload.expires_time,
  43. )
  44. return ApiKeyCreateResponse(
  45. id=entity.id,
  46. tenant_id=entity.tenant_id,
  47. name=entity.name,
  48. key_prefix=entity.key_prefix,
  49. api_key=api_key,
  50. status=entity.status,
  51. scopes=entity.scopes,
  52. expires_time=entity.expires_time,
  53. created_time=entity.created_time,
  54. )
  55. @router.get("/gateway/api-keys", response_model=list[ApiKeyResponse])
  56. def list_api_keys(
  57. tenant_id: str = Query(...),
  58. db: Session = Depends(get_db),
  59. ) -> list[ApiKeyResponse]:
  60. return [
  61. ApiKeyResponse.from_entity(item)
  62. for item in ApiKeyRepository(db).list_by_tenant(tenant_id=tenant_id)
  63. ]
  64. @router.patch("/gateway/api-keys/{api_key_id}/status", response_model=ApiKeyResponse)
  65. def update_api_key_status(
  66. api_key_id: str,
  67. payload: ApiKeyStatusUpdateRequest,
  68. db: Session = Depends(get_db),
  69. ) -> ApiKeyResponse:
  70. entity = ApiKeyRepository(db).update_status(
  71. tenant_id=payload.tenant_id,
  72. api_key_id=api_key_id,
  73. status=payload.status,
  74. )
  75. if entity is None:
  76. raise HTTPException(status_code=404, detail=f"api key not found: {api_key_id}")
  77. return ApiKeyResponse.from_entity(entity)
  78. @router.get("/gateway/audits", response_model=list[GatewayRequestAuditResponse])
  79. def list_gateway_audits(
  80. tenant_id: str = Query(...),
  81. request_id: str | None = Query(default=None),
  82. target_service: str | None = Query(default=None),
  83. limit: int = Query(default=100, ge=1, le=500),
  84. db: Session = Depends(get_db),
  85. ) -> list[GatewayRequestAuditResponse]:
  86. items = GatewayRequestAuditRepository(db).list_by_scope(
  87. tenant_id=tenant_id,
  88. request_id=request_id,
  89. target_service=target_service,
  90. limit=limit,
  91. )
  92. return [GatewayRequestAuditResponse.from_entity(item) for item in items]
  93. @router.get("/gateway/audits/stats", response_model=GatewayAuditStatsResponse)
  94. def gateway_audit_stats(
  95. tenant_id: str = Query(...),
  96. db: Session = Depends(get_db),
  97. ) -> GatewayAuditStatsResponse:
  98. rows = GatewayRequestAuditRepository(db).stats_by_service(tenant_id=tenant_id)
  99. services = [
  100. GatewayAuditServiceStats(
  101. target_service=target_service,
  102. request_count=request_count,
  103. error_count=error_count,
  104. average_duration_ms=round(average_duration_ms, 2),
  105. )
  106. for target_service, request_count, error_count, average_duration_ms in rows
  107. ]
  108. return GatewayAuditStatsResponse(
  109. tenant_id=tenant_id,
  110. total_request_count=sum(item.request_count for item in services),
  111. total_error_count=sum(item.error_count for item in services),
  112. services=services,
  113. )
  114. def get_gateway_settings() -> ApiGatewaySettings:
  115. return ApiGatewaySettings()
  116. def get_service_proxy(settings: ApiGatewaySettings = Depends(get_gateway_settings)) -> ServiceProxy:
  117. return ServiceProxy(settings=settings, timeout_seconds=settings.proxy_timeout_seconds)
  118. def build_proxy_targets(settings: ApiGatewaySettings) -> dict[ProxyServiceName, ProxyTarget]:
  119. return {
  120. "workflow-service": ProxyTarget(
  121. service_name="workflow-service",
  122. base_url=settings.workflow_service_url,
  123. path_prefix="/workflows",
  124. health_path="/workflows/health",
  125. ),
  126. "session-service": ProxyTarget(
  127. service_name="session-service",
  128. base_url=settings.session_service_url,
  129. path_prefix="/sessions",
  130. health_path="/sessions/health",
  131. ),
  132. "runtime-service": ProxyTarget(
  133. service_name="runtime-service",
  134. base_url=settings.runtime_service_url,
  135. path_prefix="/runtime",
  136. health_path="/runtime/health",
  137. ),
  138. "tool-service": ProxyTarget(
  139. service_name="tool-service",
  140. base_url=settings.tool_service_url,
  141. path_prefix="/tools",
  142. health_path="/tools/health",
  143. ),
  144. "model-gateway-service": ProxyTarget(
  145. service_name="model-gateway-service",
  146. base_url=settings.model_gateway_service_url,
  147. path_prefix="/models",
  148. health_path="/models/health",
  149. ),
  150. "code-runner-service": ProxyTarget(
  151. service_name="code-runner-service",
  152. base_url=settings.code_runner_service_url,
  153. path_prefix="/code",
  154. health_path="/code/health",
  155. ),
  156. "agent-service": ProxyTarget(
  157. service_name="agent-service",
  158. base_url=settings.agent_service_url,
  159. path_prefix="/agents",
  160. health_path="/agents/health",
  161. ),
  162. "memory-service": ProxyTarget(
  163. service_name="memory-service",
  164. base_url=settings.memory_service_url,
  165. path_prefix="/memories",
  166. health_path="/memories/health",
  167. ),
  168. "team-service": ProxyTarget(
  169. service_name="team-service",
  170. base_url=settings.team_service_url,
  171. path_prefix="/teams",
  172. health_path="/teams/health",
  173. ),
  174. "skill-service": ProxyTarget(
  175. service_name="skill-service",
  176. base_url=settings.skill_service_url,
  177. path_prefix="/skills",
  178. health_path="/skills/health",
  179. ),
  180. "human-service": ProxyTarget(
  181. service_name="human-service",
  182. base_url=settings.human_service_url,
  183. path_prefix="/human",
  184. health_path="/human/health",
  185. ),
  186. "knowledge-service": ProxyTarget(
  187. service_name="knowledge-service",
  188. base_url=settings.knowledge_service_url,
  189. path_prefix="/knowledge",
  190. health_path="/knowledge/health",
  191. ),
  192. "event-service": ProxyTarget(
  193. service_name="event-service",
  194. base_url=settings.event_service_url,
  195. path_prefix="/events",
  196. health_path="/events/health",
  197. ),
  198. "auth-service": ProxyTarget(
  199. service_name="auth-service",
  200. base_url=settings.auth_service_url,
  201. path_prefix="/auth",
  202. health_path="/auth/health",
  203. ),
  204. "scheduler-service": ProxyTarget(
  205. service_name="scheduler-service",
  206. base_url=settings.scheduler_service_url,
  207. path_prefix="/scheduler",
  208. health_path="/scheduler/health",
  209. ),
  210. }
  211. @router.get("/gateway/services/health", response_model=GatewayServicesHealthResponse)
  212. async def downstream_health_check(
  213. settings: ApiGatewaySettings = Depends(get_gateway_settings),
  214. ) -> GatewayServicesHealthResponse:
  215. targets = build_proxy_targets(settings)
  216. health_proxy = ServiceProxy(
  217. settings=settings,
  218. timeout_seconds=settings.downstream_health_timeout_seconds,
  219. )
  220. downstream_services = await asyncio.gather(
  221. *[health_proxy.check_health(target) for target in targets.values()]
  222. )
  223. status = "ok" if all(item.status == "ok" for item in downstream_services) else "degraded"
  224. return GatewayServicesHealthResponse(
  225. status=status,
  226. downstream_services=downstream_services,
  227. )
  228. @router.api_route(
  229. "/gateway/workflows",
  230. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  231. )
  232. @router.api_route(
  233. "/gateway/workflows/{path:path}",
  234. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  235. )
  236. async def proxy_workflow_service(
  237. request: Request,
  238. path: str = "",
  239. settings: ApiGatewaySettings = Depends(get_gateway_settings),
  240. proxy: ServiceProxy = Depends(get_service_proxy),
  241. ) -> Response:
  242. return await proxy.forward(
  243. request=request,
  244. target=build_proxy_targets(settings)["workflow-service"],
  245. path=path,
  246. )
  247. @router.api_route(
  248. "/gateway/sessions",
  249. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  250. )
  251. @router.api_route(
  252. "/gateway/sessions/{path:path}",
  253. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  254. )
  255. async def proxy_session_service(
  256. request: Request,
  257. path: str = "",
  258. settings: ApiGatewaySettings = Depends(get_gateway_settings),
  259. proxy: ServiceProxy = Depends(get_service_proxy),
  260. ) -> Response:
  261. return await proxy.forward(
  262. request=request,
  263. target=build_proxy_targets(settings)["session-service"],
  264. path=path,
  265. )
  266. @router.api_route(
  267. "/gateway/runtime",
  268. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  269. )
  270. @router.api_route(
  271. "/gateway/runtime/{path:path}",
  272. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  273. )
  274. async def proxy_runtime_service(
  275. request: Request,
  276. path: str = "",
  277. settings: ApiGatewaySettings = Depends(get_gateway_settings),
  278. proxy: ServiceProxy = Depends(get_service_proxy),
  279. ) -> Response:
  280. return await proxy.forward(
  281. request=request,
  282. target=build_proxy_targets(settings)["runtime-service"],
  283. path=path,
  284. )
  285. @router.api_route(
  286. "/gateway/agents",
  287. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  288. )
  289. @router.api_route(
  290. "/gateway/agents/{path:path}",
  291. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  292. )
  293. async def proxy_agent_service(
  294. request: Request,
  295. path: str = "",
  296. settings: ApiGatewaySettings = Depends(get_gateway_settings),
  297. proxy: ServiceProxy = Depends(get_service_proxy),
  298. ) -> Response:
  299. return await proxy.forward(
  300. request=request,
  301. target=build_proxy_targets(settings)["agent-service"],
  302. path=path,
  303. )
  304. @router.api_route(
  305. "/gateway/memories",
  306. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  307. )
  308. @router.api_route(
  309. "/gateway/memories/{path:path}",
  310. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  311. )
  312. async def proxy_memory_service(
  313. request: Request,
  314. path: str = "",
  315. settings: ApiGatewaySettings = Depends(get_gateway_settings),
  316. proxy: ServiceProxy = Depends(get_service_proxy),
  317. ) -> Response:
  318. return await proxy.forward(
  319. request=request,
  320. target=build_proxy_targets(settings)["memory-service"],
  321. path=path,
  322. )
  323. @router.api_route(
  324. "/gateway/teams",
  325. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  326. )
  327. @router.api_route(
  328. "/gateway/teams/{path:path}",
  329. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  330. )
  331. async def proxy_team_service(
  332. request: Request,
  333. path: str = "",
  334. settings: ApiGatewaySettings = Depends(get_gateway_settings),
  335. proxy: ServiceProxy = Depends(get_service_proxy),
  336. ) -> Response:
  337. return await proxy.forward(
  338. request=request,
  339. target=build_proxy_targets(settings)["team-service"],
  340. path=path,
  341. )
  342. @router.api_route(
  343. "/gateway/skills",
  344. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  345. )
  346. @router.api_route(
  347. "/gateway/skills/{path:path}",
  348. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  349. )
  350. async def proxy_skill_service(
  351. request: Request,
  352. path: str = "",
  353. settings: ApiGatewaySettings = Depends(get_gateway_settings),
  354. proxy: ServiceProxy = Depends(get_service_proxy),
  355. ) -> Response:
  356. return await proxy.forward(
  357. request=request,
  358. target=build_proxy_targets(settings)["skill-service"],
  359. path=path,
  360. )
  361. @router.api_route(
  362. "/gateway/human",
  363. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  364. )
  365. @router.api_route(
  366. "/gateway/human/{path:path}",
  367. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  368. )
  369. async def proxy_human_service(
  370. request: Request,
  371. path: str = "",
  372. settings: ApiGatewaySettings = Depends(get_gateway_settings),
  373. proxy: ServiceProxy = Depends(get_service_proxy),
  374. ) -> Response:
  375. return await proxy.forward(
  376. request=request,
  377. target=build_proxy_targets(settings)["human-service"],
  378. path=path,
  379. )
  380. @router.api_route(
  381. "/gateway/knowledge",
  382. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  383. )
  384. @router.api_route(
  385. "/gateway/knowledge/{path:path}",
  386. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  387. )
  388. async def proxy_knowledge_service(
  389. request: Request,
  390. path: str = "",
  391. settings: ApiGatewaySettings = Depends(get_gateway_settings),
  392. proxy: ServiceProxy = Depends(get_service_proxy),
  393. ) -> Response:
  394. return await proxy.forward(
  395. request=request,
  396. target=build_proxy_targets(settings)["knowledge-service"],
  397. path=path,
  398. )
  399. @router.api_route(
  400. "/gateway/events",
  401. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  402. )
  403. @router.api_route(
  404. "/gateway/events/{path:path}",
  405. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  406. )
  407. async def proxy_event_service(
  408. request: Request,
  409. path: str = "",
  410. settings: ApiGatewaySettings = Depends(get_gateway_settings),
  411. proxy: ServiceProxy = Depends(get_service_proxy),
  412. ) -> Response:
  413. return await proxy.forward(
  414. request=request,
  415. target=build_proxy_targets(settings)["event-service"],
  416. path=path,
  417. )
  418. @router.api_route(
  419. "/gateway/auth",
  420. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  421. )
  422. @router.api_route(
  423. "/gateway/auth/{path:path}",
  424. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  425. )
  426. async def proxy_auth_service(
  427. request: Request,
  428. path: str = "",
  429. settings: ApiGatewaySettings = Depends(get_gateway_settings),
  430. proxy: ServiceProxy = Depends(get_service_proxy),
  431. ) -> Response:
  432. return await proxy.forward(
  433. request=request,
  434. target=build_proxy_targets(settings)["auth-service"],
  435. path=path,
  436. )
  437. @router.api_route(
  438. "/gateway/scheduler",
  439. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  440. )
  441. @router.api_route(
  442. "/gateway/scheduler/{path:path}",
  443. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  444. )
  445. async def proxy_scheduler_service(
  446. request: Request,
  447. path: str = "",
  448. settings: ApiGatewaySettings = Depends(get_gateway_settings),
  449. proxy: ServiceProxy = Depends(get_service_proxy),
  450. ) -> Response:
  451. return await proxy.forward(
  452. request=request,
  453. target=build_proxy_targets(settings)["scheduler-service"],
  454. path=path,
  455. )
  456. @router.api_route(
  457. "/gateway/tools",
  458. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  459. )
  460. @router.api_route(
  461. "/gateway/tools/{path:path}",
  462. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  463. )
  464. async def proxy_tool_service(
  465. request: Request,
  466. path: str = "",
  467. settings: ApiGatewaySettings = Depends(get_gateway_settings),
  468. proxy: ServiceProxy = Depends(get_service_proxy),
  469. ) -> Response:
  470. return await proxy.forward(
  471. request=request,
  472. target=build_proxy_targets(settings)["tool-service"],
  473. path=path,
  474. )
  475. @router.api_route(
  476. "/gateway/models",
  477. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  478. )
  479. @router.api_route(
  480. "/gateway/models/{path:path}",
  481. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  482. )
  483. async def proxy_model_gateway_service(
  484. request: Request,
  485. path: str = "",
  486. settings: ApiGatewaySettings = Depends(get_gateway_settings),
  487. proxy: ServiceProxy = Depends(get_service_proxy),
  488. ) -> Response:
  489. return await proxy.forward(
  490. request=request,
  491. target=build_proxy_targets(settings)["model-gateway-service"],
  492. path=path,
  493. )
  494. @router.api_route(
  495. "/gateway/code",
  496. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  497. )
  498. @router.api_route(
  499. "/gateway/code/{path:path}",
  500. methods=["GET", "POST", "PUT", "PATCH", "DELETE"],
  501. )
  502. async def proxy_code_runner_service(
  503. request: Request,
  504. path: str = "",
  505. settings: ApiGatewaySettings = Depends(get_gateway_settings),
  506. proxy: ServiceProxy = Depends(get_service_proxy),
  507. ) -> Response:
  508. return await proxy.forward(
  509. request=request,
  510. target=build_proxy_targets(settings)["code-runner-service"],
  511. path=path,
  512. )