vst3_host/

audio.rs

//! Audio types and utilities for VST3 host

/// Audio buffers for plugin processing
#[derive(Debug)]
pub struct AudioBuffers {
    /// Input audio buffers, indexed `[channel][sample]`.
    pub inputs: Vec<Vec<f32>>,
    /// Output audio buffers, indexed `[channel][sample]`.
    pub outputs: Vec<Vec<f32>>,
    /// Sample rate in Hz
    pub sample_rate: f64,
    /// Number of samples per buffer
    pub block_size: usize,
}

impl AudioBuffers {
    /// Create new audio buffers
    pub fn new(
        input_channels: usize,
        output_channels: usize,
        block_size: usize,
        sample_rate: f64,
    ) -> Self {
        let inputs = vec![vec![0.0; block_size]; input_channels];
        let outputs = vec![vec![0.0; block_size]; output_channels];

        Self {
            inputs,
            outputs,
            sample_rate,
            block_size,
        }
    }

    /// Clear all buffers to silence
    pub fn clear(&mut self) {
        for buffer in &mut self.inputs {
            buffer.fill(0.0);
        }
        for buffer in &mut self.outputs {
            buffer.fill(0.0);
        }
    }

    /// Get the number of input channels
    pub fn input_channels(&self) -> usize {
        self.inputs.len()
    }

    /// Get the number of output channels
    pub fn output_channels(&self) -> usize {
        self.outputs.len()
    }
}

/// Configuration of one VST3 audio bus.
#[derive(Debug, Clone, Copy, PartialEq, Eq, serde::Serialize, serde::Deserialize)]
pub struct AudioBusConfig {
    /// Number of channels advertised for this bus.
    pub channel_count: usize,
    /// Whether the bus is currently active in the component.
    pub active: bool,
}

/// Current audio-bus configuration, preserving every VST3 bus index.
#[derive(Debug, Clone, PartialEq, Eq, serde::Serialize, serde::Deserialize)]
pub struct AudioBusLayout {
    /// Input buses in VST3 bus-index order.
    pub inputs: Vec<AudioBusConfig>,
    /// Output buses in VST3 bus-index order.
    pub outputs: Vec<AudioBusConfig>,
}

/// Sample storage for one VST3 audio bus.
#[derive(Debug, Clone, PartialEq, serde::Serialize, serde::Deserialize)]
pub struct AudioBusBuffer {
    /// Whether this bus was active when the buffer set was created.
    ///
    /// Processing validates this against the plug-in's current activation state. Recreate the
    /// buffer set after changing bus activation.
    pub active: bool,
    /// Samples indexed `[channel][sample]`. Inactive buses retain their advertised channels so
    /// their bus index and shape are never lost; their inputs are ignored and outputs silenced.
    #[serde(with = "crate::process_isolation::audio_codec")]
    pub channels: Vec<Vec<f32>>,
}

impl AudioBusBuffer {
    /// Allocate a silent bus with the requested shape.
    pub fn new(channel_count: usize, block_size: usize, active: bool) -> Self {
        Self {
            active,
            channels: vec![vec![0.0; block_size]; channel_count],
        }
    }
}

/// Bus-aware audio buffers preserving every input/output bus as a distinct slot.
#[derive(Debug, Clone, PartialEq)]
pub struct BusAudioBuffers {
    /// Input buses in VST3 bus-index order.
    pub inputs: Vec<AudioBusBuffer>,
    /// Output buses in VST3 bus-index order.
    pub outputs: Vec<AudioBusBuffer>,
    /// Sample rate in Hz.
    pub sample_rate: f64,
    /// Nominal number of samples per channel.
    pub block_size: usize,
}

impl BusAudioBuffers {
    /// Allocate silent buffers from a previously queried [`AudioBusLayout`].
    pub fn new(layout: &AudioBusLayout, block_size: usize, sample_rate: f64) -> Self {
        let make = |config: &AudioBusConfig| {
            AudioBusBuffer::new(config.channel_count, block_size, config.active)
        };
        Self {
            inputs: layout.inputs.iter().map(make).collect(),
            outputs: layout.outputs.iter().map(make).collect(),
            sample_rate,
            block_size,
        }
    }

    /// Clear all input and output buses to silence.
    pub fn clear(&mut self) {
        for bus in self.inputs.iter_mut().chain(&mut self.outputs) {
            for channel in &mut bus.channels {
                channel.fill(0.0);
            }
        }
    }
}

/// Audio level information for a single channel
#[derive(Debug, Clone, Copy)]
pub struct ChannelLevel {
    /// Peak level (0.0 to 1.0, where 1.0 = 0dB)
    pub peak: f32,
    /// RMS level (0.0 to 1.0)
    pub rms: f32,
    /// Peak hold level (0.0 to 1.0)
    pub peak_hold: f32,
}

impl Default for ChannelLevel {
    fn default() -> Self {
        Self {
            peak: 0.0,
            rms: 0.0,
            peak_hold: 0.0,
        }
    }
}

impl ChannelLevel {
    /// Convert peak level to decibels
    pub fn peak_db(&self) -> f32 {
        if self.peak <= 0.0 {
            -f32::INFINITY
        } else {
            20.0 * self.peak.log10()
        }
    }

    /// Convert RMS level to decibels
    pub fn rms_db(&self) -> f32 {
        if self.rms <= 0.0 {
            -f32::INFINITY
        } else {
            20.0 * self.rms.log10()
        }
    }

