From 52e4a5306db03d64614f7d3c7133a081c32362de Mon Sep 17 00:00:00 2001
From: Aron Heinecke <aron.heinecke@t-online.de>
Date: Tue, 11 May 2021 01:40:44 +0200
Subject: [PATCH] Use tinier voice frames

Signed-off-by: Aron Heinecke <aron.heinecke@t-online.de>
---
 src/main.rs | 34 +++++++++++++++++-----------------
 1 file changed, 17 insertions(+), 17 deletions(-)

diff --git a/src/main.rs b/src/main.rs
index 708ccd0..c8ac3ec 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -65,7 +65,7 @@ impl TypeMapKey for ListenerHolder {
     type Value = AudioBufferDiscord;
 }
 
-const TICK_TIME: u64 = 20;
+const TICK_TIME: u64 = 15;
 const FRAME_SIZE_MS: usize = 20;
 const STEREO_20MS: usize = 48000 * 2 * FRAME_SIZE_MS / 1000;
 
@@ -173,20 +173,20 @@ async fn main() -> Result<()> {
 	loop {
 		let t2a = audiodata.ts2a.clone();
 		let events = con.events().try_for_each(|e| async {
-			// if let StreamItem::Audio(packet) = e {
-			// 	let from = ClientId(match packet.data().data() {
-			// 		AudioData::S2C { from, .. } => *from,
-			// 		AudioData::S2CWhisper { from, .. } => *from,
-			// 		_ => panic!("Can only handle S2C packets but got a C2S packet"),
-			// 	});
-			// 	let mut t2a = t2a.lock().unwrap();
-			// 	if let Err(e) = t2a.play_packet((con_id, from), packet) {
-			// 		debug!(logger, "Failed to play packet"; "error" => %e);
-			// 	}
-			// }
+			if let StreamItem::Audio(packet) = e {
+				let from = ClientId(match packet.data().data() {
+					AudioData::S2C { from, .. } => *from,
+					AudioData::S2CWhisper { from, .. } => *from,
+					_ => panic!("Can only handle S2C packets but got a C2S packet"),
+				});
+				let mut t2a = t2a.lock().unwrap();
+				if let Err(e) = t2a.play_packet((con_id, from), packet) {
+					debug!(logger, "Failed to play packet"; "error" => %e);
+				}
+			}
 			Ok(())
 		});
-		let start = std::time::Instant::now();
+		// let start = std::time::Instant::now();
 		// Wait for ctrl + c
 		tokio::select! {
 			// send_audio = recv.recv() => {
@@ -207,10 +207,10 @@ async fn main() -> Result<()> {
 			// 	}
 			// }
 			_send = interval.tick() => {
-				let dur = start.elapsed();
-				if dur.as_millis() > TICK_TIME as u128 {
-					//eprintln!("Tick took {}ms",dur.as_millis());
-				}
+				// let dur = start.elapsed();
+				// if dur.as_millis() > TICK_TIME as u128 {
+				// 	eprintln!("Tick took {}ms",dur.as_millis());
+				// }
 				let start = std::time::Instant::now();
 				if let Some(processed) = process_audio(&voice_buffer,&encoder).await {
 					con.send_audio(processed)?;