fix(render): address #49 review: contents budget, case-insensitive sources, non-Exa snippet bound

crates/tinysearch-bus/src/render/mod.rs

@@ -117,6 +117,44 @@ fn result_images(response: &ExecuteToolResponse) -> Vec<Option<&str>> {
         .collect()
 }
 
+/// A URL as compared for repeats: the scheme and host of an HTTP(S) URL are
+/// case-insensitive, the rest (including any userinfo) is not.
+fn url_key(url: &str) -> String {
+    let url = url.trim();
+    let Some(split) = url.find("://") else {
+        return url.to_string();
+    };
+    let (scheme, rest) = url.split_at(split);
+    if !scheme.eq_ignore_ascii_case("http") && !scheme.eq_ignore_ascii_case("https") {
+        return url.to_string();
+    }
+    let rest = &rest[3..];
+    let end = rest.find(['/', '?', '#']).unwrap_or(rest.len());
+    let (authority, tail) = rest.split_at(end);
+    let (userinfo, host) = match authority.rfind('@') {
+        Some(at) => authority.split_at(at + 1),
+        None => ("", authority),
+    };
+    format!(
+        "{}://{userinfo}{}{tail}",
+        scheme.to_ascii_lowercase(),
+        host.to_ascii_lowercase()
+    )
+}
+
+/// The answer text to print. A page-contents response may carry the first
+/// page as its answer as well as in its result snippet; under non-default
+/// options that copy would bypass the per-page budget, so it is left out when
+/// the page is listed. Answer-role responses are never touched, and the
+/// default options keep the original output.
+fn answer_text<'a>(response: &'a ExecuteToolResponse, options: &RenderOptions) -> Option<&'a str> {
+    let answer = non_empty(response.answer.as_deref())?;
+    let duplicates_page = response.role == Some(Role::Contents)
+        && !response.results.is_empty()
+        && *options != RenderOptions::default();
+    (!duplicates_page).then_some(answer)
+}
+
 /// The citations to list under `Sources`, with their 1-based numbers.
 ///
 /// All of them unless `options.compact_sources` is set; then only those that
@@ -134,14 +172,14 @@ fn sources<'a>(
     if !options.compact_sources {
         return numbered.collect();
     }
-    let shown: HashSet<&str> = response
+    let shown: HashSet<String> = response
         .results
         .iter()
         .take(max_results)
-        .map(|result| result.url.trim())
+        .map(|result| url_key(&result.url))
         .collect();
     numbered
-        .filter(|(_, citation)| !shown.contains(citation.url.trim()))
+        .filter(|(_, citation)| !shown.contains(&url_key(&citation.url)))
         .take(max_results)
         .collect()
 }
