mii/maudio-router
1
0
Fork 0
mirror of https://github.com/mii443/maudio-router.git synced 2025-08-22 16:05:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

wip (need audio resampling)

Browse Source
This commit is contained in:
mii443
2024-02-14 21:56:35 +09:00
parent 3860a9caf5
commit 7ecd48672f
3 changed files with 49 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

47
src/commands/run.rs
View File

@ -136,12 +136,14 @@ pub fn run(run: Run) {
.find(|device| device.name().unwrap() == local.name)
.unwrap();
let config = device.default_input_config().unwrap();
println!("input config: {:?}", config);
let channels = config.channels();
let virtual_devices = virtual_devices.iter().filter(|device| device.lock().unwrap().name == input_route.virtual_device).map(|d| d.clone()).collect::<Vec<_>>()[0].clone();
let stream = device.build_input_stream(
&config.into(),
{
move |data, _| {
println!("Data length: {}", data.len());
let audio_data = reshape_audio_data(&data, channels as usize);
for (i, buffer) in audio_data.iter().enumerate() {
@ -161,5 +163,50 @@ pub fn run(run: Run) {
}
}
for output_route in &config.routes.output {
match &output_route.device {
crate::config::Device::Local { local } => {
let device = output_devices
.iter()
.find(|device| device.name().unwrap() == local.name)
.unwrap();
let config = device.default_output_config().unwrap();
println!("output config: {:?}", config);
let channels = config.channels();
let virtual_device = virtual_devices.iter().filter(|device| device.lock().unwrap().name == output_route.input.virtual_device).map(|d| d.clone()).collect::<Vec<_>>()[0].clone();
let index = virtual_device.lock().unwrap().add_output();
let stream = device.build_output_stream(
&config.into(),
{
move |data, _| {
println!("Data length: {}", data.len());
let mut audio_data = vec![];
for i in 0..channels {
audio_data.push(virtual_device.lock().unwrap().take_output(index, i as u8, data.len() / channels as usize).unwrap_or_default());
}
let mut audio_data = to_flat_audio_data(&audio_data);
let data_len = data.len();
let audio_data_len = audio_data.len();
if data_len > audio_data_len {
audio_data.extend(vec![0.0; data_len - audio_data_len]);
}
data.clone_from_slice(&audio_data);
println!("Data: {:?}", data);
}
},
move |err| eprintln!("An error occurred on the output stream: {}", err),
None
).unwrap();
stream.play().unwrap();
streams.push(stream);
}
crate::config::Device::Remote { remote } => {
unimplemented!();
}
}
}
std::thread::sleep(std::time::Duration::from_secs(10));
}