mirror/strudel
1
0
Fork 0
mirror of https://codeberg.org/uzu/strudel synced 2026-07-22 13:13:10 -04:00
Code Issues Packages Projects Releases Wiki Activity

tests: reverb

Browse Source
This commit is contained in:
Vasilii Milovidov
2023-10-03 00:04:07 +04:00
parent c2fc2272c5
commit 56dd5bb604
2 changed files with 30 additions and 49 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src-tauri/src/superdough.rs
+19 -1
View File
@@ -74,7 +74,6 @@ pub trait WebAudioInstrument {
}
pub struct Delay {
pub delay: DelayNode,
pub input: GainNode,
@@ -99,6 +98,25 @@ impl Delay {
}
}
pub struct Reverb {
pub reverb: ConvolverNode,
pub room: f32,
pub size: f32,
}
impl Reverb {
pub fn new(context: &AudioContext, compressor: &DynamicsCompressorNode, room: f32, size: f32) -> Self {
let reverb = context.create_convolver();
reverb.connect(compressor);
Self { reverb, room, size }
}
pub fn asign_buffer(&mut self, buffer: AudioBuffer) {
self.reverb.set_buffer(buffer.clone());
}
}
pub struct Synth {
pub oscillator: OscillatorNode,
pub envelope: GainNode,
src-tauri/src/webaudiobridge.rs
+11 -48
View File
@@ -20,8 +20,9 @@ use web_audio_api::{
context::{AudioContext, AudioContextLatencyCategory, AudioContextOptions},
node::AudioNode,
};
use web_audio_api::context::OfflineAudioContext;
use web_audio_api::node::{ConvolverNode, DelayNode};
use crate::superdough::{ADSRMessage, apply_filter_adsr, BPFMessage, DelayMessage, Delay, FilterADSRMessage, HPFMessage, LoopMessage, LPFMessage, Sampler, Synth, WebAudioInstrument, ReverbMessage};
use crate::superdough::{ADSRMessage, apply_filter_adsr, BPFMessage, DelayMessage, Delay, FilterADSRMessage, HPFMessage, LoopMessage, LPFMessage, Sampler, Synth, WebAudioInstrument, ReverbMessage, Reverb};
#[derive(Debug, Clone)]
@@ -121,11 +122,12 @@ pub fn init(
});
let _ = audio_context.create_buffer_source();
let mut delays: HashMap<usize, Delay> = HashMap::new();
let mut reverbs: HashMap<usize, ConvolverNode> = HashMap::new();
let mut reverbs: HashMap<usize, Reverb> = HashMap::new();
let compressor = audio_context.create_dynamics_compressor();
compressor.threshold().set_value(-50.0);
compressor.connect(&audio_context.destination());
let cache: Cache<String, AudioBuffer> = Cache::builder()
.max_capacity(31 * 1024 * 1024)
.time_to_idle(Duration::from_secs(40))
@@ -219,58 +221,19 @@ pub fn init(
delay.pre_gain.gain().set_value_at_time(message.delay.wet.unwrap_or(0.25), t + message.delay.delay_time.unwrap_or(0.5) as f64);
};
// REVERB
if message.reverb.ir.is_some() {
// CREATE FILEPATHS
let (ir_url, ir_file_path, ir_file_path_clone) = create_ir_filepath(&message);
// DOWNLOAD FILE IS IT DOESN'T EXIST
tokio::spawn(async move {
if tokio::fs::metadata(&ir_file_path.clone()).await.is_err() {
let response = reqwest::get(ir_url)
.await
.unwrap_or_else(|_| panic!("Failed to send GET request"));
let bytes = response.bytes().await.unwrap();
let path = Path::new(&ir_file_path);
let mut file = create_file_and_dirs(path).await;
file.write_all(&bytes)
.await
.unwrap_or_else(|_| panic!("Failed to write to file"));
}
});
// IF BUFFER IS CACHED - PLAY IT
if let Some(ir_buffer) = cache.get(&ir_file_path_clone) {
// IF REVERB IS NOT CREATED - CREATE IT
reverbs.entry(message.orbit).or_insert({
let mut reverb = audio_context.create_convolver();
reverb.connect(&compressor);
reverb.set_buffer(ir_buffer.clone());
reverb
});
// GET AND CONNECT REVERB
let reverb = reverbs.get(&message.orbit).unwrap();
sampler.envelope.connect(reverb);
} else if let Ok(file) = File::open(&ir_file_path_clone) {
println!("Loading IR file {}", &ir_file_path_clone);
let ir_buffer = audio_context.decode_audio_data_sync(file).unwrap_or_else(|_| panic!("Failed to decode audio data"));
cache.insert(ir_file_path_clone.clone(), ir_buffer);
}
}
// CONNECT SAMPLER TO OUTPUT AND PLAY
sampler.envelope.connect(&compressor);
sampler.play(t, &message, audio_buffer_duration);
// IF FILE EXIST - DECODE IT
} else if let Ok(file) = File::open(&file_path_clone) {
let audio_buffer = audio_context.decode_audio_data_sync(file)
.unwrap_or_else(|_| panic!("Failed to decode audio data"));
cache.insert(file_path_clone.clone(), audio_buffer);
let cache_clone = cache.clone();
println!("{:?}", file);
tokio::spawn(async move {
let context = OfflineAudioContext::new(2, 88200, 44100.0);
let audio_buffer = context.decode_audio_data_sync(file).expect("OOOPS!");
cache_clone.insert(file_path_clone.clone(), audio_buffer);
});
}
}
}