diff options
author | metamuffin <metamuffin@disroot.org> | 2025-04-13 14:38:00 +0200 |
---|---|---|
committer | metamuffin <metamuffin@disroot.org> | 2025-04-13 14:38:00 +0200 |
commit | 821af51985ace4dc0efb7f7c3ff86c7f8730c9ea (patch) | |
tree | a77d38a791b7e2ae94ee93ecef7c6c413956d18a /src | |
parent | 12f974fc95c9c166423c40381d698286cc6dff39 (diff) | |
download | gpn-tron-rust-821af51985ace4dc0efb7f7c3ff86c7f8730c9ea.tar gpn-tron-rust-821af51985ace4dc0efb7f7c3ff86c7f8730c9ea.tar.bz2 gpn-tron-rust-821af51985ace4dc0efb7f7c3ff86c7f8730c9ea.tar.zst |
Diffstat (limited to 'src')
-rw-r--r-- | src/bot/mod.rs | 7 | ||||
-rw-r--r-- | src/lib.rs | 1 | ||||
-rw-r--r-- | src/spectate/server.rs | 6 |
3 files changed, 5 insertions, 9 deletions
diff --git a/src/bot/mod.rs b/src/bot/mod.rs index 17472d2..3722bf8 100644 --- a/src/bot/mod.rs +++ b/src/bot/mod.rs @@ -1,6 +1,6 @@ use crate::{game::protocol::Direction, State}; use log::debug; -use rand::{seq::IteratorRandom, thread_rng}; +use rand::{rng, seq::IteratorRandom}; use serde::Deserialize; use std::{ops::DerefMut, sync::Arc}; use tokio::spawn; @@ -38,10 +38,7 @@ async fn bot(_config: Config, state: Arc<State>, name: String) { possible.push(d) } } - *dir = *possible - .iter() - .choose(&mut thread_rng()) - .unwrap_or(&Direction::Up); + *dir = *possible.iter().choose(&mut rng()).unwrap_or(&Direction::Up); debug!(name:?, dir:?; ""); } } @@ -1,4 +1,3 @@ -#![feature(async_closure)] #![feature(iterator_try_collect)] use game::Game; use redb::Database; diff --git a/src/spectate/server.rs b/src/spectate/server.rs index fdcc815..7f8c90a 100644 --- a/src/spectate/server.rs +++ b/src/spectate/server.rs @@ -5,7 +5,7 @@ use axum::{ extract::{ self, connect_info::ConnectInfo, - ws::{Message, WebSocket, WebSocketUpgrade}, + ws::{Message, Utf8Bytes, WebSocket, WebSocketUpgrade}, }, http::HeaderMap, response::{Html, IntoResponse}, @@ -217,7 +217,7 @@ async fn handle_socket( let past = state.past_events.read().await.clone(); for p in past { socket - .send(Message::Text(serde_json::to_string(&p)?)) + .send(Message::Text(Utf8Bytes::from(serde_json::to_string(&p)?))) .await?; } let mut live = state.events.subscribe(); @@ -229,7 +229,7 @@ async fn handle_socket( } event = live.recv() => { socket - .send(Message::Text(serde_json::to_string(&event?)?)) + .send(Message::Text(Utf8Bytes::from( serde_json::to_string(&event?)?))) .await?; } } |