Reintroduce spread

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "buckshot"
-version = "4.0.5"
+version = "4.0.6"
 authors = ["tropicbliss <[email protected]>"]
 edition = "2021"
 license = "MIT"

src/config.rs

@@ -11,6 +11,7 @@ struct PrivateConfig {
  mode: SnipeTask,
  skin: Option<Skin>,
  name_queue: Option<NameQueue>,
+ spread: u32,
 }
 
 #[derive(Deserialize, Clone)]
@@ -27,6 +28,7 @@ pub struct Config {
  pub mode: SnipeTask,
  pub skin: Option<Skin>,
  pub name_queue: Option<NameQueue>,
+ pub spread: u32,
 }
 
 #[derive(PartialEq)]
@@ -112,6 +114,7 @@ impl From<PrivateConfig> for Config {
  mode: item.mode,
  skin: item.skin,
  name_queue: item.name_queue,
+ spread: item.spread,
  }
  }
 }

src/constants.rs

@@ -2,3 +2,4 @@ use std::time::Duration;
 
 pub const CONFIG_PATH: &str = "config.toml";
 pub const IO_TIMEOUT: Duration = Duration::from_secs(5);
+pub const BARRIER_THRESHOLD: u32 = 27;

src/main.rs

@@ -184,9 +184,10 @@ async fn main() -> Result<()> {
  writeln!(stdout(), "Setup complete")?;
  let mut is_success = None;
  let is_gc = task == &SnipeTask::Giftcode;
- let res_data = sockets::snipe_executor(name, &bearer_tokens, snipe_time, is_gc)
- .await
- .with_context(|| format!("Failed to execute the snipe of {}", name))?;
+ let res_data =
+ sockets::snipe_executor(name, &bearer_tokens, snipe_time, is_gc, config.spread)
+ .await
+ .with_context(|| format!("Failed to execute the snipe of {}", name))?;
  for res in res_data {
  let formatted_timestamp = res.timestamp.format("%F %T%.6f");
  match res.status {

src/sockets.rs

@@ -1,4 +1,4 @@
-use crate::constants::IO_TIMEOUT;
+use crate::constants::{BARRIER_THRESHOLD, IO_TIMEOUT};
 use anyhow::Result;
 use chrono::{DateTime, Duration, Local};
 use native_tls::TlsConnector;
@@ -22,6 +22,7 @@ pub async fn snipe_executor(
  bearer_tokens: &[String],
  snipe_time: DateTime<Local>,
  is_gc: bool,
+ spread: u32,
 ) -> Result<Vec<ResData>> {
  let req_count = if is_gc { 6 } else { 3 };
  let addr = "api.minecraftservices.com:443"
@@ -32,7 +33,13 @@ pub async fn snipe_executor(
  let cx = tokio_native_tls::TlsConnector::from(cx);
  let cx = Arc::new(cx);
  let mut handles = Vec::with_capacity(req_count * bearer_tokens.len());
- let barrier = Arc::new(Barrier::new(req_count * bearer_tokens.len()));
+ let barrier_count = if spread <= BARRIER_THRESHOLD {
+ req_count * bearer_tokens.len()
+ } else {
+ 0
+ };
+ let barrier = Arc::new(Barrier::new(barrier_count));
+ let mut snipe_time = snipe_time;
  for (account_idx, bearer_token) in bearer_tokens.iter().enumerate() {
  let payload = if is_gc {
  let post_body = json!({ "profileName": name }).to_string();
@@ -91,6 +98,8 @@ pub async fn snipe_executor(
  account_idx,
  }
  });
+ // Before you rag on me for not using +=, += doesn't work here
+ snipe_time = snipe_time + Duration::milliseconds(i64::from(spread));
  handles.push(handle);
  }
  }