Function normalizeDataPackets

frontend/src/store/executionTimelineStore.ts:211–258

(
  rawPackets: RawDataPacket[] = [],
  timelineStartTime: number | null,
  totalDuration: number,
)

};

const normalizeDataPackets = (
  rawPackets: RawDataPacket[] = [],
  timelineStartTime: number | null,
  totalDuration: number,
): DataPacket[] => {
  if (!rawPackets.length) {
    return [];
  }

  return rawPackets
    .filter(
      (
        packet,
      ): packet is RawDataPacket & {
        id: string;
        sourceNode: string;
        targetNode: string;
        timestamp: string;
      } => {
        return Boolean(packet.id && packet.sourceNode && packet.targetNode && packet.timestamp);
      },
    )
    .map((packet) => {
      const packetTimestamp = new Date(packet.timestamp).getTime();
      const baseStart = timelineStartTime ?? packetTimestamp;
      const computedTotal =
        totalDuration > 0 ? totalDuration : Math.max(packetTimestamp - baseStart, 1);

      const visualTime =
        typeof packet.visualTime === 'number'
          ? packet.visualTime
          : computedTotal > 0
            ? Math.max(0, Math.min(1, (packetTimestamp - baseStart) / computedTotal))
            : 0;

      return {
        id: packet.id,
        sourceNode: packet.sourceNode,
        targetNode: packet.targetNode,
        inputKey: packet.inputKey,
        payload: packet.payload,
        timestamp: packetTimestamp,
        size: typeof packet.size === 'number' ? packet.size : Number(packet.size ?? 0),
        type: (packet.type as DataPacket['type']) ?? 'json',
        visualTime,
      };
    });
};

const calculateNodeStates = (
  events: TimelineEvent[],