Skip to main content

alef_e2e/
fixture.rs

1//! Fixture loading, validation, and grouping for e2e test generation.
2
3use anyhow::{Context, Result, bail};
4use serde::{Deserialize, Serialize};
5use std::collections::HashMap;
6use std::path::Path;
7
8/// Mock HTTP response for testing HTTP clients.
9#[derive(Debug, Clone, Serialize, Deserialize)]
10pub struct MockResponse {
11    /// HTTP status code.
12    pub status: u16,
13    /// JSON response body (for non-streaming responses).
14    #[serde(default)]
15    pub body: Option<serde_json::Value>,
16    /// SSE stream chunks (for streaming responses).
17    /// Each chunk is a JSON object sent as `data: <chunk>\n\n`.
18    #[serde(default)]
19    pub stream_chunks: Option<Vec<serde_json::Value>>,
20    /// Response headers to apply to the mock response.
21    /// Bridged from `http.expected_response.headers` for consumer-style fixtures.
22    #[serde(default)]
23    pub headers: HashMap<String, String>,
24}
25
26/// Visitor specification for visitor pattern tests.
27#[derive(Debug, Clone, Serialize, Deserialize)]
28pub struct VisitorSpec {
29    /// Map of callback method name to action.
30    pub callbacks: HashMap<String, CallbackAction>,
31}
32
33/// Action a visitor callback should take.
34#[derive(Debug, Clone, Serialize, Deserialize)]
35#[serde(tag = "action")]
36pub enum CallbackAction {
37    /// Return VisitResult::Skip.
38    #[serde(rename = "skip")]
39    Skip,
40    /// Return VisitResult::Continue.
41    #[serde(rename = "continue")]
42    Continue,
43    /// Return VisitResult::PreserveHtml.
44    #[serde(rename = "preserve_html")]
45    PreserveHtml,
46    /// Return VisitResult::Custom with static output.
47    #[serde(rename = "custom")]
48    Custom {
49        /// The static replacement string.
50        output: String,
51    },
52    /// Return VisitResult::Custom with template interpolation.
53    #[serde(rename = "custom_template")]
54    CustomTemplate {
55        /// Template with placeholders like {text}, {href}.
56        template: String,
57        /// How the generated visitor returns the rendered template to the host.
58        /// `Dict` (default) returns `{"custom": "..."}` (or per-language equivalent)
59        /// to hit the structured-result code path; `BareString` returns the raw
60        /// rendered string to hit the string-result code path. Both must produce
61        /// `VisitResult::Custom`.
62        #[serde(default)]
63        return_form: TemplateReturnForm,
64    },
65}
66
67/// How a `CustomTemplate` action returns its rendered value from the visitor.
68#[derive(Debug, Clone, Copy, Default, PartialEq, Eq, Serialize, Deserialize)]
69#[serde(rename_all = "snake_case")]
70pub enum TemplateReturnForm {
71    /// Return a host-native structured value (e.g. dict, hash, array, object)
72    /// carrying the rendered string under a `custom` key.
73    #[default]
74    Dict,
75    /// Return the rendered string directly, with no wrapper.
76    BareString,
77}
78
79/// Environment variable requirements for a smoke/live test fixture.
80#[derive(Debug, Clone, Serialize, Deserialize)]
81pub struct FixtureEnv {
82    /// Name of the env var that holds the API key (e.g. `"OPENAI_API_KEY"`).
83    #[serde(default)]
84    pub api_key_var: Option<String>,
85}
86
87/// A single e2e test fixture.
88#[derive(Debug, Clone, Serialize, Deserialize)]
89pub struct Fixture {
90    /// Unique identifier (used as test function name).
91    pub id: String,
92    /// Optional category (defaults to parent directory name).
93    #[serde(default)]
94    pub category: Option<String>,
95    /// Human-readable description.
96    pub description: String,
97    /// Optional tags for filtering.
98    #[serde(default)]
99    pub tags: Vec<String>,
100    /// Skip directive.
101    #[serde(default)]
102    pub skip: Option<SkipDirective>,
103    /// Environment variable requirements (used by smoke/live tests).
104    #[serde(default)]
105    pub env: Option<FixtureEnv>,
106    /// Named call config to use (references `[e2e.calls.<name>]`).
107    /// When omitted, uses the default `[e2e.call]`.
108    #[serde(default)]
109    pub call: Option<String>,
110    /// Input data passed to the function under test.
111    #[serde(default)]
112    pub input: serde_json::Value,
113    /// Optional mock HTTP response for testing HTTP clients.
114    #[serde(default)]
115    pub mock_response: Option<MockResponse>,
116    /// Optional visitor specification for visitor pattern tests.
117    #[serde(default)]
118    pub visitor: Option<VisitorSpec>,
119    /// List of assertions to check.
120    #[serde(default)]
121    pub assertions: Vec<Assertion>,
122    /// Source file path (populated during loading).
123    #[serde(skip)]
124    pub source: String,
125    /// HTTP server test specification. When present, this fixture tests
126    /// an HTTP handler rather than a function call.
127    #[serde(default)]
128    pub http: Option<HttpFixture>,
129}
130
131/// HTTP server test specification.
132#[derive(Debug, Clone, Serialize, Deserialize)]
133pub struct HttpFixture {
134    /// Handler/route definition.
135    pub handler: HttpHandler,
136    /// The HTTP request to send.
137    pub request: HttpRequest,
138    /// Expected response.
139    pub expected_response: HttpExpectedResponse,
140}
141
142/// Handler/route definition for HTTP server tests.
143#[derive(Debug, Clone, Serialize, Deserialize)]
144pub struct HttpHandler {
145    /// Route pattern (e.g., "/users/{user_id}").
146    pub route: String,
147    /// HTTP method (GET, POST, PUT, etc.).
148    pub method: String,
149    /// JSON Schema for request body validation.
150    #[serde(default)]
151    pub body_schema: Option<serde_json::Value>,
152    /// Parameter schemas by source (path, query, header, cookie).
153    #[serde(default)]
154    pub parameters: HashMap<String, HashMap<String, serde_json::Value>>,
155    /// Middleware configuration.
156    #[serde(default)]
157    pub middleware: Option<HttpMiddleware>,
158}
159
160/// HTTP request to send in a server test.
161#[derive(Debug, Clone, Serialize, Deserialize)]
162pub struct HttpRequest {
163    pub method: String,
164    pub path: String,
165    #[serde(default)]
166    pub headers: HashMap<String, String>,
167    #[serde(default)]
168    pub query_params: HashMap<String, serde_json::Value>,
169    #[serde(default)]
170    pub cookies: HashMap<String, String>,
171    #[serde(default)]
172    pub body: Option<serde_json::Value>,
173    #[serde(default)]
174    pub content_type: Option<String>,
175}
176
177/// Expected HTTP response specification.
178#[derive(Debug, Clone, Serialize, Deserialize)]
179pub struct HttpExpectedResponse {
180    pub status_code: u16,
181    /// Exact body match.
182    #[serde(default)]
183    pub body: Option<serde_json::Value>,
184    /// Partial body match (only check specified fields).
185    #[serde(default)]
186    pub body_partial: Option<serde_json::Value>,
187    /// Header expectations. Special tokens: `<<uuid>>`, `<<present>>`, `<<absent>>`.
188    #[serde(default)]
189    pub headers: HashMap<String, String>,
190    /// Expected validation errors (for 422 responses).
191    #[serde(default)]
192    pub validation_errors: Option<Vec<ValidationErrorExpectation>>,
193}
194
195/// Expected validation error entry.
196#[derive(Debug, Clone, Serialize, Deserialize)]
197pub struct ValidationErrorExpectation {
198    pub loc: Vec<String>,
199    pub msg: String,
200    #[serde(rename = "type")]
201    pub error_type: String,
202}
203
204/// CORS policy configuration for HTTP handler tests.
205#[derive(Debug, Clone, Default, Serialize, Deserialize)]
206pub struct CorsConfig {
207    /// Allowed origins (e.g. `["https://example.com"]`). Empty means deny all.
208    #[serde(default)]
209    pub allow_origins: Vec<String>,
210    /// Allowed HTTP methods (e.g. `["GET", "POST"]`). Empty means deny all.
211    #[serde(default)]
212    pub allow_methods: Vec<String>,
213    /// Allowed request headers (e.g. `["Content-Type"]`). Empty means deny all.
214    #[serde(default)]
215    pub allow_headers: Vec<String>,
216    /// Exposed response headers (e.g. `["X-Total-Count"]`).
217    #[serde(default)]
218    pub expose_headers: Vec<String>,
219    /// `Access-Control-Max-Age` value in seconds.
220    #[serde(default)]
221    pub max_age: Option<u64>,
222    /// Whether to allow credentials.
223    #[serde(default)]
224    pub allow_credentials: bool,
225}
226
227/// A single static file entry for the static-files middleware.
228#[derive(Debug, Clone, Serialize, Deserialize)]
229pub struct StaticFile {
230    /// Relative path within the served directory (e.g. `"hello.txt"`).
231    pub path: String,
232    /// File content (plain text or HTML string).
233    pub content: String,
234}
235
236/// Static-files middleware configuration for HTTP handler tests.
237#[derive(Debug, Clone, Serialize, Deserialize)]
238pub struct StaticFilesConfig {
239    /// URL route prefix (e.g. `"/public"`).
240    pub route_prefix: String,
241    /// Files to write to the temporary directory.
242    #[serde(default)]
243    pub files: Vec<StaticFile>,
244    /// Whether to serve `index.html` for directory requests.
245    #[serde(default)]
246    pub index_file: bool,
247    /// `Cache-Control` header value to apply.
248    #[serde(default)]
249    pub cache_control: Option<String>,
250}
251
252/// Middleware configuration for HTTP handler tests.
253#[derive(Debug, Clone, Default, Serialize, Deserialize)]
254pub struct HttpMiddleware {
255    #[serde(default)]
256    pub jwt_auth: Option<serde_json::Value>,
257    #[serde(default)]
258    pub api_key_auth: Option<serde_json::Value>,
259    #[serde(default)]
260    pub compression: Option<serde_json::Value>,
261    #[serde(default)]
262    pub rate_limit: Option<serde_json::Value>,
263    #[serde(default)]
264    pub request_timeout: Option<serde_json::Value>,
265    #[serde(default)]
266    pub request_id: Option<serde_json::Value>,
267    /// CORS policy to apply via tower-http `CorsLayer`.
268    #[serde(default)]
269    pub cors: Option<CorsConfig>,
270    /// Static-files configuration to serve via tower-http `ServeDir`.
271    #[serde(default)]
272    pub static_files: Option<Vec<StaticFilesConfig>>,
273}
274
275/// Returns true for paths that the crawler fetches from the host root rather than under a
276/// fixture-namespaced prefix.  Mirrors the identical predicate in the standalone mock-server
277/// binary (`codegen/rust/mock_server.rs`).
278fn is_host_root_path(path: &str) -> bool {
279    path.starts_with("/robots") || path.starts_with("/sitemap")
280}
281
282impl Fixture {
283    /// Returns true if this is an HTTP server test fixture.
284    pub fn is_http_test(&self) -> bool {
285        self.http.is_some()
286    }
287
288    /// Returns true if this fixture requires a mock HTTP server.
289    /// This is true when either `mock_response` (liter-llm shape),
290    /// `http.expected_response` (consumer shape), or the kreuzcrawl-style
291    /// `input.mock_responses` array is non-empty.
292    pub fn needs_mock_server(&self) -> bool {
293        if self.mock_response.is_some() || self.http.is_some() {
294            return true;
295        }
296        // kreuzcrawl-style: input.mock_responses array with at least one entry
297        self.input
298            .get("mock_responses")
299            .and_then(|v| v.as_array())
300            .map(|arr| !arr.is_empty())
301            .unwrap_or(false)
302    }
303
304    /// Returns the effective mock response for this fixture, bridging both schemas:
305    /// - liter-llm shape: `mock_response: { status, body, stream_chunks }`
306    /// - consumer shape: `http.expected_response: { status_code, body, headers }`
307    ///
308    /// Returns `None` if neither schema is present.
309    pub fn as_mock_response(&self) -> Option<MockResponse> {
310        if let Some(mock) = &self.mock_response {
311            return Some(mock.clone());
312        }
313        if let Some(http) = &self.http {
314            return Some(MockResponse {
315                status: http.expected_response.status_code,
316                body: http.expected_response.body.clone(),
317                stream_chunks: None,
318                headers: http.expected_response.headers.clone(),
319            });
320        }
321        None
322    }
323
324    /// Returns true if the mock response uses streaming (SSE).
325    pub fn is_streaming_mock(&self) -> bool {
326        self.mock_response
327            .as_ref()
328            .and_then(|m| m.stream_chunks.as_ref())
329            .map(|c| !c.is_empty())
330            .unwrap_or(false)
331    }
332
333    /// Returns true if any of this fixture's mock response paths are host-root paths —
334    /// i.e. paths the crawler fetches from the host root rather than under a
335    /// fixture-namespaced prefix.  Mirrors the `is_host_root_path` predicate in the
336    /// standalone mock-server binary (`codegen/rust/mock_server.rs`).
337    ///
338    /// Host-root fixtures get a dedicated per-fixture listener and their base URL is
339    /// published in the `MOCK_SERVERS={"fixture_id":"http://..."}` JSON line.
340    pub fn has_host_root_route(&self) -> bool {
341        // Array schema: input.mock_responses[*].path
342        if let Some(arr) = self.input.get("mock_responses").and_then(|v| v.as_array()) {
343            // Direct host-root paths (/robots*, /sitemap*).
344            if arr.iter().any(|entry| {
345                entry
346                    .get("path")
347                    .and_then(|v| v.as_str())
348                    .map(is_host_root_path)
349                    .unwrap_or(false)
350            }) {
351                return true;
352            }
353            // Any response that triggers an intra-fixture redirect to a host-root path:
354            // the engine resolves the redirect target against the origin (not the
355            // /fixtures/<id>/ namespace), so the fixture must serve at host root for the
356            // follow-up GET to hit the correct route. Three trigger shapes are detected:
357            //   - 3xx with Location: /...
358            //   - any status with Refresh: <s>;url=/...
359            //   - 200 HTML with <meta http-equiv="refresh" content="...url=/...">
360            return arr.iter().any(|entry| {
361                let status = entry.get("status_code").and_then(|v| v.as_u64()).unwrap_or(0);
362                let headers = entry.get("headers").and_then(|v| v.as_object());
363                let location_redirect = (300..400).contains(&status)
364                    && headers
365                        .map(|hdrs| {
366                            hdrs.iter().any(|(name, value)| {
367                                name.eq_ignore_ascii_case("location")
368                                    && value.as_str().is_some_and(|s| s.starts_with('/'))
369                            })
370                        })
371                        .unwrap_or(false);
372                let refresh_redirect = headers
373                    .map(|hdrs| {
374                        hdrs.iter().any(|(name, value)| {
375                            if !name.eq_ignore_ascii_case("refresh") {
376                                return false;
377                            }
378                            value
379                                .as_str()
380                                .and_then(|s| s.to_ascii_lowercase().find("url=").map(|i| (s.to_owned(), i)))
381                                .map(|(s, idx)| s[idx + 4..].trim_start().starts_with('/'))
382                                .unwrap_or(false)
383                        })
384                    })
385                    .unwrap_or(false);
386                let meta_refresh = entry
387                    .get("body_inline")
388                    .and_then(|v| v.as_str())
389                    .map(|body| {
390                        let lower = body.to_ascii_lowercase();
391                        lower
392                            .split("http-equiv=\"refresh\"")
393                            .nth(1)
394                            .and_then(|s| s.split("content=").nth(1))
395                            .map(|s| s.trim_start_matches(['"', '\'']).contains("url=/"))
396                            .unwrap_or(false)
397                    })
398                    .unwrap_or(false);
399                location_redirect || refresh_redirect || meta_refresh
400            });
401        }
402        false
403    }
404
405    /// Get the resolved category (explicit or from source directory).
406    pub fn resolved_category(&self) -> String {
407        self.category.clone().unwrap_or_else(|| {
408            Path::new(&self.source)
409                .parent()
410                .and_then(|p| p.file_name())
411                .and_then(|n| n.to_str())
412                .unwrap_or("default")
413                .to_string()
414        })
415    }
416}
417
418/// Skip directive for conditionally excluding fixtures.
419#[derive(Debug, Clone, Serialize, Deserialize)]
420pub struct SkipDirective {
421    /// Languages to skip (empty means skip all).
422    #[serde(default)]
423    pub languages: Vec<String>,
424    /// Human-readable reason for skipping.
425    #[serde(default)]
426    pub reason: Option<String>,
427}
428
429impl SkipDirective {
430    /// Check if this fixture should be skipped for a given language.
431    pub fn should_skip(&self, language: &str) -> bool {
432        self.languages.is_empty() || self.languages.iter().any(|l| l == language)
433    }
434}
435
436/// A single assertion in a fixture.
437#[derive(Debug, Clone, Default, Serialize, Deserialize)]
438pub struct Assertion {
439    /// Assertion type (equals, contains, not_empty, error, etc.).
440    #[serde(rename = "type")]
441    pub assertion_type: String,
442    /// Field path to access on the result (dot-separated).
443    #[serde(default)]
444    pub field: Option<String>,
445    /// Expected value (string, number, bool, or array depending on type).
446    #[serde(default)]
447    pub value: Option<serde_json::Value>,
448    /// Expected values (for contains_all, contains_any).
449    #[serde(default)]
450    pub values: Option<Vec<serde_json::Value>>,
451    /// Method name to call on the result (for method_result assertions).
452    #[serde(default)]
453    pub method: Option<String>,
454    /// Assertion check type for the method result (equals, is_true, is_false, greater_than_or_equal, count_min).
455    #[serde(default)]
456    pub check: Option<String>,
457    /// Arguments to pass to the method call (for method_result assertions).
458    #[serde(default)]
459    pub args: Option<serde_json::Value>,
460    /// Return type hint for C method_result codegen.
461    ///
462    /// Supported values:
463    /// - `"string"` — the method returns a heap-allocated `char*` that must be
464    ///   freed with `free()` after the assertion.  The generator emits
465    ///   `char* _r = call(); assert(...); free(_r);`.
466    ///
467    /// Defaults to primitive integer dispatch when absent.
468    #[serde(default)]
469    pub return_type: Option<String>,
470}
471
472/// A group of fixtures sharing the same category.
473#[derive(Debug, Clone)]
474pub struct FixtureGroup {
475    pub category: String,
476    pub fixtures: Vec<Fixture>,
477}
478
479/// Load all fixtures from a directory recursively.
480pub fn load_fixtures(dir: &Path) -> Result<Vec<Fixture>> {
481    let mut fixtures = Vec::new();
482    load_fixtures_recursive(dir, dir, &mut fixtures)?;
483
484    // Validate: check for duplicate IDs
485    let mut seen: HashMap<String, String> = HashMap::new();
486    for f in &fixtures {
487        if let Some(prev_source) = seen.get(&f.id) {
488            bail!(
489                "duplicate fixture ID '{}': found in '{}' and '{}'",
490                f.id,
491                prev_source,
492                f.source
493            );
494        }
495        seen.insert(f.id.clone(), f.source.clone());
496    }
497
498    // Sort by (category, id) for deterministic output
499    fixtures.sort_by(|a, b| {
500        let cat_cmp = a.resolved_category().cmp(&b.resolved_category());
501        cat_cmp.then_with(|| a.id.cmp(&b.id))
502    });
503
504    Ok(fixtures)
505}
506
507fn load_fixtures_recursive(base: &Path, dir: &Path, fixtures: &mut Vec<Fixture>) -> Result<()> {
508    let entries =
509        std::fs::read_dir(dir).with_context(|| format!("failed to read fixture directory: {}", dir.display()))?;
510
511    let mut paths: Vec<_> = entries.filter_map(|e| e.ok()).map(|e| e.path()).collect();
512    paths.sort();
513
514    for path in paths {
515        if path.is_dir() {
516            load_fixtures_recursive(base, &path, fixtures)?;
517        } else if path.extension().is_some_and(|ext| ext == "json") {
518            let filename = path.file_name().and_then(|n| n.to_str()).unwrap_or("");
519            // Skip schema files and files starting with _
520            if filename == "schema.json" || filename.starts_with('_') {
521                continue;
522            }
523            let content = std::fs::read_to_string(&path)
524                .with_context(|| format!("failed to read fixture: {}", path.display()))?;
525            let relative = path.strip_prefix(base).unwrap_or(&path).to_string_lossy().to_string();
526
527            // Try parsing as array first, then as single fixture
528            let parsed: Vec<Fixture> = if content.trim_start().starts_with('[') {
529                serde_json::from_str(&content)
530                    .with_context(|| format!("failed to parse fixture array: {}", path.display()))?
531            } else {
532                let single: Fixture = serde_json::from_str(&content)
533                    .with_context(|| format!("failed to parse fixture: {}", path.display()))?;
534                vec![single]
535            };
536
537            for mut fixture in parsed {
538                fixture.source = relative.clone();
539                // Expand template expressions (e.g. `{{ repeat 'x' 10000 times }}`)
540                // in all JSON string values so generators emit the expanded values.
541                expand_json_templates(&mut fixture.input);
542                if let Some(ref mut http) = fixture.http {
543                    for (_, v) in http.request.headers.iter_mut() {
544                        *v = crate::escape::expand_fixture_templates(v);
545                    }
546                    if let Some(ref mut body) = http.request.body {
547                        expand_json_templates(body);
548                    }
549                }
550                fixtures.push(fixture);
551            }
552        }
553    }
554    Ok(())
555}
556
557/// Group fixtures by their resolved category.
558pub fn group_fixtures(fixtures: &[Fixture]) -> Vec<FixtureGroup> {
559    let mut groups: HashMap<String, Vec<Fixture>> = HashMap::new();
560    for f in fixtures {
561        groups.entry(f.resolved_category()).or_default().push(f.clone());
562    }
563    let mut result: Vec<FixtureGroup> = groups
564        .into_iter()
565        .map(|(category, fixtures)| FixtureGroup { category, fixtures })
566        .collect();
567    result.sort_by(|a, b| a.category.cmp(&b.category));
568    result
569}
570
571/// Recursively expand fixture template expressions in all string values of a JSON tree.
572fn expand_json_templates(value: &mut serde_json::Value) {
573    match value {
574        serde_json::Value::String(s) => {
575            let expanded = crate::escape::expand_fixture_templates(s);
576            if expanded != *s {
577                *s = expanded;
578            }
579        }
580        serde_json::Value::Array(arr) => {
581            for item in arr {
582                expand_json_templates(item);
583            }
584        }
585        serde_json::Value::Object(map) => {
586            for (_, v) in map.iter_mut() {
587                expand_json_templates(v);
588            }
589        }
590        _ => {}
591    }
592}
593
594#[cfg(test)]
595mod tests {
596    use super::*;
597
598    #[test]
599    fn test_fixture_with_mock_response() {
600        let json = r#"{
601            "id": "test_chat",
602            "description": "Test chat",
603            "call": "chat",
604            "input": {"model": "gpt-4", "messages": [{"role": "user", "content": "hi"}]},
605            "mock_response": {
606                "status": 200,
607                "body": {"choices": [{"message": {"content": "hello"}}]}
608            },
609            "assertions": [{"type": "not_error"}]
610        }"#;
611        let fixture: Fixture = serde_json::from_str(json).unwrap();
612        assert!(fixture.needs_mock_server());
613        assert!(!fixture.is_streaming_mock());
614        assert_eq!(fixture.mock_response.unwrap().status, 200);
615    }
616
617    #[test]
618    fn test_fixture_with_streaming_mock_response() {
619        let json = r#"{
620            "id": "test_stream",
621            "description": "Test streaming",
622            "input": {},
623            "mock_response": {
624                "status": 200,
625                "stream_chunks": [{"delta": "hello"}, {"delta": " world"}]
626            },
627            "assertions": []
628        }"#;
629        let fixture: Fixture = serde_json::from_str(json).unwrap();
630        assert!(fixture.needs_mock_server());
631        assert!(fixture.is_streaming_mock());
632    }
633
634    #[test]
635    fn test_fixture_without_mock_response() {
636        let json = r#"{
637            "id": "test_no_mock",
638            "description": "No mock",
639            "input": {},
640            "assertions": []
641        }"#;
642        let fixture: Fixture = serde_json::from_str(json).unwrap();
643        assert!(!fixture.needs_mock_server());
644        assert!(!fixture.is_streaming_mock());
645    }
646
647    #[test]
648    fn has_host_root_route_true_for_robots_path() {
649        let json = r#"{
650            "id": "robots_disallow_path",
651            "description": "Robots fixture",
652            "input": {
653                "mock_responses": [
654                    {"path": "/robots.txt", "status_code": 200, "body_inline": "User-agent: *\nDisallow: /"},
655                    {"path": "/", "status_code": 200, "body_inline": "<html/>"}
656                ]
657            },
658            "assertions": []
659        }"#;
660        let fixture: Fixture = serde_json::from_str(json).unwrap();
661        assert!(fixture.has_host_root_route(), "expected true for /robots.txt path");
662    }
663
664    #[test]
665    fn has_host_root_route_true_for_sitemap_path() {
666        let json = r#"{
667            "id": "sitemap_index",
668            "description": "Sitemap fixture",
669            "input": {
670                "mock_responses": [
671                    {"path": "/sitemap.xml", "status_code": 200, "body_inline": "<?xml version='1.0'?>"},
672                    {"path": "/", "status_code": 200, "body_inline": "<html/>"}
673                ]
674            },
675            "assertions": []
676        }"#;
677        let fixture: Fixture = serde_json::from_str(json).unwrap();
678        assert!(fixture.has_host_root_route(), "expected true for /sitemap.xml path");
679    }
680
681    #[test]
682    fn has_host_root_route_false_for_data_json_path() {
683        let json = r#"{
684            "id": "data_endpoint",
685            "description": "Non-host-root fixture",
686            "input": {
687                "mock_responses": [
688                    {"path": "/data.json", "status_code": 200, "body_inline": "{}"}
689                ]
690            },
691            "assertions": []
692        }"#;
693        let fixture: Fixture = serde_json::from_str(json).unwrap();
694        assert!(!fixture.has_host_root_route(), "expected false for /data.json path");
695    }
696
697    #[test]
698    fn has_host_root_route_false_for_single_mock_response_schema() {
699        // Single mock_response schema (no input.mock_responses array) is never host-root.
700        let json = r#"{
701            "id": "basic_chat",
702            "description": "Basic chat",
703            "mock_response": {"status": 200, "body": {}},
704            "input": {},
705            "assertions": []
706        }"#;
707        let fixture: Fixture = serde_json::from_str(json).unwrap();
708        assert!(
709            !fixture.has_host_root_route(),
710            "expected false for single mock_response schema"
711        );
712    }
713
714    #[test]
715    fn has_host_root_route_false_for_empty_mock_responses() {
716        let json = r#"{
717            "id": "empty_responses",
718            "description": "No mock_responses",
719            "input": {},
720            "assertions": []
721        }"#;
722        let fixture: Fixture = serde_json::from_str(json).unwrap();
723        assert!(!fixture.has_host_root_route(), "expected false when no mock_responses");
724    }
725}