splashboard 2.10.0

//! `rss` — generic feed fetcher (RSS 2.0 / RSS 1.0 / Atom / JSON Feed via `feed-rs`).
//!
//! Safety::Network — the URL is config-provided, so the destination is whatever the user (or a
//! local-config they trust) types. Local configs must be `splashboard trust`-ed before this
//! widget runs; global config is implicitly trusted.
//!
//! Output shapes: `LinkedTextBlock` (default — clickable rows for `list_links`),
//! `ImageLinkedList` (cards with thumbnails), and `TextBlock` (titles only). All wiring around
//! HTTP retrieval, feed-rs parsing, and entry-to-row formatting lives in `crate::fetcher::feed`
//! so the `news_*` family can reuse it.

use async_trait::async_trait;
use serde::Deserialize;
use url::Url;

use crate::fetcher::feed;
use crate::fetcher::github::common::{cache_key, parse_options, payload};
use crate::fetcher::{FetchContext, FetchError, Fetcher, Safety};
use crate::options::OptionSchema;
use crate::payload::{Body, Payload};
use crate::render::Shape;
use crate::samples;

const SHAPES: &[Shape] = &[
    Shape::LinkedTextBlock,
    Shape::ImageLinkedList,
    Shape::TextBlock,
    Shape::Text,
    Shape::MarkdownTextBlock,
    Shape::Entries,
    Shape::Image,
    Shape::Timeline,
];

const OPTION_SCHEMAS: &[OptionSchema] = &[
    OptionSchema {
        name: "url",
        type_hint: "string (http / https)",
        required: true,
        default: None,
        description: "Feed URL — RSS 2.0, RSS 1.0, Atom, or JSON Feed.",
    },
    OptionSchema {
        name: "count",
        type_hint: "integer (1..=20)",
        required: false,
        default: Some("5"),
        description: "Number of feed entries to display.",
    },
];

pub struct RssFetcher;

#[derive(Debug, Default, Deserialize)]
#[serde(deny_unknown_fields)]
pub struct Options {
    #[serde(default)]
    pub url: Option<String>,
    #[serde(default)]
    pub count: Option<u32>,
}

#[async_trait]
impl Fetcher for RssFetcher {
    fn name(&self) -> &str {
        "rss"
    }
    fn safety(&self) -> Safety {
        Safety::Network
    }
    fn description(&self) -> &'static str {
        "Generic feed reader for any RSS 2.0 / RSS 1.0 / Atom / JSON Feed URL, parsed via `feed-rs`. Each row shows the entry's published date and title, optionally linked. Trust-gated because the URL is config-controlled."
    }
    fn refresh_interval(&self) -> u64 {
        60 * 15
    }
    fn shapes(&self) -> &[Shape] {
        SHAPES
    }
    fn option_schemas(&self) -> &[OptionSchema] {
        OPTION_SCHEMAS
    }
    fn cache_key(&self, ctx: &FetchContext) -> String {
        let extra = ctx
            .options
            .as_ref()
            .and_then(|v| toml::to_string(v).ok())
            .unwrap_or_default();
        cache_key(self.name(), ctx, &extra)
    }
    fn sample_body(&self, shape: Shape) -> Option<Body> {
        Some(match shape {
            Shape::LinkedTextBlock => samples::linked_text_block(&[
                ("Apr 26  Why X over Y", Some("https://example.com/post-1")),
                (
                    "Apr 24  Release notes 0.42",
                    Some("https://example.com/post-2"),
                ),
                ("Apr 22  A short note", Some("https://example.com/post-3")),
            ]),
            Shape::ImageLinkedList => samples::image_linked_list(&[
                (
                    "Why X over Y",
                    Some("https://example.com/post-1"),
                    None,
                    Some("Apr 26"),
                ),
                (
                    "Release notes 0.42",
                    Some("https://example.com/post-2"),
                    None,
                    Some("Apr 24"),
                ),
                (
                    "A short note",
                    Some("https://example.com/post-3"),
                    None,
                    Some("Apr 22"),
                ),
            ]),
            Shape::TextBlock => samples::text_block(&[
                "Apr 26  Why X over Y",
                "Apr 24  Release notes 0.42",
                "Apr 22  A short note",
            ]),
            Shape::Text => samples::text("Why X over Y"),
            Shape::MarkdownTextBlock => samples::markdown(
                "- [Apr 26  Why X over Y](https://example.com/post-1)\n- [Apr 24  Release notes 0.42](https://example.com/post-2)\n- [Apr 22  A short note](https://example.com/post-3)",
            ),
            Shape::Entries => samples::entries(&[
                ("Why X over Y", "Apr 26"),
                ("Release notes 0.42", "Apr 24"),
                ("A short note", "Apr 22"),
            ]),
            Shape::Timeline => samples::timeline(&[
                (1_745_625_600, "Why X over Y", Some("example.com")),
                (1_745_452_800, "Release notes 0.42", Some("example.com")),
                (1_745_280_000, "A short note", Some("example.com")),
            ]),
            _ => return None,
        })
    }
    async fn fetch(&self, ctx: &FetchContext) -> Result<Payload, FetchError> {
        let opts: Options = parse_options(ctx.options.as_ref()).map_err(FetchError::Failed)?;
        let url = validated_url(opts.url.as_deref())?;
        let count = opts
            .count
            .unwrap_or(feed::DEFAULT_COUNT)
            .clamp(feed::MIN_COUNT, feed::MAX_COUNT) as usize;
        let bytes = feed::fetch_bytes(&url, "rss").await?;
        let parsed = feed::parse_feed(&bytes, "rss")?;
        let shape = ctx.shape.unwrap_or(Shape::LinkedTextBlock);
        let body = match shape {
            Shape::ImageLinkedList => feed::render_image_linked(&parsed, count, ctx).await,
            Shape::Image => feed::render_image_body(&parsed).await,
            other => feed::render_body(
                &parsed,
                count,
                other,
                ctx.timezone.as_deref(),
                ctx.locale.as_deref(),
            ),
        };
        Ok(payload(body))
    }
}