    /// Check if the signal is clipping (> 0dB)
    pub fn is_clipping(&self) -> bool {
        self.peak > 1.0
    }
}

/// Audio level information for all channels
#[derive(Debug, Clone)]
pub struct AudioLevels {
    /// Level information for each channel
    pub channels: Vec<ChannelLevel>,
}

impl AudioLevels {
    /// Create new audio levels for the given number of channels
    pub fn new(channel_count: usize) -> Self {
        Self {
            channels: vec![ChannelLevel::default(); channel_count],
        }
    }

    /// Update levels from audio buffers
    pub fn update_from_buffers(&mut self, buffers: &[Vec<f32>]) {
        for (i, buffer) in buffers.iter().enumerate() {
            if i >= self.channels.len() {
                break;
            }

            // Calculate peak
            let peak = buffer.iter().map(|&x| x.abs()).fold(0.0f32, f32::max);

            // Calculate RMS (guard against a zero-length channel buffer → 0/0 = NaN).
            let sum_squares: f32 = buffer.iter().map(|&x| x * x).sum();
            let rms = if buffer.is_empty() {
                0.0
            } else {
                (sum_squares / buffer.len() as f32).sqrt()
            };

            // Update channel levels
            let channel = &mut self.channels[i];
            channel.peak = peak;
            channel.rms = rms;

            // Update peak hold if necessary
            if peak > channel.peak_hold {
                channel.peak_hold = peak;
            }
        }
    }

    /// Update levels from active output buses, preserving bus/channel order.
    pub fn update_from_bus_buffers(&mut self, buses: &[AudioBusBuffer]) {
        let mut level_index = 0usize;
        for channel in buses
            .iter()
            .filter(|bus| bus.active)
            .flat_map(|bus| &bus.channels)
        {
            let Some(level) = self.channels.get_mut(level_index) else {
                break;
            };
            let peak = channel
                .iter()
                .map(|sample| sample.abs())
                .fold(0.0, f32::max);
            let sum_squares: f32 = channel.iter().map(|sample| sample * sample).sum();
            level.peak = peak;
            level.rms = if channel.is_empty() {
                0.0
            } else {
                (sum_squares / channel.len() as f32).sqrt()
            };
            level.peak_hold = level.peak_hold.max(peak);
            level_index += 1;
        }
        for level in self.channels.iter_mut().skip(level_index) {
            level.peak = 0.0;
            level.rms = 0.0;
        }
    }

    /// Reset peak hold values
    pub fn reset_peak_hold(&mut self) {
        for channel in &mut self.channels {
            channel.peak_hold = channel.peak;
        }
    }

    /// Check if any channel is clipping
    pub fn is_clipping(&self) -> bool {
        self.channels.iter().any(|ch| ch.is_clipping())
    }
}

/// A VST3 speaker arrangement: a bitmask where each set bit is one channel (so the channel
/// count is the number of set bits). Wraps the SDK's `SpeakerArrangement` (a `u64` bitmask);
/// use the named constants or [`from_raw`](Self::from_raw).
#[derive(Debug, Clone, Copy, PartialEq, Eq, serde::Serialize, serde::Deserialize)]
pub struct SpeakerArrangement(pub u64);

impl SpeakerArrangement {
    /// No channels (`kEmpty`).
    pub const EMPTY: Self = Self(0);
    /// Mono (`kMono` = front-center).
    pub const MONO: Self = Self(0x0008_0000);
    /// Stereo L/R (`kStereo`).
    pub const STEREO: Self = Self(0x3);
    /// Stereo surround Ls/Rs (`kStereoSurround`).
    pub const STEREO_SURROUND: Self = Self(0x30);

    /// Wrap a raw VST3 `SpeakerArrangement` bitmask.
    pub fn from_raw(bits: u64) -> Self {
        Self(bits)
    }

    /// The raw VST3 bitmask.
    pub fn raw(self) -> u64 {
        self.0
    }

    /// Number of channels in this arrangement (the count of set bits).
    pub fn channel_count(self) -> usize {
        self.0.count_ones() as usize
    }
}

/// The kind of data a VST3 bus carries: PCM audio or events (MIDI). Maps to the SDK's
/// `MediaTypes` (`kAudio` / `kEvent`).
#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash, serde::Serialize, serde::Deserialize)]
pub enum MediaType {
    /// Audio (PCM sample) buses (`kAudio`).
    Audio,
    /// Event / MIDI buses (`kEvent`).
    Event,
}

/// Which side of the plugin a bus sits on: input or output. Maps to the SDK's
/// `BusDirections` (`kInput` / `kOutput`).
#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash, serde::Serialize, serde::Deserialize)]
pub enum BusDirection {
    /// An input bus (`kInput`).
    Input,
    /// An output bus (`kOutput`).
    Output,
}

/// The speaker arrangements of a plugin's audio input and output buses.
#[derive(Debug, Clone, PartialEq, Eq, serde::Serialize, serde::Deserialize)]
pub struct BusArrangements {
    /// Arrangement of each audio input bus, in bus-index order.
    pub inputs: Vec<SpeakerArrangement>,
    /// Arrangement of each audio output bus, in bus-index order.
    pub outputs: Vec<SpeakerArrangement>,
}

