diff --git a/src/sockets.rs b/src/sockets.rs index d686a62..af8caa3 100644 --- a/src/sockets.rs +++ b/src/sockets.rs @@ -7,7 +7,6 @@ use tokio::{ io::{AsyncReadExt, AsyncWriteExt}, net::TcpStream, sync::Barrier, - task::JoinHandle, time::sleep, }; @@ -47,37 +46,40 @@ pub async fn snipe_executor( let c = barrier.clone(); let mut buf = [0; 12]; let handshake_time = snipe_time - Duration::seconds(32); - let handle: JoinHandle> = tokio::task::spawn(async move { + let handle = tokio::task::spawn(async move { let sleep_duration = (handshake_time - Local::now()) .to_std() .unwrap_or(std::time::Duration::ZERO); sleep(sleep_duration).await; - let socket = TcpStream::connect(&addr).await?; - let mut socket = cx.connect("api.minecraftservices.com", socket).await?; - socket.write_all(&payload).await?; + let socket = TcpStream::connect(&addr).await.unwrap(); + let mut socket = cx + .connect("api.minecraftservices.com", socket) + .await + .unwrap(); + socket.write_all(&payload).await.unwrap(); let sleep_duration = (snipe_time - Local::now()) .to_std() .unwrap_or(std::time::Duration::ZERO); sleep(sleep_duration).await; - socket.write_all(b"\r\n").await?; + socket.write_all(b"\r\n").await.unwrap(); c.wait().await; - socket.read_exact(&mut buf).await?; + socket.read_exact(&mut buf).await.unwrap(); let timestamp = Local::now(); let res = String::from_utf8_lossy(&buf[..]); - let status: u16 = res[9..].parse()?; + let status: u16 = res[9..].parse().unwrap(); let res_data = ResData { status, timestamp, account_idx, }; - Ok(res_data) + res_data }); handles.push(handle); } } let mut res_vec = Vec::with_capacity(req_count * bearer_tokens.len()); for handle in handles { - let res_data = handle.await??; + let res_data = handle.await?; res_vec.push(res_data); } res_vec.sort_by(|a, b| a.timestamp.cmp(&b.timestamp));