chore: check server time to delete shred slots

Author: asuzuki-jumptrading

src/atoms.ts

@@ -1,10 +1,11 @@
 import { atom } from "jotai";
-import { slotsPerLeader } from "./consts";
+import { nsPerMs, slotsPerLeader } from "./consts";
 import { atomWithImmer } from "jotai-immer";
 import {
   bootProgressAtom,
   estimatedSlotDurationAtom,
   identityKeyAtom,
+  serverTimeNanosAtom,
   skippedSlotsAtom,
   startupProgressAtom,
 } from "./api/atoms";
@@ -695,3 +696,9 @@ export const [
     }),
   ];
 })();
+
+export const serverTimeMsAtom = atom((get) => {
+  const serverTimeNanos = get(serverTimeNanosAtom);
+  if (serverTimeNanos == null) return undefined;
+  return Math.round(serverTimeNanos / nsPerMs);
+});

src/features/Overview/ShredsProgression/atoms.ts

@@ -5,6 +5,7 @@ import { delayMs, xRangeMs } from "./const";
 import { nsPerMs, slotsPerLeader } from "../../../consts";
 import { getSlotGroupLeader } from "../../../utils";
 import { startupFinalTurbineHeadAtom } from "../../StartupProgress/atoms";
+import { serverTimeMsAtom } from "../../../atoms";
 
 type ShredEventTsDeltaMs = number | undefined;
 /**
@@ -169,11 +170,10 @@ export function createLiveShredsAtoms() {
 
         set(_liveShredsAtom, (prev) => {
           const slotRange = get(_slotRangeAtom);
+          const now = get(serverTimeMsAtom) ?? Date.now();
 
           if (!prev || !slotRange) return prev;
 
-          const now = Date.now();
-
           if (isStartup) {
             // During startup, we only show event dots, not spans. Delete slots without events in chart view
             for (

src/features/Overview/ShredsProgression/shredsProgressionPlugin.ts

@@ -18,12 +18,11 @@ import {
   shredReplayStartedColor,
   shredSkippedColor,
 } from "../../../colors";
-import { skippedClusterSlotsAtom } from "../../../atoms";
+import { serverTimeMsAtom, skippedClusterSlotsAtom } from "../../../atoms";
 import { clamp } from "lodash";
 import { ShredEvent } from "../../../api/entities";
 import { getSlotGroupLabelId, getSlotLabelId } from "./utils";
-import { nsPerMs, slotsPerLeader } from "../../../consts";
-import { serverTimeNanosAtom } from "../../../api/atoms";
+import { slotsPerLeader } from "../../../consts";
 
 const store = getDefaultStore();
 export const shredsXScaleKey = "shredsXScaleKey";
@@ -56,15 +55,15 @@ export function shredsProgressionPlugin(
           const minCompletedSlot = store.get(atoms.minCompletedSlot);
           const skippedSlotsCluster = store.get(skippedClusterSlotsAtom);
           const rangeAfterStartup = store.get(atoms.rangeAfterStartup);
-          const serverTimeNanos = store.get(serverTimeNanosAtom);
+          const serverTimeMs = store.get(serverTimeMsAtom);
 
           const maxX = u.scales[shredsXScaleKey].max;
 
           if (
             !liveShreds ||
             !slotRange ||
             maxX == null ||
-            serverTimeNanos == null
+            serverTimeMs == null
           ) {
             return;
           }
@@ -81,7 +80,7 @@ export function shredsProgressionPlugin(
           }
 
           // Offset to convert shred event delta to chart x value
-          const delayedNow = Math.trunc(serverTimeNanos / nsPerMs) - delayMs;
+          const delayedNow = serverTimeMs - delayMs;
 
           const tsXValueOffset = delayedNow - liveShreds.referenceTs;