Show historical stats for node until we get realtime feed running

streamr-dev · Feb 6, 2025 · 8d7d17e · 8d7d17e
1 parent 660621c
commit 8d7d17e
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 5 deletions.
diff --git a/src/components/Stats.tsx b/src/components/Stats.tsx
@@ -434,7 +434,6 @@ const defaultMetricEntry = {
 
 export function NodeStats({ nodeId }: NodeStatsProps) {
   const [metricKey, setMetricKey] = useState<NodeMetricKey>('broadcastMessagesPerSecond')
-
   const [interval, setInterval] = useState<Interval>('realtime')
 
   const reports = useSortedOperatorNodeMetricEntries({
@@ -447,8 +446,19 @@ export function NodeStats({ nodeId }: NodeStatsProps) {
     [reports, metricKey],
   )
 
-  const { broadcastMessagesPerSecond, broadcastBytesPerSecond, receiveBytesPerSecond } =
-    useRecentOperatorNodeMetricEntry(nodeId) || defaultMetricEntry
+  const recentMetrics = useRecentOperatorNodeMetricEntry(nodeId)
+
+  // Get last values from historical data if there is no realtime metrics
+  const lastMetrics = useMemo(() => {
+    if (recentMetrics) {
+      return recentMetrics
+    }
+
+    const lastReport = reports[reports.length - 1]
+    return lastReport || defaultMetricEntry
+  }, [recentMetrics, reports])
+
+  const { broadcastMessagesPerSecond, broadcastBytesPerSecond, receiveBytesPerSecond } = lastMetrics
 
   return (
     <>

diff --git a/src/utils/streams.ts b/src/utils/streams.ts
@@ -136,8 +136,6 @@ export function useSortedOperatorNodeMetricEntries(
 
   const partition = useStreamPartitionFromNodeId(nodeId, stream)
 
-  console.log('partition', partition)
-
   return useStreamMessagesOrderedByTime<NodeMetricReport>(
     {
       streamId,