diff --git a/Cargo.toml b/Cargo.toml index cc53324..98bc989 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -2,7 +2,7 @@ name = "flow-engine" version = "0.1.0" edition = "2024" -rust-version = "1.85" +rust-version = "1.95" description = "Node-RED-style visual flow editor + runtime in Rust (axum + SQLite + Svelte/xyflow). Single binary." [dependencies] diff --git a/src/auth.rs b/src/auth.rs index 225dbeb..8bb8fea 100644 --- a/src/auth.rs +++ b/src/auth.rs @@ -162,10 +162,10 @@ pub async fn logout(State(st): State, req: Request) -> Response { /// Extract the token from the Authorization header or the `?token=` query. fn extract_token(req: &Request) -> Option { - if let Some(value) = req.headers().get(header::AUTHORIZATION) { - if let Some(token) = value.to_str().ok().and_then(|s| s.strip_prefix("Bearer ")) { - return Some(token.to_string()); - } + if let Some(value) = req.headers().get(header::AUTHORIZATION) + && let Some(token) = value.to_str().ok().and_then(|s| s.strip_prefix("Bearer ")) + { + return Some(token.to_string()); } req.uri().query().and_then(|q| { q.split('&') diff --git a/src/runtime/mod.rs b/src/runtime/mod.rs index acc1434..f1480e6 100644 --- a/src/runtime/mod.rs +++ b/src/runtime/mod.rs @@ -49,11 +49,11 @@ fn merge_broker( .filter(|id| !id.is_empty()) .and_then(|id| configs.get(id)); let mut merged = node_cfg.clone(); - if let (Some(broker), Some(obj)) = (broker, merged.as_object_mut()) { - if let Some(fields) = broker.as_object() { - for (k, v) in fields { - obj.insert(k.clone(), v.clone()); - } + if let (Some(broker), Some(obj)) = (broker, merged.as_object_mut()) + && let Some(fields) = broker.as_object() + { + for (k, v) in fields { + obj.insert(k.clone(), v.clone()); } } merged diff --git a/src/runtime/nodes/range.rs b/src/runtime/nodes/range.rs index bffb2a7..9ee5f6e 100644 --- a/src/runtime/nodes/range.rs +++ b/src/runtime/nodes/range.rs @@ -84,10 +84,10 @@ impl RangeNode { let Some(v) = msgprop::get(msg, &self.property).and_then(|v| v.as_f64()) else { return; }; - if let Some(mapped) = self.map(v) { - if let Some(n) = serde_json::Number::from_f64(mapped) { - msgprop::set(msg, &self.property, json!(n)); - } + if let Some(mapped) = self.map(v) + && let Some(n) = serde_json::Number::from_f64(mapped) + { + msgprop::set(msg, &self.property, json!(n)); } } }