From 51a2ac8931f0bd8dfc5a994bc11718081abd2e62 Mon Sep 17 00:00:00 2001
From: Qiuxia Fan <fine0830@outlook.com>
Date: Fri, 21 Jan 2022 18:07:06 +0800
Subject: [PATCH] feat: enhance source processor

---
 src/hooks/useProcessor.ts | 24 ++++++++++++++++++++++++
 1 file changed, 24 insertions(+)

diff --git a/src/hooks/useProcessor.ts b/src/hooks/useProcessor.ts
index 816e0013..568e6026 100644
--- a/src/hooks/useProcessor.ts
+++ b/src/hooks/useProcessor.ts
@@ -141,6 +141,30 @@ export function useSourceProcessor(
     ) {
       source[m] = Object.values(resp.data)[0] || [];
     }
+    if (type === MetricQueryTypes.READHEATMAP) {
+      const resVal = Object.values(resp.data)[0] || {};
+      const nodes = [] as any;
+      if (!(resVal && resVal.values)) {
+        source[m] = { nodes: [] };
+        return;
+      }
+      resVal.values.forEach((items: { values: number[] }, x: number) => {
+        const grids = items.values.map((val: number, y: number) => [x, y, val]);
+
+        nodes.push(...grids);
+      });
+      let buckets = [] as any;
+      if (resVal.buckets.length) {
+        buckets = [
+          resVal.buckets[0].min,
+          ...resVal.buckets.map(
+            (item: { min: string; max: string }) => item.max
+          ),
+        ];
+      }
+
+      source[m] = { nodes, buckets }; // nodes: number[][]
+    }
   });
 
   return source;