1 files changed, 32 insertions, 4 deletions

diff --git a/src/voice/mod.rs b/src/voice/mod.rs
index d8308eb..2866f54 100644
--- a/src/voice/mod.rs
+++ b/src/voice/mod.rs
@@ -342,15 +342,17 @@ impl tokio::io::AsyncRead for FfmpegChild {
     }
 }
 
-/// Decode a local audio file via ffmpeg to raw f32 PCM at 48 kHz stereo.
-/// No reconnect flags (those are for HTTP streams only).
-pub async fn ffmpeg_decode_file(path: &str) -> Result<songbird::input::Input> {
+/// Decode an in-memory audio file via ffmpeg to raw f32 PCM at 48 kHz stereo.
+///
+/// Used for compressed playback so the intermediate file never has to touch
+/// disk (and therefore cannot leak into `TEMP_PATH`).
+pub async fn ffmpeg_decode_bytes(data: Vec<u8>) -> Result<songbird::input::Input> {
     use std::process::Stdio;
 
     let mut child = tokio::process::Command::new("ffmpeg")
         .args([
             "-i",
-            path,
+            "pipe:0",
             "-vn",
             "-f",
             "f32le",
@@ -360,17 +362,43 @@ pub async fn ffmpeg_decode_file(path: &str) -> Result<songbird::input::Input> {
             "2",
             "pipe:1",
         ])
+        .stdin(Stdio::piped())
         .stdout(Stdio::piped())
         .stderr(Stdio::piped())
         .kill_on_drop(true)
         .spawn()
         .map_err(|e| Error::Custom(format!("ffmpeg decode spawn: {e}")))?;
 
+    let mut stdin = child
+        .stdin
+        .take()
+        .ok_or_else(|| Error::Custom("ffmpeg stdin not captured".into()))?;
     let stdout = child
         .stdout
         .take()
         .ok_or_else(|| Error::Custom("ffmpeg stdout not captured".into()))?;
 
+    tokio::spawn(async move {
+        use tokio::io::AsyncWriteExt;
+        let _ = stdin.write_all(&data).await;
+        // Dropping stdin gives ffmpeg EOF.
+    });
+
+    if let Some(stderr) = child.stderr.take() {
+        tokio::spawn(async move {
+            use tokio::io::AsyncReadExt;
+            let mut buf = Vec::with_capacity(4096);
+            let mut reader = tokio::io::BufReader::new(stderr);
+            let _ = reader.read_to_end(&mut buf).await;
+            if !buf.is_empty() {
+                warn!(
+                    "ffmpeg (decode) stderr: {}",
+                    String::from_utf8_lossy(&buf).trim_end()
+                );
+            }
+        });
+    }
+
     let ffmpeg_child = FfmpegChild {
         _child: child,
         stdout,