rawdio 0.14.0

An Audio Engine, inspired by the Web Audio API
Documentation 
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
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121

use itertools::izip;

use super::{
    adsr_envelope::AdsrEnvelope,
    adsr_event::{AdsrEvent, AdsrEventType},
};
use crate::{
    effects::{utility::EventProcessor, Channel},
    graph::DspProcessor,
    prelude::*,
};
use std::time::Duration;

pub struct AdsrProcessor {
    event_processor: EventProcessor<AdsrEvent>,
    envelope: AdsrEnvelope,
    envelope_buffer: Vec<f32>,
}

const MAX_PENDING_EVENTS: usize = 64;

impl AdsrProcessor {
    pub fn new(
        event_receiver: Channel::Receiver<AdsrEvent>,
        sample_rate: usize,
        maximum_frame_count: usize,
    ) -> Self {
        Self {
            event_processor: EventProcessor::with_capacity(
                MAX_PENDING_EVENTS,
                event_receiver,
                sample_rate,
            ),
            envelope: AdsrEnvelope::new(
                sample_rate,
                Duration::ZERO,
                Duration::ZERO,
                Level::from_db(0.0),
                Duration::ZERO,
            ),
            envelope_buffer: vec![0.0_f32; maximum_frame_count],
        }
    }

    fn process_event(&mut self, event: AdsrEvent) {
        match event.get_event_type() {
            AdsrEventType::NoteOn => self.envelope.open(),
            AdsrEventType::NoteOff => self.envelope.close(),
            AdsrEventType::SetAttack(attack_time) => self.envelope.set_attack_time(*attack_time),
            AdsrEventType::SetDecay(decay_time) => self.envelope.set_decay_time(*decay_time),
            AdsrEventType::SetSustain(sustain_level) => {
                self.envelope.set_sustain_level(*sustain_level)
            }
            AdsrEventType::SetRelease(release_time) => {
                self.envelope.set_release_time(*release_time)
            }
        }
    }

    fn prepare_envelope(&mut self, frame_count: usize, start_time: &Timestamp, sample_rate: usize) {
        self.event_processor.receive_events();

        let mut current_time = *start_time;
        let mut position = 0;

        while position < frame_count {
            let (end_frame, event) =
                self.event_processor
                    .next_event(start_time, &current_time, frame_count);

            let frame_count = end_frame - position;

            for frame in 0..frame_count {
                let envelope = self.envelope.process();
                self.envelope_buffer[frame + position] = envelope as f32;
            }

            current_time = current_time.incremented_by_samples(frame_count, sample_rate);

            position += frame_count;

            if let Some(event) = event {
                self.process_event(event);
            }
        }
    }
}

impl DspProcessor for AdsrProcessor {
    fn process_audio(&mut self, context: &mut crate::ProcessContext) {
        let channel_count = std::cmp::min(
            context.input_buffer.channel_count(),
            context.output_buffer.channel_count(),
        );

        let frame_count = std::cmp::min(
            context.input_buffer.frame_count(),
            context.output_buffer.frame_count(),
        );

        self.prepare_envelope(
            frame_count,
            context.start_time,
            context.output_buffer.sample_rate(),
        );

        for channel in 0..channel_count {
            let location = SampleLocation::channel(channel);
            let output_channel = context.output_buffer.get_channel_data_mut(location);
            let input_channel = context.input_buffer.get_channel_data(location);

            for (output_sample, input_sample, envelope) in izip!(
                output_channel.iter_mut(),
                input_channel.iter(),
                self.envelope_buffer.iter()
            ) {
                *output_sample = *input_sample * *envelope;
            }
        }
    }
}