1pub mod api_keys;
4pub mod approval_delegations;
5pub mod approve_run;
6pub mod audit_logs;
7pub mod auth;
8pub mod cancel_run;
9pub mod create_run;
10pub mod download_artifact;
11pub mod events;
12pub mod get_run;
13pub mod get_run_logs;
14pub mod get_stats;
15pub mod get_stats_history;
16pub mod get_workflow;
17pub mod health_check;
18pub mod human_input;
19mod internal;
20pub mod list_runs;
21pub mod list_workflows;
22#[cfg(feature = "prometheus")]
23pub mod metrics;
24pub mod openapi_spec;
25pub mod plan_workflow;
26pub mod provider_accounts;
27pub mod replay_run;
28pub mod retry_run;
29pub mod run_events;
30pub mod schedules;
31pub mod secrets;
32pub mod templates;
33#[cfg(test)]
34mod test_helpers;
35pub mod users;
36
37use std::path::PathBuf;
38
39use axum::Extension;
40use axum::Router;
41use axum::middleware as axum_mw;
42use axum::routing::{delete, get, patch, post, put};
43use tower_http::limit::RequestBodyLimitLayer;
44use tower_http::services::{ServeDir, ServeFile};
45
46use crate::middleware::{WorkerToken, security_headers, worker_token_auth};
47use crate::rate_limit::{RateLimitContext, per_minute, rate_limit};
48use crate::state::AppState;
49
50const MAX_BODY_SIZE: usize = 2 * 1024 * 1024;
52
53const MAX_ARTIFACT_BODY_SIZE: usize = 128 * 1024 * 1024;
59
60#[derive(Debug, Clone)]
82pub struct RouterConfig {
83 pub dashboard_dir: Option<PathBuf>,
86 pub rate_limit_auth: Option<u32>,
89 pub rate_limit_general: Option<u32>,
92}
93
94impl Default for RouterConfig {
95 fn default() -> Self {
96 Self {
97 dashboard_dir: None,
98 rate_limit_auth: Some(10),
99 rate_limit_general: Some(60),
100 }
101 }
102}
103
104#[cfg(not(feature = "sign-up"))]
106async fn sign_up_disabled() -> impl axum::response::IntoResponse {
107 crate::error::ApiError::BadRequest("sign-up is disabled".to_string())
108}
109
110pub fn create_router(state: AppState, config: RouterConfig) -> Router {
142 let internal_routes = Router::new()
144 .route("/runs", post(internal::create_run::create_run))
145 .route("/runs/next", get(internal::pick_next_run::pick_next_run))
146 .route(
147 "/runs/pending-count",
148 get(internal::count_pending_runs::count_pending_runs),
149 )
150 .route(
151 "/runs/{id}",
152 get(internal::get_run::get_run).put(internal::update_run::update_run),
153 )
154 .route(
155 "/runs/{id}/status",
156 put(internal::update_run_status::update_run_status),
157 )
158 .route("/runs/{id}/logs", post(internal::push_logs::push_logs))
159 .route("/runs/{id}/lease", post(internal::renew_lease::renew_lease))
160 .route(
161 "/runs/{id}/artifacts",
162 get(internal::list_artifacts::list_artifacts),
163 )
164 .route("/steps", post(internal::create_step::create_step))
165 .route("/steps/{id}", put(internal::update_step::update_step))
166 .route(
167 "/step-dependencies",
168 post(internal::create_step_dependencies::create_step_dependencies),
169 )
170 .route("/secrets/{*key}", get(internal::get_secret::get_secret))
171 .route(
172 "/provider-accounts/candidates",
173 get(internal::provider_accounts::list_candidates),
174 )
175 .route(
176 "/provider-accounts/{id}/observations",
177 post(internal::provider_accounts::record_observation),
178 )
179 .layer(axum_mw::from_fn(worker_token_auth))
180 .layer(Extension(WorkerToken(state.worker_token.clone())))
181 .with_state(state.clone());
182
183 let artifact_upload_routes = Router::new()
186 .route(
187 "/api/v1/internal/runs/{id}/steps/{step_id}/artifacts/{name}",
188 post(internal::upload_artifact::upload_artifact),
189 )
190 .layer(axum_mw::from_fn(worker_token_auth))
191 .layer(Extension(WorkerToken(state.worker_token.clone())))
192 .layer(RequestBodyLimitLayer::new(MAX_ARTIFACT_BODY_SIZE))
193 .with_state(state.clone());
194
195 #[allow(unused_mut)]
197 let mut auth_credential_routes = Router::new();
198
199 #[cfg(feature = "sign-up")]
200 {
201 auth_credential_routes =
202 auth_credential_routes.route("/sign-up", post(auth::sign_up::sign_up));
203 }
204
205 #[cfg(not(feature = "sign-up"))]
206 {
207 auth_credential_routes = auth_credential_routes.route("/sign-up", post(sign_up_disabled));
208 }
209
210 let mut auth_credential_routes =
211 auth_credential_routes.route("/sign-in", post(auth::sign_in::sign_in));
212
213 if let Some(rpm) = config.rate_limit_auth {
214 let ctx = RateLimitContext {
215 store: state.store.clone(),
216 jwt_config: state.jwt_config.clone(),
217 limiter: per_minute(rpm),
218 };
219 auth_credential_routes = auth_credential_routes
220 .layer(axum_mw::from_fn(rate_limit))
221 .layer(Extension(ctx));
222 }
223
224 let auth_session_routes = Router::new()
226 .route("/refresh", post(auth::refresh::refresh))
227 .route("/sign-out", post(auth::sign_out::sign_out))
228 .route("/me", get(auth::me::me))
229 .route("/password", patch(auth::change_password::change_password));
230
231 #[allow(unused_mut)]
233 let mut api_v1 = Router::new()
234 .route("/health-check", get(health_check::health_check))
235 .route("/openapi.json", get(openapi_spec::openapi_spec))
236 .route(
237 "/runs",
238 get(list_runs::list_runs).post(create_run::create_run),
239 )
240 .route("/runs/{id}", get(get_run::get_run))
241 .route("/runs/{id}/logs", get(get_run_logs::get_run_logs))
242 .route("/runs/{id}/cancel", post(cancel_run::cancel_run))
243 .route("/runs/{id}/approve", post(approve_run::approve_run))
244 .route("/runs/{id}/reject", post(approve_run::reject_run))
245 .route("/runs/{id}/retry", post(retry_run::retry_run))
246 .route("/runs/{id}/replay", post(replay_run::replay_run))
247 .route("/runs/{id}/events", get(run_events::run_events))
248 .route(
249 "/runs/{id}/steps/{step_id}/artifacts/{name}",
250 get(download_artifact::download_artifact),
251 )
252 .route(
253 "/runs/{id}/steps/{step_id}/input",
254 post(human_input::submit_human_input),
255 )
256 .route(
257 "/runs/{id}/steps/{step_id}/reject",
258 post(human_input::reject_human_input),
259 )
260 .route("/workflows", get(list_workflows::list_workflows))
261 .route("/workflows/{name}", get(get_workflow::get_workflow))
262 .route("/workflows/{name}/plan", post(plan_workflow::plan_workflow))
263 .route("/stats", get(get_stats::get_stats))
264 .route("/stats/history", get(get_stats_history::get_stats_history))
265 .route("/audit-logs", get(audit_logs::list_audit_logs))
266 .route("/events", get(events::events))
267 .route(
268 "/api-keys",
269 get(api_keys::list::list_api_keys).post(api_keys::create::create_api_key),
270 )
271 .route(
272 "/api-keys/scopes",
273 get(api_keys::available_scopes::available_scopes),
274 )
275 .route("/api-keys/{id}", delete(api_keys::delete::delete_api_key))
276 .route(
277 "/users",
278 get(users::list::list_users).post(users::create::create_user),
279 )
280 .route("/users/{id}", delete(users::delete::delete_user))
281 .route("/users/{id}/role", patch(users::update_role::update_role))
282 .route(
283 "/users/{id}/groups",
284 get(users::groups::get_user_groups).put(users::groups::update_user_groups),
285 )
286 .route(
287 "/secrets",
288 get(secrets::list::list_secrets).post(secrets::create::create_secret),
289 )
290 .route("/secrets/rotate", post(secrets::rotate::rotate_secrets))
293 .route(
294 "/secrets/key-versions",
295 get(secrets::key_versions::secret_key_versions),
296 )
297 .route(
298 "/secrets/{*key}",
299 put(secrets::update::update_secret).delete(secrets::delete::delete_secret),
300 )
301 .route(
302 "/provider-accounts",
303 get(provider_accounts::list::list_provider_accounts)
304 .post(provider_accounts::create::create_provider_account),
305 )
306 .route(
309 "/provider-accounts/kinds",
310 get(provider_accounts::kinds::list_account_kinds),
311 )
312 .route(
313 "/provider-accounts/{id}",
314 get(provider_accounts::get::get_provider_account)
315 .patch(provider_accounts::update::update_provider_account)
316 .delete(provider_accounts::delete::delete_provider_account),
317 )
318 .route(
319 "/provider-accounts/{id}/test",
320 post(provider_accounts::test::test_provider_account),
321 )
322 .route(
323 "/provider-accounts/{id}/usage",
324 get(provider_accounts::usage::provider_account_usage),
325 )
326 .route(
327 "/approval-delegations",
328 get(approval_delegations::list::list_approval_delegations)
329 .post(approval_delegations::create::create_approval_delegation),
330 )
331 .route(
332 "/approval-delegations/{id}",
333 delete(approval_delegations::delete::delete_approval_delegation),
334 )
335 .route(
336 "/schedules",
337 get(schedules::list::list_schedules).post(schedules::create::create_schedule),
338 )
339 .route(
340 "/schedules/{id}",
341 get(schedules::get::get_schedule).delete(schedules::delete::delete_schedule),
342 )
343 .route(
344 "/schedules/{id}/pause",
345 post(schedules::pause_resume::pause_schedule),
346 )
347 .route(
348 "/schedules/{id}/resume",
349 post(schedules::pause_resume::resume_schedule),
350 )
351 .route(
352 "/schedules/{id}/trigger",
353 post(schedules::trigger::trigger_schedule),
354 )
355 .route(
356 "/templates/registry",
357 get(templates::list_registry_templates),
358 );
359
360 #[cfg(feature = "prometheus")]
361 {
362 api_v1 = api_v1.route("/metrics", get(metrics::metrics));
363 }
364
365 let mut api_v1 = api_v1
366 .nest("/auth", auth_credential_routes)
367 .nest("/auth", auth_session_routes);
368
369 if let Some(rpm) = config.rate_limit_general {
370 let ctx = RateLimitContext {
371 store: state.store.clone(),
372 jwt_config: state.jwt_config.clone(),
373 limiter: per_minute(rpm),
374 };
375 api_v1 = api_v1
376 .layer(axum_mw::from_fn(rate_limit))
377 .layer(Extension(ctx));
378 }
379
380 let api_v1 = api_v1.with_state(state.clone());
381
382 #[allow(unused_mut)]
383 let mut app = Router::new()
384 .nest("/api/v1/internal", internal_routes)
385 .nest("/api/v1", api_v1)
386 .with_state(state)
387 .layer(RequestBodyLimitLayer::new(MAX_BODY_SIZE))
388 .merge(artifact_upload_routes)
389 .layer(axum_mw::from_fn(security_headers));
390
391 #[cfg(feature = "prometheus")]
392 {
393 app = app.layer(axum_mw::from_fn(crate::middleware::request_metrics));
394 }
395
396 match config.dashboard_dir {
397 Some(dir) => {
398 let index = dir.join("index.html");
399 let serve = ServeDir::new(dir).fallback(ServeFile::new(index));
400 app.fallback_service(serve)
401 }
402 #[cfg(feature = "dashboard")]
403 None => app.fallback_service(crate::dashboard::EmbeddedDashboard),
404 #[cfg(not(feature = "dashboard"))]
405 None => app,
406 }
407}
408
409#[cfg(test)]
410mod tests {
411 use super::*;
412 use axum::body::Body;
413 use axum::http::{Request, StatusCode};
414 use http_body_util::BodyExt;
415 use ironflow_core::providers::claude::ClaudeCodeProvider;
416 use ironflow_engine::engine::Engine;
417 use ironflow_engine::notify::Event;
418 use ironflow_store::memory::InMemoryStore;
419 use std::sync::Arc;
420 use tokio::sync::broadcast;
421 use tower::ServiceExt;
422 fn test_state() -> AppState {
423 let store = Arc::new(InMemoryStore::new());
424 let provider = Arc::new(ClaudeCodeProvider::new());
425 let engine = Arc::new(Engine::new(store.clone(), provider));
426 let jwt_config = Arc::new(ironflow_auth::jwt::JwtConfig {
427 secret: "test-secret".to_string(),
428 access_token_ttl_secs: 900,
429 refresh_token_ttl_secs: 604800,
430 cookie_domain: None,
431 cookie_secure: false,
432 });
433 let (event_sender, _) = broadcast::channel::<Event>(1);
434 AppState::new(
435 store,
436 engine,
437 jwt_config,
438 "test-worker-token".to_string(),
439 event_sender,
440 )
441 }
442
443 #[tokio::test]
444 async fn health_check_route() {
445 let state = test_state();
446 let app = create_router(state, RouterConfig::default());
447
448 let req = Request::builder()
449 .uri("/api/v1/health-check")
450 .body(Body::empty())
451 .unwrap();
452
453 let resp = app.oneshot(req).await.unwrap();
454 assert_eq!(resp.status(), StatusCode::OK);
455
456 let body = resp.into_body().collect().await.unwrap().to_bytes();
457 assert_eq!(&body[..], b"OK");
458 }
459
460 fn make_auth_header(state: &AppState) -> String {
461 use ironflow_auth::jwt::AccessToken;
462 use uuid::Uuid;
463
464 let user_id = Uuid::now_v7();
465 let token = AccessToken::for_user(user_id, "testuser", false, &state.jwt_config).unwrap();
466 format!("Bearer {}", token.0)
467 }
468
469 #[tokio::test]
470 async fn runs_route_exists() {
471 let state = test_state();
472 let app = create_router(state.clone(), RouterConfig::default());
473 let auth_header = make_auth_header(&state);
474
475 let req = Request::builder()
476 .uri("/api/v1/runs?page=1&per_page=20")
477 .header("authorization", auth_header)
478 .body(Body::empty())
479 .unwrap();
480
481 let resp = app.oneshot(req).await.unwrap();
482 assert_eq!(resp.status(), StatusCode::OK);
483 }
484
485 #[tokio::test]
486 async fn stats_route_exists() {
487 let state = test_state();
488 let app = create_router(state.clone(), RouterConfig::default());
489 let auth_header = make_auth_header(&state);
490
491 let req = Request::builder()
492 .uri("/api/v1/stats")
493 .header("authorization", auth_header)
494 .body(Body::empty())
495 .unwrap();
496
497 let resp = app.oneshot(req).await.unwrap();
498 assert_eq!(resp.status(), StatusCode::OK);
499 }
500
501 #[tokio::test]
502 async fn responses_include_security_headers() {
503 let state = test_state();
504 let app = create_router(state, RouterConfig::default());
505
506 let req = Request::builder()
507 .uri("/api/v1/health-check")
508 .body(Body::empty())
509 .unwrap();
510
511 let resp = app.oneshot(req).await.unwrap();
512
513 assert_eq!(
514 resp.headers().get("x-content-type-options").unwrap(),
515 "nosniff"
516 );
517 assert_eq!(resp.headers().get("x-frame-options").unwrap(), "DENY");
518 assert_eq!(
519 resp.headers().get("x-xss-protection").unwrap(),
520 "1; mode=block"
521 );
522 assert_eq!(
523 resp.headers().get("strict-transport-security").unwrap(),
524 "max-age=63072000; includeSubDomains"
525 );
526 assert!(
527 resp.headers()
528 .get("content-security-policy")
529 .unwrap()
530 .to_str()
531 .unwrap()
532 .contains("default-src 'self'")
533 );
534 }
535
536 #[tokio::test]
537 async fn body_size_limit_rejects_oversized_payload() {
538 let state = test_state();
539 let app = create_router(state.clone(), RouterConfig::default());
540 let auth_header = make_auth_header(&state);
541
542 let oversized = vec![0u8; 3 * 1024 * 1024];
544
545 let req = Request::builder()
546 .method("POST")
547 .uri("/api/v1/runs")
548 .header("content-type", "application/json")
549 .header("authorization", auth_header)
550 .body(Body::from(oversized))
551 .unwrap();
552
553 let resp = app.oneshot(req).await.unwrap();
554 assert_eq!(resp.status(), StatusCode::PAYLOAD_TOO_LARGE);
555 }
556}