From 6228b2393d8a3aff9396f137887607531c455047 Mon Sep 17 00:00:00 2001 From: prplV Date: Fri, 21 Feb 2025 14:18:48 +0300 Subject: [PATCH] tagged array creation rework --- crates/api-grub/src/json.rs | 20 +++++++++++--------- crates/api-grub/src/net.rs | 2 +- 2 files changed, 12 insertions(+), 10 deletions(-) diff --git a/crates/api-grub/src/json.rs b/crates/api-grub/src/json.rs index 6208724..c6ecedd 100644 --- a/crates/api-grub/src/json.rs +++ b/crates/api-grub/src/json.rs @@ -21,8 +21,8 @@ impl JsonParser { return Value::Null; } - let mut vec_value: Vec = Vec::new(); - let mut array_key = String::new(); + // let mut vec_value: Vec = Vec::new(); + // let mut array_key = String::new(); let mut value_json: Value = serde_json::from_str(json).unwrap_or(Value::Null); let target_attr_vec = target.addr @@ -97,16 +97,18 @@ impl JsonParser { .enumerate() .map(|(idx, val)| { let val = val.get(tag_name).unwrap_or(&Value::Null).clone(); - (serde_json::from_value::>(json!({tag_name: val})), + (serde_json::from_value::>( + json!({"tag_name": tag_name, "tag_value": val}) + ), serde_json::from_value::>(metrics[idx].clone())) }) - .for_each(|(key, val)| { - // dbg!(&key); - if key.is_ok() && val.is_ok() { - let mut key = key.unwrap(); + .for_each(|(tags, val)| { + if val.is_ok() && tags.is_ok() { + let mut tags = tags.unwrap(); let mut val = val.unwrap(); - key.append(&mut val); - values.push(json!(key)); + tags.append(&mut val); + dbg!(&tags); + values.push(json!(tags)); } }); if values.len() == 0 { diff --git a/crates/api-grub/src/net.rs b/crates/api-grub/src/net.rs index 5434b6c..8b21b39 100644 --- a/crates/api-grub/src/net.rs +++ b/crates/api-grub/src/net.rs @@ -14,7 +14,7 @@ use dotenv::dotenv; use crate::json::JsonParser; use crate::export::Exporter; use integr_structs::api::v3::{Config, ConfigEndpoint, Credentials, Metrics, PrometheusMetrics}; -use md5::compute; +// use md5::compute; // type BufferType = Arc>>;