legato 0.0.12

Legato is a WIP audiograph and DSL for quickly developing audio applications
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102

use crate::{
    context::AudioContext,
    math::fast_tanh_vf32,
    node::{Inputs, Node},
    ports::{PortBuilder, Ports},
    simd::{LANES, Vf32},
};

// TODO: More mixers, matrix, panning, etc.

/// A simple node for mixing down tracks.
///
/// A "track", in this context, is an arbitrary amount of channels.
///
/// So, this TrackMixer can take say two tracks of stereo -> one track stereo
#[derive(Clone)]
pub struct TrackMixer {
    chans_per_track: usize,
    ports: Ports,
    gain: Vec<Vf32>,
}

impl TrackMixer {
    pub fn new(chans_per_track: usize, tracks: usize, gain: Vec<f32>) -> Self {
        Self {
            chans_per_track,
            gain: gain.into_iter().map(Vf32::splat).collect(),
            ports: PortBuilder::default()
                .audio_in(chans_per_track * tracks)
                .audio_out(chans_per_track)
                .build(),
        }
    }
}

impl Node for TrackMixer {
    fn process<'a>(&mut self, _: &mut AudioContext, ai: &Inputs, ao: &mut [&mut [f32]]) {
        // Note: the graph does not explicity clear ao. So, if you are going to do multiple passes, you have to clear it first
        for buffer in ao.iter_mut() {
            buffer.fill(0.0);
        }

        for (i, track) in ai.chunks_exact(self.chans_per_track).enumerate() {
            let gain = self.gain[i];
            for (chan_idx, chan) in track.iter().enumerate() {
                for (chunk_in, chunk_out) in chan
                    .unwrap()
                    .chunks_exact(LANES)
                    .zip(ao[chan_idx].chunks_exact_mut(LANES))
                {
                    let gained = Vf32::from_slice(chunk_in) * gain;
                    let mut out = Vf32::from_slice(chunk_out);
                    out += gained;
                    chunk_out.copy_from_slice(&out.to_array());
                }
            }
        }
        for chan in ao {
            for chunk in chan.chunks_exact_mut(LANES) {
                chunk.copy_from_slice(fast_tanh_vf32(Vf32::from_slice(chunk)).as_array());
            }
        }
    }
    fn ports(&self) -> &Ports {
        &self.ports
    }
}

/// A mono -> N mixer with unity gain
#[derive(Clone)]
pub struct MonoFanOut {
    ports: Ports,
}

impl MonoFanOut {
    pub fn new(chans_out: usize) -> Self {
        Self {
            ports: PortBuilder::default()
                .audio_in(1)
                .audio_out(chans_out)
                .build(),
        }
    }
}

impl Node for MonoFanOut {
    fn process(&mut self, _: &mut AudioContext, ai: &Inputs, ao: &mut [&mut [f32]]) {
        // TODO: Chunks + SIMD
        let chans_out = self.ports.audio_out.len();
        let gain = 1.0 / f32::sqrt(chans_out as f32);

        for (i, sample) in ai[0].unwrap().iter().enumerate() {
            let normalized = sample * gain;
            for chan_out in ao.iter_mut() {
                chan_out[i] = normalized
            }
        }
    }
    fn ports(&self) -> &Ports {
        &self.ports
    }
}