fn validated_url(raw: Option<&str>) -> Result<Url, FetchError> {
    let raw = raw
        .map(str::trim)
        .filter(|s| !s.is_empty())
        .ok_or_else(|| FetchError::Failed("rss: option `url` is required".into()))?;
    let parsed =
        Url::parse(raw).map_err(|e| FetchError::Failed(format!("rss: invalid url: {e}")))?;
    match parsed.scheme() {
        "http" | "https" => Ok(parsed),
        other => Err(FetchError::Failed(format!(
            "rss: unsupported url scheme `{other}` (only http/https allowed)"
        ))),
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use chrono::{TimeZone, Utc};
    use feed_rs::model::{Entry, Feed};
    use feed_rs::parser;
    use std::future::Future;
    use std::io::{Read, Write};
    use std::net::TcpListener;
    use std::thread;
    use std::time::Duration;

    fn ctx(shape: Option<Shape>, options: Option<toml::Value>) -> FetchContext {
        FetchContext {
            widget_id: "w".into(),
            timeout: Duration::from_secs(1),
            shape,
            options,
            ..Default::default()
        }
    }

    fn run_async<T>(future: impl Future<Output = T>) -> T {
        tokio::runtime::Builder::new_current_thread()
            .enable_all()
            .build()
            .unwrap()
            .block_on(future)
    }

    fn serve_once(
        status: &str,
        content_type: &str,
        body: &[u8],
    ) -> (String, thread::JoinHandle<()>) {
        let listener = TcpListener::bind("127.0.0.1:0").unwrap();
        let addr = listener.local_addr().unwrap();
        let status = status.to_owned();
        let content_type = content_type.to_owned();
        let body = body.to_vec();
        let handle = thread::spawn(move || {
            let (mut stream, _) = listener.accept().unwrap();
            let mut request = [0; 1024];
            let _ = stream.read(&mut request);
            let header = format!(
                "HTTP/1.1 {status}\r\ncontent-type: {content_type}\r\ncontent-length: {}\r\nconnection: close\r\n\r\n",
                body.len()
            );
            stream.write_all(header.as_bytes()).unwrap();
            stream.write_all(&body).unwrap();
            stream.flush().unwrap();
        });
        (format!("http://{addr}"), handle)
    }

    fn assert_failed_contains(err: FetchError, needle: &str) {
        assert!(
            matches!(&err, FetchError::Failed(message) if message.contains(needle)),
            "expected Failed containing {needle:?}, got {err:?}",
        );
    }

    #[test]
    fn options_default_to_none() {
        let opts = Options::default();
        assert!(opts.url.is_none());
        assert!(opts.count.is_none());
    }

    #[test]
    fn options_deserialize_url_and_count() {
        let raw: toml::Value =
            toml::from_str("url = \"https://example.com/feed.xml\"\ncount = 7").unwrap();
        let opts: Options = raw.try_into().unwrap();
        assert_eq!(opts.url.as_deref(), Some("https://example.com/feed.xml"));
        assert_eq!(opts.count, Some(7));
    }

    #[test]
    fn options_reject_unknown_keys() {
        let raw: toml::Value = toml::from_str("url = \"https://e.com\"\nbogus = 1").unwrap();
        assert!(raw.try_into::<Options>().is_err());
    }

    #[test]
    fn missing_url_is_error() {
        let err = validated_url(None).unwrap_err();
        assert_failed_contains(err, "required");
    }

    #[test]
    fn empty_url_is_error() {
        assert!(validated_url(Some("   ")).is_err());
    }

    #[test]
    fn rejects_non_http_schemes() {
        for bad in ["file:///etc/passwd", "ftp://x", "data:,abc", "javascript:0"] {
            let err = validated_url(Some(bad)).unwrap_err();
            assert!(
                matches!(
                    &err,
                    FetchError::Failed(m) if m.contains("scheme") || m.contains("invalid url"),
                ),
                "expected scheme rejection for {bad}: {err:?}",
            );
        }
    }

    #[test]
    fn accepts_http_and_https() {
        assert!(validated_url(Some("http://example.com/feed")).is_ok());
        assert!(validated_url(Some("https://example.com/feed")).is_ok());
    }

    #[test]
    fn invalid_url_syntax_is_error() {
        let err = validated_url(Some("http://[::1")).unwrap_err();
        assert_failed_contains(err, "invalid url");
    }

    const RSS_FIXTURE: &str = r#"<?xml version="1.0"?>
<rss version="2.0">
  <channel>
    <title>Example</title>
    <link>https://example.com</link>
    <description>x</description>
    <item>
      <title>First post</title>
      <link>https://example.com/1</link>
      <pubDate>Sun, 26 Apr 2026 09:00:00 +0000</pubDate>
    </item>
    <item>
      <title>Second post</title>
      <link>https://example.com/2</link>
      <pubDate>Fri, 24 Apr 2026 11:30:00 +0000</pubDate>
    </item>
  </channel>
</rss>"#;

    const ATOM_FIXTURE: &str = r#"<?xml version="1.0" encoding="utf-8"?>
<feed xmlns="http://www.w3.org/2005/Atom">
  <title>Atom Example</title>
  <id>urn:atom:1</id>
  <updated>2026-04-26T10:00:00Z</updated>
  <entry>
    <title>Atom one</title>
    <id>urn:atom:1:1</id>
    <link href="https://example.com/atom-1"/>
    <updated>2026-04-26T10:00:00Z</updated>
  </entry>
</feed>"#;

    fn parse_fixture(fixture: &str) -> Feed {
        parser::parse(fixture.as_bytes()).expect("fixture must parse")
    }

    #[test]
    fn rss_parses_into_linked_text_block_with_dates_and_urls() {
        let feed_doc = parse_fixture(RSS_FIXTURE);
        let body = feed::render_body(&feed_doc, 5, Shape::LinkedTextBlock, None, None);
        assert!(matches!(
            &body,
            Body::LinkedTextBlock(b)
                if b.items.len() == 2
                    && b.items[0].text.contains("First post")
                    && b.items[0].text.starts_with("Apr 26")
                    && b.items[0].url.as_deref() == Some("https://example.com/1"),
        ));
    }

    #[test]
    fn rss_parses_into_text_block_without_urls() {
        let feed_doc = parse_fixture(RSS_FIXTURE);
        let body = feed::render_body(&feed_doc, 5, Shape::TextBlock, None, None);
        assert!(matches!(
            &body,
            Body::TextBlock(t) if t.lines.len() == 2 && t.lines[0].contains("First post"),
        ));
    }

    #[test]
    fn atom_parses_with_link_and_date() {
        let feed_doc = parse_fixture(ATOM_FIXTURE);
        let body = feed::render_body(&feed_doc, 5, Shape::LinkedTextBlock, None, None);
        assert!(matches!(
            &body,
            Body::LinkedTextBlock(b)
                if b.items.len() == 1
                    && b.items[0].url.as_deref() == Some("https://example.com/atom-1")
                    && b.items[0].text.contains("Atom one"),
        ));
    }

    #[test]
    fn line_text_without_date_uses_title_only() {
        let mut feed_doc = parse_fixture(RSS_FIXTURE);
        feed_doc.entries[0].published = None;
        feed_doc.entries[0].updated = None;
        let text = feed::line_text(&feed_doc.entries[0], None, None);
        assert_eq!(text, "First post");
    }

    #[test]
    fn format_short_uses_explicit_timezone() {
        let dt = Utc.with_ymd_and_hms(2026, 4, 30, 23, 30, 0).unwrap();
        assert_eq!(feed::format_short(dt, Some("UTC"), None), "Apr 30");
        assert_eq!(feed::format_short(dt, Some("Asia/Tokyo"), None), "May 01");
    }

    #[test]
    fn count_caps_entries() {
        let feed_doc = parse_fixture(RSS_FIXTURE);
        let body = feed::render_body(&feed_doc, 1, Shape::LinkedTextBlock, None, None);
        assert!(matches!(
            &body,
            Body::LinkedTextBlock(b) if b.items.len() == 1,
        ));
    }

    #[test]
    fn empty_feed_renders_empty_body() {
        let empty = Feed {
            feed_type: feed_rs::model::FeedType::RSS2,
            id: String::new(),
            updated: None,
            authors: vec![],
            title: None,
            description: None,
            links: vec![],
            categories: vec![],
            contributors: vec![],
            generator: None,
            icon: None,
            language: None,
            logo: None,
            published: None,
            rating: None,
            rights: None,
            ttl: None,
            entries: vec![],
        };
        let body = feed::render_body(&empty, 5, Shape::LinkedTextBlock, None, None);
        assert!(matches!(
            &body,
            Body::LinkedTextBlock(b) if b.items.is_empty(),
        ));
    }

    #[test]
    fn missing_title_falls_back_to_placeholder() {
        let mut feed_doc = parse_fixture(RSS_FIXTURE);
        feed_doc.entries[0].title = None;
        let body = feed::render_body(&feed_doc, 1, Shape::TextBlock, None, None);
        assert!(matches!(
            &body,
            Body::TextBlock(t) if t.lines[0].contains("(no title)"),
        ));
    }

    #[test]
    fn collapses_whitespace_in_titles() {
        assert_eq!(
            feed::collapse_whitespace("hello\n  world\t!"),
            "hello world !".to_string()
        );
    }

    #[test]
    fn count_clamps_extremes() {
        assert_eq!(
            0u32.clamp(feed::MIN_COUNT, feed::MAX_COUNT),
            feed::MIN_COUNT
        );
        assert_eq!(
            999u32.clamp(feed::MIN_COUNT, feed::MAX_COUNT),
            feed::MAX_COUNT
        );
        assert_eq!(
            feed::DEFAULT_COUNT.clamp(feed::MIN_COUNT, feed::MAX_COUNT),
            feed::DEFAULT_COUNT
        );
    }

    #[test]
    fn cache_key_varies_with_url() {
        let f = RssFetcher;
        let parse_opts =
            |raw: &str| -> toml::Value { toml::from_str(raw).expect("test toml must parse") };
        let mut a = FetchContext {
            widget_id: "w".into(),
            ..Default::default()
        };
        let mut b = a.clone();
        a.options = Some(parse_opts("url = \"https://a.example/feed\""));
        b.options = Some(parse_opts("url = \"https://b.example/feed\""));
        assert_ne!(f.cache_key(&a), f.cache_key(&b));
    }

    #[test]
    fn sample_body_covers_every_declared_shape() {
        let f = RssFetcher;
        assert!(matches!(
            f.sample_body(Shape::LinkedTextBlock),
            Some(Body::LinkedTextBlock(_))
        ));
        assert!(matches!(
            f.sample_body(Shape::ImageLinkedList),
            Some(Body::ImageLinkedList(_))
        ));
        assert!(matches!(
            f.sample_body(Shape::TextBlock),
            Some(Body::TextBlock(_))
        ));
        assert!(matches!(f.sample_body(Shape::Text), Some(Body::Text(_))));
        assert!(matches!(
            f.sample_body(Shape::MarkdownTextBlock),
            Some(Body::MarkdownTextBlock(_))
        ));
        assert!(matches!(
            f.sample_body(Shape::Entries),
            Some(Body::Entries(_))
        ));
        assert!(matches!(
            f.sample_body(Shape::Timeline),
            Some(Body::Timeline(_))
        ));
        // Image samples need a real on-disk path, which test data can't supply portably —
        // `random_cat` skips it the same way.
        assert!(f.sample_body(Shape::Image).is_none());
        // Shapes outside SHAPES still return None.
        assert!(f.sample_body(Shape::Ratio).is_none());
    }

    #[test]
    fn first_inline_image_src_extracts_first_http_src() {
        let html = r#"<p>intro</p><img src="https://example.com/cover.jpg" /><img src="https://example.com/second.png">"#;
        assert_eq!(
            feed::first_inline_image_src(html).as_deref(),
            Some("https://example.com/cover.jpg"),
        );
    }

    #[test]
    fn first_inline_image_src_skips_data_and_cid_uris() {
        let html =
            r#"<img src="data:image/png;base64,AAAA"><img src="https://example.com/real.png">"#;
        assert_eq!(
            feed::first_inline_image_src(html).as_deref(),
            Some("https://example.com/real.png"),
        );
    }

    #[test]
    fn first_inline_image_src_decodes_encoded_amp_entities() {
        let html = r#"<img src="https://example.com/img.png?a&amp;b&#x3D;1">"#;
        assert_eq!(
            feed::first_inline_image_src(html).as_deref(),
            Some("https://example.com/img.png?a&b=1"),
        );
    }

    #[test]
    fn first_inline_image_src_returns_none_without_img() {
        assert!(feed::first_inline_image_src("<p>no images here</p>").is_none());
        assert!(feed::first_inline_image_src("").is_none());
    }

    #[test]
    fn thumbnail_url_falls_back_to_html_img_when_media_absent() {
        use feed_rs::model::Content;
        let entry = Entry {
            content: Some(Content {
                body: Some(r#"<p>lead</p><img src="https://example.com/hero.jpg"/>"#.to_string()),
                ..Default::default()
            }),
            ..Default::default()
        };
        assert_eq!(
            feed::thumbnail_url_for(&entry).as_deref(),
            Some("https://example.com/hero.jpg"),
        );
    }

    #[test]
    fn thumbnail_url_picks_media_thumbnail_first_then_content() {
        use feed_rs::model::{Image, MediaContent, MediaObject, MediaThumbnail};
        let mut entry = Entry::default();
        let media = MediaObject {
            title: None,
            content: vec![MediaContent {
                url: Some(Url::parse("https://example.com/big.jpg").unwrap()),
                content_type: None,
                height: None,
                width: None,
                duration: None,
                size: None,
                rating: None,
            }],
            duration: None,
            thumbnails: vec![MediaThumbnail {
                image: Image {
                    uri: "https://example.com/thumb.jpg".into(),
                    title: None,
                    link: None,
                    width: None,
                    height: None,
                    description: None,
                },
                time: None,
            }],
            texts: vec![],
            description: None,
            community: None,
            credits: vec![],
        };
        entry.media = vec![media];
        assert_eq!(
            feed::thumbnail_url_for(&entry).as_deref(),
            Some("https://example.com/thumb.jpg"),
        );

        let empty = Entry::default();
        assert!(feed::thumbnail_url_for(&empty).is_none());
    }

    #[test]
    fn thumbnail_url_for_returns_none_when_no_source_available() {
        let empty = Entry::default();
        assert!(feed::thumbnail_url_for(&empty).is_none());
    }

    #[test]
    fn subtitle_for_returns_none_when_no_signal() {
        let entry = Entry::default();
        assert!(feed::subtitle_for(&entry, None, None).is_none());
    }

    #[test]
    fn subtitle_for_falls_back_to_date_only_when_link_missing() {
        let entry = Entry {
            published: Some(chrono::Utc.with_ymd_and_hms(2026, 4, 26, 12, 0, 0).unwrap()),
            ..Default::default()
        };
        let sub = feed::subtitle_for(&entry, Some("UTC"), None).unwrap();
        assert_eq!(sub, "Apr 26");
        assert!(!sub.contains('·'));
    }

    #[test]
    fn subtitle_for_falls_back_to_host_only_when_date_missing() {
        use feed_rs::model::Link;
        let entry = Entry {
            links: vec![Link {
                href: "https://blog.rust-lang.org/post".into(),
                rel: None,
                media_type: None,
                href_lang: None,
                title: None,
                length: None,
            }],
            ..Default::default()
        };
        let sub = feed::subtitle_for(&entry, Some("UTC"), None).unwrap();
        assert_eq!(sub, "blog.rust-lang.org");
        assert!(!sub.contains('·'));
    }

    #[test]
    fn subtitle_combines_date_and_host_when_both_present() {
        use feed_rs::model::Link;
        let entry = Entry {
            published: Some(chrono::Utc.with_ymd_and_hms(2026, 4, 26, 12, 0, 0).unwrap()),
            links: vec![Link {
                href: "https://blog.rust-lang.org/post".into(),
                rel: None,
                media_type: None,
                href_lang: None,
                title: None,
                length: None,
            }],
            ..Default::default()
        };
        let sub = feed::subtitle_for(&entry, Some("UTC"), None).unwrap();
        assert!(sub.contains("Apr 26"));
        assert!(sub.contains("blog.rust-lang.org"));
    }

    #[test]
    fn fetcher_exposes_catalog_contract() {
        let fetcher = RssFetcher;
        assert_eq!(fetcher.name(), "rss");
        assert_eq!(fetcher.safety(), Safety::Network);
        assert_eq!(fetcher.default_shape(), Shape::LinkedTextBlock);
        assert_eq!(fetcher.shapes(), SHAPES);
        assert_eq!(
            fetcher
                .option_schemas()
                .iter()
                .map(|schema| schema.name)
                .collect::<Vec<_>>(),
            vec!["url", "count"]
        );
        assert!(fetcher.description().contains("feed-rs"));
    }

    #[test]
    fn whitespace_only_titles_fall_back_to_placeholder() {
        let mut feed_doc = parse_fixture(RSS_FIXTURE);
        feed_doc.entries[0].title.as_mut().unwrap().content = " \n\t ".into();
        let body = feed::render_body(&feed_doc, 1, Shape::TextBlock, None, None);
        assert!(matches!(
            &body,
            Body::TextBlock(t) if t.lines[0].contains("(no title)"),
        ));
    }

    #[test]
    fn fetch_rejects_unknown_options_before_network() {
        let raw: toml::Value =
            toml::from_str("url = \"https://example.com\"\nbogus = true").unwrap();
        let err = run_async(RssFetcher.fetch(&ctx(None, Some(raw)))).unwrap_err();
        assert_failed_contains(err, "unknown field");
    }

    #[test]
    fn fetch_rejects_invalid_url_before_network() {
        let raw: toml::Value = toml::from_str("url = \"ftp://example.com/feed.xml\"").unwrap();
        let err = run_async(RssFetcher.fetch(&ctx(None, Some(raw)))).unwrap_err();
        assert_failed_contains(err, "unsupported url scheme");
    }

    #[test]
    fn fetch_parses_remote_feed_and_uses_default_linked_shape() {
        let (url, server) = serve_once("200 OK", "application/rss+xml", RSS_FIXTURE.as_bytes());
        let raw: toml::Value = toml::from_str(&format!("url = \"{url}\"")).unwrap();
        let payload = run_async(RssFetcher.fetch(&ctx(None, Some(raw)))).unwrap();
        server.join().unwrap();
        assert!(matches!(
            &payload.body,
            Body::LinkedTextBlock(body)
                if body.items.len() == 2
                    && body.items[1].url.as_deref() == Some("https://example.com/2"),
        ));
    }

    #[test]
    fn fetch_surfaces_parse_errors_from_non_feed_body() {
        let (url, server) = serve_once("200 OK", "text/plain", b"not a feed");
        let raw: toml::Value = toml::from_str(&format!("url = \"{url}\"")).unwrap();
        let err = run_async(RssFetcher.fetch(&ctx(None, Some(raw)))).unwrap_err();
        server.join().unwrap();
        assert_failed_contains(err, "rss parse");
    }

    #[test]
    fn fetch_bytes_reports_http_status_and_size_cap() {
        let (status_url, status_server) =
            serve_once("500 Internal Server Error", "text/plain", b"oops");
        let url = validated_url(Some(&status_url)).unwrap();
        let status_err = run_async(feed::fetch_bytes(&url, "rss")).unwrap_err();
        status_server.join().unwrap();
        assert_failed_contains(status_err, "rss 500");

        let oversized = vec![b'x'; feed::MAX_BYTES + 1];
        let (size_url, size_server) = serve_once("200 OK", "application/octet-stream", &oversized);
        let url = validated_url(Some(&size_url)).unwrap();
        let size_err = run_async(feed::fetch_bytes(&url, "rss")).unwrap_err();
        size_server.join().unwrap();
        assert_failed_contains(size_err, "too large");
    }

    /// Atom feeds frequently carry both `rel="self"` (feed-internal permalink) and
    /// `rel="alternate"` (the article URL). Picking the first non-empty link would surface the
    /// self-pointer; readers want the alternate.
    const ATOM_MULTI_REL_FIXTURE: &str = r#"<?xml version="1.0" encoding="utf-8"?>
<feed xmlns="http://www.w3.org/2005/Atom">
  <title>multi rel</title>
  <id>urn:atom:m</id>
  <updated>2026-04-26T10:00:00Z</updated>
  <entry>
    <title>Pick the article URL</title>
    <id>urn:atom:m:1</id>
    <link rel="self" href="https://feed.example.com/entries/1"/>
    <link rel="alternate" href="https://example.com/articles/1"/>
    <updated>2026-04-26T10:00:00Z</updated>
  </entry>
</feed>"#;

    #[test]
    fn link_prefers_alternate_over_self_in_atom() {
        let feed_doc = parse_fixture(ATOM_MULTI_REL_FIXTURE);
        let body = feed::render_body(&feed_doc, 5, Shape::LinkedTextBlock, None, None);
        assert!(matches!(
            &body,
            Body::LinkedTextBlock(b)
                if b.items[0].url.as_deref() == Some("https://example.com/articles/1"),
        ));
    }

    #[test]
    fn link_falls_back_to_first_non_empty_href_when_no_alternate_exists() {
        let mut feed_doc = parse_fixture(ATOM_FIXTURE);
        feed_doc.entries[0].links[0].rel = Some("self".into());
        assert_eq!(
            feed::link_for(&feed_doc.entries[0]).as_deref(),
            Some("https://example.com/atom-1")
        );
    }

    #[test]
    fn fetch_bytes_reports_request_failure_for_unreachable_host() {
        let listener = TcpListener::bind("127.0.0.1:0").unwrap();
        let url_str = format!("http://{}/feed.xml", listener.local_addr().unwrap());
        drop(listener);
        let url = validated_url(Some(&url_str)).unwrap();
        let err = run_async(feed::fetch_bytes(&url, "rss")).unwrap_err();
        assert_failed_contains(err, "rss request failed");
    }

    #[tokio::test]
    #[ignore]
    async fn live_rust_blog_feed_returns_at_least_one_entry() {
        let url = validated_url(Some("https://blog.rust-lang.org/feed.xml")).unwrap();
        let bytes = feed::fetch_bytes(&url, "rss").await.unwrap();
        let feed_doc = feed::parse_feed(&bytes, "rss").unwrap();
        assert!(!feed_doc.entries.is_empty());
        let body = feed::render_body(&feed_doc, 3, Shape::LinkedTextBlock, None, None);
        if let Body::LinkedTextBlock(b) = body {
            for it in &b.items {
                eprintln!("{}  -> {:?}", it.text, it.url);
            }
        }
    }

    #[tokio::test]
    #[ignore]
    async fn live_bbc_tech_thumbnail_url_extracts_media_thumbnail() {
        let url = validated_url(Some("https://feeds.bbci.co.uk/news/technology/rss.xml")).unwrap();
        let bytes = feed::fetch_bytes(&url, "rss").await.unwrap();
        let feed_doc = feed::parse_feed(&bytes, "rss").unwrap();
        let with_thumb = feed_doc
            .entries
            .iter()
            .take(5)
            .filter(|e| feed::thumbnail_url_for(e).is_some())
            .count();
        for entry in feed_doc.entries.iter().take(5) {
            eprintln!(
                "{:?} -> {:?}",
                entry.title.as_ref().map(|t| &t.content),
                feed::thumbnail_url_for(entry),
            );
        }
        assert!(
            with_thumb > 0,
            "expected at least one entry with a media:thumbnail",
        );
    }
}