From 2474a2be29a32b4ea7fa84f419e4881bf710fb0d Mon Sep 17 00:00:00 2001
From: Ashish Kolhe <35160958+oasisk@users.noreply.github.com>
Date: Sat, 25 Mar 2023 10:52:54 +0530
Subject: [PATCH] Updated stream size in mb (#408)

---
 src/meta/telemetry.rs | 19 ++++++++++++-------
 1 file changed, 12 insertions(+), 7 deletions(-)

diff --git a/src/meta/telemetry.rs b/src/meta/telemetry.rs
index b0db8a4d01..85d59f677a 100644
--- a/src/meta/telemetry.rs
+++ b/src/meta/telemetry.rs
@@ -16,6 +16,8 @@ use segment::{message::Track, Client, Message};
 use serde_json::Value;
 use std::collections::HashMap;
 
+const SIZE_IN_MB: f64 = 1024.0 * 1024.0;
+
 use crate::infra::{
     cache::stats::STATS,
     config::{
@@ -158,16 +160,19 @@ pub fn add_zo_info(data: &mut HashMap<String, Value>) {
             }
         }
     }
-    let mut sterams_orig_size: f64 = 0.0;
-    let mut sterams_compressed_size: f64 = 0.0;
+    let mut streams_orig_size: f64 = 0.0;
+    let mut streams_compressed_size: f64 = 0.0;
     for stats in STATS.iter().clone() {
-        sterams_orig_size += stats.storage_size;
-        sterams_compressed_size += stats.compressed_size
+        streams_orig_size += stats.storage_size;
+        streams_compressed_size += stats.compressed_size
     }
-    data.insert("streams_total_size".to_string(), sterams_orig_size.into());
     data.insert(
-        "streams_compressed_size".to_string(),
-        sterams_compressed_size.into(),
+        "streams_total_size_mb".to_string(),
+        format!("{:.0}", (streams_orig_size / SIZE_IN_MB)).into(),
+    );
+    data.insert(
+        "streams_compressed_size_mb".to_string(),
+        format!("{:.0}", (streams_compressed_size / SIZE_IN_MB)).into(),
     );
 
     let iter = STREAM_FUNCTIONS.iter().clone();