aboutsummaryrefslogtreecommitdiff
path: root/server
diff options
context:
space:
mode:
Diffstat (limited to 'server')
-rw-r--r--server/bot/src/algos/customer.rs14
-rw-r--r--server/bot/src/algos/dishwasher.rs4
-rw-r--r--server/discover/src/main.rs2
-rw-r--r--server/registry/src/conn_test.rs2
-rw-r--r--server/registry/src/main.rs3
-rw-r--r--server/src/commands.rs15
-rw-r--r--server/src/entity/campaign.rs2
-rw-r--r--server/src/entity/tutorial.rs2
-rw-r--r--server/src/message.rs6
-rw-r--r--server/src/network/register.rs2
-rw-r--r--server/src/server.rs2
11 files changed, 24 insertions, 30 deletions
diff --git a/server/bot/src/algos/customer.rs b/server/bot/src/algos/customer.rs
index 67605ad5..e26acf09 100644
--- a/server/bot/src/algos/customer.rs
+++ b/server/bot/src/algos/customer.rs
@@ -173,15 +173,11 @@ impl CustomerState {
}
} else if check
&& path.remaining_segments() < 5
- && game
- .players
- .iter()
- .find(|(id, p)| {
- p.class == PlayerClass::Customer
- && **id != me
- && p.movement.position.distance(chair.as_vec2() + 0.5) < 1.
- })
- .is_some()
+ && game.players.iter().any(|(id, p)| {
+ p.class == PlayerClass::Customer
+ && *id != me
+ && p.movement.position.distance(chair.as_vec2() + 0.5) < 1.
+ })
{
*self = CustomerState::New;
BotInput::default()
diff --git a/server/bot/src/algos/dishwasher.rs b/server/bot/src/algos/dishwasher.rs
index b52b72d1..e4a49978 100644
--- a/server/bot/src/algos/dishwasher.rs
+++ b/server/bot/src/algos/dishwasher.rs
@@ -32,9 +32,9 @@ type LogicRes<Out = ()> = Result<Out, ()>;
impl BotAlgo for DishWasher {
fn tick(&mut self, me: PlayerID, game: &Game, dt: f32) -> BotInput {
- if let None = self.dirty_plate {
+ if self.dirty_plate.is_none() {
self.dirty_plate = game.data.get_item_by_name("dirty-plate");
- if let None = self.dirty_plate {
+ if self.dirty_plate.is_none() {
return BotInput::default();
}
}
diff --git a/server/discover/src/main.rs b/server/discover/src/main.rs
index f1f2bb35..f546cd6c 100644
--- a/server/discover/src/main.rs
+++ b/server/discover/src/main.rs
@@ -57,7 +57,7 @@ async fn async_main() -> Result<!> {
.to_owned(),
address: service_info
.get_addresses()
- .into_iter()
+ .iter()
.map(|a| {
format!("ws://{}", SocketAddr::new(*a, service_info.get_port()))
})
diff --git a/server/registry/src/conn_test.rs b/server/registry/src/conn_test.rs
index 2fda288c..9825997c 100644
--- a/server/registry/src/conn_test.rs
+++ b/server/registry/src/conn_test.rs
@@ -72,7 +72,7 @@ async fn test_connect_inner(addr: SocketAddr, uri: &str) -> Result<(u32, u32)> {
let net = Network::connect_raw(stream, uri).await?;
let packet = net.receive().await?;
match packet {
- Some(PacketC::Version { minor, major, .. }) => return Ok((major, minor)),
+ Some(PacketC::Version { minor, major, .. }) => Ok((major, minor)),
_ => bail!("bad initial packet"),
}
}
diff --git a/server/registry/src/main.rs b/server/registry/src/main.rs
index 30fb8d66..85c0f066 100644
--- a/server/registry/src/main.rs
+++ b/server/registry/src/main.rs
@@ -138,7 +138,7 @@ impl Registry {
self.servers.retain(|_, e| {
e.address
.retain(|_, updated| updated.elapsed() < Duration::from_secs(120));
- e.address.len() > 0
+ !e.address.is_empty()
});
}
}
@@ -152,6 +152,7 @@ struct InternalEntry {
version: (u32, u32),
}
+#[allow(clippy::derivable_impls)]
impl Default for InternalEntry {
fn default() -> Self {
Self {
diff --git a/server/src/commands.rs b/server/src/commands.rs
index 86a3de15..24752cc5 100644
--- a/server/src/commands.rs
+++ b/server/src/commands.rs
@@ -332,15 +332,10 @@ impl Server {
.get_item_by_name(&item)
.ok_or(tre!("s.error.item_not_found", s = item))?;
#[cfg(not(test))] // TODO rust-analyser does not undestand trait upcasting
- if self
- .entities
- .iter()
- .find(|e| {
- <dyn std::any::Any>::downcast_ref::<Tutorial>(e.as_ref())
- .map_or(false, |t| t.player == player)
- })
- .is_some()
- {
+ if self.entities.iter().any(|e| {
+ <dyn std::any::Any>::downcast_ref::<Tutorial>(e.as_ref())
+ .map_or(false, |t| t.player == player)
+ }) {
return Err(tre!("s.error.tutorial_already_running"));
}
self.entities.push(Box::new(Tutorial::new(player, item)));
@@ -365,7 +360,7 @@ impl Server {
player,
message: Some(Message::Translation {
id: message_id,
- params: arguments.into_iter().map(|c| Message::Text(c)).collect(),
+ params: arguments.into_iter().map(Message::Text).collect(),
}),
timeout: None,
});
diff --git a/server/src/entity/campaign.rs b/server/src/entity/campaign.rs
index 6683716d..39926a12 100644
--- a/server/src/entity/campaign.rs
+++ b/server/src/entity/campaign.rs
@@ -117,6 +117,8 @@ impl GateCondition {
.reduce(|a, b| trm!("s.campaign.list_helper", m = a, m = b))
.unwrap_or(Message::Text(String::new())),
GateCondition::Stars(map, thres) => {
+ // TODO show current score
+ let _ = scoreboard;
trm!(
"s.campaign.condition.stars",
s = thres.to_string(),
diff --git a/server/src/entity/tutorial.rs b/server/src/entity/tutorial.rs
index 1d28f13e..60b32c79 100644
--- a/server/src/entity/tutorial.rs
+++ b/server/src/entity/tutorial.rs
@@ -138,7 +138,7 @@ struct StepContext<'a> {
player: PlayerID,
}
-impl<'a> StepContext<'a> {
+impl StepContext<'_> {
fn is_hand_item(&self, item: ItemIndex) -> bool {
self.ent
.game
diff --git a/server/src/message.rs b/server/src/message.rs
index 79c004a2..069c2b0b 100644
--- a/server/src/message.rs
+++ b/server/src/message.rs
@@ -25,7 +25,7 @@ macro_rules! trm {
($id:literal $(, $typ:ident = $param:expr)*) => {
hurrycurry_protocol::Message::Translation {
id: $id.to_owned(),
- params: vec![$(crate::trm_param!($typ, $param)),*]
+ params: vec![$($crate::trm_param!($typ, $param)),*]
}
};
}
@@ -76,9 +76,9 @@ impl Debug for TrError {
#[macro_export]
macro_rules! tre {
($id:literal $(, $typ:ident = $param:expr)*) => {
- crate::message::TrError::Tr {
+ $crate::message::TrError::Tr {
id: $id,
- params: vec![$(crate::tre_param!($typ, $param)),*]
+ params: vec![$($crate::tre_param!($typ, $param)),*]
}
};
}
diff --git a/server/src/network/register.rs b/server/src/network/register.rs
index 2bd4fa92..eccdf22b 100644
--- a/server/src/network/register.rs
+++ b/server/src/network/register.rs
@@ -29,7 +29,7 @@ use std::{
};
use tokio::{sync::RwLock, time::interval};
-const REGISTRY_URI: &'static str = "https://hurrycurry-registry.metamuffin.org";
+const REGISTRY_URI: &str = "https://hurrycurry-registry.metamuffin.org";
pub struct Register {
name: String,
diff --git a/server/src/server.rs b/server/src/server.rs
index d3e9ab59..b9cafede 100644
--- a/server/src/server.rs
+++ b/server/src/server.rs
@@ -568,7 +568,7 @@ impl Server {
if let Some((_, t)) = &player.communicate_persist {
timeout.initial = t.initial;
};
- player.communicate_persist = message.clone().map(|m| (m, timeout.clone()));
+ player.communicate_persist = message.clone().map(|m| (m, timeout));
Some(timeout)
} else {
None