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