mindfork 0.10.1

//! `fetch_url` tool (spec §9.3): fetch a web page and summarize it.
//!
//! Under the global switch `tools.web_enabled` (network access/privacy, like
//! `web_search`). Steps: fetch the page via its own `reqwest` client →
//! extract readable text (`web::extract_rich` — **headings and code blocks
//! included**, unlike the prose-only extraction `web_search` uses for ranking)
//! → summarize via `ctx.engine` (an independent single-turn request, like
//! `call_subagent`). With `summarize=false`, the extracted text is returned
//! without calling the model (the fast path).
//!
//! A page too big for one result **is attached to the chat** (spec §9.7) instead
//! of being silently cut: an attachment is already paged (`attachment_read`) and
//! searchable (`attachment_search`), so nothing is lost and the model can reach
//! all of it. The threshold is the attachment budget itself, exactly as
//! `youtube_watch(transcript:)` uses it. See
//! docs/history/fetch-url-fidelity.md (forks F1a/F2b).

use std::time::Duration;

use anyhow::Result;
use futures_util::StreamExt;
use tokio_util::sync::CancellationToken;

use crate::entities::attachment::{Attachment, decide_mode, inline_tokens_excluding};
use crate::entities::profile::ToolId;
use crate::entities::sampling::SamplingConfig;
use crate::shared::api::contract::Prefill;
use crate::shared::api::{ApiMessage, ChatChunk, ChatRequest};
use crate::shared::http_text::MAX_INFLATED_MB;
use crate::shared::net::{self, AddressPolicy, GuardedClient};

use super::web::{ACCEPT_HTML, ACCEPT_LANGUAGE, USER_AGENT, extract_rich, truncate_chars};
use super::{ChatEffect, Tool, ToolContext, ToolOutcome};

/// Page-fetch timeout.
const REQUEST_TIMEOUT: Duration = Duration::from_secs(20);
/// Hard ceiling on the extracted text of one page (characters) — a bound on what
/// a single page may put into a chat. Far above the attachment budget: beyond
/// that budget the text is attached rather than cut, so this only fires on a
/// genuinely enormous page, and when it does the result **says so** (unlike the
/// silent 12 000-character cut this replaced — see the plan doc, P2).
const MAX_EXTRACT_CHARS: usize = 400_000;
/// How much of the text goes into the summarizer: it is a single-turn subagent
/// with its own context, so a 250 000-character page cannot be handed over
/// whole. When the page exceeds this the summary covers its head, and the full
/// text travels as the attachment.
const SUMMARY_INPUT_CHARS: usize = 12_000;
/// Ceiling on the page title used as the attachment's display name.
const NAME_TITLE_CHARS: usize = 60;
/// Token limit for the summary reply.
const SUMMARY_MAX_TOKENS: usize = 768;
/// Summarization timeout (a model call).
const SUMMARY_TIMEOUT: Duration = Duration::from_secs(90);

/// `fetch_url` — fetch a page and (by default) summarize it.
pub struct FetchUrl {
    /// Which addresses this tool may reach is the client's business, not the tool's: the
    /// model picks the URL, and the default refuses local and private ones (`shared::net`,
    /// docs/research/fetch-url-address-policy.md).
    http: GuardedClient,
}

impl Default for FetchUrl {
    fn default() -> Self {
        Self::new(AddressPolicy::PublicOnly)
    }
}

impl FetchUrl {
    pub fn new(policy: AddressPolicy) -> Self {
        Self {
            http: GuardedClient::new(policy, REQUEST_TIMEOUT),
        }
    }

    /// Fetches the page and extracts readable text. An error → a clear message
    /// (in the scaffold language `loc` — goes to the model in the `fetch_url` result).
    async fn fetch_text(&self, url: &str, loc: &crate::shared::i18n::Locale) -> Result<PageText> {
        let resp = self
            .http
            .get(url)
            // A blocked literal is refused here, before a request exists.
            .map_err(|_| anyhow::anyhow!(loc.t("tool.fetch_url.err.address_blocked").to_string()))?
            .header(reqwest::header::USER_AGENT, USER_AGENT)
            .header(reqwest::header::ACCEPT, ACCEPT_HTML)
            .header(reqwest::header::ACCEPT_LANGUAGE, ACCEPT_LANGUAGE)
            .send()
            .await
            .map_err(|e| {
                // A refusal by the address policy is not a network failure, and must not
                // read as one: "the site is down" invites a retry, and this one can only
                // fail again (lessons §4).
                if net::was_blocked(&e) {
                    anyhow::anyhow!(loc.t("tool.fetch_url.err.address_blocked").to_string())
                } else {
                    anyhow::Error::new(e)
                        .context(loc.tf("tool.fetch_url.err.request", &[("url", url)]))
                }
            })?;
        let status = resp.status();
        if !status.is_success() {
            anyhow::bail!(loc.tf(
                "tool.fetch_url.err.status",
                &[("status", &status.to_string())]
            ));
        }
        // Not `resp.text()`: that reads the bytes as UTF-8 whatever the page declares, and
        // a windows-1251 page came back as U+FFFD (docs/research/page-charset.md §1).
        let body =
            crate::shared::http_text::read(resp)
                .await
                .map_err(|err| match err.coding() {
                    _ if err.too_large() => anyhow::anyhow!(loc.tf(
                        "tool.fetch_url.err.too_large",
                        &[("max", &format!("{} MB", MAX_INFLATED_MB))]
                    )),
                    Some(coding) => {
                        anyhow::anyhow!(
                            loc.tf("tool.fetch_url.err.compressed", &[("coding", coding)])
                        )
                    }
                    None => anyhow::Error::new(err)
                        .context(loc.tf("tool.fetch_url.err.read", &[("url", url)])),
                })?;
        tracing::debug!(
            url,
            encoding = body.encoding.name(),
            source = ?body.source,
            "fetch_url: the page's encoding"
        );
        body_to_text(&body.content_type, &body.text)
            .ok_or_else(|| anyhow::anyhow!(loc.t("tool.fetch_url.err.no_text").to_string()))
    }
}

/// The page's extracted text plus what the caller has to be honest about.
pub(crate) struct PageText {
    pub text: String,
    /// The text hit [`MAX_EXTRACT_CHARS`] — this is not the whole page.
    pub truncated: bool,
    /// The page's name, when it states one ([`page_name`]) — the attachment's display name.
    pub title: Option<String>,
}

/// Picks the text to return from the response body. Non-HTML **text** responses
/// (JSON/text/csv/JS — detected by `Content-Type`, or by the body's JSON shape
/// when it's absent) are returned as-is: this is API data, readability
/// doesn't apply to it (no `<p>`/`<li>`) — this is exactly why the JSON Steam API used to
/// give "failed to extract readable text". HTML → rich extraction
/// (`web::extract_rich`: prose **plus headings and code blocks**).
/// `None` — nothing to extract (empty). A pure function — testable without a network.
fn body_to_text(content_type: &str, body: &str) -> Option<PageText> {
    let ct = content_type.to_ascii_lowercase();
    let is_html = ct.contains("html") || ct.contains("xml");
    let is_texty = ct.contains("json")
        || ct.contains("text/plain")
        || ct.contains("javascript")
        || ct.contains("csv");
    let looks_json = {
        let t = body.trim_start();
        t.starts_with('{') || t.starts_with('[')
    };
    if is_texty || (looks_json && !is_html) {
        let trimmed = body.trim();
        if !trimmed.is_empty() {
            return Some(PageText {
                text: truncate_chars(trimmed, MAX_EXTRACT_CHARS),
                truncated: trimmed.chars().count() > MAX_EXTRACT_CHARS,
                title: None,
            });
        }
    }
    let text = extract_rich(body, MAX_EXTRACT_CHARS);
    (!text.is_empty()).then(|| PageText {
        truncated: text.chars().count() >= MAX_EXTRACT_CHARS,
        text,
        title: page_name(body),
    })
}

/// The page's name for the attachment: the name a second field confirms
/// (docs/research/page-attachment-name.md §4). A page states its name in up to three
/// places — `og:title`, an `<h1>`, the `<title>` — and its site's name in some of the
/// same ones: `docs.vlang.io` gives every page one `<title>` ("V Documentation"),
/// `sector.biz.ua` every article one `<h1>` (the archive's banner). Taking either field
/// first names every page of one of them after the site — measured, six sites of 43
/// under the `<h1>`-first rule this replaces.
fn page_name(body: &str) -> Option<String> {
    let doc = scraper::Html::parse_document(body);
    let fields = NameFields::read(&doc);
    let clipped: String = fields.name()?.chars().take(NAME_TITLE_CHARS).collect();
    let name = clipped.trim();
    (!name.is_empty()).then(|| name.to_string())
}

