Skip to content

Commit b4818c5

Browse files
committed
Refactor json_value_to_variant method calls to use associated function syntax
1 parent ca799f8 commit b4818c5

File tree

1 file changed

+5
-5
lines changed
  • crates/core/src/runtime/nodes/network_nodes

1 file changed

+5
-5
lines changed

crates/core/src/runtime/nodes/network_nodes/mqtt_in.rs

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -291,7 +291,7 @@ impl MqttInNode {
291291
match std::str::from_utf8(payload) {
292292
Ok(s) => {
293293
match serde_json::from_str::<serde_json::Value>(s) {
294-
Ok(json_val) => self.json_value_to_variant(json_val),
294+
Ok(json_val) => Self::json_value_to_variant(json_val),
295295
Err(_) => Variant::String(s.to_string()), // Fallback to string
296296
}
297297
}
@@ -305,7 +305,7 @@ impl MqttInNode {
305305
if datatype == &MqttDataType::AutoDetect
306306
&& let Ok(json_val) = serde_json::from_str::<serde_json::Value>(utf8_str)
307307
{
308-
return self.json_value_to_variant(json_val);
308+
return Self::json_value_to_variant(json_val);
309309
}
310310
// Return as string
311311
Variant::String(utf8_str.to_string())
@@ -318,19 +318,19 @@ impl MqttInNode {
318318
}
319319

320320
/// Convert JSON value to Variant
321-
fn json_value_to_variant(&self, json_val: serde_json::Value) -> Variant {
321+
fn json_value_to_variant(json_val: serde_json::Value) -> Variant {
322322
match json_val {
323323
serde_json::Value::Null => Variant::Null,
324324
serde_json::Value::Bool(b) => Variant::Bool(b),
325325
serde_json::Value::Number(n) => Variant::Number(n),
326326
serde_json::Value::String(s) => Variant::String(s),
327327
serde_json::Value::Array(arr) => {
328-
let variants: Vec<Variant> = arr.into_iter().map(|v| self.json_value_to_variant(v)).collect();
328+
let variants: Vec<Variant> = arr.into_iter().map(Self::json_value_to_variant).collect();
329329
Variant::Array(variants)
330330
}
331331
serde_json::Value::Object(obj) => {
332332
let map: std::collections::BTreeMap<String, Variant> =
333-
obj.into_iter().map(|(k, v)| (k, self.json_value_to_variant(v))).collect();
333+
obj.into_iter().map(|(k, v)| (k, Self::json_value_to_variant(v))).collect();
334334
Variant::Object(map)
335335
}
336336
}

0 commit comments

Comments
 (0)