@@ -162,7 +200,7 @@ pub fn render_text_with(
 ) -> String {
     let excerpt_chars = options.excerpt_for(response.role);
     let mut lines = vec![heading(response, subject)];
-    if let Some(answer) = non_empty(response.answer.as_deref()) {
+    if let Some(answer) = answer_text(response, options) {
         lines.push(String::new());
         lines.push(answer.to_string());
     }
@@ -219,7 +257,7 @@ pub fn render_markdown_with(
 ) -> String {
     let excerpt_chars = options.excerpt_for(response.role);
     let mut out = format!("# {}\n", heading(response, subject));
-    if let Some(answer) = non_empty(response.answer.as_deref()) {
+    if let Some(answer) = answer_text(response, options) {
         let _ = write!(out, "\n{answer}\n");
     }
     let images = result_images(response);

crates/tinysearch-bus/src/render/mod_tests.rs

@@ -287,6 +287,69 @@ fn contents_pages_are_bounded_by_the_contents_cap() {
     assert!(!text.contains(&"y".repeat(201)));
 }
 
+#[test]
+fn compact_matches_repeated_sources_by_case_insensitive_host_only() {
+    let mut r = listed(1);
+    r.results[0].url = "https://Example.COM/Path".into();
+    r.citations = vec![
+        Citation {
+            url: "HTTPS://example.com/Path".into(),
+            title: None,
+        },
+        Citation {
+            url: "https://example.com/path".into(),
+            title: None,
+        },
+    ];
+    let text = render_text_with(&r, "q", 5, &RenderOptions::compact());
+    assert!(!text.contains("[1]"));
+    assert!(text.contains("[2] https://example.com/path"));
+}
+
+#[test]
+fn compact_keeps_a_citation_whose_userinfo_differs_only_in_case() {
+    let mut r = listed(1);
+    r.results[0].url = "https://reader:TokenA@Example.com/Path".into();
+    r.citations = vec![
+        Citation {
+            url: "https://reader:TokenA@example.com/Path".into(),
+            title: None,
+        },
+        Citation {
+            url: "https://reader:Tokena@example.com/Path".into(),
+            title: None,
+        },
+    ];
+    let text = render_text_with(&r, "q", 5, &RenderOptions::compact());
+    assert!(!text.contains("[1]"));
+    assert!(text.contains("[2] https://reader:Tokena@example.com/Path"));
+}
+
+#[test]
+fn contents_answer_copy_of_the_page_is_left_out_under_a_budget_only() {
+    let mut page = response(Some(Role::Contents));
+    page.provider = "tinyfish".into();
+    page.results[0].snippet = Some("y".repeat(4000));
+    page.answer = Some("y".repeat(4000));
+    let narrow = RenderOptions {
+        contents_chars: 200,
+        ..RenderOptions::default()
+    };
+    for out in [
+        render_text_with(&page, "u", 5, &narrow),
+        render_markdown_with(&page, "u", 5, &narrow),
+    ] {
+        assert!(!out.contains(&"y".repeat(201)));
+    }
+    // Default output is unchanged.
+    assert!(render_text(&page, "u", 5).contains(&"y".repeat(4000)));
+    // Answer-role responses are never trimmed.
+    let mut answer = answer_fixture();
+    answer.answer = Some("a".repeat(4000));
+    let out = render_text_with(&answer, "q", 5, &RenderOptions::compact());
+    assert!(out.contains(&"a".repeat(4000)));
+}
+
 #[test]
 fn the_default_contents_cap_matches_todays_output() {
     let mut page = response(Some(Role::Contents));

crates/tinysearch/src/provider/mod_tests.rs

@@ -1241,6 +1241,21 @@ fn contents_snippets_keep_the_page_cap_but_search_snippets_stay_bounded() {
     );
 }
 
+#[test]
+fn non_exa_contents_snippets_keep_the_search_snippet_bound() {
+    let value = json!({"results":[{"url":"https://a","text":"z".repeat(3000)}]});
+    for (provider, tool) in [("keenable", "keenable_fetch"), ("tavily", "tavily_extract")] {
+        let page = normalize(provider, tool, &value);
+        assert_eq!(
+            page.results[0]
+                .snippet
+                .as_deref()
+                .map(|s| s.chars().count()),
+            Some(1200)
+        );
+    }
+}
+
 #[tokio::test]
 async fn brave_direct_operations_map_and_normalize() -> TestResult<()> {
     for (tool, path, payload) in [

crates/tinysearch/src/provider/normalize.rs

@@ -212,12 +212,15 @@ fn add_grounding_citations(citations: &mut Vec<Citation>, value: &Value) {
 pub(super) fn normalize(provider: &str, tool: &str, value: &Value) -> ExecuteToolResponse {
     let mut results = Vec::new();
     let mut citations = Vec::new();
-    // A page-contents tool keeps up to a page's worth of text per result.
-    let snippet_chars = if role_provider_tool(Role::Contents, provider) == Some(tool) {
-        MAX_PAGE_CHARS
-    } else {
-        MAX_SNIPPET_CHARS
-    };
+    // Only Exa honours a per-page bound upstream (`contents_max_chars`), so
+    // only its contents tool keeps a page's worth of text per result; every
+    // other tool keeps today's snippet bound.
+    let snippet_chars =
+        if provider == "exa" && role_provider_tool(Role::Contents, provider) == Some(tool) {
+            MAX_PAGE_CHARS
+        } else {
+            MAX_SNIPPET_CHARS
+        };
     if let Some(items) = value.get("results").and_then(Value::as_array) {
         for item in items {
             add_result(&mut results, item, snippet_chars);