/// What a page says about its own name, each field as [`clean_field`] leaves it.
struct NameFields {
    title: String,
    h1s: Vec<String>,
    og_title: Option<String>,
    og_site_name: Option<String>,
}

impl NameFields {
    fn read(doc: &scraper::Html) -> Self {
        let texts = |selector: &str| -> Vec<String> {
            scraper::Selector::parse(selector)
                .map(|sel| {
                    doc.select(&sel)
                        .map(|e| clean_field(&e.text().collect::<String>()))
                        .filter(|t| !t.is_empty())
                        .collect()
                })
                .unwrap_or_default()
        };
        let meta = |property: &str| -> Option<String> {
            let sel = scraper::Selector::parse(&format!(r#"meta[property="{property}"]"#)).ok()?;
            doc.select(&sel)
                .find_map(|e| e.value().attr("content"))
                .map(clean_field)
                .filter(|c| !c.is_empty())
        };
        Self {
            title: texts("title").into_iter().next().unwrap_or_default(),
            h1s: texts("h1"),
            og_title: meta("og:title"),
            og_site_name: meta("og:site_name"),
        }
    }

    /// First match wins:
    /// 1. `og:title`, unless it is the site's own name — without a trailing segment it
    ///    shares with the `<title>` ("Moon - Wikipedia" → "Moon");
    /// 2. an `<h1>` the `<title>` begins with, as the `<title>` spells it — any `<h1>`, a
    ///    blog's banner often being the first;
    /// 3. the `<title>` without its last segment, which is where a title puts its site;
    /// 4. the first `<h1>` — a `<title>` that is the site's name alone;
    /// 5. the `<title>`.
    fn name(&self) -> Option<&str> {
        let title = self.title.as_str();
        let site = split_last_segment(title).map(|(_, site)| site);
        let is_site = |text: &str| {
            site.is_some_and(|site| same_text(text, site))
                || self
                    .og_site_name
                    .as_deref()
                    .is_some_and(|name| same_text(text, name))
        };
        if let Some(og) = self.og_title.as_deref().filter(|og| !is_site(og)) {
            return Some(match split_last_segment(og) {
                Some((head, tail)) if site.is_some_and(|site| same_text(tail, site)) => head,
                _ => og,
            });
        }
        if let Some(head) = self.h1s.iter().find_map(|h1| title_begins_with(title, h1)) {
            return Some(head);
        }
        split_last_segment(title)
            .map(|(head, _)| head)
            .or_else(|| self.h1s.first().map(String::as_str))
            .or_else(|| (!title.is_empty()).then_some(title))
    }
}

/// The spaced separators a `<title>` puts between a page and its site — every one the
/// research corpus uses (§2).
const TITLE_SEPARATORS: [&str; 10] = [
    " | ", " — ", " – ", " - ", " -> ", " :: ", " · ", " » ", " / ", " : ",
];

/// `text` split at its last spaced separator: everything before it — a page's own name
/// may hold a separator ("json — JSON encoder and decoder") — and the last segment.
fn split_last_segment(text: &str) -> Option<(&str, &str)> {
    let (at, len) = TITLE_SEPARATORS
        .iter()
        .filter_map(|sep| text.rfind(sep).map(|at| (at, sep.len())))
        .max_by_key(|&(at, _)| at)?;
    let head = text[..at].trim();
    (!head.is_empty()).then(|| (head, text[at + len..].trim()))
}

/// The start of `title` that reads as `h1` ignoring case, spelled as `title` spells it —
/// and only at a word's end, so an `<h1>` "Go" does not name "Google Search".
fn title_begins_with<'a>(title: &'a str, h1: &str) -> Option<&'a str> {
    let n = h1.chars().count();
    let end = title
        .char_indices()
        .nth(n)
        .map_or(title.len(), |(at, _)| at);
    let head = &title[..end];
    let word_ends = title[end..]
        .chars()
        .next()
        .is_none_or(|c| !c.is_alphanumeric());
    (n > 0 && word_ends && head.chars().count() == n && same_text(head, h1)).then_some(head)
}

fn same_text(a: &str, b: &str) -> bool {
    a.to_lowercase() == b.to_lowercase()
}

/// Whitespace collapsed, and a heading's permalink mark trimmed from its ends — Sphinx's
/// `¶`, the zero-width space VitePress anchors with — so a field compares as it reads.
fn clean_field(raw: &str) -> String {
    let collapsed = raw.split_whitespace().collect::<Vec<_>>().join(" ");
    collapsed
        .trim_matches(|c: char| {
            c.is_whitespace()
                || c == '¶'
                || matches!(c, '\u{200b}'..='\u{200d}' | '\u{2060}' | '\u{feff}')
        })
        .to_string()
}

/// Keeps the display name unique within the chat: a page whose every field names
/// its site would still collide (docs/research/page-attachment-name.md §5), so a
/// name already taken by a **different** page gets the URL's last segment appended. Deterministic (no
/// counters), so re-fetching the same page produces the same name and replaces
/// its own attachment rather than piling up copies.
fn unique_name(base: &str, url: &str, existing: &[Attachment]) -> String {
    let taken = existing
        .iter()
        .any(|a| a.name.eq_ignore_ascii_case(base) && !a.source.eq_ignore_ascii_case(url));
    match taken.then(|| url_segment(url)).flatten() {
        Some(seg) => format!("{base} — {seg}"),
        None => base.to_string(),
    }
}

/// The URL's last non-empty path segment, else its host — the shortest thing
/// that still tells two pages of one site apart.
fn url_segment(url: &str) -> Option<String> {
    let without_scheme = url.split_once("://").map(|(_, r)| r).unwrap_or(url);
    let path = without_scheme.split(['?', '#']).next().unwrap_or("");
    let mut parts = path.split('/').filter(|s| !s.is_empty());
    let host = parts.next()?;
    Some(parts.next_back().unwrap_or(host).to_string())
}

#[async_trait::async_trait]
impl Tool for FetchUrl {
    fn id(&self) -> ToolId {
        super::FETCH_URL_ID.into()
    }
    /// A page fetch changes nothing and holds nothing: three pages from three
    /// hosts are three unrelated connections — the largest win a concurrent
    /// round has (docs/research/concurrent-tools.md §2.3). The summary request
    /// it may make takes a session permit of its own (§4.5).
    fn concurrent(&self) -> bool {
        true
    }
    fn group(&self) -> crate::features::tools::meta::ToolGroup {
        crate::features::tools::meta::ToolGroup::ExternalWorld
    }
    fn ui_label(&self) -> &'static str {
        "fetch page"
    }
    fn gate(&self) -> Option<crate::features::tools::meta::ToolGate> {
        Some(crate::features::tools::meta::ToolGate::Web)
    }
    fn description(&self, loc: &crate::shared::i18n::Locale) -> String {
        loc.t("tool.fetch_url.desc").into()
    }
    fn parameters(&self, loc: &crate::shared::i18n::Locale) -> serde_json::Value {
        serde_json::json!({
            "type": "object",
            "properties": {
                "url": {"type": "string", "description": loc.t("tool.fetch_url.param.url")},
                "focus": {
                    "type": "string",
                    "description": loc.t("tool.fetch_url.param.focus")
                },
                "summarize": {
                    "type": "boolean",
                    "description": loc.t("tool.fetch_url.param.summarize")
                }
            },
            "required": ["url"]
        })
    }
    async fn invoke(&self, ctx: &ToolContext, args: serde_json::Value) -> Result<ToolOutcome> {
        let url = args
            .get("url")
            .and_then(|v| v.as_str())
            .map(str::trim)
            .filter(|s| !s.is_empty())
            .ok_or_else(|| anyhow::anyhow!(ctx.loc.t("tool.fetch_url.err.url_empty")))?;
        if !(url.starts_with("http://") || url.starts_with("https://")) {
            anyhow::bail!(ctx.loc.t("tool.fetch_url.err.url_scheme"));
        }
        // A YouTube watch page is a JavaScript shell: measured, it has zero
        // paragraphs and zero list items, so readability extracts nothing and
        // this used to answer "failed to extract readable text" — a dead end the
        // model cannot reason its way out of. Hand back what the free paths know
        // and point at the tool that can actually watch it (fork R6,
        // docs/research/youtube-integration.md §1).
        if super::youtube::is_youtube_url(url)
            && let Some(id) = super::youtube::video_id(url)
        {
            let meta = super::youtube::fetch_meta(self.http.unchecked_inner(), &id)
                .await
                .unwrap_or_default();
            let mut out = super::youtube::YoutubeWatch::meta_block(
                &meta,
                &super::youtube::watch_url(&id),
                ctx.loc,
            );
            out.push('\n');
            out.push_str(ctx.loc.t("tool.fetch_url.result.youtube"));
            return Ok(ToolOutcome::text(out));
        }
        let focus = args
            .get("focus")
            .and_then(|v| v.as_str())
            .map(str::trim)
            .filter(|s| !s.is_empty());
        let summarize = args
            .get("summarize")
            .and_then(|v| v.as_bool())
            .unwrap_or(true);

        let page = match self.fetch_text(url, ctx.loc).await {
            Ok(t) => t,
            Err(err) => {
                return Ok(ToolOutcome::text(ctx.loc.tf(
                    "tool.fetch_url.result.fetch_failed",
                    &[("url", url), ("err", &err.to_string())],
                )));
            }
        };

        // Small enough to read at once → straight into the result: the model
        // needs no second call, and attaching would put the same text in the
        // pinned block *and* in the history. The threshold is the attachment
        // budget itself (sub-decision S1), which is also why an attached page is
        // always by reference: inline requires `est <= max_file_tokens`, and this
        // branch is exactly the other side of it.
        let est = crate::shared::tokens::estimate_text(&page.text) as usize;
        if est <= ctx.attachment_cfg.max_file_tokens {
            return Ok(self.inline_result(ctx, url, focus, summarize, &page).await);
        }
        Ok(self.attached_result(ctx, url, focus, summarize, page).await)
    }
}

