From cdc292ddd116f20bd3cd3f8edf6d8bc0f2bf959a Mon Sep 17 00:00:00 2001
From: rozgo <alex.rozgo@gmail.com>
Date: Tue, 29 Jul 2025 03:13:17 -0600
Subject: [PATCH] proper telemetry

---
 node-hub/dora-rerun/src/lib.rs    | 11 ++++++++---
 node-hub/dora-rerun/src/series.rs | 15 ---------------
 2 files changed, 8 insertions(+), 18 deletions(-)
 delete mode 100644 node-hub/dora-rerun/src/series.rs

diff --git a/node-hub/dora-rerun/src/lib.rs b/node-hub/dora-rerun/src/lib.rs
index 0c102aff..1c3a696d 100644
--- a/node-hub/dora-rerun/src/lib.rs
+++ b/node-hub/dora-rerun/src/lib.rs
@@ -18,9 +18,7 @@ use rerun::{
 };
 pub mod boxes2d;
 pub mod boxes3d;
-pub mod series;
 pub mod urdf;
-use series::update_series;
 use urdf::{init_urdf, update_visualization};
 
 pub fn lib_main() -> Result<()> {
@@ -412,7 +410,14 @@ pub fn lib_main() -> Result<()> {
                     }
                 }
                 "series" => {
-                    update_series(&rec, id, data).context("could not plot series")?;
+                    let values = into_vec::<f32>(&data).context("could not cast series values")?;
+                    if !values.is_empty() {
+                        rec.log(
+                            id.as_str(),
+                            &rerun::Scalars::new([values[0] as f64]),
+                        )
+                        .context("could not log series")?;
+                    }
                 }
                 "points3d" => {
                     // Get color from metadata
diff --git a/node-hub/dora-rerun/src/series.rs b/node-hub/dora-rerun/src/series.rs
deleted file mode 100644
index ea81d003..00000000
--- a/node-hub/dora-rerun/src/series.rs
+++ /dev/null
@@ -1,15 +0,0 @@
-use dora_node_api::{dora_core::config::DataId, into_vec, ArrowData};
-use eyre::{Context, Result};
-use rerun::RecordingStream;
-
-pub fn update_series(rec: &RecordingStream, id: DataId, data: ArrowData) -> Result<()> {
-    let series = into_vec::<f64>(&data).context("could not cast values")?;
-    for (i, value) in series.iter().enumerate() {
-        rec.log(
-            format!("{}_{}", id.as_str(), i),
-            &rerun::Scalars::new([*value]),
-        )
-        .wrap_err("could not log series")?;
-    }
-    Ok(())
-}