/// A single-channel peak meter with falling ballistics and a timed peak-hold marker —
/// the behaviour a level meter UI wants but [`AudioLevels`]'s sticky `peak_hold` doesn't give.
///
/// Time is **injected** ([`push`](Self::push) takes `now: Instant`) so the meter is
/// deterministic and independent of any clock — pass `Instant::now()` from real code, or
/// synthetic instants in tests. Feed it the per-block peak amplitude; read [`level`](Self::level)
/// for the falling meter value and [`peak_hold`](Self::peak_hold) for the held marker.
///
/// ```
/// use std::time::{Duration, Instant};
/// use vst3_host::audio::PeakMeter;
///
/// let mut meter = PeakMeter::new(20.0, Duration::from_secs(2)); // 20 dB/s fall, 2 s hold
/// let t0 = Instant::now();
/// meter.push(0.8, t0);
/// assert_eq!(meter.level(), 0.8);
/// // After silence the displayed level falls but the hold marker stays put (within the window).
/// meter.push(0.0, t0 + Duration::from_millis(100));
/// assert!(meter.level() < 0.8 && meter.level() > 0.0);
/// assert_eq!(meter.peak_hold(), 0.8);
/// ```
#[derive(Debug, Clone)]
pub struct PeakMeter {
    fall_db_per_sec: f32,
    hold: std::time::Duration,
    level: f32,
    peak_hold: f32,
    peak_hold_at: Option<std::time::Instant>,
    last: Option<std::time::Instant>,
}

impl PeakMeter {
    /// Below this the level snaps to exactly 0.0 (≈ -100 dB), so a meter fully empties
    /// instead of asymptotically approaching zero forever.
    const SILENCE: f32 = 1e-5;

    /// Create a meter that falls at `fall_db_per_sec` decibels per second and holds the peak
    /// marker for `hold` before it, too, begins to fall. A typical UI meter uses ~20 dB/s and
    /// a 1–3 second hold.
    pub fn new(fall_db_per_sec: f32, hold: std::time::Duration) -> Self {
        Self {
            fall_db_per_sec: fall_db_per_sec.max(0.0),
            hold,
            level: 0.0,
            peak_hold: 0.0,
            peak_hold_at: None,
            last: None,
        }
    }

    /// Linear gain after falling for `dt`, e.g. `10^(-(dB/s · dt)/20)`.
    fn decay(&self, dt: std::time::Duration) -> f32 {
        let db = self.fall_db_per_sec * dt.as_secs_f32();
        10f32.powf(-db / 20.0)
    }

    /// Update with a new block's peak amplitude (`0.0..`) observed at `now`. The displayed
    /// level rises instantly to a louder peak and decays toward quieter input; the hold marker
    /// latches the loudest value and only starts falling once `hold` has elapsed since it was set.
    pub fn push(&mut self, block_peak: f32, now: std::time::Instant) {
        // Treat non-finite input (NaN/±inf from a misbehaving plugin) as silence so it can't
        // permanently poison the meter — `inf * decay` stays inf and would never fall.
        let block_peak = if block_peak.is_finite() {
            block_peak.max(0.0)
        } else {
            0.0
        };
        let decay = match self.last {
            Some(prev) => self.decay(now.saturating_duration_since(prev)),
            None => 1.0,
        };

        self.level = (self.level * decay).max(block_peak);
        if self.level < Self::SILENCE {
            self.level = 0.0;
        }

        if block_peak >= self.peak_hold {
            // New loudest value — latch it and restart the hold timer.
            self.peak_hold = block_peak;
            self.peak_hold_at = Some(now);
        } else if self
            .peak_hold_at
            .is_some_and(|at| now.saturating_duration_since(at) > self.hold)
        {
            // Hold window expired — the marker falls at the same ballistic, never below `level`.
            self.peak_hold = (self.peak_hold * decay).max(self.level);
            if self.peak_hold < Self::SILENCE {
                self.peak_hold = 0.0;
            }
        }

        self.last = Some(now);
    }

    /// The current falling-meter level (`0.0..`).
    pub fn level(&self) -> f32 {
        self.level
    }

    /// The held peak marker (`0.0..`).
    pub fn peak_hold(&self) -> f32 {
        self.peak_hold
    }

    /// Reset the meter to silence.
    pub fn reset(&mut self) {
        self.level = 0.0;
        self.peak_hold = 0.0;
        self.peak_hold_at = None;
        self.last = None;
    }
}

/// A moving-window RMS estimator over the most recent `N` samples.
///
/// Unlike [`AudioLevels`]'s per-block RMS (which resets every buffer), this gives a smooth
/// level over a fixed time window regardless of block size — feed it samples or whole blocks
/// and read [`rms`](Self::rms). The window length in samples is `window_secs · sample_rate`.
///
/// ```
/// use vst3_host::audio::RmsWindow;
///
/// let mut rms = RmsWindow::new(4);
/// for _ in 0..4 { rms.push_sample(0.5); }
/// assert!((rms.rms() - 0.5).abs() < 1e-6); // constant 0.5 → RMS 0.5
/// ```
#[derive(Debug, Clone)]
pub struct RmsWindow {
    capacity: usize,
    squares: std::collections::VecDeque<f32>,
    // f64 accumulator so a meter running for the lifetime of a stream (millions of
    // add/subtract cycles) doesn't drift from f32 rounding error.
    sum: f64,
}

