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