v2.1.0: add European roulette with split bets and wheel animation

12 files changed, 923 insertions, 31 deletions

diff --git a/src/bin/client/repl.rs b/src/bin/client/repl.rs
index 1ed3073..e028cc2 100644
--- a/src/bin/client/repl.rs
+++ b/src/bin/client/repl.rs
@@ -20,6 +20,7 @@ use zagan_bet::client::ui::{
     visual_line_count,
 };
 use zagan_bet::protocol::io_failure_message;
+use zagan_bet::roulette::WHEEL;
 
 use crate::connection::TlsStream;
 
@@ -150,6 +151,16 @@ impl ClientState {
                     }
                 }
                 Effect::ReplaceRegion(lines) => self.draw_region(&lines),
+                Effect::AnimateRoulette {
+                    winning,
+                    final_lines,
+                } => {
+                    self.animate_wheel(winning);
+                    self.draw_region(&final_lines);
+                    while crossterm::event::poll(std::time::Duration::ZERO).unwrap_or(false) {
+                        let _ = crossterm::event::read();
+                    }
+                }
                 Effect::ClearRegion => self.clear_region(),
                 Effect::SetPrompt { text, cursor_col } => self.draw_prompt(&text, cursor_col),
                 Effect::SendLine(line) => {
@@ -276,6 +287,49 @@ impl ClientState {
         self.game_lines = 0;
     }
 
+    /// CS:GO-style wheel strip: the ball marker is fixed and the numbers move
+    /// left-to-right under it, ending with the winning number in the center.
+    fn animate_wheel(&mut self, winning: u8) {
+        use std::thread;
+        use std::time::Duration;
+
+        let target = WHEEL
+            .iter()
+            .position(|number| *number == winning)
+            .unwrap_or(0) as f64;
+        let wheel_len = WHEEL.len() as f64;
+        let start = target - 4.0 * wheel_len - 7.0;
+        let frames = 32;
+
+        for frame in 0..frames {
+            let t = frame as f64 / (frames - 1) as f64;
+            let ease = 1.0 - (1.0 - t).powi(3);
+            let center = (start + (target - start) * ease).round() as isize;
+
+            let strip = (0..9)
+                .map(|offset| {
+                    let index = (center - 4 + offset).rem_euclid(WHEEL.len() as isize) as usize;
+                    format!("[ {:>2} ]", WHEEL[index])
+                })
+                .collect::<Vec<_>>()
+                .join(" ");
+            let marker = format!("{}▼", " ".repeat(4 * 7 + 3));
+            let lines = vec![
+                "=== ROULETTE ===".to_string(),
+                strip,
+                marker,
+                "Spinning...".to_string(),
+            ];
+
+            self.draw_region(&lines);
+            thread::sleep(Duration::from_millis(35));
+        }
+
+        // Let the winning number sit under the static ball before the result
+        // board replaces the wheel.
+        thread::sleep(Duration::from_millis(450));
+    }
+
     fn draw_prompt(&mut self, text: &str, cursor_col: u16) {
         execute!(stdout(), MoveToColumn(0), Clear(ClearType::CurrentLine)).unwrap();
         print!("{}", "> ".cyan());
diff --git a/src/client/core.rs b/src/client/core.rs
index a88991b..e005f2a 100644
--- a/src/client/core.rs
+++ b/src/client/core.rs
@@ -1,9 +1,10 @@
 use crate::client::games::manager::GameManager;
-use crate::client::games::response::parse_spin_response;
+use crate::client::games::response::{parse_roulette_response, parse_spin_response};
 use crate::client::ui::{
     command_names, completion_lines, display_width, help_lines, input_cursor_column,
     parse_bet_arg, record_history,
 };
+use crate::roulette::{Bets, NumberBet};
 
 #[derive(Debug, Clone, Copy, PartialEq, Eq)]
 pub enum Key {
@@ -33,6 +34,11 @@ pub enum Effect {
     Print(Vec<String>),
     /// Replace the game board region in place.
     ReplaceRegion(Vec<String>),
+    /// Run the roulette wheel animation, then draw the final board lines.
+    AnimateRoulette {
+        winning: u8,
+        final_lines: Vec<String>,
+    },
     /// Remove the game board region.
     ClearRegion,
     /// Redraw the command prompt. `text` is the input without the `> ` prefix.
@@ -54,11 +60,20 @@ pub enum Effect {
 #[derive(Debug, Clone, Copy, PartialEq, Eq)]
 enum Pending {
     Spin,
+    RouletteSpin,
     Ping,
     Echo,
     Info,
 }
 
+#[derive(Debug, Clone, Copy)]
+enum RouletteSide {
+    Red,
+    Black,
+    Even,
+    Odd,
+}
+
 pub struct ClientCore {
     input: String,
     history: Vec<String>,
@@ -160,6 +175,22 @@ impl ClientCore {
                     self.board_effects()
                 }
             },
+            Some(Pending::RouletteSpin) => match parse_roulette_response(reply) {
+                Ok(result) => {
+                    self.balance = Some(result.balance);
+                    let winning = result.number;
+                    self.game.apply_roulette_result(result);
+                    let final_lines = self.board_lines().unwrap_or_default();
+                    vec![Effect::AnimateRoulette {
+                        winning,
+                        final_lines,
+                    }]
+                }
+                Err(message) => {
+                    self.game.set_error(message);
+                    self.board_effects()
+                }
+            },
             Some(Pending::Ping) => {
                 if reply.trim() == "PONG" {
                     print_line("Pong")
@@ -194,6 +225,15 @@ impl ClientCore {
     }
 
     fn handle_game_key(&mut self, key: Key) -> Vec<Effect> {
+        if self
+            .game
+            .get_current_state()
+            .map(|state| state.game_type.as_str())
+            == Some("roulette")
+        {
+            return self.handle_roulette_key(key);
+        }
+
         match key {
             Key::CtrlC => vec![Effect::Quit],
             Key::Esc | Key::Char('q') => {
@@ -230,6 +270,147 @@ impl ClientCore {
         effects
     }
 
+    fn handle_roulette_key(&mut self, key: Key) -> Vec<Effect> {
+        match key {
+            Key::CtrlC => vec![Effect::Quit],
+            Key::Char('q') => {
+                self.game.end_game();
+                vec![
+                    Effect::ClearRegion,
+                    Effect::Print(vec!["Game exited.".to_string()]),
+                ]
+            }
+            Key::Esc => {
+                self.game.set_roulette_number_input("");
+                self.board_effects()
+            }
+            Key::Char(' ') => self.spin_roulette(),
+            Key::Char('r') => self.add_roulette_side(RouletteSide::Red),
+            Key::Char('b') => self.add_roulette_side(RouletteSide::Black),
+            Key::Char('e') => self.add_roulette_side(RouletteSide::Even),
+            Key::Char('o') => self.add_roulette_side(RouletteSide::Odd),
+            Key::Char('c') => {
+                self.game.set_roulette_bets(&Bets::default());
+                self.game.set_roulette_number_input("");
+                self.game.set_roulette_status("place");
+                self.board_effects()
+            }
+            Key::Char('+') | Key::Char('=') => {
+                let chip = self.game.roulette_chip().saturating_add(10);
+                self.game.set_roulette_chip(chip);
+                self.board_effects()
+            }
+            Key::Char('-') => {
+                let chip = self.game.roulette_chip().saturating_sub(10).max(10);
+                self.game.set_roulette_chip(chip);
+                self.board_effects()
+            }
+            Key::Char(c) if c.is_ascii_digit() => {
+                let mut input = self.roulette_input();
+                if input.len() < 2 {
+                    input.push(c);
+                    self.game.set_roulette_number_input(&input);
+                }
+                self.board_effects()
+            }
+            Key::Backspace => {
+                let mut input = self.roulette_input();
+                input.pop();
+                self.game.set_roulette_number_input(&input);
+                self.board_effects()
+            }
+            Key::Enter => {
+                let input = self.roulette_input();
+                if !input.is_empty() {
+                    match input.parse::<u8>() {
+                        Ok(number) if number <= 36 => {
+                            self.add_roulette_number(number);
+                            self.game.set_roulette_number_input("");
+                        }
+                        _ => {
+                            self.game.set_roulette_number_input("");
+                            self.game.set_error("Number must be 0-36");
+                        }
+                    }
+                }
+                self.board_effects()
+            }
+            _ => Vec::new(),
+        }
+    }
+
+    fn add_roulette_side(&mut self, side: RouletteSide) -> Vec<Effect> {
+        let chip = self.game.roulette_chip();
+        let mut bets = self.game.roulette_bets();
+        match side {
+            RouletteSide::Red => bets.red = bets.red.saturating_add(chip),
+            RouletteSide::Black => bets.black = bets.black.saturating_add(chip),
+            RouletteSide::Even => bets.even = bets.even.saturating_add(chip),
+            RouletteSide::Odd => bets.odd = bets.odd.saturating_add(chip),
+        }
+        self.place_roulette_bets(bets)
+    }
+
+    fn add_roulette_number(&mut self, number: u8) -> Vec<Effect> {
+        let chip = self.game.roulette_chip();
+        let mut bets = self.game.roulette_bets();
+        if let Some(existing) = bets.numbers.iter_mut().find(|bet| bet.number == number) {
+            existing.amount = existing.amount.saturating_add(chip);
+        } else {
+            bets.numbers.push(NumberBet {
+                number,
+                amount: chip,
+            });
+        }
+        self.place_roulette_bets(bets)
+    }
+
+    fn place_roulette_bets(&mut self, bets: Bets) -> Vec<Effect> {
+        if let Some(balance) = self.balance {
+            if bets.total() > balance.max(0) as u64 {
+                self.game.set_error("Insufficient balance");
+                return self.board_effects();
+            }
+        }
+
+        self.game.set_roulette_bets(&bets);
+        self.game.set_roulette_status("place");
+        self.board_effects()
+    }
+
+    fn spin_roulette(&mut self) -> Vec<Effect> {
+        let bets = self.game.roulette_bets();
+        if bets.is_empty() {
+            self.game.set_error("Place at least one bet");
+            return self.board_effects();
+        }
+        if let Some(balance) = self.balance {
+            if bets.total() > balance.max(0) as u64 {
+                self.game.set_error("Insufficient balance");
+                return self.board_effects();
+            }
+        }
+        let Some(request) = self.game.spin_request() else {
+            return Vec::new();
+        };
+        if self.game.begin_spin().is_err() {
+            return Vec::new();
+        }
+        self.pending = Some(Pending::RouletteSpin);
+
+        let mut effects = self.board_effects();
+        effects.push(Effect::SendLine(request));
+        effects
+    }
+
+    fn roulette_input(&self) -> String {
+        self.game
+            .get_current_state()
+            .and_then(|state| state.data.get("number_input"))
+            .cloned()
+            .unwrap_or_default()
+    }
+
     fn submit(&mut self) -> Vec<Effect> {
         let line = self.input.trim().to_string();
         self.input.clear();
diff --git a/src/client/games/manager.rs b/src/client/games/manager.rs
index 168c49d..02e9451 100644
--- a/src/client/games/manager.rs
+++ b/src/client/games/manager.rs
@@ -1,6 +1,8 @@
-use super::response::SpinResult;
+use super::response::{RouletteResult, SpinResult};
+use super::roulette::RouletteGame;
 use super::slots::SlotsGame;
 use super::traits::{Game, GameError, GamePhase, GameState};
+use crate::roulette::Bets;
 use std::collections::HashMap;
 
 pub struct GameManager {
@@ -12,6 +14,7 @@ impl GameManager {
     pub fn new() -> Self {
         let mut games: HashMap<String, Box<dyn Game>> = HashMap::new();
         games.insert("slots".to_string(), Box::new(SlotsGame::new()));
+        games.insert("roulette".to_string(), Box::new(RouletteGame::new()));
 
         Self {
             current_session: None,
@@ -38,11 +41,25 @@ impl GameManager {
             return Err(GameError::InvalidAction);
         }
 
+        let mut data = HashMap::new();
+        let bet_amount = if game_type == "roulette" {
+            data.insert(
+                "bets".to_string(),
+                serde_json::to_string(&Bets::default()).unwrap_or_else(|_| "{}".to_string()),
+            );
+            data.insert("chip".to_string(), "10".to_string());
+            data.insert("status".to_string(), "place".to_string());
+            data.insert("number_input".to_string(), String::new());
+            0
+        } else {
+            10
+        };
+
         self.current_session = Some(GameState {
             game_type: game_type.to_string(),
-            bet_amount: 10,
+            bet_amount,
             phase: GamePhase::WaitingToStart,
-            data: HashMap::new(),
+            data,
         });
 
         Ok(())
@@ -54,6 +71,17 @@ impl GameManager {
         if session.phase != GamePhase::WaitingToStart && session.phase != GamePhase::Finished {
             return None;
         }
+        if session.game_type == "roulette" {
+            let bets = session
+                .data
+                .get("bets")
+                .cloned()
+                .unwrap_or_else(|| "{}".to_string());
+            return Some(format!(
+                "PLAY_START roulette {} {}",
+                session.bet_amount, bets
+            ));
+        }
         Some(format!(
             "PLAY_START {} {}",
             session.game_type, session.bet_amount
@@ -78,6 +106,13 @@ impl GameManager {
         session.data.remove("win_lines");
         session.data.remove("win_cells");
         session.data.remove("winnings");
+        session.data.remove("number");
+        session.data.remove("color");
+        if session.game_type == "roulette" {
+            session
+                .data
+                .insert("status".to_string(), "spinning".to_string());
+        }
         Ok(())
     }
 
@@ -130,6 +165,13 @@ impl GameManager {
         session.data.remove("win_lines");
         session.data.remove("win_cells");
         session.data.remove("winnings");
+        session.data.remove("number");
+        session.data.remove("color");
+        if session.game_type == "roulette" {
+            session
+                .data
+                .insert("status".to_string(), "place".to_string());
+        }
         session.data.insert("error".to_string(), message.into());
     }
 
@@ -141,6 +183,83 @@ impl GameManager {
         }
     }
 
+    pub fn roulette_bets(&self) -> Bets {
+        self.current_session
+            .as_ref()
+            .and_then(|session| session.data.get("bets"))
+            .and_then(|raw| serde_json::from_str(raw).ok())
+            .unwrap_or_default()
+    }
+
+    pub fn set_roulette_bets(&mut self, bets: &Bets) {
+        if let Some(session) = self.current_session.as_mut() {
+            session.data.insert(
+                "bets".to_string(),
+                serde_json::to_string(bets).unwrap_or_else(|_| "{}".to_string()),
+            );
+            session.bet_amount = bets.total();
+        }
+    }
+
+    pub fn roulette_chip(&self) -> u64 {
+        self.current_session
+            .as_ref()
+            .and_then(|session| session.data.get("chip"))
+            .and_then(|value| value.parse().ok())
+            .unwrap_or(10)
+    }
+
+    pub fn set_roulette_chip(&mut self, chip: u64) {
+        if let Some(session) = self.current_session.as_mut() {
+            session.data.insert("chip".to_string(), chip.to_string());
+        }
+    }
+
+    pub fn set_roulette_number_input(&mut self, value: &str) {
+        if let Some(session) = self.current_session.as_mut() {
+            session
+                .data
+                .insert("number_input".to_string(), value.to_string());
+        }
+    }
+
+    pub fn set_roulette_status(&mut self, status: &str) {
+        if let Some(session) = self.current_session.as_mut() {
+            session
+                .data
+                .insert("status".to_string(), status.to_string());
+            if status != "error" {
+                session.data.remove("error");
+            }
+        }
+    }
+
+    pub fn apply_roulette_result(&mut self, result: RouletteResult) {
+        let Some(session) = self.current_session.as_mut() else {
+            return;
+        };
+        session.phase = GamePhase::Finished;
+        session.bet_amount = result.bet_amount;
+        session.data.remove("error");
+        session.data.insert("bets".to_string(), result.bets);
+        session
+            .data
+            .insert("number".to_string(), result.number.to_string());
+        session.data.insert("color".to_string(), result.color);
+        session
+            .data
+            .insert("winnings".to_string(), result.winnings.to_string());
+        session
+            .data
+            .insert("balance".to_string(), result.balance.to_string());
+        session
+            .data
+            .insert("status".to_string(), "result".to_string());
+        session
+            .data
+            .insert("number_input".to_string(), String::new());
+    }
+
     pub fn get_current_game(&self) -> Option<&dyn Game> {
         self.current_session
             .as_ref()
@@ -167,6 +286,12 @@ impl GameManager {
         if session.phase != GamePhase::WaitingToStart && session.phase != GamePhase::Finished {
             return Err(GameError::InvalidAction);
         }
+        if session.game_type == "roulette" {
+            session
+                .data
+                .insert("chip".to_string(), bet.max(10).to_string());
+            return Ok(bet.max(10));
+        }
         session.bet_amount = bet.max(10);
         Ok(session.bet_amount)
     }
diff --git a/src/client/games/mod.rs b/src/client/games/mod.rs
index 63cc579..131ffbb 100644
--- a/src/client/games/mod.rs
+++ b/src/client/games/mod.rs
@@ -1,4 +1,5 @@
 pub mod manager;
 pub mod response;
+pub mod roulette;
 pub mod slots;
 pub mod traits;
diff --git a/src/client/games/response.rs b/src/client/games/response.rs
index d7f9d45..73080dd 100644
--- a/src/client/games/response.rs
+++ b/src/client/games/response.rs
@@ -77,3 +77,67 @@ fn parse_indices(raw: &str) -> Vec<usize> {
         .filter_map(|value| value.trim().parse::<usize>().ok())
         .collect()
 }
+
+#[derive(Debug, Clone, PartialEq, Eq)]
+pub struct RouletteResult {
+    pub session_id: String,
+    pub winnings: u64,
+    pub bet_amount: u64,
+    pub balance: i64,
+    pub number: u8,
+    pub color: String,
+    pub bets: String,
+}
+
+pub fn parse_roulette_response(response: &str) -> Result<RouletteResult, String> {
+    let response = response.trim();
+    if response.is_empty() {
+        return Err("No response from server".to_string());
+    }
+    if let Some(message) = response.strip_prefix("ERROR") {
+        let message = message.trim();
+        return Err(if message.is_empty() {
+            "Server error".to_string()
+        } else {
+            message.to_string()
+        });
+    }
+
+    let parts: Vec<&str> = response.split_whitespace().collect();
+    if parts.first() != Some(&"ROULETTE_RESULT") || parts.len() < 8 {
+        return Err(format!("Unexpected server response: {response}"));
+    }
+
+    let winnings = parts[2]
+        .parse::<u64>()
+        .map_err(|_| format!("Invalid winnings from server: {}", parts[2]))?;
+    let bet_amount = parts[3]
+        .parse::<u64>()
+        .map_err(|_| format!("Invalid bet from server: {}", parts[3]))?;
+    let balance = parts[4]
+        .parse::<i64>()
+        .map_err(|_| format!("Invalid balance from server: {}", parts[4]))?;
+    let number = parts[5]
+        .parse::<u8>()
+        .map_err(|_| format!("Invalid roulette number: {}", parts[5]))?;
+    if number > 36 {
+        return Err(format!("Invalid roulette number: {number}"));
+    }
+    let color = parts[6].to_string();
+    if !matches!(color.as_str(), "green" | "red" | "black") {
+        return Err(format!("Invalid roulette color: {color}"));
+    }
+    let bets = parts[7].to_string();
+    let _: crate::roulette::Bets = serde_json::from_str(&bets)
+        .map_err(|error| format!("Invalid roulette bets: {error}"))?;
+
+    Ok(RouletteResult {
+        session_id: parts[1].to_string(),
+        winnings,
+        bet_amount,
+        balance,
+        number,
+        color,
+        bets,
+    })
+}
diff --git a/src/client/games/roulette.rs b/src/client/games/roulette.rs
new file mode 100644
index 0000000..3379317
--- /dev/null
+++ b/src/client/games/roulette.rs
@@ -0,0 +1,157 @@
+use super::traits::{Game, GameState};
+use crate::roulette::{is_even, is_odd, Bets};
+
+pub const ROULETTE_BOARD_LINES: usize = 8;
+
+pub struct RouletteGame;
+
+impl RouletteGame {
+    pub fn new() -> Self {
+        Self
+    }
+
+    fn bets(state: &GameState) -> Bets {
+        state
+            .data
+            .get("bets")
+            .and_then(|raw| serde_json::from_str(raw).ok())
+            .unwrap_or_default()
+    }
+
+    fn bets_line(bets: &Bets) -> String {
+        let mut parts = Vec::new();
+        if bets.red > 0 {
+            parts.push(format!("RED {}", bets.red));
+        }
+        if bets.black > 0 {
+            parts.push(format!("BLACK {}", bets.black));
+        }
+        if bets.even > 0 {
+            parts.push(format!("EVEN {}", bets.even));
+        }
+        if bets.odd > 0 {
+            parts.push(format!("ODD {}", bets.odd));
+        }
+        for bet in &bets.numbers {
+            parts.push(format!("#{} {}", bet.number, bet.amount));
+        }
+
+        let list = if parts.is_empty() {
+            "(none)".to_string()
+        } else {
+            parts.join("  ")
+        };
+        format!("Bets: {}   Total: {} PLN", list, bets.total())
+    }
+
+    fn result_lines(state: &GameState) -> (String, String) {
+        if let Some(error) = state.data.get("error") {
+            if !error.is_empty() {
+                return (format!("ERROR: {error}"), String::new());
+            }
+        }
+
+        match state.data.get("status").map(String::as_str) {
+            Some("result") => {
+                let number = state
+                    .data
+                    .get("number")
+                    .map(String::as_str)
+                    .unwrap_or("?");
+                let color = state
+                    .data
+                    .get("color")
+                    .map(|value| value.to_uppercase())
+                    .unwrap_or_default();
+                let parity = number
+                    .parse::<u8>()
+                    .ok()
+                    .map(|number| {
+                        if is_even(number) {
+                            " EVEN"
+                        } else if is_odd(number) {
+                            " ODD"
+                        } else {
+                            ""
+                        }
+                    })
+                    .unwrap_or("");
+                let winnings = state
+                    .data
+                    .get("winnings")
+                    .map(String::as_str)
+                    .unwrap_or("0");
+                let result = if winnings == "0" {
+                    "No win.".to_string()
+                } else {
+                    format!("Won {winnings} PLN")
+                };
+                (format!("Winning: {number} {color}{parity}"), result)
+            }
+            Some("spinning") => ("Spinning...".to_string(), String::new()),
+            _ => ("Place bets, then SPACE to spin.".to_string(), String::new()),
+        }
+    }
+}
+
+impl Game for RouletteGame {
+    fn get_name(&self) -> &'static str {
+        "Roulette"
+    }
+
+    fn render(&self, state: &GameState) -> String {
+        let bets = Self::bets(state);
+        let chip = state.data.get("chip").map(String::as_str).unwrap_or("10");
+        let balance = state
+            .data
+            .get("balance")
+            .map(String::as_str)
+            .unwrap_or("?");
+        let input = state
+            .data
+            .get("number_input")
+            .map(String::as_str)
+            .unwrap_or("");
+        let input_line = if input.is_empty() {
+            String::new()
+        } else {
+            format!("Number: {input}_")
+        };
+        let (status, result) = Self::result_lines(state);
+
+        format!(
+            "=== ROULETTE ===\r\nBalance: {} PLN   Chip: {} PLN\r\n{}\r\n{}\r\n{}\r\n{}\r\n[R]ed [B]lack [E]ven [O]dd  [#]Number  [C]lear\r\n[+/-] Chip   [SPACE] Spin   [Q] Quit",
+            balance,
+            chip,
+            Self::bets_line(&bets),
+            input_line,
+            status,
+            result
+        )
+    }
+
+    fn render_lines(&self, _state: &GameState) -> usize {
+        ROULETTE_BOARD_LINES
+    }
+
+    fn get_help(&self) -> String {
+        "ROULETTE (European)\n\
+        ==================\n\
+        37 pockets: 0 plus 1-36. 0 is green and loses all outside bets.\n\
+        \n\
+        Betting:\n\
+        R / B / E / O - add the current chip to red/black/even/odd\n\
+        digits + Enter - add the current chip to that number\n\
+        C - clear all bets\n\
+        + or = / - - change the chip size\n\
+        SPACE - spin when at least one bet is placed\n\
+        Q - exit\n\
+        \n\
+        Payouts:\n\
+        straight number: 35:1 (36x returned)\n\
+        red/black: 1:1 (2x returned)\n\
+        even/odd: 1:1 (2x returned)\n\
+        Multiple bets are settled independently and added together."
+            .to_string()
+    }
+}
diff --git a/src/lib.rs b/src/lib.rs
index a261ab0..84628e5 100644
--- a/src/lib.rs
+++ b/src/lib.rs
@@ -7,6 +7,7 @@
 
 pub mod client;
 pub mod protocol;
+pub mod roulette;
 pub mod server;
 pub mod slots;
 pub mod tofu;
diff --git a/src/roulette.rs b/src/roulette.rs
new file mode 100644
index 0000000..b59f92e
--- /dev/null
+++ b/src/roulette.rs
@@ -0,0 +1,132 @@
+//! European roulette rules shared by the server and client.
+
+use serde::{Deserialize, Serialize};
+
+/// European wheel clockwise from zero.
+pub const WHEEL: [u8; 37] = [
+    0, 32, 15, 19, 4, 21, 2, 25, 17, 34, 6, 27, 13, 36, 11, 30, 8, 23, 10, 5,
+    24, 16, 33, 1, 20, 14, 31, 9, 22, 18, 29, 7, 28, 12, 35, 3, 26,
+];
+
+pub const RED_NUMBERS: [u8; 18] = [
+    1, 3, 5, 7, 9, 12, 14, 16, 18, 19, 21, 23, 25, 27, 30, 32, 34, 36,
+];
+
+/// Total return on a winning straight (35:1 plus the stake).
+pub const STRAIGHT_RETURN: u64 = 36;
+/// Total return on a winning outside bet (1:1 plus the stake).
+pub const EVEN_MONEY_RETURN: u64 = 2;
+
+pub fn is_red(number: u8) -> bool {
+    RED_NUMBERS.contains(&number)
+}
+
+pub fn is_black(number: u8) -> bool {
+    number != 0 && !is_red(number)
+}
+
+pub fn color(number: u8) -> &'static str {
+    if number == 0 {
+        "green"
+    } else if is_red(number) {
+        "red"
+    } else {
+        "black"
+    }
+}
+
+pub fn is_even(number: u8) -> bool {
+    number != 0 && number % 2 == 0
+}
+
+pub fn is_odd(number: u8) -> bool {
+    number != 0 && number % 2 == 1
+}
+
+pub fn rtp() -> f64 {
+    36.0 / 37.0
+}
+
+#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
+pub struct NumberBet {
+    pub number: u8,
+    pub amount: u64,
+}
+
+#[derive(Debug, Clone, Default, PartialEq, Eq, Serialize, Deserialize)]
+pub struct Bets {
+    #[serde(default)]
+    pub red: u64,
+    #[serde(default)]
+    pub black: u64,
+    #[serde(default)]
+    pub even: u64,
+    #[serde(default)]
+    pub odd: u64,
+    #[serde(default)]
+    pub numbers: Vec<NumberBet>,
+}
+
+impl Bets {
+    pub fn total(&self) -> u64 {
+        let mut total = self
+            .red
+            .saturating_add(self.black)
+            .saturating_add(self.even)
+            .saturating_add(self.odd);
+        for bet in &self.numbers {
+            total = total.saturating_add(bet.amount);
+        }
+        total
+    }
+
+    pub fn is_empty(&self) -> bool {
+        self.total() == 0
+    }
+
+    /// Total returned for a winning number, including returned stakes.
+    pub fn winnings(&self, number: u8) -> u64 {
+        let mut winnings = 0u64;
+
+        if number != 0 {
+            if is_red(number) {
+                winnings = winnings.saturating_add(self.red.saturating_mul(EVEN_MONEY_RETURN));
+            } else {
+                winnings =
+                    winnings.saturating_add(self.black.saturating_mul(EVEN_MONEY_RETURN));
+            }
+            if is_even(number) {
+                winnings = winnings.saturating_add(self.even.saturating_mul(EVEN_MONEY_RETURN));
+            } else {
+                winnings = winnings.saturating_add(self.odd.saturating_mul(EVEN_MONEY_RETURN));
+            }
+        }
+
+        for bet in &self.numbers {
+            if bet.number == number {
+                winnings = winnings
+                    .saturating_add(bet.amount.saturating_mul(STRAIGHT_RETURN));
+            }
+        }
+
+        winnings
+    }
+
+    pub fn validate(&self, balance: u64) -> Result<(), String> {
+        if self.is_empty() {
+            return Err("Place at least one bet".to_string());
+        }
+        if self.total() > balance {
+            return Err("Insufficient balance".to_string());
+        }
+        for bet in &self.numbers {
+            if bet.number > 36 {
+                return Err(format!("Invalid number: {}", bet.number));
+            }
+            if bet.amount == 0 {
+                return Err("A bet amount must be positive".to_string());
+            }
+        }
+        Ok(())
+    }
+}
diff --git a/src/server/core.rs b/src/server/core.rs
index 7231577..2ce8b2b 100644
--- a/src/server/core.rs
+++ b/src/server/core.rs
@@ -85,11 +85,11 @@ impl ServerCore {
                 }
             }
             "PLAY_START" => {
-                if parts.len() != 3 {
-                    "ERROR Invalid PLAY_START format. Usage: PLAY_START <game_type> <bet_amount>"
+                if parts.len() != 3 && parts.len() != 4 {
+                    "ERROR Invalid PLAY_START format. Usage: PLAY_START <game_type> <bet_amount> [payload]"
                         .to_string()
                 } else {
-                    self.handle_play_start(state, parts[1], parts[2])
+                    self.handle_play_start(state, parts[1], parts[2], parts.get(3).copied())
                 }
             }
             "REGISTER" => {
@@ -187,6 +187,7 @@ impl ServerCore {
         state: &ConnectionState,
         game_type: &str,
         bet_amount_str: &str,
+        payload: Option<&str>,
     ) -> String {
         let Some(user) = state.user.as_deref() else {
             return "ERROR Not logged in".to_string();
@@ -216,7 +217,8 @@ impl ServerCore {
         }
 
         let game_state = game.prepare_state(user, bet_amount as u64);
-        let new_state = match game.process_action(&game_state, "spin", &[]) {
+        let params: Vec<&str> = payload.into_iter().collect();
+        let new_state = match game.process_action(&game_state, "spin", &params) {
             Ok(state) => state,
             Err(error) => return game_error(error),
         };
@@ -239,26 +241,6 @@ impl ServerCore {
             }
         };
 
-        let reels = result
-            .result_data
-            .get("reels")
-            .cloned()
-            .unwrap_or_default();
-        let win_type = result
-            .result_data
-            .get("win_type")
-            .cloned()
-            .unwrap_or_default();
-        let win_lines = result
-            .result_data
-            .get("win_lines")
-            .cloned()
-            .unwrap_or_else(|| "-".to_string());
-        let win_cells = result
-            .result_data
-            .get("win_cells")
-            .cloned()
-            .unwrap_or_else(|| "-".to_string());
         let details =
             serde_json::to_string(&result.result_data).unwrap_or_else(|_| "{}".to_string());
 
@@ -273,9 +255,50 @@ impl ServerCore {
         ) {
             Ok(new_balance) => {
                 let _ = self.sessions.remove_session(&session_id);
-                format!(
-                    "GAME_RESULT {session_id} {winnings} {bet_amount} {new_balance} {reels} {win_type} {win_lines} {win_cells}"
-                )
+                if game_type == "roulette" {
+                    let number = result
+                        .result_data
+                        .get("number")
+                        .cloned()
+                        .unwrap_or_default();
+                    let color = result
+                        .result_data
+                        .get("color")
+                        .cloned()
+                        .unwrap_or_default();
+                    let bets = result
+                        .result_data
+                        .get("bets")
+                        .cloned()
+                        .unwrap_or_else(|| "{}".to_string());
+                    format!(
+                        "ROULETTE_RESULT {session_id} {winnings} {bet_amount} {new_balance} {number} {color} {bets}"
+                    )
+                } else {
+                    let reels = result
+                        .result_data
+                        .get("reels")
+                        .cloned()
+                        .unwrap_or_default();
+                    let win_type = result
+                        .result_data
+                        .get("win_type")
+                        .cloned()
+                        .unwrap_or_default();
+                    let win_lines = result
+                        .result_data
+                        .get("win_lines")
+                        .cloned()
+                        .unwrap_or_else(|| "-".to_string());
+                    let win_cells = result
+                        .result_data
+                        .get("win_cells")
+                        .cloned()
+                        .unwrap_or_else(|| "-".to_string());
+                    format!(
+                        "GAME_RESULT {session_id} {winnings} {bet_amount} {new_balance} {reels} {win_type} {win_lines} {win_cells}"
+                    )
+                }
             }
             Err(error) => {
                 let _ = self.sessions.remove_session(&session_id);
diff --git a/src/server/games/mod.rs b/src/server/games/mod.rs
index 4c62760..35728a1 100644
--- a/src/server/games/mod.rs
+++ b/src/server/games/mod.rs
@@ -1,4 +1,5 @@
 pub mod registry;
+pub mod roulette;
 pub mod session;
 pub mod slots;
 pub mod traits;
diff --git a/src/server/games/registry.rs b/src/server/games/registry.rs
index b7ed9d3..51d446b 100644
--- a/src/server/games/registry.rs
+++ b/src/server/games/registry.rs
@@ -1,5 +1,6 @@
 #![allow(dead_code)]
 
+use super::roulette::RouletteGame;
 use super::slots::SlotsGame;
 use super::traits::Game;
 use std::collections::HashMap;
@@ -21,6 +22,7 @@ impl GameRegistry {
     pub fn with_defaults() -> Self {
         let registry = Self::new();
         registry.register_game(SlotsGame::new());
+        registry.register_game(RouletteGame::new());
         registry
     }
 
diff --git a/src/server/games/roulette.rs b/src/server/games/roulette.rs
new file mode 100644
index 0000000..7beb8c9
--- /dev/null
+++ b/src/server/games/roulette.rs
@@ -0,0 +1,151 @@
+use super::traits::{Game, GameError, GamePhase, GameResult, GameState};
+use crate::roulette::{color, Bets};
+use rand::Rng;
+use std::collections::HashMap;
+
+pub struct RouletteGame {
+    fixed_number: Option<u8>,
+}
+
+impl RouletteGame {
+    pub fn new() -> Self {
+        Self { fixed_number: None }
+    }
+
+    pub fn with_result(number: u8) -> Self {
+        Self {
+            fixed_number: Some(number),
+        }
+    }
+
+    fn spin(&self) -> u8 {
+        match self.fixed_number {
+            Some(number) => number,
+            None => rand::thread_rng().gen_range(0..37),
+        }
+    }
+}
+
+impl Game for RouletteGame {
+    fn game_type(&self) -> &'static str {
+        "roulette"
+    }
+
+    fn get_name(&self) -> &'static str {
+        "Roulette"
+    }
+
+    fn get_description(&self) -> &'static str {
+        "European roulette. Bet on red/black, even/odd, or a straight number."
+    }
+
+    fn prepare_state(&self, username: &str, bet_amount: u64) -> GameState {
+        let mut data = HashMap::new();
+        data.insert("username".to_string(), username.to_string());
+        data.insert("status".to_string(), "ready".to_string());
+
+        GameState {
+            session_id: String::new(),
+            game_type: "roulette".to_string(),
+            bet_amount,
+            phase: GamePhase::WaitingToStart,
+            data,
+        }
+    }
+
+    fn process_action(
+        &self,
+        state: &GameState,
+        action: &str,
+        params: &[&str],
+    ) -> Result<GameState, GameError> {
+        if state.phase == GamePhase::Finished {
+            return Err(GameError::GameOver);
+        }
+
+        match action {
+            "spin" => {
+                if state.phase != GamePhase::WaitingToStart
+                    && state.phase != GamePhase::Playing
+                {
+                    return Err(GameError::InvalidAction(
+                        "Cannot spin in current phase".to_string(),
+                    ));
+                }
+
+                let payload = params
+                    .first()
+                    .ok_or(GameError::InvalidAction("Missing roulette bets".to_string()))?;
+                let bets: Bets = serde_json::from_str(payload)
+                    .map_err(|error| GameError::InvalidAction(format!("Invalid bets: {error}")))?;
+
+                if bets.is_empty() {
+                    return Err(GameError::InvalidBet);
+                }
+                if let Err(message) = bets.validate(state.bet_amount) {
+                    return Err(GameError::InvalidAction(message));
+                }
+                if bets.total() != state.bet_amount {
+                    return Err(GameError::InvalidBet);
+                }
+
+                let number = self.spin();
+                let bets_json = serde_json::to_string(&bets)
+                    .map_err(|error| GameError::InternalError(error.to_string()))?;
+
+                let mut new_data = state.data.clone();
+                new_data.insert("status".to_string(), "spun".to_string());
+                new_data.insert("bets".to_string(), bets_json);
+                new_data.insert("number".to_string(), number.to_string());
+                new_data.insert("color".to_string(), color(number).to_string());
+
+                Ok(GameState {
+                    session_id: state.session_id.clone(),
+                    game_type: state.game_type.clone(),
+                    bet_amount: state.bet_amount,
+                    phase: GamePhase::Finished,
+                    data: new_data,
+                })
+            }
+            _ => Err(GameError::InvalidAction(format!(
+                "Unknown action: {action}"
+            ))),
+        }
+    }
+
+    fn calculate_result(&self, state: &GameState) -> Result<GameResult, GameError> {
+        if state.phase != GamePhase::Finished {
+            return Err(GameError::InternalError("Game not finished".to_string()));
+        }
+
+        let number: u8 = state
+            .data
+            .get("number")
+            .ok_or(GameError::InternalError("No winning number".to_string()))?
+            .parse()
+            .map_err(|_| GameError::InternalError("Invalid winning number".to_string()))?;
+        let bets_json = state
+            .data
+            .get("bets")
+            .ok_or(GameError::InternalError("No bets".to_string()))?
+            .clone();
+        let bets: Bets = serde_json::from_str(&bets_json)
+            .map_err(|error| GameError::InternalError(format!("Invalid bets: {error}")))?;
+
+        let winnings = bets.winnings(number);
+
+        let mut result_data = HashMap::new();
+        result_data.insert("number".to_string(), number.to_string());
+        result_data.insert("color".to_string(), color(number).to_string());
+        result_data.insert("bets".to_string(), bets_json);
+
+        Ok(GameResult {
+            session_id: state.session_id.clone(),
+            game_type: state.game_type.clone(),
+            bet_amount: state.bet_amount,
+            winnings,
+            final_balance: 0,
+            result_data,
+        })
+    }
+}