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