impl RmsWindow {
    /// Create a window holding the most recent `window_samples` samples (minimum 1).
    pub fn new(window_samples: usize) -> Self {
        let capacity = window_samples.max(1);
        Self {
            capacity,
            squares: std::collections::VecDeque::with_capacity(capacity),
            sum: 0.0,
        }
    }

    /// Create a window sized for `window_secs` of audio at `sample_rate` Hz.
    ///
    /// The sample count is clamped: a non-finite or absurd duration/rate would otherwise saturate
    /// to `usize::MAX` and panic in `VecDeque::with_capacity`.
    pub fn from_duration(window_secs: f32, sample_rate: f64) -> Self {
        const MAX_WINDOW_SAMPLES: f64 = (1u64 << 26) as f64; // ~23 min at 48 kHz; 256 MiB of f32
        let samples = window_secs.max(0.0) as f64 * sample_rate;
        let samples = if samples.is_finite() {
            samples.round().clamp(1.0, MAX_WINDOW_SAMPLES) as usize
        } else {
            1
        };
        Self::new(samples)
    }

    /// Add one sample, evicting the oldest if the window is full.
    pub fn push_sample(&mut self, sample: f32) {
        // Treat a non-finite square as silence. The running sum is an accumulator: a single NaN
        // (or an overflow to infinity from a huge sample) poisons it permanently, because evicting
        // that entry subtracts NaN again. `rms()`'s `max(0.0)` guard then reports NaN as 0.0, so
        // the meter would read digital silence for the rest of its life while audio flows.
        let sq = sample * sample;
        let sq = if sq.is_finite() { sq } else { 0.0 };
        if self.squares.len() == self.capacity {
            if let Some(old) = self.squares.pop_front() {
                self.sum -= old as f64;
            }
        }
        self.squares.push_back(sq);
        self.sum += sq as f64;
    }

    /// Add a whole block of samples.
    pub fn push_block(&mut self, block: &[f32]) {
        for &s in block {
            self.push_sample(s);
        }
    }

    /// Current RMS over the samples in the window (`0.0` when empty).
    pub fn rms(&self) -> f32 {
        if self.squares.is_empty() {
            return 0.0;
        }
        // Guard against tiny negative drift from float subtraction.
        (self.sum.max(0.0) / self.squares.len() as f64).sqrt() as f32
    }

    /// Number of samples currently in the window.
    pub fn len(&self) -> usize {
        self.squares.len()
    }

    /// Whether the window holds no samples yet.
    pub fn is_empty(&self) -> bool {
        self.squares.is_empty()
    }

    /// Drop all samples.
    pub fn clear(&mut self) {
        self.squares.clear();
        self.sum = 0.0;
    }
}

/// Audio processing configuration
#[derive(Debug, Clone, Copy)]
pub struct AudioConfig {
    /// Sample rate in Hz
    pub sample_rate: f64,
    /// Block size in samples
    pub block_size: usize,
    /// Number of input channels
    pub input_channels: usize,
    /// Number of output channels
    pub output_channels: usize,
    /// Transport tempo in beats per minute, advertised to plugins in the host
    /// `ProcessContext` (drives tempo-synced DSP such as LFOs and synced delays).
    pub tempo: f64,
    /// Time signature numerator (beats per bar), advertised in the `ProcessContext`.
    pub time_sig_numerator: i32,
    /// Time signature denominator (note value of one beat), advertised in the
    /// `ProcessContext`.
    pub time_sig_denominator: i32,
}

impl Default for AudioConfig {
    fn default() -> Self {
        Self {
            sample_rate: 44100.0,
            block_size: 512,
            input_channels: 0,
            output_channels: 2,
            tempo: 120.0,
            time_sig_numerator: 4,
            time_sig_denominator: 4,
        }
    }
}

/// Audio stream trait for controlling playback.
///
/// Deliberately **not** `Send`: real backends (cpal among them) make their stream handle
/// thread-affine — construction, `play`/`pause` and teardown must all happen on the thread
/// that opened the device. Implementations that *are* movable simply also implement `Send`;
/// nothing here takes that away.
pub trait AudioStream {
    /// Start playback
    fn play(&self) -> Result<(), Box<dyn std::error::Error>>;

    /// Pause playback
    fn pause(&self) -> Result<(), Box<dyn std::error::Error>>;
}

/// Audio backend trait for creating audio streams
#[allow(clippy::type_complexity)] // Box<dyn FnMut...> callbacks are intrinsic to the API
pub trait AudioBackend: Send + Sync {
    /// The stream type this backend produces. Not required to be `Send` — see [`AudioStream`].
    type Stream: AudioStream + 'static;
    /// The device type this backend uses
    type Device: Send + Sync;
    /// The error type this backend returns
    type Error: std::error::Error + Send + Sync + 'static;

    /// Enumerate available output devices
    fn enumerate_output_devices(&self) -> Result<Vec<Self::Device>, Self::Error>;

    /// Enumerate available input devices
    fn enumerate_input_devices(&self) -> Result<Vec<Self::Device>, Self::Error>;

    /// Get the default output device
    fn default_output_device(&self) -> Option<Self::Device>;

    /// Get the default input device
    fn default_input_device(&self) -> Option<Self::Device>;