impl FetchUrl {
    /// The page fits the budget: previous behaviour — a summary, or the text
    /// itself when `summarize=false` (or when summarization failed).
    async fn inline_result(
        &self,
        ctx: &ToolContext,
        url: &str,
        focus: Option<&str>,
        summarize: bool,
        page: &PageText,
    ) -> ToolOutcome {
        let summary = if summarize {
            summarize_text(ctx, url, focus, &page.text).await.ok()
        } else {
            None
        };
        // The engine's timing of the summary's prompt rides the outcome
        // whatever the text made of it (page-summary-usage §3.2).
        let prefill = summary.as_ref().and_then(|s| s.prefill);
        let mut out = match (summarize, summary) {
            (true, Some(s)) if !s.text.trim().is_empty() => s.text,
            // Summarization failed/came back empty → return the extracted text
            // (graceful degradation: the model still gets the page's content).
            (true, _) => format!(
                "{}\n{}",
                ctx.loc
                    .tf("tool.fetch_url.result.content_no_summary", &[("url", url)]),
                page.text
            ),
            (false, _) => format!(
                "{}\n{}",
                ctx.loc.tf("tool.fetch_url.result.content", &[("url", url)]),
                page.text
            ),
        };
        if page.truncated {
            out.push('\n');
            out.push_str(ctx.loc.t("tool.fetch_url.result.truncated"));
        }
        ToolOutcome::text(out).with_prefill(prefill)
    }

    /// The page is over the attachment budget: attach it whole (spec §9.7) and
    /// return a summary of its head plus how to reach the rest. The alternative —
    /// cutting the text into the result — is what made a long documentation page
    /// indistinguishable from a complete one (the plan doc, P2).
    async fn attached_result(
        &self,
        ctx: &ToolContext,
        url: &str,
        focus: Option<&str>,
        summarize: bool,
        page: PageText,
    ) -> ToolOutcome {
        let base = page.title.clone().unwrap_or_else(|| url.to_string());
        let name = unique_name(&base, url, &ctx.attachments);
        let header = ctx.loc.tf(
            "tool.fetch_url.attachment.header",
            &[("name", &name), ("url", url)],
        );
        let text = format!("{header}\n\n{}", page.text);
        // Through the shared rule rather than hardcoding `ByReference`: that is a
        // *consequence* of the threshold above, and the orchestrator decides
        // `/file attach` the same way, so the two cannot drift.
        let used = inline_tokens_excluding(&ctx.attachments, url);
        let est = crate::shared::tokens::estimate_text(&text) as usize;
        let mode = decide_mode(est, used, &ctx.attachment_cfg);
        let bytes = text.len();
        let attachment = Attachment::new(name.clone(), url.to_string(), text, bytes, mode);
        let pages = attachment.page_count(ctx.attachment_cfg.page_tokens);

        let mut out = String::new();
        let mut prefill = None;
        if summarize {
            // The head only: the summarizer is a single-turn subagent with its
            // own context. The result says the whole page is attached, so a
            // partial summary is a starting point rather than the only access.
            let head = truncate_chars(&page.text, SUMMARY_INPUT_CHARS);
            if let Ok(s) = summarize_text(ctx, url, focus, &head).await {
                prefill = s.prefill;
                if !s.text.trim().is_empty() {
                    out.push_str(s.text.trim());
                    out.push('\n');
                }
            }
        }
        out.push_str(&ctx.loc.tf(
            "tool.fetch_url.result.attached",
            &[("name", &name), ("pages", &pages.to_string())],
        ));
        if page.truncated {
            out.push('\n');
            out.push_str(ctx.loc.t("tool.fetch_url.result.truncated"));
        }
        ToolOutcome::with_effects(out, vec![ChatEffect::AddAttachment(Box::new(attachment))])
            .with_prefill(prefill)
    }
}

/// What a summary's stream left: the text, and the engine's timing of the
/// prompt (`None` from every provider but llama.cpp, and from a stream that
/// ended before its usage chunk).
struct Summarized {
    text: String,
    prefill: Option<Prefill>,
}

