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