1 files changed, 44 insertions, 48 deletions

diff --git a/tests/server_core.rs b/tests/server_core.rs
index 0350fb6..6b7b415 100644
--- a/tests/server_core.rs
+++ b/tests/server_core.rs
@@ -4,13 +4,13 @@ use std::sync::Arc;
 use rusqlite::Connection;
 use zagan_bet::blackjack::BlackjackState;
 use zagan_bet::crash::CrashState;
+use zagan_bet::roulette::Bets;
 use zagan_bet::server::core::{ConnectionState, ServerCore};
 use zagan_bet::server::database;
 use zagan_bet::server::games::crash::ManualClock;
 use zagan_bet::server::games::registry::GameRegistry;
 use zagan_bet::server::games::roulette::RouletteGame;
 use zagan_bet::server::games::slots::SlotsGame;
-use zagan_bet::roulette::Bets;
 
 fn setup(name: &str, grid: &str) -> (ServerCore, String) {
     let path = PathBuf::from(env!("CARGO_TARGET_TMPDIR"))
@@ -63,8 +63,7 @@ fn setup_blackjack(name: &str, deck: &[&str]) -> (ServerCore, String) {
 
     let deck = deck.iter().map(|card| card.to_string()).collect();
     (
-        ServerCore::with_registry(conn, GameRegistry::with_defaults(), 4)
-            .with_blackjack_deck(deck),
+        ServerCore::with_registry(conn, GameRegistry::with_defaults(), 4).with_blackjack_deck(deck),
         path,
     )
 }
@@ -216,7 +215,10 @@ fn plays_record_the_game_type_and_game_specific_details() {
     login(&mut core, &mut state, "alice");
 
     let response = core.handle_message(&mut state, "PLAY_START slots 10");
-    assert!(response.starts_with("GAME_RESULT"), "spin failed: {response}");
+    assert!(
+        response.starts_with("GAME_RESULT"),
+        "spin failed: {response}"
+    );
 
     let conn = Connection::open(&path).unwrap();
     let (game_type, details): (String, String) = conn
@@ -242,8 +244,7 @@ fn roulette_settles_split_bets_and_records_details() {
     register(&mut core, &mut state, "alice");
     login(&mut core, &mut state, "alice");
 
-    let bets =
-        r#"{"red":10,"black":10,"even":10,"odd":10,"numbers":[{"number":17,"amount":5}]}"#;
+    let bets = r#"{"red":10,"black":10,"even":10,"odd":10,"numbers":[{"number":17,"amount":5}]}"#;
     let response = core.handle_message(&mut state, &format!("PLAY_START roulette 45 {bets}"));
 
     assert!(
@@ -254,7 +255,10 @@ fn roulette_settles_split_bets_and_records_details() {
         response.contains(" 220 45 1175 17 black "),
         "response: {response}"
     );
-    assert!(response.ends_with(&format!(" {bets}")), "response: {response}");
+    assert!(
+        response.ends_with(&format!(" {bets}")),
+        "response: {response}"
+    );
     assert_eq!(core.balance("alice"), Some(1175));
     assert_eq!(core.play_count("alice"), 1);
     assert_eq!(core.session_count(), 0);
@@ -327,7 +331,10 @@ fn a_winning_spin_updates_the_balance_and_the_audit_row() {
     login(&mut core, &mut state, "alice");
 
     let response = core.handle_message(&mut state, "PLAY_START slots 10");
-    assert!(response.starts_with("GAME_RESULT"), "spin failed: {response}");
+    assert!(
+        response.starts_with("GAME_RESULT"),
+        "spin failed: {response}"
+    );
     assert!(response.contains(" 10 10 1000 "), "response: {response}");
     assert!(response.ends_with(" win 1 0,3,6"), "response: {response}");
 
@@ -364,11 +371,8 @@ fn a_negative_balance_is_rejected_without_wrapping() {
     login(&mut core, &mut state, "alice");
 
     let conn = Connection::open(&path).unwrap();
-    conn.execute(
-        "UPDATE users SET balance = -5 WHERE username = 'alice'",
-        [],
-    )
-    .unwrap();
+    conn.execute("UPDATE users SET balance = -5 WHERE username = 'alice'", [])
+        .unwrap();
 
     assert_eq!(
         core.handle_message(&mut state, "PLAY_START slots 10"),
@@ -394,10 +398,7 @@ fn unknown_games_are_rejected_before_a_session_is_created() {
 
 #[test]
 fn blackjack_reserves_the_bet_and_settles_a_hit_hand() {
-    let (mut core, path) = setup_blackjack(
-        "blackjack-hit",
-        &["10S", "9D", "6H", "8C", "5D"],
-    );
+    let (mut core, path) = setup_blackjack("blackjack-hit", &["10S", "9D", "6H", "8C", "5D"]);
     let mut state = ConnectionState::default();
     register(&mut core, &mut state, "alice");
     login(&mut core, &mut state, "alice");
@@ -442,10 +443,7 @@ fn blackjack_reserves_the_bet_and_settles_a_hit_hand() {
 
 #[test]
 fn blackjack_double_reserves_an_extra_bet() {
-    let (mut core, path) = setup_blackjack(
-        "blackjack-double",
-        &["5S", "9D", "5H", "8C", "10D"],
-    );
+    let (mut core, path) = setup_blackjack("blackjack-double", &["5S", "9D", "5H", "8C", "10D"]);
     let mut state = ConnectionState::default();
     register(&mut core, &mut state, "alice");
     login(&mut core, &mut state, "alice");
@@ -483,8 +481,7 @@ fn blackjack_double_reserves_an_extra_bet() {
 
 #[test]
 fn blackjack_natural_settles_immediately() {
-    let (mut core, _path) =
-        setup_blackjack("blackjack-natural", &["AS", "9D", "KH", "8C"]);
+    let (mut core, _path) = setup_blackjack("blackjack-natural", &["AS", "9D", "KH", "8C"]);
     let mut state = ConnectionState::default();
     register(&mut core, &mut state, "alice");
     login(&mut core, &mut state, "alice");
@@ -501,8 +498,7 @@ fn blackjack_natural_settles_immediately() {
 
 #[test]
 fn blackjack_forfeit_keeps_the_reserved_bet() {
-    let (mut core, _path) =
-        setup_blackjack("blackjack-cancel", &["10S", "9D", "6H", "8C"]);
+    let (mut core, _path) = setup_blackjack("blackjack-cancel", &["10S", "9D", "6H", "8C"]);
     let mut state = ConnectionState::default();
     register(&mut core, &mut state, "alice");
     login(&mut core, &mut state, "alice");
@@ -524,8 +520,7 @@ fn blackjack_forfeit_keeps_the_reserved_bet() {
 
 #[test]
 fn blackjack_disconnect_forfeits_the_reserved_bet() {
-    let (mut core, _path) =
-        setup_blackjack("blackjack-disconnect", &["10S", "9D", "6H", "8C"]);
+    let (mut core, _path) = setup_blackjack("blackjack-disconnect", &["10S", "9D", "6H", "8C"]);
     let mut state = ConnectionState::default();
     register(&mut core, &mut state, "alice");
     login(&mut core, &mut state, "alice");
@@ -578,10 +573,9 @@ fn crash_cashout_pays_the_multiplier_from_the_server_clock() {
 
     // Five seconds of round time: 2.00x, still below the 3.00x crash point.
     clock.advance(5.0);
-    let cashed = crash_state(&core.handle_message(
-        &mut state,
-        &format!("CRASH_CASHOUT {}", started.session_id),
-    ));
+    let cashed = crash_state(
+        &core.handle_message(&mut state, &format!("CRASH_CASHOUT {}", started.session_id)),
+    );
 
     assert_eq!(cashed.phase, "cashed");
     assert_eq!(cashed.multiplier, 2.0);
@@ -600,7 +594,15 @@ fn crash_cashout_pays_the_multiplier_from_the_server_clock() {
             "SELECT game_type, bet_amount, winnings, balance_after, details
              FROM plays WHERE username = 'alice'",
             [],
-            |row| Ok((row.get(0)?, row.get(1)?, row.get(2)?, row.get(3)?, row.get(4)?)),
+            |row| {
+                Ok((
+                    row.get(0)?,
+                    row.get(1)?,
+                    row.get(2)?,
+                    row.get(3)?,
+                    row.get(4)?,
+                ))
+            },
         )
         .unwrap();
     assert_eq!(game_type, "crash");
@@ -627,10 +629,9 @@ fn a_cashout_after_the_crash_time_loses_the_reserved_bet() {
     let started = crash_state(&core.handle_message(&mut state, "PLAY_START crash 10"));
 
     clock.advance(20.0);
-    let late = crash_state(&core.handle_message(
-        &mut state,
-        &format!("CRASH_CASHOUT {}", started.session_id),
-    ));
+    let late = crash_state(
+        &core.handle_message(&mut state, &format!("CRASH_CASHOUT {}", started.session_id)),
+    );
 
     assert_eq!(late.phase, "crashed");
     assert_eq!(late.payout, 0);
@@ -679,10 +680,9 @@ fn crash_forfeit_keeps_the_reserved_bet() {
     login(&mut core, &mut state, "alice");
 
     let started = crash_state(&core.handle_message(&mut state, "PLAY_START crash 10"));
-    let forfeited = crash_state(&core.handle_message(
-        &mut state,
-        &format!("CRASH_FORFEIT {}", started.session_id),
-    ));
+    let forfeited = crash_state(
+        &core.handle_message(&mut state, &format!("CRASH_FORFEIT {}", started.session_id)),
+    );
 
     assert_eq!(forfeited.phase, "forfeit");
     assert_eq!(forfeited.payout, 0);
@@ -747,10 +747,7 @@ fn crash_rounds_are_owned_by_the_player_who_started_them() {
 
     clock.advance(5.0);
     assert_eq!(
-        core.handle_message(
-            &mut bob,
-            &format!("CRASH_CASHOUT {}", started.session_id)
-        ),
+        core.handle_message(&mut bob, &format!("CRASH_CASHOUT {}", started.session_id)),
         "ERROR Invalid session"
     );
     assert_eq!(core.balance("bob"), Some(1000));
@@ -775,10 +772,9 @@ fn a_crash_reservation_is_durable_until_the_round_settles() {
     drop(conn);
 
     clock.advance(5.0);
-    let cashed = crash_state(&core.handle_message(
-        &mut state,
-        &format!("CRASH_CASHOUT {}", started.session_id),
-    ));
+    let cashed = crash_state(
+        &core.handle_message(&mut state, &format!("CRASH_CASHOUT {}", started.session_id)),
+    );
     assert_eq!(cashed.phase, "cashed");
 
     let conn = Connection::open(&path).unwrap();