Function calculateNodeStates

frontend/src/store/executionTimelineStore.ts:260–474

(
  events: TimelineEvent[],
  dataFlows: DataPacket[],
  currentTime: number,
  timelineStartTime?: number | null,
)

};

const calculateNodeStates = (
  events: TimelineEvent[],
  dataFlows: DataPacket[],
  currentTime: number,
  timelineStartTime?: number | null,
): Record<string, NodeVisualState> => {
  const states: Record<string, NodeVisualState> = {};

  if (events.length === 0) {
    return states;
  }

  const firstEventTimestamp = new Date(events[0].timestamp).getTime();
  const startTime = timelineStartTime ?? firstEventTimestamp;
  const absoluteCurrentTime = startTime + currentTime;
  const filteredPackets = dataFlows.filter((packet) => {
    const packetTime = new Date(packet.timestamp).getTime();
    return packetTime <= absoluteCurrentTime;
  });

  const inputPacketsByNode = new Map<string, DataPacket[]>();
  const outputPacketsByNode = new Map<string, DataPacket[]>();

  filteredPackets.forEach((packet) => {
    if (!inputPacketsByNode.has(packet.targetNode)) {
      inputPacketsByNode.set(packet.targetNode, []);
    }
    inputPacketsByNode.get(packet.targetNode)!.push(packet);

    if (!outputPacketsByNode.has(packet.sourceNode)) {
      outputPacketsByNode.set(packet.sourceNode, []);
    }
    outputPacketsByNode.get(packet.sourceNode)!.push(packet);
  });

  // Group events by node
  const nodeEvents = new Map<string, TimelineEvent[]>();
  events.forEach((event) => {
    if (event.nodeId) {
      if (!nodeEvents.has(event.nodeId)) {
        nodeEvents.set(event.nodeId, []);
      }
      nodeEvents.get(event.nodeId)!.push(event);
    }
  });

  // Calculate state for each node
  nodeEvents.forEach((nodeEventList, nodeId) => {
    const sortedEvents = [...nodeEventList].sort(
      (a, b) => new Date(a.timestamp).getTime() - new Date(b.timestamp).getTime(),
    );

    const relevantEvents = sortedEvents.filter(
      (event) => new Date(event.timestamp).getTime() <= absoluteCurrentTime,
    );

    if (relevantEvents.length === 0) {
      states[nodeId] = {