/// Summarizes the page text via an independent single-turn request to the model
/// (like `call_subagent`: no history/tools, with a token/time limit).
async fn summarize_text(
    ctx: &ToolContext,
    url: &str,
    focus: Option<&str>,
    text: &str,
) -> Result<Summarized> {
    let system = ctx.loc.t("tool.fetch_url.summarize.system").to_string();
    let task = match focus {
        Some(f) => ctx.loc.tf(
            "tool.fetch_url.summarize.task_focus",
            &[("url", url), ("f", f), ("text", text)],
        ),
        None => ctx.loc.tf(
            "tool.fetch_url.summarize.task",
            &[("url", url), ("text", text)],
        ),
    };

    let max_tokens = ctx
        .effective_sampling
        .max_tokens
        .map_or(SUMMARY_MAX_TOKENS, |m| m.min(SUMMARY_MAX_TOKENS));
    // What the stream will occupy of a shared KV pool: the request's estimate
    // (no earlier round of its own to floor it) plus its reply cap
    // (docs/research/admission-by-budget.md §4.2).
    let estimate = crate::shared::tokens::estimate_prompt(Some(&system), [task.as_str()]);
    // Reasoning muted the way the title's and the roll's is (`title.rs`): a
    // one-shot retelling of a page, whose reply cap a thinking model spent
    // whole on thoughts and answered with nothing — both pages tried on the
    // gate model, `finish = Length` (docs/research/page-summary-usage.md
    // §2.1, fork F3).
    let sampling = SamplingConfig {
        max_tokens: Some(max_tokens),
        reasoning_budget: Some(0),
        ..ctx.effective_sampling.clone()
    };
    let request = ChatRequest {
        continue_final: false,
        system: Some(system),
        messages: vec![ApiMessage::user(task)],
        sampling,
        tools: Vec::new(), // no tools (a nesting ban)
    };

    // A permit of the turn's session budget, held for the stream and for
    // nothing else (docs/research/concurrent-tools.md §4.5): the summary is a
    // request stream like the loops' own, so with `sessions = 1` three pages
    // fetched at once are summarised one after another — and under a shared
    // KV pool as many at once as the pool holds, not as many as the permits
    // allow (admission-by-budget §4.5). Taken before the timeout starts —
    // waiting behind a sibling's stream is not this summary's slowness. A
    // background task has no budget to take (`None`).
    let _permit = match ctx.sessions.as_deref() {
        Some(budget) => {
            let need = budget.price(
                crate::shared::session_budget::Shape::Summary,
                estimate,
                0,
                Some(max_tokens as u64),
            );
            // A silent loop's summary takes the silent lane: one of the
            // app's own requests at a time (silent-tasks-budget §4.2).
            let reservation = if ctx.silent_lane {
                // One tool call inside a round that already dropped its own
                // reservation: it holds (silent-preemption §4.3).
                budget
                    .acquire_silent(need, &ctx.cancel, "summary", false)
                    .await
            } else {
                budget.acquire(need, &ctx.cancel).await
            };
            match reservation {
                Some(reservation) => Some(reservation),
                None => anyhow::bail!(ctx.loc.t("tool.fetch_url.err.summary_cancelled")),
            }
        }
        None => None,
    };
    let cancel = CancellationToken::new();
    let engine = ctx.engine.clone();
    let collect = async {
        let mut stream = engine.chat_stream(request, cancel.clone()).await?;
        let mut out = String::new();
        let mut prefill = None;
        while let Some(chunk) = stream.next().await {
            match chunk {
                ChatChunk::Text(t) => out.push_str(&t),
                ChatChunk::Finished(_) => break,
                // A background turn: the retry is worth a log line (a flaky provider is
                // otherwise invisible here) but has nothing to show — these turns have no
                // chip of their own.
                ChatChunk::Retry {
                    attempt,
                    max,
                    delay,
                } => {
                    tracing::info!(attempt, max, ?delay, "retrying a a page-summary turn");
                }
                ChatChunk::Error { message, .. } => {
                    tracing::warn!(error = %message, "engine error while summarizing a page");
                }
                // The server's exact count beside the estimate the reservation
                // was priced from, under the summary's own kind — a page's
                // text under-counts on four pages of five, the one kind that
                // does as a rule (docs/research/page-summary-usage.md §3.1) —
                // and the engine's timing of the prompt for the outcome (§3.2).
                // Taken here: the collect breaks at `Finished`.
                ChatChunk::Usage(u) => {
                    if let Some(budget) = ctx.sessions.as_deref() {
                        budget.record_usage(
                            crate::shared::session_budget::Shape::Summary,
                            estimate,
                            u.prompt_tokens as u64,
                        );
                    }
                    prefill = u.prefill;
                }
                ChatChunk::Thoughts(_)
                | ChatChunk::ThoughtsSignature(_)
                | ChatChunk::ToolCall(_) => {}
            }
        }
        Ok::<Summarized, anyhow::Error>(Summarized { text: out, prefill })
    };

    match tokio::time::timeout(SUMMARY_TIMEOUT, collect).await {
        Ok(res) => res,
        Err(_) => {
            cancel.cancel();
            anyhow::bail!(ctx.loc.t("tool.fetch_url.err.summary_timeout"));
        }
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::shared::api::Embedder;
    use crate::shared::api::contract::{ChatStream, EngineBackend, FinishReason};
    use crate::shared::api::mock::{MockBackend, MockEmbedder};
    use std::sync::{Arc, Mutex};
    use uuid::Uuid;

    /// An engine that remembers the last request and returns a fixed reply.
    struct CapturingBackend {
        last: Mutex<Option<ChatRequest>>,
        reply: String,
    }

    #[async_trait::async_trait]
    impl EngineBackend for CapturingBackend {
        async fn chat_stream(
            &self,
            req: ChatRequest,
            _cancel: CancellationToken,
        ) -> Result<ChatStream> {
            *self.last.lock().unwrap() = Some(req);
            let reply = self.reply.clone();
            let s = async_stream::stream! {
                yield ChatChunk::Text(reply);
                yield ChatChunk::Finished(FinishReason::Stop);
            };
            Ok(Box::pin(s))
        }
    }

    fn ctx_with_engine(engine: Arc<dyn EngineBackend>) -> (tempfile::TempDir, ToolContext) {
        let embedder: Arc<dyn Embedder> = Arc::new(MockEmbedder::new(16));
        let (dir, _storage, ctx) =
            super::super::testkit::ctx_with_backends(Uuid::new_v4(), engine, embedder);
        (dir, ctx)
    }

    /// A page big enough to be over the attachment budget.
    fn big_page(title: Option<&str>) -> PageText {
        // Deliberately long enough that `estimate_text` clears
        // `max_file_tokens` (4000 by default) several times over.
        let body = "Абзац с содержательным текстом страницы. ".repeat(2000);
        PageText {
            text: format!("НАЧАЛО\n{body}\nКОНЕЦ"),
            truncated: false,
            title: title.map(str::to_string),
        }
    }

    /// The defect this closes (plan doc, P2): a long page used to be cut at
    /// 12 000 characters, mid-word, with nothing saying so and no way to reach
    /// the rest. Now it arrives whole as an attachment.
    #[tokio::test]
    async fn a_page_over_the_budget_is_attached_whole() {
        let (_d, ctx) = ctx_with_engine(Arc::new(MockBackend::scripted(vec![])));
        let page = big_page(Some("Управление памятью в V"));
        let full = page.text.clone();
        let out = FetchUrl::default()
            .attached_result(&ctx, "https://docs.vlang.io/x.html", None, false, page)
            .await;

        let [ChatEffect::AddAttachment(att)] = out.effects.as_slice() else {
            panic!("no attachment effect: {:?}", out.effects);
        };
        assert!(
            att.text.contains("НАЧАЛО") && att.text.contains("КОНЕЦ"),
            "the text is not whole"
        );
        assert!(att.text.contains(&full), "the extracted text was altered");
        assert_eq!(
            att.name, "Управление памятью в V",
            "the page title names it"
        );
        assert_eq!(att.source, "https://docs.vlang.io/x.html");
        // Over `max_file_tokens` by construction — the other side of the same
        // threshold, so an attachment made this way is never inline.
        assert_eq!(
            att.mode,
            crate::entities::attachment::AttachMode::ByReference
        );
        // The attachment carries its own header, so the file still says what it
        // is when it is read page by page much later.
        assert!(
            att.text.contains("https://docs.vlang.io/x.html"),
            "no source in the header"
        );

        // And the result must say where the text went and how to reach it —
        // otherwise this repeats P2 in a politer form.
        let pages = att.page_count(ctx.attachment_cfg.page_tokens).to_string();
        assert!(
            out.result.contains("attachment_read"),
            "got: {}",
            out.result
        );
        assert!(
            out.result.contains("attachment_search"),
            "got: {}",
            out.result
        );
        assert!(out.result.contains(&pages), "no page count: {}", out.result);
    }

    #[tokio::test]
    async fn a_titleless_page_is_named_by_its_url() {
        let (_d, ctx) = ctx_with_engine(Arc::new(MockBackend::scripted(vec![])));
        let out = FetchUrl::default()
            .attached_result(&ctx, "https://example.com/a", None, false, big_page(None))
            .await;
        let [ChatEffect::AddAttachment(att)] = out.effects.as_slice() else {
            panic!("no attachment effect");
        };
        assert_eq!(att.name, "https://example.com/a");
    }

    /// `summarize=true` still summarizes — from the head, since the summarizer is
    /// a single-turn subagent — and still attaches, so a partial summary is a
    /// starting point rather than the only access to the page.
    #[tokio::test]
    async fn an_attached_page_is_still_summarized_from_its_head() {
        let backend = Arc::new(CapturingBackend {
            last: Mutex::new(None),
            reply: "краткое содержание".into(),
        });
        let (_d, ctx) = ctx_with_engine(backend.clone());
        let out = FetchUrl::default()
            .attached_result(&ctx, "https://example.com", None, true, big_page(None))
            .await;
        assert!(
            out.result.contains("краткое содержание"),
            "got: {}",
            out.result
        );
        assert!(
            out.result.contains("attachment_read"),
            "got: {}",
            out.result
        );
        assert_eq!(
            out.effects.len(),
            1,
            "the page is attached as well as summarized"
        );

        let req = backend.last.lock().unwrap().take().unwrap();
        let sent = format!("{:?}", req.messages[0]);
        assert!(
            sent.chars().count() < SUMMARY_INPUT_CHARS * 2,
            "the whole page went to the summarizer ({} chars)",
            sent.chars().count()
        );
    }

    /// The size ceiling stays, but it is announced — the other half of P2.
    #[tokio::test]
    async fn hitting_the_size_ceiling_is_announced() {
        use crate::shared::i18n::{Lang, locale};
        let (_d, ctx) = ctx_with_engine(Arc::new(MockBackend::scripted(vec![])));
        let mut page = big_page(None);
        page.truncated = true;
        let out = FetchUrl::default()
            .attached_result(&ctx, "https://example.com", None, false, page)
            .await;
        let marker = locale(Lang::Ru).t("tool.fetch_url.result.truncated");
        assert!(out.result.contains(marker), "got: {}", out.result);

        // The same on the path where the page fits and is returned inline.
        let small = PageText {
            text: "короткий текст".into(),
            truncated: true,
            title: None,
        };
        let inline = FetchUrl::default()
            .inline_result(&ctx, "https://example.com", None, false, &small)
            .await;
        assert!(inline.result.contains(marker), "got: {}", inline.result);
    }

    /// A page within the budget keeps the previous behaviour: the text itself,
    /// in the result, with no attachment.
    #[tokio::test]
    async fn a_small_page_comes_back_in_the_result() {
        let (_d, ctx) = ctx_with_engine(Arc::new(MockBackend::scripted(vec![])));
        let page = PageText {
            text: "Небольшая страница целиком.".into(),
            truncated: false,
            title: Some("t".into()),
        };
        let out = FetchUrl::default()
            .inline_result(&ctx, "https://example.com", None, false, &page)
            .await;
        assert!(
            out.result.contains("Небольшая страница целиком."),
            "got: {}",
            out.result
        );
    }

    /// One fixture per shape the corpus measured (docs/research/page-attachment-name.md
    /// §2), each pinning the step of the rule (§4) that has to name it.
    #[test]
    fn the_attachment_is_named_by_what_a_second_field_confirms() {
        let name = |head: &str, body: &str| {
            let page = body_to_text(
                "text/html",
                &format!(
                    "<html><head>{head}</head><body>{body}\
                     <p>Достаточно длинный абзац, чтобы пройти порог отсева фрагментов.</p>\
                     </body></html>"
                ),
            )
            .unwrap();
            assert!(!page.truncated);
            page.title
        };
        // (shape, <head>, <body>, the name)
        let cases: &[(&str, &str, &str, &str)] = &[
            (
                "og:title, without the site suffix it shares with the title",
                r#"<title>Moon - Wikipedia</title><meta property="og:title" content="Moon - Wikipedia">"#,
                "<h1>Moon</h1>",
                "Moon",
            ),
            (
                "og:title over a blog's banner <h1>",
                r#"<title>Any Nix package, live in your browser</title>
                   <meta property="og:title" content="Any Nix package, live in your browser">"#,
                "<h1>Simon Willison’s Weblog</h1>",
                "Any Nix package, live in your browser",
            ),
            (
                "an og:title that is the title's site segment is the site",
                r#"<title>Pods | Kubernetes</title><meta property="og:title" content="Kubernetes">"#,
                "<h1>Pods</h1>",
                "Pods",
            ),
            (
                "an og:title that is og:site_name is the site",
                r#"<title>Pods | Kubernetes</title><meta property="og:title" content="Kubernetes Docs">
                   <meta property="og:site_name" content="Kubernetes Docs">"#,
                "<h1>Pods</h1>",
                "Pods",
            ),
            (
                "an <h1> the title begins with",
                "<title>Array.prototype.map() - JavaScript | MDN</title>",
                "<h1>Array.prototype.map()</h1>",
                "Array.prototype.map()",
            ),
            (
                "an <h1> agrees ignoring case and its permalink mark, and reads as the title spells it",
                "<title>Getting Started - Guide | Vite</title>",
                "<h1>Getting started <a class=\"header-anchor\" href=\"#getting-started\">\u{200b}</a></h1>",
                "Getting Started",
            ),
            (
                "the post's <h1> after a banner <h1>",
                "<title>Learning a few things about running SQLite</title>",
                "<h1>Julia Evans</h1><h1>Learning a few things about running SQLite</h1>",
                "Learning a few things about running SQLite",
            ),
            (
                "an <h1> that is only a word's start does not agree",
                "<title>Google Search Central | Blog</title>",
                "<h1>Go</h1>",
                "Google Search Central",
            ),
            (
                "the archive's banner <h1> over an article-first title (the reported page)",
                "<title>Попьем чайку? Петр 'roxton' Семилетов | Архив журнала «Мой компьютер» №32/203 `2002</title>",
                "<h1>АРХИВ СТАТЕЙ ЖУРНАЛА «МОЙ КОМПЬЮТЕР» ЗА 2002 ГОД</h1>",
                "Попьем чайку? Петр 'roxton' Семилетов",
            ),
            (
                "mdBook: the banner <h1> is the title's own suffix",
                "<title>What is Ownership? - The Rust Programming Language</title>",
                "<h1 class=\"menu-title\">The Rust Programming Language</h1>",
                "What is Ownership?",
            ),
            (
                "rustdoc: the <h1> carries a button's text",
                "<title>serde - Rust</title>",
                "<h1>Crate <span>serde</span><button>Copy item path</button></h1>",
                "serde",
            ),
            (
                "a page's own name keeps its separator",
                "<title>The Qualcomm DSP Driver - Unexpectedly Excavating an Exploit - Project Zero</title>",
                "",
                "The Qualcomm DSP Driver - Unexpectedly Excavating an Exploit",
            ),
            (
                "docs.vlang.io: a title that is the site alone, over the page's <h1>",
                "<title>V Documentation</title>",
                "<h1>Memory management<a href=\"#memory-management\">¶</a></h1>",
                "Memory management",
            ),
            (
                "no <h1> and no separator: the title, collapsed",
                "<title>  Memory\n management  </title>",
                "",
                "Memory management",
            ),
        ];
        for (shape, head, body, expected) in cases {
            assert_eq!(name(head, body).as_deref(), Some(*expected), "{shape}");
        }
    }

    #[test]
    fn a_title_is_split_at_its_last_spaced_separator() {
        for sep in [
            " | ", " — ", " – ", " - ", " -> ", " :: ", " · ", " » ", " / ", " : ",
        ] {
            let head = format!("Page{sep}Section");
            let title = format!("{head}{sep}Site");
            assert_eq!(
                split_last_segment(&title),
                Some((head.as_str(), "Site")),
                "{sep:?}"
            );
        }
        // Unspaced, a separator belongs to a name: "PostgreSQL: Documentation", a path.
        assert_eq!(
            split_last_segment("PostgreSQL: Documentation: 18: SELECT"),
            None
        );
        assert_eq!(split_last_segment("Lib.ru/Classics|poems-A-Z"), None);
    }

    /// The reported defect through the tool (docs/research/page-attachment-name.md §1):
    /// two articles of one windows-1251 archive, each under the archive's banner `<h1>`,
    /// attached as the banner and as the banner plus a file name. Each is named by its
    /// article now, and the second needs no URL segment to differ.
    #[tokio::test]
    async fn two_articles_of_one_archive_are_named_by_their_articles() {
        let archive_page = |article: &str| -> Vec<u8> {
            let prose =
                "Абзац статьи из архива журнала, достаточно длинный для порога. ".repeat(1500);
            let html = format!(
                "<html><head><meta http-equiv=\"Content-Type\" content=\"text/html; charset=windows-1251\">\
                 <title>{article} | Архив журнала «Мой компьютер» №32/203 `2002</title></head>\
                 <body><h1>АРХИВ СТАТЕЙ ЖУРНАЛА «МОЙ КОМПЬЮТЕР» ЗА 2002 ГОД</h1><p>{prose}</p></body></html>"
            );
            let body = encoding_rs::WINDOWS_1251.encode(&html).0;
            let mut out = format!(
                "HTTP/1.1 200 OK\r\nContent-Type: text/html\r\nContent-Length: {}\r\n\
                 Connection: close\r\n\r\n",
                body.len()
            )
            .into_bytes();
            out.extend_from_slice(&body);
            out
        };
        let articles = [
            "Попьем чайку? Петр 'roxton' Семилетов",
            "ВодВАRить на место. Геннадий Осипенко",
        ];
        let (base, _h) =
            crate::features::image_fetch::stub::serve(articles.map(archive_page).to_vec());
        let tool = FetchUrl::new(AddressPolicy::Unrestricted);
        let (_d, mut ctx) = ctx_with_engine(Arc::new(MockBackend::scripted(vec![])));
        let mut names = Vec::new();
        for path in ["mycomp/mid203/aid5.html", "mycomp/mid199/aid2.html"] {
            let url = format!("{base}/{path}");
            let out = tool
                .invoke(&ctx, serde_json::json!({"url": url, "summarize": false}))
                .await
                .unwrap();
            let [ChatEffect::AddAttachment(att)] = out.effects.as_slice() else {
                panic!("not attached: {}", out.result);
            };
            names.push(att.name.clone());
            ctx.attachments = Arc::from(vec![(**att).clone()]);
        }
        assert_eq!(names, articles);
    }

    #[test]
    fn a_name_already_taken_by_another_page_gets_the_url_segment() {
        use crate::entities::attachment::AttachMode;
        let mine = "https://docs.example.io/memory-management.html";
        let other = Attachment::new(
            "V Documentation",
            "https://docs.example.io/concurrency.html",
            "x".into(),
            1,
            AttachMode::ByReference,
        );
        assert_eq!(
            unique_name("V Documentation", mine, std::slice::from_ref(&other)),
            "V Documentation — memory-management.html"
        );
        // Re-fetching the *same* page keeps the plain name: the attachment it
        // replaces is its own, so nothing collides and the name stays stable.
        let same = Attachment::new(
            "V Documentation",
            mine,
            "x".into(),
            1,
            AttachMode::ByReference,
        );
        assert_eq!(
            unique_name("V Documentation", mine, &[same]),
            "V Documentation"
        );
        assert_eq!(unique_name("V Documentation", mine, &[]), "V Documentation");
    }

    #[test]
    fn url_segment_falls_back_to_the_host() {
        assert_eq!(
            url_segment("https://a.io/x/y.html?q=1").as_deref(),
            Some("y.html")
        );
        assert_eq!(url_segment("https://a.io/").as_deref(), Some("a.io"));
        assert_eq!(url_segment("https://a.io").as_deref(), Some("a.io"));
    }

    #[test]
    fn fetch_url_description_and_summary_system_localized() {
        // The description and the summarization system prompt are localized (en≠ru,
        // no Cyrillic). §3.5 docs/history/i18n.md.
        use crate::shared::i18n::{Lang, locale};
        let tool = FetchUrl::default();
        let (ru, en) = (locale(Lang::Ru), locale(Lang::En));
        let no_cyr = |s: &str| {
            !s.chars()
                .any(|c| ('а'..='я').contains(&c) || ('А'..='Я').contains(&c))
        };
        assert_ne!(tool.description(ru), tool.description(en));
        assert!(no_cyr(&tool.description(en)));
        assert_ne!(
            ru.t("tool.fetch_url.summarize.system"),
            en.t("tool.fetch_url.summarize.system")
        );
        assert!(no_cyr(en.t("tool.fetch_url.summarize.system")));
    }

    #[tokio::test]
    async fn rejects_non_http_url() {
        let (_d, ctx) = ctx_with_engine(Arc::new(MockBackend::scripted(vec![])));
        assert!(
            FetchUrl::default()
                .invoke(&ctx, serde_json::json!({"url": "ftp://x/y"}))
                .await
                .is_err()
        );
    }

    #[tokio::test]
    async fn rejects_empty_url() {
        let (_d, ctx) = ctx_with_engine(Arc::new(MockBackend::scripted(vec![])));
        assert!(
            FetchUrl::default()
                .invoke(&ctx, serde_json::json!({"url": "  "}))
                .await
                .is_err()
        );
    }

    /// Summarization builds a request with no tools, with a token limit, and includes
    /// focus in the task. Checks the pure function `summarize_text` directly.
    #[tokio::test]
    async fn summarize_builds_single_turn_request_with_focus() {
        let backend = Arc::new(CapturingBackend {
            last: Mutex::new(None),
            reply: "краткое содержание".into(),
        });
        let (_d, ctx) = ctx_with_engine(backend.clone());
        let summary = summarize_text(
            &ctx,
            "https://example.com",
            Some("какова цена?"),
            "Длинный текст страницы про цены и условия.",
        )
        .await
        .unwrap();
        assert_eq!(summary.text, "краткое содержание");
        assert!(summary.prefill.is_none(), "no usage chunk, no timing");

        let req = backend.last.lock().unwrap().take().unwrap();
        assert!(req.system.is_some());
        assert_eq!(req.messages.len(), 1);
        assert!(req.tools.is_empty(), "no tools (a nesting ban)");
        assert!(req.sampling.max_tokens.unwrap() <= SUMMARY_MAX_TOKENS);
        assert_eq!(
            req.sampling.reasoning_budget,
            Some(0),
            "reasoning muted, the title's shape (page-summary-usage §3.3)"
        );
        // focus made it into the task.
        let msg = format!("{:?}", req.messages[0]);
        assert!(msg.contains("какова цена"), "focus in the task: {msg}");
    }

    /// An engine whose streams report how many are open at once, each one
    /// slow enough that two summaries could overlap if nothing stopped them.
    struct CountingBackend {
        in_flight: Arc<std::sync::atomic::AtomicUsize>,
        max_in_flight: Arc<std::sync::atomic::AtomicUsize>,
    }

    struct Open(Arc<std::sync::atomic::AtomicUsize>);

    impl Drop for Open {
        fn drop(&mut self) {
            self.0.fetch_sub(1, std::sync::atomic::Ordering::SeqCst);
        }
    }

    #[async_trait::async_trait]
    impl EngineBackend for CountingBackend {
        async fn chat_stream(
            &self,
            _req: ChatRequest,
            _cancel: CancellationToken,
        ) -> Result<ChatStream> {
            use std::sync::atomic::Ordering::SeqCst;
            let open = self.in_flight.fetch_add(1, SeqCst) + 1;
            self.max_in_flight.fetch_max(open, SeqCst);
            let guard = Open(self.in_flight.clone());
            let s = async_stream::stream! {
                let _open = guard;
                tokio::time::sleep(Duration::from_millis(40)).await;
                yield ChatChunk::Text("summary".into());
                yield ChatChunk::Finished(FinishReason::Stop);
            };
            Ok(Box::pin(s))
        }
    }

    /// The summary's stream takes a permit of the turn's session budget and
    /// releases it with the stream (docs/research/concurrent-tools.md §4.5):
    /// with one session two summaries never overlap, and with no budget —
    /// a background task's context — both run at once.
    #[tokio::test]
    async fn summary_takes_a_session_permit_for_its_stream() {
        let counting = Arc::new(CountingBackend {
            in_flight: Arc::new(std::sync::atomic::AtomicUsize::new(0)),
            max_in_flight: Arc::new(std::sync::atomic::AtomicUsize::new(0)),
        });
        let (_d, mut ctx) = ctx_with_engine(counting.clone());
        let sessions = Arc::new(crate::shared::session_budget::SessionBudget::new(1, None));
        ctx.sessions = Some(sessions.clone());
        let (a, b) = tokio::join!(
            summarize_text(&ctx, "https://a.example", None, "text a"),
            summarize_text(&ctx, "https://b.example", None, "text b"),
        );
        assert_eq!(
            (a.unwrap().text, b.unwrap().text),
            ("summary".to_string(), "summary".to_string())
        );
        assert_eq!(
            counting
                .max_in_flight
                .load(std::sync::atomic::Ordering::SeqCst),
            1,
            "one session: the summaries streamed one after another"
        );
        assert_eq!(sessions.available_sessions(), 1, "the permit came back");

        ctx.sessions = None;
        counting
            .max_in_flight
            .store(0, std::sync::atomic::Ordering::SeqCst);
        let (a, b) = tokio::join!(
            summarize_text(&ctx, "https://a.example", None, "text a"),
            summarize_text(&ctx, "https://b.example", None, "text b"),
        );
        assert!(a.is_ok() && b.is_ok());
        assert_eq!(
            counting
                .max_in_flight
                .load(std::sync::atomic::Ordering::SeqCst),
            2,
            "no budget: nothing holds the second summary back"
        );
    }

    /// An engine whose one stream ends with the server's usage: an exact
    /// count far above any estimate of the short texts here, and the
    /// engine's timing of the prompt — the shape of a `llama-server` stream.
    struct UsageBackend;

    const EXACT: u32 = 50_000;

    #[async_trait::async_trait]
    impl EngineBackend for UsageBackend {
        async fn chat_stream(
            &self,
            _req: ChatRequest,
            _cancel: CancellationToken,
        ) -> Result<ChatStream> {
            let s = async_stream::stream! {
                yield ChatChunk::Text("summary".into());
                yield ChatChunk::Usage(crate::shared::api::contract::TokenUsage {
                    prompt_tokens: EXACT,
                    completion_tokens: 1,
                    reasoning_tokens: 0,
                    prefill: Some(Prefill {
                        tokens: EXACT,
                        ms: 1000,
                    }),
                });
                yield ChatChunk::Finished(FinishReason::Stop);
            };
            Ok(Box::pin(s))
        }
    }

    /// The summary records its exact count under its own kind
    /// (docs/research/page-summary-usage.md §3.1): the ratio the next
    /// summary prices with, and no other kind's — the turn's stays at 1.0.
    #[tokio::test]
    async fn summary_records_its_usage_under_its_own_kind() {
        use crate::shared::session_budget::{SessionBudget, Shape};
        let (_d, mut ctx) = ctx_with_engine(Arc::new(UsageBackend));
        let budget = Arc::new(SessionBudget::new(2, Some(100_000)));
        ctx.sessions = Some(budget.clone());
        let s = summarize_text(&ctx, "https://a.example", None, "text a")
            .await
            .unwrap();
        assert_eq!(s.text, "summary");
        assert!(budget.density(Shape::Summary) > 1.0, "{budget:?}");
        assert_eq!(budget.density(Shape::Turn), 1.0, "no other kind touched");
        assert_eq!(budget.in_flight(), 0, "the reservation came back");
    }

    /// The engine's timing of the summary's prompt rides the outcome on both
    /// paths (§3.2) — a page under the attachment budget and one over it —
    /// and only where a summary was made: `summarize=false` asks nothing of
    /// the engine, and an engine that sends no usage leaves `None`.
    #[tokio::test]
    async fn the_outcome_carries_the_summarys_sample() {
        let (_d, ctx) = ctx_with_engine(Arc::new(UsageBackend));
        let small = PageText {
            text: "A small page.".into(),
            truncated: false,
            title: None,
        };
        let inline = FetchUrl::default()
            .inline_result(&ctx, "https://example.com", None, true, &small)
            .await;
        assert_eq!(inline.prefill.map(|p| p.tokens), Some(EXACT));
        assert!(inline.result.contains("summary"), "{}", inline.result);
        let attached = FetchUrl::default()
            .attached_result(&ctx, "https://example.com", None, true, big_page(None))
            .await;
        assert_eq!(attached.prefill.map(|p| p.tokens), Some(EXACT));
        assert_eq!(attached.effects.len(), 1, "the page attached as before");

        let plain = FetchUrl::default()
            .inline_result(&ctx, "https://example.com", None, false, &small)
            .await;
        assert!(
            plain.prefill.is_none(),
            "no summary asked, nothing to report"
        );

        let (_d, ctx) = ctx_with_engine(Arc::new(CapturingBackend {
            last: Mutex::new(None),
            reply: "summary".into(),
        }));
        let no_usage = FetchUrl::default()
            .inline_result(&ctx, "https://example.com", None, true, &small)
            .await;
        assert!(no_usage.prefill.is_none(), "a stream without a usage chunk");
    }

    /// Under a shared KV pool the summary reserves its prompt plus its reply
    /// cap (docs/research/admission-by-budget.md §4.5): with two sessions
    /// over a pool two summaries do not fit in, they stream one after the
    /// other; over a roomy pool, together.
    #[tokio::test]
    async fn summary_reserves_room_in_a_shared_pool() {
        use crate::shared::session_budget::SessionBudget;
        let counting = Arc::new(CountingBackend {
            in_flight: Arc::new(std::sync::atomic::AtomicUsize::new(0)),
            max_in_flight: Arc::new(std::sync::atomic::AtomicUsize::new(0)),
        });
        let (_d, mut ctx) = ctx_with_engine(counting.clone());
        // Each reservation is at least the 768-token cap, so two exceed 1000.
        ctx.sessions = Some(Arc::new(SessionBudget::new(2, Some(1000))));
        let (a, b) = tokio::join!(
            summarize_text(&ctx, "https://a.example", None, "text a"),
            summarize_text(&ctx, "https://b.example", None, "text b"),
        );
        assert!(a.is_ok() && b.is_ok());
        assert_eq!(
            counting
                .max_in_flight
                .load(std::sync::atomic::Ordering::SeqCst),
            1,
            "two sessions, one pool too small for both: one at a time"
        );
        let budget = ctx.sessions.as_deref().unwrap();
        assert_eq!(
            (budget.in_flight(), budget.available_sessions()),
            (0, 2),
            "both reservations and both permits came back"
        );

        ctx.sessions = Some(Arc::new(SessionBudget::new(2, Some(100_000))));
        counting
            .max_in_flight
            .store(0, std::sync::atomic::Ordering::SeqCst);
        let (a, b) = tokio::join!(
            summarize_text(&ctx, "https://a.example", None, "text a"),
            summarize_text(&ctx, "https://b.example", None, "text b"),
        );
        assert!(a.is_ok() && b.is_ok());
        assert_eq!(
            counting
                .max_in_flight
                .load(std::sync::atomic::Ordering::SeqCst),
            2,
            "a pool with room for both: together"
        );
    }

    #[test]
    fn json_body_returned_as_is_not_extracted() {
        // A JSON API response (by Content-Type) is returned as-is — readability used to
        // return empty → "failed to extract readable text" (Steam appreviews).
        let body = r#"{"success":1,"query_summary":{"total_positive":200,"total_negative":30}}"#;
        let out = body_to_text("application/json; charset=utf-8", body)
            .unwrap()
            .text;
        assert!(out.contains("total_positive"), "got: {out}");
    }

    #[test]
    fn json_shaped_body_returned_when_content_type_missing() {
        // No Content-Type, but the body has a JSON shape (starts with `{`) → return as-is.
        let out = body_to_text("", r#"  {"a":1}"#).unwrap().text;
        assert!(out.contains("\"a\":1"), "got: {out}");
    }

    #[test]
    fn html_without_readable_text_yields_none() {
        // HTML with no readable text (only scripts) → nothing to extract.
        assert!(body_to_text("text/html", "<html><script>var x=1;</script></html>").is_none());
    }

    #[test]
    fn html_with_paragraph_is_extracted() {
        let out = body_to_text(
            "text/html; charset=utf-8",
            "<html><body><p>Реальный читаемый абзац страницы, достаточно длинный, \
             чтобы пройти порог отсева коротких фрагментов.</p></body></html>",
        )
        .unwrap()
        .text;
        assert!(out.contains("читаемый абзац"), "got: {out}");
    }

    /// The defect this closes (docs/research/page-charset.md §1): a windows-1251 page
    /// came back as U+FFFD, because `resp.text()` read its bytes as UTF-8 whatever they
    /// declared. Through the tool's own request path, in the two shapes the old path
    /// could not read at all — the encoding declared only in `<meta>`, and a body
    /// gzipped though nothing asked for it.
    #[tokio::test]
    async fn a_legacy_page_is_read_in_its_own_encoding() {
        let (_d, ctx) = ctx_with_engine(Arc::new(MockBackend::scripted(vec![])));
        let prose =
            "Попьем чайку? Текстовый редактор, написанный для себя, вырос в программу для всех.";
        let (base, _h) = crate::features::image_fetch::stub::serve(vec![
            crate::shared::http_text::testkit::legacy_page_response("Архив статей", prose),
        ]);
        let page = FetchUrl::new(AddressPolicy::Unrestricted)
            .fetch_text(&format!("{base}/mycomp/aid5.html"), ctx.loc)
            .await
            .unwrap();
        assert!(page.text.contains(prose), "{}", page.text);
        assert_eq!(page.title.as_deref(), Some("Архив статей"));
    }

    /// A body past the ceiling is refused **as it arrives** — the bound is the bytes
    /// read, not the `Content-Length` a server may omit or misstate — and the refusal
    /// says so rather than reading as a transport failure worth retrying
    /// (docs/research/safe-defaults.md N3). The cap is 32 MB, so the stub lies about a
    /// small body to exercise the header half, and sends more than it promised to
    /// exercise the streaming half.
    #[tokio::test]
    async fn a_page_past_the_ceiling_is_refused_and_says_so() {
        let (_d, ctx) = ctx_with_engine(Arc::new(MockBackend::scripted(vec![])));
        let huge = 40 * 1024 * 1024usize;
        let mut claimed = format!(
            "HTTP/1.1 200 OK\r\nContent-Type: text/html\r\nContent-Length: {huge}\r\nConnection: close\r\n\r\n"
        )
        .into_bytes();
        claimed.extend(std::iter::repeat_n(b'a', 64));
        let (base, _h) = crate::features::image_fetch::stub::serve(vec![claimed]);
        let refusal = FetchUrl::new(AddressPolicy::Unrestricted)
            .fetch_text(&format!("{base}/huge.html"), ctx.loc)
            .await
            .err()
            .expect("a body past the ceiling must be refused");
        let refusal = format!("{refusal:#}");
        assert!(refusal.contains("32 MB"), "{refusal}");

        // The same page under the ceiling still reads, so the cap is what refused it.
        let body = "<html><head><title>Small</title></head><body><h1>Small</h1><p>This page is small enough to be read whole, and long enough to be readable text rather than a fragment the extractor discards.</p></body></html>";
        let ok = format!(
            "HTTP/1.1 200 OK\r\nContent-Type: text/html\r\nContent-Length: {}\r\nConnection: close\r\n\r\n{body}",
            body.len()
        )
        .into_bytes();
        let (base, _h) = crate::features::image_fetch::stub::serve(vec![ok]);
        let page = FetchUrl::new(AddressPolicy::Unrestricted)
            .fetch_text(&format!("{base}/small.html"), ctx.loc)
            .await
            .unwrap();
        assert!(page.text.contains("small enough"), "{}", page.text);
    }

    /// The page from the chat that reported the defect (docs/research/page-charset.md
    /// §1), fetched the way the assistant fetched it: a windows-1251 page over the
    /// attachment budget, which had become an attachment named and filled with U+FFFD.
    /// Needs no key — only network.
    #[tokio::test]
    #[ignore = "requires network access"]
    async fn live_windows_1251_page_is_readable() {
        let (_d, ctx) = ctx_with_engine(Arc::new(MockBackend::scripted(vec![])));
        let url = "https://sector.biz.ua/mycomp/mid203/aid5.html";
        let out = FetchUrl::default()
            .invoke(&ctx, serde_json::json!({"url": url, "summarize": false}))
            .await
            .unwrap();
        let (name, text) = match out.effects.as_slice() {
            [ChatEffect::AddAttachment(att)] => (att.name.clone(), att.text.clone()),
            _ => (String::new(), out.result.clone()),
        };
        eprintln!(
            "--- fetch_url on {url}: attached as {name:?}, {} chars ---",
            text.chars().count()
        );
        assert!(
            text.contains("Попьем чайку"),
            "the article is missing: {text}"
        );
        assert!(
            !text.contains('\u{FFFD}') && !name.contains('\u{FFFD}'),
            "replacement characters are back: {name:?}"
        );
        // Named by the article, not by the banner `<h1>` every article of the archive
        // repeats (docs/research/page-attachment-name.md §1).
        assert_eq!(name, "Попьем чайку? Петр 'roxton' Семилетов");
    }

    /// A YouTube link used to be a dead end here — the watch page is a
    /// JavaScript shell, so readability extracted nothing and the answer was
    /// "failed to extract readable text". Now it hands back what the free paths
    /// know and points at `youtube_watch` (fork R6). Needs no key — only network.
    #[tokio::test]
    #[ignore = "requires network access"]
    async fn live_youtube_link_returns_metadata_not_a_dead_end() {
        let (_d, ctx) = ctx_with_engine(Arc::new(MockBackend::scripted(vec![])));
        let out = FetchUrl::default()
            .invoke(
                &ctx,
                serde_json::json!({"url": "https://youtu.be/dQw4w9WgXcQ"}),
            )
            .await
            .unwrap();
        eprintln!("--- fetch_url on a YouTube link ---\n{}", out.result);
        assert!(
            out.result.contains("Never Gonna Give You Up"),
            "the live watch page's title is missing: {}",
            out.result
        );
        assert!(
            out.result.contains(super::super::YOUTUBE_WATCH_ID),
            "the answer must point at the tool that can watch it: {}",
            out.result
        );
    }

    /// The page from the transcript that prompted this work
    /// (docs/history/fetch-url-fidelity.md). Two claims that only a live fetch
    /// can settle, because both depend on the real markup: the code examples
    /// come back (P1 — VitePress wraps them in a bare `div.language-v`, which
    /// prose extraction dropped), and a documentation page of this size arrives
    /// as an attachment rather than cut mid-word (P2). Needs no key — only network.
    #[tokio::test]
    #[ignore = "requires network access"]
    async fn live_documentation_page_keeps_its_code() {
        let (_d, ctx) = ctx_with_engine(Arc::new(MockBackend::scripted(vec![])));
        let out = FetchUrl::default()
            .invoke(
                &ctx,
                serde_json::json!({
                    "url": "https://docs.vlang.io/memory-management.html",
                    "summarize": false
                }),
            )
            .await
            .unwrap();

        // The text is wherever the size rule put it — that is the point of the
        // rule, so the test asks for the content, not for a particular branch.
        let attached = match out.effects.as_slice() {
            [ChatEffect::AddAttachment(a)] => Some(a.clone()),
            [] => None,
            other => panic!("unexpected effects: {other:?}"),
        };
        let text = attached
            .as_ref()
            .map(|a| a.text.clone())
            .unwrap_or_else(|| out.result.clone());
        eprintln!(
            "--- fetch_url on the V docs page: {} chars, attached={} ---",
            text.chars().count(),
            attached.is_some()
        );

        assert!(
            text.contains("fn (data &MyType) free()"),
            "the code example is missing — prose-only extraction is back: {text}"
        );
        assert!(text.contains("```"), "code is not fenced: {text}");
        assert!(
            text.contains("## Control") || text.contains("# Control"),
            "section headings are missing: {text}"
        );
        assert!(
            text.contains("Arena allocation is available"),
            "the prose is missing: {text}"
        );
        if let Some(att) = attached {
            let pages = att.page_count(ctx.attachment_cfg.page_tokens);
            eprintln!(
                "attached as {:?}, {pages} page(s), mode {:?}",
                att.name, att.mode
            );
            // Every page of the site shares one `<title>`; its `<h1>` is the page
            // (docs/research/page-attachment-name.md §1).
            assert_eq!(att.name, "Memory management");
            assert!(
                out.result.contains("attachment_read"),
                "the result must say how to reach the attached page: {}",
                out.result
            );
        }
    }

    /// The summary's usage on a live engine (docs/research/page-summary-usage.md
    /// §6, fork F4a): a JSON page — the text measured to under-count most
    /// (1.28) — fetched under a budget of four sessions over the LAN stack's
    /// pool. The result carries a summary (reasoning muted: not the "summary
    /// unavailable" fallback with the JSON behind it), the budget's `Summary`
    /// ratio is above 1.0, and the outcome carries the engine's timing of the
    /// prompt.
    ///
    /// `MINDFORK_ENGINE_URL=…/v1 cargo test summary_usage_e2e_live -- --ignored --nocapture`.
    #[tokio::test]
    #[ignore = "requires a running llama-server (MINDFORK_ENGINE_URL) and network access"]
    async fn summary_usage_e2e_live() {
        use crate::shared::session_budget::{SessionBudget, Shape};
        let Some(client) =
            crate::shared::api::live_client("MINDFORK_ENGINE_URL", "MINDFORK_ENGINE_KEY")
        else {
            eprintln!("skip: MINDFORK_ENGINE_URL not set");
            return;
        };
        let (_d, mut ctx) = ctx_with_engine(Arc::new(client));
        let budget = Arc::new(SessionBudget::new(4, Some(16_384)));
        ctx.sessions = Some(budget.clone());
        let url = "https://api.github.com/repos/rust-lang/rust";
        let started = std::time::Instant::now();
        let out = FetchUrl::default()
            .invoke(&ctx, serde_json::json!({"url": url}))
            .await
            .unwrap();
        eprintln!(
            "summary_usage_e2e_live: {:.1} s, ratio {:.2}, sample {:?}\n{}",
            started.elapsed().as_secs_f64(),
            budget.density(Shape::Summary),
            out.prefill,
            out.result
        );
        assert!(
            !out.result.contains("\"node_id\""),
            "the JSON itself came back, not a summary: {}",
            out.result
        );
        assert!(!out.result.trim().is_empty());
        assert!(
            budget.density(Shape::Summary) > 1.0,
            "a JSON page under-counts: {budget:?}"
        );
        assert_eq!(budget.density(Shape::Turn), 1.0, "no other kind touched");
        assert!(
            out.prefill.is_some(),
            "the engine's timing rides the outcome"
        );
    }

    /// A real network smoke (manual: `cargo test -- --ignored`).
    #[tokio::test]
    #[ignore = "requires network access"]
    async fn live_fetch_without_summarize() {
        let (_d, ctx) = ctx_with_engine(Arc::new(MockBackend::scripted(vec![])));
        let out = FetchUrl::default()
            .invoke(
                &ctx,
                serde_json::json!({"url": "https://example.com", "summarize": false}),
            )
            .await
            .unwrap();
        assert!(out.result.contains("Содержимое"), "got: {}", out.result);
    }
}