    /// Create an output stream
    fn create_output_stream(
        &self,
        device: &Self::Device,
        config: AudioConfig,
        data_callback: Box<dyn FnMut(&mut [f32]) + Send>,
        error_callback: Box<dyn FnMut(Self::Error) + Send>,
    ) -> Result<Self::Stream, Self::Error>;

    /// Create an input stream
    fn create_input_stream(
        &self,
        device: &Self::Device,
        config: AudioConfig,
        data_callback: Box<dyn FnMut(&[f32]) + Send>,
        error_callback: Box<dyn FnMut(Self::Error) + Send>,
    ) -> Result<Self::Stream, Self::Error>;
}

/// Write deinterleaved channel buffers to a 32-bit float WAV file (`WAVE_FORMAT_IEEE_FLOAT`).
///
/// `channels[ch][frame]`; all channels must be the same length. Used by offline rendering
/// (e.g. [`crate::simple::render_to_wav`]) and audio export. No external dependency.
pub fn write_wav<P: AsRef<std::path::Path>>(
    path: P,
    channels: &[Vec<f32>],
    sample_rate: u32,
) -> crate::error::Result<()> {
    use crate::error::Error;
    use std::io::Write;

    let num_channels = channels.len().max(1) as u16;
    let frames = channels.iter().map(|c| c.len()).min().unwrap_or(0);
    let bits_per_sample: u16 = 32;
    let block_align = num_channels * (bits_per_sample / 8);
    let byte_rate = sample_rate * block_align as u32;
    let data_size = (frames * num_channels as usize * (bits_per_sample / 8) as usize) as u32;

    let mut buf: Vec<u8> = Vec::with_capacity(44 + data_size as usize);
    buf.extend_from_slice(b"RIFF");
    buf.extend_from_slice(&(36 + data_size).to_le_bytes());
    buf.extend_from_slice(b"WAVE");
    buf.extend_from_slice(b"fmt ");
    buf.extend_from_slice(&16u32.to_le_bytes());
    buf.extend_from_slice(&3u16.to_le_bytes()); // IEEE float
    buf.extend_from_slice(&num_channels.to_le_bytes());
    buf.extend_from_slice(&sample_rate.to_le_bytes());
    buf.extend_from_slice(&byte_rate.to_le_bytes());
    buf.extend_from_slice(&block_align.to_le_bytes());
    buf.extend_from_slice(&bits_per_sample.to_le_bytes());
    buf.extend_from_slice(b"data");
    buf.extend_from_slice(&data_size.to_le_bytes());
    // Interleave channels frame by frame.
    for f in 0..frames {
        for ch in channels {
            buf.extend_from_slice(&ch[f].to_le_bytes());
        }
    }

    let mut file =
        std::fs::File::create(path).map_err(|e| Error::Other(format!("create wav: {e}")))?;
    file.write_all(&buf)
        .map_err(|e| Error::Other(format!("write wav: {e}")))?;
    Ok(())
}

/// Read a WAV file written as 32-bit float (`WAVE_FORMAT_IEEE_FLOAT`) or 16-bit PCM, returning
/// deinterleaved channels (`channels[ch][frame]`) and the sample rate. The inverse of
/// [`write_wav`]; used to feed a recorded signal into a plugin's input.
pub fn read_wav<P: AsRef<std::path::Path>>(path: P) -> crate::error::Result<(Vec<Vec<f32>>, u32)> {
    use crate::error::Error;
    let data = std::fs::read(path).map_err(|e| Error::Other(format!("read wav: {e}")))?;
    let err = |m: &str| Error::Other(format!("invalid wav: {m}"));
    if data.len() < 44 || &data[0..4] != b"RIFF" || &data[8..12] != b"WAVE" {
        return Err(err("not a RIFF/WAVE file"));
    }
    // Walk chunks to find fmt and data (handles extra chunks before data).
    let (mut fmt_tag, mut channels, mut sample_rate, mut bits) = (0u16, 0u16, 0u32, 0u16);
    let mut data_range: Option<(usize, usize)> = None;
    let mut pos = 12;
    while pos + 8 <= data.len() {
        let id = &data[pos..pos + 4];
        let size = u32::from_le_bytes([data[pos + 4], data[pos + 5], data[pos + 6], data[pos + 7]])
            as usize;
        let body = pos + 8;
        if id == b"fmt " && body + 16 <= data.len() {
            fmt_tag = u16::from_le_bytes([data[body], data[body + 1]]);
            channels = u16::from_le_bytes([data[body + 2], data[body + 3]]);
            sample_rate = u32::from_le_bytes([
                data[body + 4],
                data[body + 5],
                data[body + 6],
                data[body + 7],
            ]);
            bits = u16::from_le_bytes([data[body + 14], data[body + 15]]);
        } else if id == b"data" {
            data_range = Some((body, (body + size).min(data.len())));
        }
        pos = body + size + (size & 1); // chunks are word-aligned
    }
    let (ds, de) = data_range.ok_or_else(|| err("no data chunk"))?;
    if channels == 0 {
        return Err(err("zero channels"));
    }
    let nch = channels as usize;
    let mut out: Vec<Vec<f32>> = vec![Vec::new(); nch];
    let bytes = &data[ds..de];
    match (fmt_tag, bits) {
        (3, 32) => {
            for (i, frame) in bytes.chunks_exact(4 * nch).enumerate() {
                let _ = i;
                for (ch, s) in frame.chunks_exact(4).enumerate() {
                    out[ch].push(f32::from_le_bytes([s[0], s[1], s[2], s[3]]));
                }
            }
        }
        (1, 16) => {
            for frame in bytes.chunks_exact(2 * nch) {
                for (ch, s) in frame.chunks_exact(2).enumerate() {
                    let v = i16::from_le_bytes([s[0], s[1]]) as f32 / 32768.0;
                    out[ch].push(v);
                }
            }
        }
        _ => return Err(err("unsupported format (need 32-bit float or 16-bit PCM)")),
    }
    Ok((out, sample_rate))
}

