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