aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authormetamuffin <metamuffin@disroot.org>2025-04-13 14:38:00 +0200
committermetamuffin <metamuffin@disroot.org>2025-04-13 14:38:00 +0200
commit821af51985ace4dc0efb7f7c3ff86c7f8730c9ea (patch)
treea77d38a791b7e2ae94ee93ecef7c6c413956d18a /src
parent12f974fc95c9c166423c40381d698286cc6dff39 (diff)
downloadgpn-tron-rust-821af51985ace4dc0efb7f7c3ff86c7f8730c9ea.tar
gpn-tron-rust-821af51985ace4dc0efb7f7c3ff86c7f8730c9ea.tar.bz2
gpn-tron-rust-821af51985ace4dc0efb7f7c3ff86c7f8730c9ea.tar.zst
update for newer rust versionsHEADmaster
Diffstat (limited to 'src')
-rw-r--r--src/bot/mod.rs7
-rw-r--r--src/lib.rs1
-rw-r--r--src/spectate/server.rs6
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:?; "");
}
}
diff --git a/src/lib.rs b/src/lib.rs
index f07a24a..349c988 100644
--- a/src/lib.rs
+++ b/src/lib.rs
@@ -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?;
}
}