/// A source that fills a plugin's input buffers each block — a generated test signal or a
/// preloaded audio file — so effects can be auditioned/rendered with a known input.
pub trait InputSource: Send {
    /// Fill `inputs[ch][..frames]` with the next block of audio at `sample_rate`.
    fn fill(&mut self, inputs: &mut [Vec<f32>], frames: usize, sample_rate: f64);
}

/// A host-synthesized input signal (no capture device needed). Carries its own cursor so blocks
/// are continuous across calls.
#[derive(Debug, Clone)]
pub enum SignalSource {
    /// Silence (all zeros).
    Silence,
    /// A sine tone at `freq` Hz and linear `amplitude` (0..1).
    Sine {
        /// Frequency in Hz.
        freq: f32,
        /// Linear amplitude (0..1).
        amplitude: f32,
        /// Running phase in radians (cursor; start at 0.0).
        phase: f64,
    },
    /// White noise with linear `amplitude` (0..1).
    WhiteNoise {
        /// Linear amplitude (0..1).
        amplitude: f32,
        /// xorshift RNG state (cursor; seed non-zero).
        rng: u64,
    },
    /// A preloaded multi-channel sample (e.g. from [`read_wav`]), played from `pos`.
    Wav {
        /// Channel samples (`samples[ch][frame]`).
        samples: std::sync::Arc<Vec<Vec<f32>>>,
        /// Playback cursor (frame index).
        pos: usize,
        /// Loop back to the start at the end instead of going silent.
        looping: bool,
    },
}

impl SignalSource {
    /// A sine tone.
    pub fn sine(freq: f32, amplitude: f32) -> Self {
        SignalSource::Sine {
            freq,
            amplitude,
            phase: 0.0,
        }
    }
    /// White noise (deterministic from a fixed seed).
    pub fn white_noise(amplitude: f32) -> Self {
        SignalSource::WhiteNoise {
            amplitude,
            rng: 0x9E37_79B9_7F4A_7C15,
        }
    }
    /// A preloaded WAV/sample buffer.
    pub fn wav(samples: Vec<Vec<f32>>, looping: bool) -> Self {
        SignalSource::Wav {
            samples: std::sync::Arc::new(samples),
            pos: 0,
            looping,
        }
    }
}

impl InputSource for SignalSource {
    fn fill(&mut self, inputs: &mut [Vec<f32>], frames: usize, sample_rate: f64) {
        for ch in inputs.iter_mut() {
            if ch.len() < frames {
                ch.resize(frames, 0.0);
            }
        }
        match self {
            SignalSource::Silence => {
                for ch in inputs.iter_mut() {
                    for s in &mut ch[..frames] {
                        *s = 0.0;
                    }
                }
            }
            SignalSource::Sine {
                freq,
                amplitude,
                phase,
            } => {
                let step = std::f64::consts::TAU * *freq as f64 / sample_rate.max(1.0);
                for f in 0..frames {
                    let v = (phase.sin() as f32) * *amplitude;
                    for ch in inputs.iter_mut() {
                        ch[f] = v;
                    }
                    *phase = (*phase + step) % std::f64::consts::TAU;
                }
            }
            SignalSource::WhiteNoise { amplitude, rng } => {
                for f in 0..frames {
                    // xorshift64
                    let mut x = *rng;
                    x ^= x << 13;
                    x ^= x >> 7;
                    x ^= x << 17;
                    *rng = x;
                    // Map to [-1, 1) then scale.
                    let unit = ((x >> 11) as f64 / (1u64 << 53) as f64) as f32 * 2.0 - 1.0;
                    let v = unit * *amplitude;
                    for ch in inputs.iter_mut() {
                        ch[f] = v;
                    }
                }
            }
            SignalSource::Wav {
                samples,
                pos,
                looping,
            } => {
                let total = samples.iter().map(|c| c.len()).max().unwrap_or(0);
                for f in 0..frames {
                    let p = *pos + f;
                    let src_idx = if total == 0 {
                        None
                    } else if p < total {
                        Some(p)
                    } else if *looping {
                        Some(p % total)
                    } else {
                        None
                    };
                    for (ci, ch) in inputs.iter_mut().enumerate() {
                        ch[f] = match src_idx {
                            Some(i) => samples
                                .get(ci % samples.len().max(1))
                                .and_then(|c| c.get(i))
                                .copied()
                                .unwrap_or(0.0),
                            None => 0.0,
                        };
                    }
                }
                *pos += frames;
            }
        }
    }
}

#[cfg(test)]
mod wav_tests {
    use super::*;

