fix: preserve xml entities in xmltv

crates/ersatztv-playout-generator/src/xmltv.rs

@@ -130,18 +130,21 @@ fn read_existing_programmes(
                 let stop = OffsetDateTime::parse(&stop_s, &XMLTV_FMT)?;
 
                 let mut title = String::new();
-                let mut in_title = false;
                 loop {
                     match reader
                         .read_event_into(&mut inner_buf)
                         .map_err(std::io::Error::other)?
                     {
-                        Event::Start(t) if t.name().as_ref() == b"title" => in_title = true,
-                        Event::End(t) if t.name().as_ref() == b"title" => in_title = false,
-                        Event::Text(t) if in_title => title.push_str(
-                            &t.xml_content(XmlVersion::Implicit1_0)
-                                .map_err(std::io::Error::other)?,
-                        ),
+                        Event::Start(t) if t.name().as_ref() == b"title" => {
+                            let mut text_buf = Vec::new();
+                            let text_event = reader
+                                .read_text_into(t.name(), &mut text_buf)
+                                .map_err(std::io::Error::other)?;
+                            let text = text_event.decode().map_err(std::io::Error::other)?;
+                            title = quick_xml::escape::unescape(&text)
+                                .map_err(std::io::Error::other)?
+                                .into_owned();
+                        }
                         Event::End(t) if t.name().as_ref() == b"programme" => break,
                         Event::Eof => break,
                         _ => {}

crates/ersatztv/src/channel_session.rs

@@ -48,7 +48,7 @@ impl ChannelSession {
 
             let _ = child.wait().await;
             watcher.abort();
-            log::debug!("channel {} exited", &channel_number);
+            log::debug!("channel {} exited", channel_number);
             active.lock().await.remove(&channel_number);
 
             if ready_file.exists() {

crates/ersatztv/src/xmltv.rs

@@ -88,7 +88,7 @@ fn copy_programmes<R: BufRead, W: Write>(
     buf: &mut Vec<u8>,
 ) -> std::io::Result<()> {
     let mut reader = Reader::from_reader(reader);
-    reader.config_mut().trim_text(true);
+    reader.config_mut().trim_text(false);
     let mut depth = 0u32;
     loop {
         match reader.read_event_into(buf).map_err(std::io::Error::other)? {
@@ -103,12 +103,61 @@ fn copy_programmes<R: BufRead, W: Write>(
             Event::Empty(e) if e.name().as_ref() == b"programme" || depth > 0 => {
                 writer.write_event(Event::Empty(e))?
             }
-            Event::Text(e) if depth > 0 => writer.write_event(Event::Text(e))?,
-            Event::CData(e) if depth > 0 => writer.write_event(Event::CData(e))?,
             Event::Eof => return Ok(()),
+            other if depth > 0 => {
+                writer.write_event(other)?;
+            }
             _ => {}
         }
 
         buf.clear();
     }
 }
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    // regression test for #172: entity/character references inside programmes were
+    // dropped because quick-xml emits them as separate `Event::GeneralRef`
+    // events that the copy loop did not forward.
+    #[test]
+    fn copy_programmes_preserves_entities_and_children() {
+        let input = r#"<?xml version="1.0" encoding="UTF-8"?>
+<tv generator-info-name="ErsatzTV">
+  <programme start="20260630153000 -0600" stop="20260630160000 -0600" channel="tv.1">
+    <title lang="en">Mister Rogers&#39; Neighborhood</title>
+    <sub-title lang="en">DAY CARE &amp; NIGHT CARE</sub-title>
+    <desc lang="en">Line one.&#xA;&#xA;Line two.</desc>
+    <category lang="en">Kids</category>
+    <episode-num system="onscreen">S13E16</episode-num>
+  </programme>
+</tv>"#;
+
+        let mut writer = Writer::new(Cursor::new(Vec::new()));
+        let mut buf = Vec::new();
+        copy_programmes(input.as_bytes(), &mut writer, &mut buf).unwrap();
+        let output = String::from_utf8(writer.into_inner().into_inner()).unwrap();
+
+        assert!(
+            output.contains("Mister Rogers&#39; Neighborhood"),
+            "apostrophe reference dropped: {output}"
+        );
+        assert!(
+            output.contains("DAY CARE &amp; NIGHT CARE"),
+            "ampersand reference dropped: {output}"
+        );
+        assert!(
+            output.contains("Line one.&#xA;&#xA;Line two."),
+            "newline references dropped: {output}"
+        );
+        assert!(
+            output.contains(r#"<sub-title lang="en">"#),
+            "child element dropped: {output}"
+        );
+        assert!(
+            output.contains(r#"<episode-num system="onscreen">S13E16</episode-num>"#),
+            "child element dropped: {output}"
+        );
+    }
+}

crates/ffpipeline/src/probe.rs

@@ -175,8 +175,7 @@ impl std::fmt::Display for ProbeResult {
         write!(
             f,
             "{}",
-            &self
-                .streams
+            self.streams
                 .iter()
                 .map(|s| s.to_string())
                 .collect::<Vec<String>>()