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