    #[test]
    fn write_wav_has_correct_header_and_size() {
        let ch = vec![vec![0.0f32, 0.5, -0.5, 1.0], vec![0.1, 0.2, 0.3, 0.4]];
        let path = std::env::temp_dir().join(format!("vh_write_wav_{}.wav", std::process::id()));
        write_wav(&path, &ch, 48_000).unwrap();
        let bytes = std::fs::read(&path).unwrap();
        let _ = std::fs::remove_file(&path);

        assert_eq!(&bytes[0..4], b"RIFF");
        assert_eq!(&bytes[8..12], b"WAVE");
        assert_eq!(u16::from_le_bytes([bytes[20], bytes[21]]), 3); // IEEE float
        assert_eq!(u16::from_le_bytes([bytes[22], bytes[23]]), 2); // channels
        assert_eq!(
            u32::from_le_bytes([bytes[24], bytes[25], bytes[26], bytes[27]]),
            48_000
        );
        // 4 frames * 2 ch * 4 bytes = 32 bytes of data; file = 44-byte header + 32.
        assert_eq!(bytes.len(), 44 + 32);
    }

    #[test]
    fn write_then_read_wav_round_trips() {
        let ch = vec![vec![0.0f32, 0.5, -0.5, 1.0], vec![0.1, 0.2, 0.3, 0.4]];
        let path = std::env::temp_dir().join(format!("vh_rw_{}.wav", std::process::id()));
        write_wav(&path, &ch, 44_100).unwrap();
        let (back, sr) = read_wav(&path).unwrap();
        let _ = std::fs::remove_file(&path);
        assert_eq!(sr, 44_100);
        assert_eq!(back.len(), 2);
        for (a, b) in ch.iter().zip(back.iter()) {
            for (x, y) in a.iter().zip(b.iter()) {
                assert!((x - y).abs() < 1e-6, "{x} vs {y}");
            }
        }
    }
}

#[cfg(test)]
mod signal_tests {
    use super::*;

    #[test]
    fn sine_starts_at_zero_and_stays_in_amplitude() {
        let mut src = SignalSource::sine(1000.0, 0.5);
        let mut inputs = vec![vec![0.0f32; 256], vec![0.0f32; 256]];
        src.fill(&mut inputs, 256, 48_000.0);
        assert!(inputs[0][0].abs() < 1e-6, "sine should start at phase 0");
        for ch in &inputs {
            assert!(
                ch.iter().all(|s| s.abs() <= 0.5 + 1e-6),
                "exceeds amplitude"
            );
        }
        // Both channels get the same (mono) signal.
        assert_eq!(inputs[0], inputs[1]);
        // Non-trivial signal (not all zero).
        assert!(inputs[0].iter().any(|s| s.abs() > 0.1));
    }

    #[test]
    fn noise_is_bounded_and_varied() {
        let mut src = SignalSource::white_noise(0.25);
        let mut inputs = vec![vec![0.0f32; 512]];
        src.fill(&mut inputs, 512, 48_000.0);
        assert!(inputs[0].iter().all(|s| s.abs() <= 0.25 + 1e-6));
        let first = inputs[0][0];
        assert!(inputs[0].iter().any(|&s| s != first), "noise should vary");
    }

    #[test]
    fn wav_source_advances_and_zero_pads() {
        let mut src = SignalSource::wav(vec![vec![1.0, 2.0, 3.0]], false);
        let mut inputs = vec![vec![0.0f32; 5]];
        src.fill(&mut inputs, 5, 48_000.0);
        assert_eq!(inputs[0], vec![1.0, 2.0, 3.0, 0.0, 0.0]); // zero-pads past the end
    }

    #[test]
    fn wav_source_loops() {
        let mut src = SignalSource::wav(vec![vec![1.0, 2.0]], true);
        let mut inputs = vec![vec![0.0f32; 5]];
        src.fill(&mut inputs, 5, 48_000.0);
        assert_eq!(inputs[0], vec![1.0, 2.0, 1.0, 2.0, 1.0]); // wraps
    }
}

#[cfg(test)]
mod speaker_arrangement_tests {
    use super::*;

    #[test]
    fn channel_counts_match_bitmask() {
        assert_eq!(SpeakerArrangement::EMPTY.channel_count(), 0);
        assert_eq!(SpeakerArrangement::MONO.channel_count(), 1);
        assert_eq!(SpeakerArrangement::STEREO.channel_count(), 2);
        assert_eq!(SpeakerArrangement::STEREO_SURROUND.channel_count(), 2);
    }

    #[test]
    fn raw_round_trips() {
        let bits = SpeakerArrangement::STEREO.raw();
        assert_eq!(bits, 0x3);
        assert_eq!(
            SpeakerArrangement::from_raw(bits),
            SpeakerArrangement::STEREO
        );
        // Arbitrary 5.1-ish mask: 6 set bits → 6 channels.
        assert_eq!(SpeakerArrangement::from_raw(0b111111).channel_count(), 6);
    }

    #[test]
    fn media_type_and_bus_direction_serde_round_trip() {
        for mt in [MediaType::Audio, MediaType::Event] {
            let json = serde_json::to_string(&mt).expect("serialize MediaType");
            let back: MediaType = serde_json::from_str(&json).expect("deserialize MediaType");
            assert_eq!(mt, back);
        }
        for dir in [BusDirection::Input, BusDirection::Output] {
            let json = serde_json::to_string(&dir).expect("serialize BusDirection");
            let back: BusDirection = serde_json::from_str(&json).expect("deserialize BusDirection");
            assert_eq!(dir, back);
        }
    }
}

