v3.2.0: straight and split bets anywhere on the felt; add history command

1 files changed, 34 insertions, 0 deletions

diff --git a/src/server/core.rs b/src/server/core.rs
index 4b68ccb..89264f3 100644
--- a/src/server/core.rs
+++ b/src/server/core.rs
@@ -172,6 +172,21 @@ impl ServerCore {
                     self.handle_auth(state, parts[1], parts[2])
                 }
             }
+            "HISTORY" => {
+                if parts.len() > 2 {
+                    "ERROR Invalid HISTORY format. Usage: HISTORY [count]".to_string()
+                } else {
+                    match parts.get(1) {
+                        Some(raw) => match raw.parse::<u32>() {
+                            Ok(count) if count > 0 => {
+                                self.handle_history(state, count.min(crate::history::MAX_HISTORY))
+                            }
+                            _ => "ERROR Invalid HISTORY count".to_string(),
+                        },
+                        None => self.handle_history(state, crate::history::DEFAULT_HISTORY),
+                    }
+                }
+            }
             "PING" => "PONG".to_string(),
             "INFO" => self.handle_info(state),
             _ => msg.to_string(),
@@ -234,6 +249,25 @@ impl ServerCore {
         }
     }
 
+    fn handle_history(&mut self, state: &ConnectionState, limit: u32) -> String {
+        let Some(user) = state.user.as_deref() else {
+            return "ERROR Not logged in".to_string();
+        };
+        match database::recent_plays(&self.conn, user, limit) {
+            Ok(records) => match serde_json::to_string(&records) {
+                Ok(json) => format!("HISTORY {json}"),
+                Err(error) => {
+                    eprintln!("History serialization failed for {user}: {error}");
+                    "ERROR Could not read history".to_string()
+                }
+            },
+            Err(error) => {
+                eprintln!("History query failed for {user}: {error}");
+                "ERROR Could not read history".to_string()
+            }
+        }
+    }
+
     fn handle_info(&self, state: &ConnectionState) -> String {
         let Some(user) = state.user.as_deref() else {
             return "ERROR Not logged in".to_string();