From bc0de9955c375cf27d52c9934403964205afc182 Mon Sep 17 00:00:00 2001 From: salmonik Date: Thu, 29 Oct 2026 22:16:15 +0100 Subject: formatting --- tests/server_core.rs | 92 +++++++++++++++++++++++++--------------------------- 1 file changed, 44 insertions(+), 48 deletions(-) (limited to 'tests/server_core.rs') 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(); -- cgit v1.2.3