#[cfg(test)]
mod meter_tests {
    use super::*;
    use std::time::{Duration, Instant};

    #[test]
    fn peak_meter_rises_instantly_and_holds() {
        let mut m = PeakMeter::new(20.0, Duration::from_secs(2));
        let t0 = Instant::now();
        m.push(0.7, t0);
        assert_eq!(m.level(), 0.7);
        assert_eq!(m.peak_hold(), 0.7);

        // A louder block snaps both up immediately.
        m.push(0.9, t0 + Duration::from_millis(10));
        assert_eq!(m.level(), 0.9);
        assert_eq!(m.peak_hold(), 0.9);
    }

    #[test]
    fn peak_meter_level_falls_but_hold_latches() {
        let mut m = PeakMeter::new(20.0, Duration::from_secs(3));
        let t0 = Instant::now();
        m.push(1.0, t0);

        // 0.5 s of silence: 20 dB/s → -10 dB ≈ 0.316 linear. Level fell; hold latched.
        m.push(0.0, t0 + Duration::from_millis(500));
        let lvl = m.level();
        assert!(
            lvl < 1.0 && lvl > 0.0,
            "level should be mid-fall, got {lvl}"
        );
        assert!((lvl - 0.316).abs() < 0.02, "≈-10 dB expected, got {lvl}");
        assert_eq!(m.peak_hold(), 1.0, "hold must latch within its window");
    }

    #[test]
    fn peak_meter_hold_falls_after_window() {
        let mut m = PeakMeter::new(20.0, Duration::from_secs(1));
        let t0 = Instant::now();
        m.push(1.0, t0);
        // Past the 1 s hold window, with continued silence the marker starts falling too.
        m.push(0.0, t0 + Duration::from_millis(1500));
        assert!(
            m.peak_hold() < 1.0,
            "hold should fall after the window expired, got {}",
            m.peak_hold()
        );
    }

    #[test]
    fn peak_meter_reaches_silence_floor() {
        let mut m = PeakMeter::new(60.0, Duration::from_millis(0));
        let t0 = Instant::now();
        m.push(0.5, t0);
        // A long gap of silence fully empties the meter (snaps to exactly 0).
        m.push(0.0, t0 + Duration::from_secs(10));
        assert_eq!(m.level(), 0.0);
        assert_eq!(m.peak_hold(), 0.0);
    }

    #[test]
    fn rms_window_constant_signal() {
        let mut r = RmsWindow::new(8);
        for _ in 0..8 {
            r.push_sample(0.5);
        }
        assert!((r.rms() - 0.5).abs() < 1e-6);
        assert_eq!(r.len(), 8);
    }

    #[test]
    fn rms_window_slides_and_evicts() {
        let mut r = RmsWindow::new(3);
        r.push_block(&[1.0, 1.0, 1.0]);
        assert!((r.rms() - 1.0).abs() < 1e-6);
        // Push three zeros: the loud samples are evicted, RMS returns to 0.
        r.push_block(&[0.0, 0.0, 0.0]);
        assert_eq!(r.len(), 3);
        assert!(
            r.rms() < 1e-6,
            "window should have slid to silence, got {}",
            r.rms()
        );
    }

    #[test]
    fn rms_window_empty_is_zero() {
        let r = RmsWindow::new(16);
        assert!(r.is_empty());
        assert_eq!(r.rms(), 0.0);
    }

    #[test]
    fn rms_window_from_duration_sizes_correctly() {
        // 10 ms at 48 kHz = 480 samples.
        let r = RmsWindow::from_duration(0.01, 48_000.0);
        assert_eq!(r.capacity, 480);
    }

    /// The running sum is an accumulator, so a single non-finite square would poison it for the
    /// life of the window — and `rms()`'s `max(0.0)` guard renders NaN as `0.0`, i.e. the meter
    /// silently reads digital silence forever while full-scale audio flows through it.
    #[test]
    fn rms_window_is_not_latched_by_a_non_finite_sample() {
        for poison in [f32::NAN, f32::INFINITY, f32::NEG_INFINITY, 1.9e19] {
            let mut w = RmsWindow::new(1);
            w.push_sample(poison);
            w.push_sample(0.5);
            assert!(
                (w.rms() - 0.5).abs() < 1e-6,
                "a {poison} sample latched the meter: rms = {}",
                w.rms()
            );
        }

        // Same through the block API, with the poison still inside the window.
        let mut w = RmsWindow::new(4);
        w.push_block(&[f32::NAN, 0.5, 0.5, 0.5]);
        assert!(w.rms().is_finite() && w.rms() > 0.0, "rms = {}", w.rms());
    }

    /// A non-finite or absurd duration/rate saturates to `usize::MAX` and panics inside
    /// `VecDeque::with_capacity`; `from_duration` takes plain `f32`/`f64` from the caller.
    #[test]
    fn rms_window_from_duration_survives_absurd_input() {
        for (secs, rate) in [
            (1.0f32, f64::INFINITY),
            (f32::INFINITY, 48_000.0f64),
            (f32::NAN, 48_000.0),
            (1.0, 1e30),
            (1.0, -48_000.0),
            (-1.0, 48_000.0),
        ] {
            let w = RmsWindow::from_duration(secs, rate);
            assert!(
                w.capacity >= 1,
                "capacity {} for ({secs}, {rate})",
                w.capacity
            );
        }
    }
}