trainrunsection.service.ts

import {TrainrunSection} from "../../models/trainrunsection.model";
import {
  NodeDto,
  TrainrunCategoryHaltezeit,
  TrainrunSectionDto,
} from "../../data-structures/business.data.structures";
import {Node} from "../../models/node.model";
import {EventEmitter, Injectable, OnDestroy} from "@angular/core";
import {BehaviorSubject, Subject} from "rxjs";
import {TrainrunService} from "./trainrun.service";
import {NodeService} from "./node.service";
import {TrainrunsectionValidator} from "../util/trainrunsection.validator";
import {Trainrun} from "../../models/trainrun.model";
import {MathUtils} from "../../utils/math";
import {GeneralViewFunctions} from "../../view/util/generalViewFunctions";
import {
  LeftAndRightTimeStructure
} from "../../view/dialogs/trainrun-and-section-dialog/trainrunsection-tab/trainrun-section-tab.component";
import {TrainrunsectionHelper} from "../util/trainrunsection.helper";
import {LogService} from "../../logger/log.service";
import {Transition} from "../../models/transition.model";
import {takeUntil} from "rxjs/operators";
import {FilterService} from "../ui/filter.service";
import {TrainrunSectionNodePair} from "../util/trainrun.iterator";
import {Operation, OperationType, TrainrunOperation} from "../../models/operation.model";

interface DepartureAndArrivalTimes {
  nodeFromDepartureTime: number;
  nodeFromArrivalTime: number;
  nodeToArrivalTime: number;
  nodeToDepartureTime: number;
}

export interface InformSelectedTrainrunClick {
  trainrunSectionId: number;
  open: boolean;
}

@Injectable({
  providedIn: "root",
})
export class TrainrunSectionService implements OnDestroy {
  // Description of observable data service: https://coryrylan.com/blog/angular-observable-data-services
  trainrunSectionsSubject = new BehaviorSubject<TrainrunSection[]>([]);
  readonly trainrunSections = this.trainrunSectionsSubject.asObservable();
  trainrunSectionsStore: { trainrunSections: TrainrunSection[] } = {
    trainrunSections: [],
  }; // store the data in memory

  readonly operation = new EventEmitter<Operation>();

  informSelectedTrainrunClickSubject =
    new BehaviorSubject<InformSelectedTrainrunClick>({
      trainrunSectionId: undefined,
      open: true,
    });
  readonly informSelectedTrainrunClick =
    this.informSelectedTrainrunClickSubject.asObservable();

  private nodeService: NodeService = null;
  private destroyed = new Subject<void>();

  constructor(
    private logger: LogService,
    private trainrunService: TrainrunService,
    private filterService: FilterService,
  ) {
    this.trainrunService.setTrainrunSectionService(this);
    this.trainrunService.trainruns
      .pipe(takeUntil(this.destroyed))
      .subscribe(() => {
        this.trainrunSectionsUpdated();
      });
  }

  static TIME_PRECISION = 10;

  static computeArrivalAndDeparture(
    nodeArrival: number,
    trainrunSection: TrainrunSection,
    nonStop: boolean,
    halteZeiten: TrainrunCategoryHaltezeit,
    precision: number = 10
  ): DepartureAndArrivalTimes {
    let haltezeit =
      halteZeiten[
        trainrunSection.getTrainrun().getTrainrunCategory().fachCategory
        ].haltezeit;
    haltezeit = nonStop ? 0 : haltezeit;
    const fromDepartureTime = MathUtils.round(
      (nodeArrival + haltezeit) % 60,
      precision,
    );
    const fromArrivalTime = MathUtils.round(
      TrainrunsectionHelper.getSymmetricTime(fromDepartureTime),
      precision,
    );
    const toArrivalTime = MathUtils.round(
      (fromDepartureTime + (trainrunSection.getTravelTime() % 60)) % 60,
      precision,
    );
    const toDepartureTime = MathUtils.round(
      TrainrunsectionHelper.getSymmetricTime(toArrivalTime),
      precision,
    );

    return {
      nodeFromDepartureTime: fromDepartureTime,
      nodeFromArrivalTime: fromArrivalTime,
      nodeToArrivalTime: toArrivalTime,
      nodeToDepartureTime: toDepartureTime,
    };
  }

  static boundMinutesToOneHour(time: number) {
    while (time >= 60) {
      time -= 60;
    }
    while (time < 0) {
      time += 60;
    }
    return time;
  }

  private static setToNode(
    sourceNodeId: number,
    trainrunSection: TrainrunSection,
    nodeToNew: Node,
    targetNodeId: number,
  ) {
    if (sourceNodeId === trainrunSection.getSourceNodeId()) {
      trainrunSection.setTargetNode(nodeToNew);
    } else if (targetNodeId === trainrunSection.getSourceNodeId()) {
      trainrunSection.setTargetNode(nodeToNew);
    } else if (sourceNodeId === trainrunSection.getTargetNodeId()) {
      trainrunSection.setSourceNode(nodeToNew);
    } else if (targetNodeId === trainrunSection.getTargetNodeId()) {
      trainrunSection.setSourceNode(nodeToNew);
    }
  }

  ngOnDestroy() {
    this.destroyed.next();
    this.destroyed.complete();
  }

  propagateTimesForNewTrainrunSection(trainrunSection: TrainrunSection) {
    let nodeFrom = trainrunSection.getSourceNode();
    let previousTrainrunSection =
      nodeFrom.getNextTrainrunSection(trainrunSection);
    if (previousTrainrunSection === undefined) {
      nodeFrom = trainrunSection.getTargetNode();
      previousTrainrunSection =
        nodeFrom.getNextTrainrunSection(trainrunSection);
    }
    if (previousTrainrunSection !== undefined) {
      const previousNodeArrival = nodeFrom.getArrivalTime(
        previousTrainrunSection,
      );
      const halteZeit = nodeFrom.getTrainrunCategoryHaltezeit();
      const arrivalDepartureTimes =
        TrainrunSectionService.computeArrivalAndDeparture(
          previousNodeArrival,
          trainrunSection,
          false,
          halteZeit,
          TrainrunSectionService.TIME_PRECISION
        );

      if (trainrunSection.getSourceNodeId() === nodeFrom.getId()) {
        trainrunSection.setSourceDeparture(
          arrivalDepartureTimes.nodeFromDepartureTime,
        );
        trainrunSection.setSourceArrival(
          arrivalDepartureTimes.nodeFromArrivalTime,
        );
        trainrunSection.setTargetDeparture(
          arrivalDepartureTimes.nodeToDepartureTime,
        );
        trainrunSection.setTargetArrival(
          arrivalDepartureTimes.nodeToArrivalTime,
        );
      } else {
        trainrunSection.setTargetDeparture(
          arrivalDepartureTimes.nodeFromDepartureTime,
        );
        trainrunSection.setTargetArrival(
          arrivalDepartureTimes.nodeFromArrivalTime,
        );
        trainrunSection.setSourceDeparture(
          arrivalDepartureTimes.nodeToDepartureTime,
        );
        trainrunSection.setSourceArrival(
          arrivalDepartureTimes.nodeToArrivalTime,
        );
      }
    } else {
      // first or unconnected section - special case
      const targetArrivalTime = MathUtils.round(
        (trainrunSection.getSourceDeparture() + (trainrunSection.getTravelTime() % 60)) % 60,
        TrainrunSectionService.TIME_PRECISION
      );
      const targetDepartureTime = MathUtils.round(
        TrainrunsectionHelper.getSymmetricTime(targetArrivalTime),
        TrainrunSectionService.TIME_PRECISION
      );
      trainrunSection.setTargetDeparture(targetDepartureTime);
      trainrunSection.setTargetArrival(targetArrivalTime);
    }

    this.trainrunService.propagateConsecutiveTimesForTrainrun(
      trainrunSection.getId(),
    );
  }

  public setNodeService(nodeService: NodeService) {
    this.nodeService = nodeService;
  }

  getTrainrunSectionFromId(trainrunSectionId: number) {
    return this.trainrunSectionsStore.trainrunSections.find(
      (tr) => tr.getId() === trainrunSectionId,
    );
  }

  setTrainrunSectionAsSelected(trainrunSectionId: number) {
    this.trainrunSectionsStore.trainrunSections.forEach((tr) => tr.unselect());
    this.getTrainrunSectionFromId(trainrunSectionId).select();
  }

  getSelectedTrainrunSection(): TrainrunSection {
    const selectedTrainrunSection =
      this.trainrunSectionsStore.trainrunSections.find((tr) => tr.selected());
    if (selectedTrainrunSection !== undefined) {
      return selectedTrainrunSection;
    } else {
      return null;
    }
  }

  setTrainrunSectionsDataAndValidate(trainrunSections: TrainrunSectionDto[]) {
    this.trainrunSectionsStore.trainrunSections = trainrunSections.map(
      (trainrunSectionDto) => new TrainrunSection(trainrunSectionDto),
    );

    this.trainrunSectionsStore.trainrunSections.forEach((trainrunSection) => {
      TrainrunsectionValidator.validateOneSection(trainrunSection);
      TrainrunsectionValidator.validateTravelTime(trainrunSection);
    });
  }

  createNewTrainrunSectionsFromDtoList(
    trainrunSections: TrainrunSectionDto[],
    nodeMap: Map<number, number>,
    trainrunMap: Map<number, number>,
    nodes: NodeDto[],
    enforceUpdate = true
  ): Map<number, number> {
    const trainrunSectionMap: Map<number, number> = new Map<number, number>();
    trainrunSections.forEach((trainrunSection) => {
      const newTrainrunSection = this.createNewTrainrunSectionFromDto(
        trainrunSection,
        nodeMap,
        trainrunMap,
        nodes,
        enforceUpdate
      );
      trainrunSectionMap.set(trainrunSection.id, newTrainrunSection.getId());
    });
    if (enforceUpdate) {
      this.trainrunSectionsUpdated();
    }
    return trainrunSectionMap;
  }

  mergeTrainrunSections(
    trainrunSections: TrainrunSectionDto[],
    nodeMap: Map<number, number>,
    trainrunMap: Map<number, number>,
    nodes: NodeDto[],
  ) {
    trainrunSections.forEach((trainrunSection) => {
      const trainrunId = trainrunMap.get(trainrunSection.trainrunId);
      const existingTrainrunSection =
        this.trainrunSectionsStore.trainrunSections.find(
          (ts: TrainrunSection) =>
            (ts.getTrainrunId() === trainrunId &&
              ts.getSourceNodeId() === trainrunSection.sourceNodeId &&
              ts.getTargetNodeId() === trainrunSection.targetNodeId) ||
            (ts.getTrainrunId() === trainrunId &&
              ts.getSourceNodeId() === trainrunSection.targetNodeId &&
              ts.getTargetNodeId() === trainrunSection.sourceNodeId),
        );
      if (existingTrainrunSection === undefined) {
        this.createNewTrainrunSectionFromDto(
          trainrunSection,
          nodeMap,
          trainrunMap,
          nodes,
        );
      }
    });
    this.trainrunSectionsUpdated();
  }

  initializeTrainrunSectionsWithReferencesToNodesAndTrainruns() {
    this.trainrunSectionsStore.trainrunSections.forEach((trainrunSection) =>
      trainrunSection.setSourceAndTargetNodeReference(
        this.nodeService.getNodeFromId(trainrunSection.getSourceNodeId()),
        this.nodeService.getNodeFromId(trainrunSection.getTargetNodeId()),
      ),
    );
    this.trainrunSectionsStore.trainrunSections.forEach((trainrunSection) =>
      trainrunSection.setTrainrun(
        this.trainrunService.getTrainrunFromId(trainrunSection.getTrainrunId()),
      ),
    );
  }

  initializeTrainrunSectionRouting() {
    this.trainrunSectionsStore.trainrunSections.forEach((trainrunSection) => {
      if (trainrunSection.isPathEmpty()) {
        trainrunSection.routeEdgeAndPlaceText();
      }
    });
  }

  updateTrainrunSectionNumberOfStops(
    trs: TrainrunSection,
    numberOfStops: number,
  ) {
    const trainrunSection = this.getTrainrunSectionFromId(trs.getId());
    trainrunSection.setNumberOfStops(numberOfStops);
    this.trainrunSectionsUpdated();
    this.operation.emit(new TrainrunOperation(OperationType.update, trainrunSection.getTrainrun()));
  }

  updateTrainrunSectionTime(
    trsId: number,
    sourceArrivalTime: number,
    sourceDeparture: number,
    targetArrival: number,
    targetDeparture: number,
    travelTime: number,
    emit: boolean = true
  ) {
    const trainrunSection = this.getTrainrunSectionFromId(trsId);
    trainrunSection.setSourceArrival(sourceArrivalTime);
    trainrunSection.setSourceDeparture(sourceDeparture);
    trainrunSection.setTargetArrival(targetArrival);
    trainrunSection.setTargetDeparture(targetDeparture);
    trainrunSection.setTravelTime(travelTime);
    TrainrunsectionValidator.validateOneSection(trainrunSection);
    this.trainrunService.propagateConsecutiveTimesForTrainrun(
      trainrunSection.getId(),
    );
    this.nodeService.validateConnections(trainrunSection.getSourceNode());
    this.nodeService.validateConnections(trainrunSection.getTargetNode());
    if (emit) {
      this.operation.emit(new TrainrunOperation(OperationType.update, trainrunSection.getTrainrun()));
    }
  }

  private propagateTimeAlongTrainrunFixStartTrainrunSection(
    trainrunSection: TrainrunSection,
    node: Node,
    stopNodeId: number,
  ) {
    const iterator = this.trainrunService.getNonStopIterator(
      node,
      trainrunSection,
    );
    while (iterator.hasNext()) {
      iterator.next();
      if (iterator.current().node.getId() === stopNodeId) {
        return iterator.current().trainrunSection.getId();
      }
    }
    return undefined;
  }

  propagateTimeAlongTrainrun(trainrunSectionId: number, fromNodeIdOn: number) {
    const trainrunSection = this.getTrainrunSectionFromId(trainrunSectionId);
    const fromNode =
      fromNodeIdOn === trainrunSection.getSourceNodeId()
        ? trainrunSection.getSourceNode()
        : trainrunSection.getTargetNode();
    if (fromNode.getId() !== fromNodeIdOn) {
      let trainrunSectionIdToStart =
        this.propagateTimeAlongTrainrunFixStartTrainrunSection(
          trainrunSection,
          trainrunSection.getSourceNode(),
          fromNodeIdOn,
        );
      if (trainrunSectionIdToStart === undefined) {
        trainrunSectionIdToStart =
          this.propagateTimeAlongTrainrunFixStartTrainrunSection(
            trainrunSection,
            trainrunSection.getTargetNode(),
            fromNodeIdOn,
          );
      }
      if (trainrunSectionIdToStart !== undefined) {
        this.iterateAlongTrainrunUntilEndAndPropagateTime(
          this.nodeService.getNodeFromId(fromNodeIdOn),
          trainrunSectionIdToStart,
        );
        this.trainrunSectionsUpdated();
        return;
      }
    }
    this.iterateAlongTrainrunUntilEndAndPropagateTime(
      fromNode,
      trainrunSectionId,
    );
    this.trainrunSectionsUpdated();
  }

  propagteTimeSourceToTarget(previousPair: TrainrunSectionNodePair,
                             pair: TrainrunSectionNodePair,
                             arrivalDepartureTimes: DepartureAndArrivalTimes,
                             isNonStop: boolean) {

    // -------------------------------------------------------------------------------------------
    // Source to Target (pair)
    // -------------------------------------------------------------------------------------------
    // retrieve haltezeit at node
    const arrivalTimeAtSource =
      previousPair.node.getId() === previousPair.trainrunSection.getTargetNodeId() ?
        previousPair.trainrunSection.getTargetArrival() :
        previousPair.trainrunSection.getSourceArrival();

    let halteZeit =
      previousPair.node.getTrainrunCategoryHaltezeit()[
        pair.trainrunSection.getTrainrun().getTrainrunCategory().fachCategory
        ].haltezeit;
    halteZeit = isNonStop ? 0 : halteZeit;

    // try to update the pair (based on previousPair)
    if (pair.trainrunSection.getSourceDepartureLock()) {
      // the source element is locked - no changes allowed!
      return;
    }

    // ----------------------------------------------------------------------------------
    // update source arrival time
    // ----------------------------------------------------------------------------------
    const depTimeAtSource = MathUtils.round(
      (arrivalTimeAtSource + halteZeit) % 60,
      TrainrunSectionService.TIME_PRECISION
    );
    const arrTimeAtSource = MathUtils.round(
      TrainrunsectionHelper.getSymmetricTime(depTimeAtSource),
      TrainrunSectionService.TIME_PRECISION
    );
    pair.trainrunSection.setSourceDeparture(depTimeAtSource);
    pair.trainrunSection.setSourceArrival(arrTimeAtSource);

    // ----------------------------------------------------------------------------------
    // Use travel time to update the target times - if allowed
    // ----------------------------------------------------------------------------------
    if (!pair.trainrunSection.getTargetArrivalLock()) {
      // Target is not locked -> update the Target Arrival Time
      const arrTimeAtTarget = MathUtils.round(
        (depTimeAtSource + pair.trainrunSection.getTravelTime()) % 60,
        TrainrunSectionService.TIME_PRECISION
      );
      const depTimeAtTarget = MathUtils.round(
        TrainrunsectionHelper.getSymmetricTime(arrTimeAtTarget),
        TrainrunSectionService.TIME_PRECISION
      );
      pair.trainrunSection.setTargetArrival(arrTimeAtTarget);
      pair.trainrunSection.setTargetDeparture(depTimeAtTarget);

      return;
    }

    // ----------------------------------------------------------------------------------
    // update travel time if possible
    // ----------------------------------------------------------------------------------
    if (pair.trainrunSection.getTravelTimeLock()) {
      return;
    }

    let newTravelTime = pair.trainrunSection.getTargetArrival() - depTimeAtSource;
    newTravelTime += Math.floor(pair.trainrunSection.getTravelTime() / 60) * 60;
    while (newTravelTime < 0.0) {
      newTravelTime += 60;
    }
    pair.trainrunSection.setTravelTime(newTravelTime);
  }

  propagteTimeTargetToSource(previousPair: TrainrunSectionNodePair,
                             pair: TrainrunSectionNodePair,
                             arrivalDepartureTimes: DepartureAndArrivalTimes,
                             isNonStop: boolean) {

    // -------------------------------------------------------------------------------------------
    // Target to Source (pair)
    // -------------------------------------------------------------------------------------------
    // retrieve haltezeit at node
    const arrivalTimeAtTarget =
      previousPair.node.getId() === previousPair.trainrunSection.getTargetNodeId() ?
        previousPair.trainrunSection.getTargetArrival() :
        previousPair.trainrunSection.getSourceArrival();

    let halteZeit =
      previousPair.node.getTrainrunCategoryHaltezeit()[
        pair.trainrunSection.getTrainrun().getTrainrunCategory().fachCategory
        ].haltezeit;
    halteZeit = isNonStop ? 0 : halteZeit;

    // try to update the pair (based on previousPair)
    if (pair.trainrunSection.getTargetDepartureLock()) {
      // the source element is locked - no changes allowed!
      return;
    }

    // ----------------------------------------------------------------------------------
    // update source arrival time
    // ----------------------------------------------------------------------------------
    const depTimeAtTarget = MathUtils.round(
      (arrivalTimeAtTarget + halteZeit) % 60,
      TrainrunSectionService.TIME_PRECISION
    );
    const arrTimeAtTarget = MathUtils.round(
      TrainrunsectionHelper.getSymmetricTime(depTimeAtTarget),
      TrainrunSectionService.TIME_PRECISION
    );
    pair.trainrunSection.setTargetDeparture(depTimeAtTarget);
    pair.trainrunSection.setTargetArrival(arrTimeAtTarget);

    // ----------------------------------------------------------------------------------
    // Use travel time to update the target times - if allowed
    // ----------------------------------------------------------------------------------
    if (!pair.trainrunSection.getSourceArrivalLock()) {
      // Target is not locked -> update the Target Arrival Time
      const arrTimeAtSource = MathUtils.round(
        (depTimeAtTarget + pair.trainrunSection.getTravelTime()) % 60,
        TrainrunSectionService.TIME_PRECISION
      );
      const depTimeAtSource = MathUtils.round(
        TrainrunsectionHelper.getSymmetricTime(arrTimeAtSource),
        TrainrunSectionService.TIME_PRECISION
      );
      pair.trainrunSection.setSourceArrival(arrTimeAtSource);
      pair.trainrunSection.setSourceDeparture(depTimeAtSource);

      return;
    }

    // ----------------------------------------------------------------------------------
    // update travel time if possible
    // ----------------------------------------------------------------------------------
    if (pair.trainrunSection.getTravelTimeLock()) {
      return;
    }

    let newTravelTime = pair.trainrunSection.getSourceArrival() - depTimeAtTarget;
    newTravelTime += Math.floor(pair.trainrunSection.getTravelTime() / 60) * 60;
    while (newTravelTime < 0.0) {
      newTravelTime += 60;
    }
    pair.trainrunSection.setTravelTime(newTravelTime);
  }

  iterateAlongTrainrunUntilEndAndPropagateTime(
    nodeFrom: Node,
    trainrunSectionId: number,
  ) {
    const trainrunSection = this.getTrainrunSectionFromId(trainrunSectionId);

    const iterator = this.trainrunService.getIterator(
      nodeFrom,
      trainrunSection,
    );
    let previousPair = iterator.next();

    TrainrunsectionValidator.validateOneSection(previousPair.trainrunSection);

    while (iterator.hasNext()) {
      const pair = iterator.next();

      const isNonStop = previousPair.node.isNonStop(pair.trainrunSection);
      const halteZeit = previousPair.node.getTrainrunCategoryHaltezeit();
      const previousNodeArrival = previousPair.node.getArrivalTime(
        previousPair.trainrunSection,
      );
      const arrivalDepartureTimes =
        TrainrunSectionService.computeArrivalAndDeparture(
          previousNodeArrival,
          pair.trainrunSection,
          isNonStop,
          halteZeit,
          TrainrunSectionService.TIME_PRECISION
        );

      if (
        pair.trainrunSection.getSourceNodeId() === previousPair.node.getId()
      ) {
        this.propagteTimeSourceToTarget(previousPair, pair, arrivalDepartureTimes, isNonStop);
      } else {
        this.propagteTimeTargetToSource(previousPair, pair, arrivalDepartureTimes, isNonStop);
      }
      TrainrunsectionValidator.validateOneSection(pair.trainrunSection);

      if (
        pair.trainrunSection.getSourceDepartureLock() ||
        pair.trainrunSection.getTargetDepartureLock()
      ) {
        break;
      }
      previousPair = pair;
    }

    if (trainrunSection !== undefined) {
      this.trainrunService.propagateConsecutiveTimesForTrainrun(
        trainrunSection.getId(),
      );
    }
  }

  updateTrainrunSectionTimeLock(
    trsId: number,
    sourceLock: boolean,
    targetLock: boolean,
    travelTimeLock: boolean,
    enforceUpdate = true
  ) {
    const trainrunSection = this.getTrainrunSectionFromId(trsId);
    if (sourceLock !== undefined) {
      trainrunSection.setSourceArrivalLock(sourceLock);
      trainrunSection.setSourceDepartureLock(sourceLock);
    }
    if (targetLock !== undefined) {
      trainrunSection.setTargetArrivalLock(targetLock);
      trainrunSection.setTargetDepartureLock(targetLock);
    }
    if (travelTimeLock !== undefined) {
      trainrunSection.setTravelTimeLock(travelTimeLock);
    }
    if (enforceUpdate) {
      this.trainrunSectionsUpdated();
    }
  }

  updateTrainrunSectionRouting(node: Node, enforceUpdate = true) {
    this.trainrunSectionsStore.trainrunSections.forEach((trainrunSection) => {
      if (
        node.getId() === trainrunSection.getSourceNodeId() ||
        node.getId() === trainrunSection.getTargetNodeId()
      ) {
        trainrunSection.routeEdgeAndPlaceText();
      }
    });

    if (enforceUpdate) {
      this.trainrunSectionsUpdated();
    }
  }

  retrieveTravelTime(sourceNodeId: number, targetNodeId: number, trainrun: Trainrun): number {
    const foundTrainruns = this.getTrainrunSections().filter(
      (ts) =>
        (
          (ts.getSourceNodeId() === sourceNodeId && ts.getTargetNodeId() === targetNodeId) ||
          (ts.getSourceNodeId() === targetNodeId && ts.getTargetNodeId() === sourceNodeId)
        )
    );
    if (foundTrainruns.length === 0) {
      return 1;
    }

    const sameTrainCat = foundTrainruns.filter((ts) =>
      ts.getTrainrun().getTrainrunCategory().id === trainrun.getTrainrunCategory().id
    );
    if (sameTrainCat.length === 0) {
      return foundTrainruns.reduce((a, b) =>
        a.getTravelTime() > b.getTravelTime() ? a : b).getTravelTime();
    }

    return sameTrainCat.reduce((a, b) =>
      a.getTravelTime() > b.getTravelTime() ? a : b).getTravelTime();
  }

  createTrainrunSection(sourceNodeId: number, targetNodeId: number, retrieveTravelTimeFromEdge: boolean = false): TrainrunSection {
    const trainrunSection: TrainrunSection = new TrainrunSection();
    const initialTrainrunsLength = this.trainrunService.trainrunsStore.trainruns.length;

    trainrunSection.setTrainrun(
      this.trainrunService.getSelectedOrNewTrainrun(),
    );

    if (retrieveTravelTimeFromEdge) {
      trainrunSection.setTravelTime(
        this.retrieveTravelTime(sourceNodeId, targetNodeId, trainrunSection.getTrainrun())
      );
    }

    let sourceNode = this.nodeService.getNodeFromId(sourceNodeId);
    let targetNode = this.nodeService.getNodeFromId(targetNodeId);

    // Enforce [source → target] [source → target] sections, disallow
    // [source → target] [target → source] and [target → source] [source → target]
    const isUpdate = this.trainrunSectionsStore.trainrunSections.some((s) =>
      trainrunSection.getTrainrunId() === s.getTrainrunId()
    );
    if (isUpdate) {
      const {
        endNode1: trainrunTargetNode,
        endNode2: trainrunSourceNode
      } = this.trainrunService.getBothEndNodesWithTrainrunId(
        trainrunSection.getTrainrunId()
      );
      if (sourceNode.getId() === trainrunSourceNode.getId() ||
          targetNode.getId() === trainrunTargetNode.getId()) {
        [sourceNode, targetNode] = [targetNode, sourceNode];
      }
    }

    trainrunSection.setSourceAndTargetNodeReference(sourceNode, targetNode);
    this.trainrunSectionsStore.trainrunSections.push(trainrunSection);
    this.logger.log(
      "create new trainrunSection between nodes",
      sourceNode.getBetriebspunktName(),
      targetNode.getBetriebspunktName(),
    );

    this.handleNodeAndTrainrunSectionDetails(
      sourceNode,
      targetNode,
      trainrunSection,
    );

    this.setTrainrunSectionAsSelected(trainrunSection.getId());
    this.propagateTimesForNewTrainrunSection(trainrunSection);
    //this.trainrunSectionsUpdated();
    this.trainrunService.trainrunsUpdated();

    if (initialTrainrunsLength !== this.trainrunService.trainrunsStore.trainruns.length) {
      this.operation.emit(new TrainrunOperation(OperationType.create, trainrunSection.getTrainrun()));
    } else {
      this.operation.emit(new TrainrunOperation(OperationType.update, trainrunSection.getTrainrun()));
    }

    return trainrunSection;
  }

  reconnectTrainrunSection(
    sourceNodeId: number,
    targetNodeId: number,
    existingTrainrunSectionId: number,
    existingTrainrunSectionTargetNodeId: number,
    existingTrainrunSectionSourceNodeId: number,
    enforceUpdate = true,
  ) {
    // swap source and target
    if (
      sourceNodeId === existingTrainrunSectionTargetNodeId ||
      targetNodeId === existingTrainrunSectionSourceNodeId
    ) {
      const tmp = targetNodeId;
      targetNodeId = sourceNodeId;
      sourceNodeId = tmp;
    }

    // early return -> if the user drops the trainrunsection to the same pin as before
    if (
      sourceNodeId === existingTrainrunSectionSourceNodeId &&
      targetNodeId === existingTrainrunSectionTargetNodeId
    ) {
      return;
    }

    const trainrunSection: TrainrunSection = this.getTrainrunSectionFromId(
      existingTrainrunSectionId,
    );

    const {nodeFrom, nodeToNew, nodeToOld} = this.getFromAndToNode(
      sourceNodeId,
      trainrunSection,
      targetNodeId,
    );
    const previousTrainrunSection =
      nodeToOld.getNextTrainrunSection(trainrunSection);

    nodeToOld.removeTransition(trainrunSection);
    nodeToOld.removeConnectionFromTrainrunSection(trainrunSection);
    nodeToOld.removePort(trainrunSection);
    nodeToOld.updateTransitionsAndConnections();
    TrainrunSectionService.setToNode(
      sourceNodeId,
      trainrunSection,
      nodeToNew,
      targetNodeId,
    );

    this.updateTrainrunSectionRouting(nodeToOld, false);
    nodeToNew.addPortWithRespectToOppositeNode(nodeFrom, trainrunSection);
    if (
      this.nodeService.isConditionToAddTransitionFullfilled(
        nodeToNew,
        trainrunSection,
      )
    ) {
      this.nodeService.addTransitionAndComputeRoutingFromFreePorts(
        nodeToNew,
        trainrunSection.getTrainrun(),
      );
    }
    nodeFrom.reAlignPortWithRespectToOppositeNode(nodeToNew, trainrunSection);

    trainrunSection.routeEdgeAndPlaceText();
    this.reRouteAffectedTrainrunSections(nodeFrom.getId(), nodeToNew.getId());

    if (previousTrainrunSection !== undefined) {
      this.nodeService.checkAndFixMissingTransitions(
        previousTrainrunSection.getSourceNodeId(),
        previousTrainrunSection.getTargetNodeId(),
        previousTrainrunSection.getId(),
        false,
      );
    }

    this.trainrunService.propagateConsecutiveTimesForTrainrun(
      trainrunSection.getId(),
    );

    if (enforceUpdate) {
      this.nodeService.nodesUpdated();
      this.nodeService.connectionsUpdated();
      this.nodeService.transitionsUpdated();
      this.trainrunSectionsUpdated();
    }
    this.operation.emit(new TrainrunOperation(OperationType.update, trainrunSection.getTrainrun()));
  }

  deleteListOfTrainrunSections(trainrunSections: TrainrunSection[], enforceUpdate = true) {
    trainrunSections.forEach((trainrunSection) => {
      this.deleteTrainrunSectionAndCleanupNodes(trainrunSection, false);
    });
    if (enforceUpdate) {
      this.nodeService.transitionsUpdated();
      this.nodeService.connectionsUpdated();
      this.trainrunService.trainrunsUpdated();
      this.trainrunSectionsUpdated();
    }
  }

  deleteAllVisibleTrainrunSections(enforceUpdate = true) {
    const allTrainrunSections = this.trainrunSectionsStore.trainrunSections;
    allTrainrunSections.forEach((trainrunSection: TrainrunSection) => {
      if (this.filterService.filterTrainrunsection(trainrunSection)) {
        this.deleteTrainrunSectionAndCleanupNodes(trainrunSection, false);
      }
    });
    if (enforceUpdate) {
      this.nodeService.transitionsUpdated();
      this.nodeService.connectionsUpdated();
      this.trainrunService.trainrunsUpdated();
      this.trainrunSectionsUpdated();
    }
  }

  deleteAllNonVisibleTrainrunSections(enforceUpdate = true) {
    const allTrainrunSections = this.trainrunSectionsStore.trainrunSections;
    allTrainrunSections.forEach((trainrunSection: TrainrunSection) => {
      if (!this.filterService.filterTrainrunsection(trainrunSection)) {
        this.deleteTrainrunSectionAndCleanupNodes(trainrunSection, false);
      }
    });
    if (enforceUpdate) {
      this.nodeService.transitionsUpdated();
      this.nodeService.connectionsUpdated();
      this.trainrunService.trainrunsUpdated();
      this.trainrunSectionsUpdated();
    }
  }

  deleteTrainrunSection(trainrunSectionId: number, enforceUpdate = true) {
    const trainrunSection = this.getTrainrunSectionFromId(trainrunSectionId);
    const sourceNodeId = trainrunSection.getSourceNodeId();
    const targetNodeId = trainrunSection.getTargetNodeId();
    this.deleteTrainrunSectionAndCleanupNodes(trainrunSection, false);
    this.getTrainrunSections()
      .filter(
        (ts: TrainrunSection) =>
          ts.getSourceNodeId() === sourceNodeId ||
          ts.getSourceNodeId() === targetNodeId ||
          ts.getTargetNodeId() === sourceNodeId ||
          ts.getTargetNodeId() === targetNodeId,
      )
      .forEach((ts: TrainrunSection) => {
        this.nodeService.checkAndFixMissingTransitions(
          sourceNodeId,
          targetNodeId,
          ts.getId(),
          false,
        );
      });
    if (enforceUpdate) {
      this.nodeService.transitionsUpdated();
      this.nodeService.connectionsUpdated();
      this.trainrunSectionsUpdated();
    }
    if (this.getTrainrunSections().length) {
      this.operation.emit(new TrainrunOperation(OperationType.update, trainrunSection.getTrainrun()));
    }
  }

  getDtos() {
    return this.trainrunSectionsStore.trainrunSections.map((trainrunSection) =>
      trainrunSection.getDto(),
    );
  }

  getTrainrunSections(): TrainrunSection[] {
    return Object.assign({}, this.trainrunSectionsStore).trainrunSections;
  }

  getAllTrainrunSectionsForTrainrun(trainrunID: number): TrainrunSection[] {
    const trainrunSections = this.trainrunSectionsStore.trainrunSections.filter(
      (t: TrainrunSection) => t.getTrainrunId() === trainrunID,
    );
    if (trainrunSections === undefined) {
      return [];
    }
    return trainrunSections;
  }

  deleteAllTrainrunSectionsOfTrainrun(trainrunId: number) {
    const filterTS = this.getAllTrainrunSectionsForTrainrun(trainrunId);
    const lastTrs = filterTS.pop();
    filterTS.forEach((trs: TrainrunSection) => {
      this.deleteTrainrunSectionAndCleanupNodes(trs, false);
    });
    if (lastTrs !== undefined) {
      this.deleteTrainrunSectionAndCleanupNodes(lastTrs, false);
      this.nodeService.transitionsUpdated();
      this.nodeService.connectionsUpdated();
      this.trainrunService.trainrunsUpdated();
    }
  }

  setTimeStructureToTrainrunSections(
    timeStructure: LeftAndRightTimeStructure,
    trainrunSection: TrainrunSection,
    precision = 0
  ) {
    const newTotalTravelTime = timeStructure.travelTime;

    const oldTotalTravelTime =
      this.trainrunService.getCumulativeTravelTime(trainrunSection);
    const travelTimeFactor = newTotalTravelTime / (oldTotalTravelTime || 1);

    // prepare data structure for the first trainrunsection
    const bothLastNonStopNodes =
      this.trainrunService.getBothLastNonStopNodes(trainrunSection);
    const bothLastNonStopTrainrunSections =
      this.trainrunService.getBothLastNonStopTrainrunSections(trainrunSection);
    const leftNode = GeneralViewFunctions.getLeftOrTopNode(
      bothLastNonStopNodes.lastNonStopNode1,
      bothLastNonStopNodes.lastNonStopNode2,
    );
    const trs =
      leftNode.getId() === bothLastNonStopNodes.lastNonStopNode1.getId()
        ? bothLastNonStopTrainrunSections.lastNonStopTrainrunSection1
        : bothLastNonStopTrainrunSections.lastNonStopTrainrunSection2;

    const trsTimeStructure =
      TrainrunsectionHelper.getDefaultTimeStructure(timeStructure);
    let summedTravelTime = 0;

    const iterator = this.trainrunService.getNonStopIterator(leftNode, trs);
    while (iterator.hasNext()) {
      const nextPair = iterator.next();

      const isRightNodeNonStop = nextPair.node.isNonStop(
        nextPair.trainrunSection,
      );
      trsTimeStructure.travelTime = TrainrunsectionHelper.getTravelTime(
        newTotalTravelTime,
        summedTravelTime,
        travelTimeFactor,
        nextPair.trainrunSection.getTravelTime(),
        isRightNodeNonStop,
        precision
      );
      trsTimeStructure.rightArrivalTime =
        TrainrunsectionHelper.getRightArrivalTime(trsTimeStructure, precision);
      trsTimeStructure.rightDepartureTime =
        TrainrunsectionHelper.getRightDepartureTime(trsTimeStructure, precision);
      const rightIsTarget =
        nextPair.node.getId() ===
        nextPair.trainrunSection.getTargetNode().getId();
      this.updateTrainrunSectionTime(
        nextPair.trainrunSection.getId(),
        rightIsTarget
          ? trsTimeStructure.leftArrivalTime
          : trsTimeStructure.rightArrivalTime,
        rightIsTarget
          ? trsTimeStructure.leftDepartureTime
          : trsTimeStructure.rightDepartureTime,
        rightIsTarget
          ? trsTimeStructure.rightArrivalTime
          : trsTimeStructure.leftArrivalTime,
        rightIsTarget
          ? trsTimeStructure.rightDepartureTime
          : trsTimeStructure.leftDepartureTime,
        trsTimeStructure.travelTime,
      );

      trsTimeStructure.leftDepartureTime = trsTimeStructure.rightArrivalTime;
      trsTimeStructure.leftArrivalTime = trsTimeStructure.rightDepartureTime;
      summedTravelTime += trsTimeStructure.travelTime;
    }

    this.trainrunSectionsUpdated();
    this.nodeService.connectionsUpdated();
  }

  trainrunSectionsUpdated() {
    this.trainrunSectionsSubject.next(
      Object.assign({}, this.trainrunSectionsStore).trainrunSections,
    );
  }

  copyAllTrainrunSectionsForTrainrun(
    trainrunIdToCopyFrom: number,
    newTrainrunId: number,
  ) {
    const trainrunSections =
      this.getAllTrainrunSectionsForTrainrun(trainrunIdToCopyFrom);
    trainrunSections.forEach((trainrunSection) => {
      const newSection = this.copyTrainrunSectionAndAddToNodes(trainrunSection, newTrainrunId);
      if (trainrunSection.selected()) {
        trainrunSection.unselect();
        newSection.select();
      }
    });
  }

  replaceIntermediateStopWithNode(
    trainrunSectionId: number,
    stopIndex: number,
    nodeId: number,
  ) {
    const trainrunSection1 = this.getTrainrunSectionFromId(trainrunSectionId);
    if (
      trainrunSection1.getSourceNodeId() === nodeId ||
      trainrunSection1.getTargetNodeId() === nodeId
    ) {
      return;
    }
    const origTravelTime = trainrunSection1.getTravelTime();
    const trainrunSection2 = this.copyTrainrunSection(
      trainrunSection1,
      trainrunSection1.getTrainrunId(),
    );
    const node1 = trainrunSection1.getSourceNode();
    const node2 = trainrunSection1.getTargetNode();
    const nodeIntermediate = this.nodeService.getNodeFromId(nodeId);
    const transition1: Transition = node1.getTransition(
      trainrunSection1.getId(),
    );
    const nonStop1 =
      transition1 !== undefined ? transition1.getIsNonStopTransit() : false;
    const transition2: Transition = node2.getTransition(
      trainrunSection1.getId(),
    );
    const nonStop2 =
      transition2 !== undefined ? transition2.getIsNonStopTransit() : false;

    node2.replaceTrainrunSectionOnPort(trainrunSection1, trainrunSection2);

    trainrunSection1.setTargetNode(nodeIntermediate);
    nodeIntermediate.addPortWithRespectToOppositeNode(node1, trainrunSection1);
    node1.reAlignPortWithRespectToOppositeNode(
      nodeIntermediate,
      trainrunSection1,
    );

    trainrunSection2.setSourceNode(nodeIntermediate);
    trainrunSection2.setTargetNode(node2);
    nodeIntermediate.addPortWithRespectToOppositeNode(node2, trainrunSection2);
    node2.reAlignPortWithRespectToOppositeNode(
      nodeIntermediate,
      trainrunSection2,
    );

    this.reRouteAffectedTrainrunSections(
      node1.getId(),
      nodeIntermediate.getId(),
    );
    this.reRouteAffectedTrainrunSections(
      node2.getId(),
      nodeIntermediate.getId(),
    );

    this.nodeService.addTransitionToNodeForTrainrunSections(
      nodeIntermediate.getId(),
      trainrunSection1,
      trainrunSection2,
    );
    this.trainrunService.propagateConsecutiveTimesForTrainrun(
      trainrunSection1.getId(),
    );

    const numberOfStops = trainrunSection1.getNumberOfStops();
    trainrunSection1.setNumberOfStops(stopIndex);
    trainrunSection2.setNumberOfStops(numberOfStops - stopIndex - 1);

    const minHalteZeitFromNode = this.nodeService.getHaltezeit(
      nodeId,
      trainrunSection1.getTrainrun().getTrainrunCategory(),
    );
    let travelTime1 =
      trainrunSection1.getTargetDepartureConsecutiveTime() -
      trainrunSection1.getSourceDepartureConsecutiveTime();
    let travelTime2 =
      trainrunSection1.getSourceArrivalConsecutiveTime() -
      trainrunSection1.getTargetDepartureConsecutiveTime();
    travelTime1 = travelTime1 < 0 ? travelTime2 : travelTime1;
    travelTime2 = travelTime2 < 0 ? travelTime1 : travelTime2;
    const calculatedTravelTime = Math.min(travelTime1, travelTime2);
    const halteZeit = Math.min(
      minHalteZeitFromNode,
      Math.max(0, calculatedTravelTime - 2),
    );
    const travelTimeIssue =
      travelTime1 === travelTime2 || minHalteZeitFromNode !== halteZeit;
    const travelTime = Math.max(
      trainrunSection1.getTravelTime() - halteZeit,
      2,
    );
    const halfTravelTime = Math.floor(travelTime / 2);
    trainrunSection1.setTravelTime(Math.max(1, travelTime - halfTravelTime));
    trainrunSection2.setTravelTime(Math.max(1, halfTravelTime));

    trainrunSection1.setTargetArrival(
      TrainrunSectionService.boundMinutesToOneHour(
        trainrunSection1.getSourceDeparture() +
        trainrunSection1.getTravelTime(),
      ),
    );
    trainrunSection2.setSourceArrival(
      TrainrunSectionService.boundMinutesToOneHour(
        trainrunSection1.getTargetDeparture() +
        trainrunSection2.getTravelTime(),
      ),
    );
    trainrunSection1.setTargetDeparture(
      TrainrunSectionService.boundMinutesToOneHour(
        halteZeit + trainrunSection2.getSourceArrival(),
      ),
    );
    trainrunSection2.setSourceDeparture(
      TrainrunSectionService.boundMinutesToOneHour(
        halteZeit + trainrunSection1.getTargetArrival(),
      ),
    );

    if (
      minHalteZeitFromNode < halteZeit ||
      trainrunSection1.getTravelTime() +
      trainrunSection2.getTravelTime() +
      halteZeit !==
      origTravelTime ||
      travelTimeIssue
    ) {
      const title = $localize`:@@app.services.data.trainrunsection.intermediate-stop-replacement.title:Intermediate stop replacement`;
      const description = $localize`:@@app.services.data.trainrunsection.intermediate-stop-replacement.description:Intermediate stop replacement led to inconsistencies in the allocation of times!`;
      trainrunSection1.setTargetArrivalWarning(title, description);
      trainrunSection1.setTargetDepartureWarning(title, description);
      trainrunSection2.setSourceArrivalWarning(title, description);
      trainrunSection2.setSourceDepartureWarning(title, description);
    }

    const transitionNew1 = node1.getTransition(trainrunSection1.getId());
    if (transitionNew1 !== undefined) {
      transitionNew1.setIsNonStopTransit(nonStop1);
    }
    const transitionNew2 = node2.getTransition(trainrunSection2.getId());
    if (transitionNew2 !== undefined) {
      transitionNew2.setIsNonStopTransit(nonStop2);
    }

    this.trainrunService.propagateConsecutiveTimesForTrainrun(
      trainrunSection1.getId(),
    );

    this.nodeService.transitionsUpdated();
    this.nodeService.connectionsUpdated();
    this.nodeService.nodesUpdated();
    this.trainrunSectionsUpdated();
  }

  setWarningOnNode(
    trainrunSectionId: number,
    nodeId: number,
    warningTitle: string,
    warningDescription: string,
  ) {
    const trainrunSection = this.getTrainrunSectionFromId(trainrunSectionId);
    if (trainrunSection.getSourceNodeId() === nodeId) {
      trainrunSection.setSourceArrivalWarning(warningTitle, warningDescription);
      trainrunSection.setSourceDepartureWarning(
        warningTitle,
        warningDescription,
      );
    } else {
      trainrunSection.setTargetArrivalWarning(warningTitle, warningDescription);
      trainrunSection.setTargetDepartureWarning(
        warningTitle,
        warningDescription,
      );
    }
  }

  clickSelectedTrainrunSection(
    informSelectedTrainrunClick: InformSelectedTrainrunClick,
  ) {
    this.informSelectedTrainrunClickSubject.next(informSelectedTrainrunClick);
  }

  private copyTrainrunSection(
    existingTrainrunSection: TrainrunSection,
    newTrainrunId: number,
  ): TrainrunSection {
    const trainrunSection: TrainrunSection = new TrainrunSection();
    trainrunSection.setTrainrun(
      this.trainrunService.getTrainrunFromId(newTrainrunId),
    );
    trainrunSection.setTravelTimeDto(
      JSON.parse(JSON.stringify(existingTrainrunSection.getTravelTimeDto())),
    );
    trainrunSection.setSourceArrivalDto(
      JSON.parse(JSON.stringify(existingTrainrunSection.getSourceArrivalDto())),
    );
    trainrunSection.setSourceDepartureDto(
      JSON.parse(
        JSON.stringify(existingTrainrunSection.getSourceDepartureDto()),
      ),
    );
    trainrunSection.setTargetArrivalDto(
      JSON.parse(JSON.stringify(existingTrainrunSection.getTargetArrivalDto())),
    );
    trainrunSection.setTargetDepartureDto(
      JSON.parse(
        JSON.stringify(existingTrainrunSection.getTargetDepartureDto()),
      ),
    );
    trainrunSection.setNumberOfStops(
      existingTrainrunSection.getNumberOfStops(),
    );
    this.trainrunSectionsStore.trainrunSections.push(trainrunSection);
    return trainrunSection;
  }

  private copyTrainrunSectionAndAddToNodes(
    existingTrainrunSection: TrainrunSection,
    newTrainrunId: number,
  ): TrainrunSection {
    const trainrunSection = this.copyTrainrunSection(
      existingTrainrunSection,
      newTrainrunId,
    );
    const sourceNode = this.nodeService.getNodeFromId(
      existingTrainrunSection.getSourceNodeId(),
    );
    const targetNode = this.nodeService.getNodeFromId(
      existingTrainrunSection.getTargetNodeId(),
    );
    trainrunSection.setSourceAndTargetNodeReference(sourceNode, targetNode);

    this.nodeService.addPortsToNodes(
      sourceNode.getId(),
      targetNode.getId(),
      trainrunSection,
    );
    this.nodeService.addTransitionToNodes(
      sourceNode.getId(),
      targetNode.getId(),
      trainrunSection,
    );
    this.nodeService.copyTransitionProperties(
      sourceNode.getId(),
      trainrunSection,
      existingTrainrunSection,
    );
    this.nodeService.copyTransitionProperties(
      targetNode.getId(),
      trainrunSection,
      existingTrainrunSection,
    );

    trainrunSection.routeEdgeAndPlaceText();
    this.reRouteAffectedTrainrunSections(
      sourceNode.getId(),
      targetNode.getId(),
    );
    this.trainrunService.propagateConsecutiveTimesForTrainrun(
      trainrunSection.getId(),
    );

    return trainrunSection;
  }

  private deleteTrainrunSectionAndCleanupNodes(
    trainrunSection: TrainrunSection,
    enforceUpdate = true,
  ) {
    this.nodeService.removeTransitionsFromNodes(trainrunSection);
    this.nodeService.removeConnectionsFromNodes(trainrunSection);
    this.nodeService.removePortsFromNodes(trainrunSection);
    this.nodeService.updateTransitionsAndConnectionsOnNodes(trainrunSection);
    if (enforceUpdate) {
      //this.nodeService.nodesUpdated();
      this.nodeService.transitionsUpdated();
      this.nodeService.connectionsUpdated();
    }
    this.trainrunSectionsStore.trainrunSections =
      this.trainrunSectionsStore.trainrunSections.filter(
        (e) => e.getId() !== trainrunSection.getId(),
      );
    this.reRouteAffectedTrainrunSections(
      trainrunSection.getSourceNodeId(),
      trainrunSection.getTargetNodeId(),
    );
    this.checkMissingTransitionsAfterDeletion(trainrunSection.getTrainrun());
    this.deleteTrainrunIfNotUsedAnymore(trainrunSection.getTrainrun(), false);

    if (
      this.getTrainrunSections().find(
        (ts) => ts.getTrainrunId() === trainrunSection.getTrainrunId(),
      ) !== undefined
    ) {
      // special case - not last trainrun section deletion
      this.trainrunService.propagateTrainrunInitialConsecutiveTimes(
        trainrunSection.getTrainrun(),
      );
      if (enforceUpdate) {
        this.trainrunService.trainrunsUpdated();
      }
    }
  }

  private checkMissingTransitionsAfterDeletion(trainrun: Trainrun) {
    const trainrunSections = this.getAllTrainrunSectionsForTrainrun(trainrun.getId());
    trainrunSections.forEach(ts => {
      const sourceNode = ts.getSourceNode();
      const targetNode = ts.getTargetNode();

      const srcPortsWithoutTransitions = sourceNode.getPorts().filter(
        (port) => port.getTrainrunSection().getTrainrunId() === trainrun.getId() &&
          sourceNode.getTransitionFromPortId(port.getId()) === undefined
      );
      const trgPortsWithoutTransitions = targetNode.getPorts().filter(
        (port) => port.getTrainrunSection().getTrainrunId() === trainrun.getId() &&
          targetNode.getTransitionFromPortId(port.getId()) === undefined
      );

      if (srcPortsWithoutTransitions.length > 1) {
        this.nodeService.addTransitionToNodes(
          sourceNode.getId(),
          targetNode.getId(),
          srcPortsWithoutTransitions[0].getTrainrunSection(),
        );
      }

      if (trgPortsWithoutTransitions.length > 1) {
        this.nodeService.addTransitionToNodes(
          sourceNode.getId(),
          targetNode.getId(),
          trgPortsWithoutTransitions[0].getTrainrunSection(),
        );
      }
    });
  }

  private reRouteAffectedTrainrunSections(
    sourceNodeId: number,
    targetNodeId: number,
  ) {
    this.trainrunSectionsStore.trainrunSections.forEach((e) => {
      if (
        e.getSourceNodeId() === sourceNodeId ||
        e.getSourceNodeId() === targetNodeId ||
        e.getTargetNodeId() === sourceNodeId ||
        e.getTargetNodeId() === targetNodeId
      ) {
        e.routeEdgeAndPlaceText();
      }
    });
  }

  private getFromAndToNode(
    sourceNodeId: number,
    trainrunSection: TrainrunSection,
    targetNodeId: number,
  ) {
    let nodeFrom: Node = null;
    let nodeToNew: Node = null;
    let nodeToOld: Node = null;

    if (sourceNodeId === trainrunSection.getSourceNodeId()) {
      nodeFrom = this.nodeService.getNodeFromId(sourceNodeId);
      nodeToNew = this.nodeService.getNodeFromId(targetNodeId);
      nodeToOld = this.nodeService.getNodeFromId(
        trainrunSection.getTargetNodeId(),
      );
    } else if (targetNodeId === trainrunSection.getSourceNodeId()) {
      nodeFrom = this.nodeService.getNodeFromId(targetNodeId);
      nodeToNew = this.nodeService.getNodeFromId(sourceNodeId);
      nodeToOld = this.nodeService.getNodeFromId(
        trainrunSection.getTargetNodeId(),
      );
    } else if (sourceNodeId === trainrunSection.getTargetNodeId()) {
      nodeFrom = this.nodeService.getNodeFromId(sourceNodeId);
      nodeToNew = this.nodeService.getNodeFromId(targetNodeId);
      nodeToOld = this.nodeService.getNodeFromId(
        trainrunSection.getSourceNodeId(),
      );
    } else if (targetNodeId === trainrunSection.getTargetNodeId()) {
      nodeFrom = this.nodeService.getNodeFromId(targetNodeId);
      nodeToNew = this.nodeService.getNodeFromId(sourceNodeId);
      nodeToOld = this.nodeService.getNodeFromId(
        trainrunSection.getSourceNodeId(),
      );
    }
    return {nodeFrom, nodeToNew, nodeToOld};
  }

  private deleteTrainrunIfNotUsedAnymore(
    trainrun: Trainrun,
    enforceUpdate = true,
  ) {
    const trainrunSectionWithTrainrun =
      this.trainrunSectionsStore.trainrunSections.find(
        (trs) => trs.getTrainrun() === trainrun,
      );
    if (trainrunSectionWithTrainrun === undefined) {
      this.trainrunService.deleteTrainrun(trainrun, enforceUpdate);
    }
  }

  private handleNodeAndTrainrunSectionDetails(
    sourceNode: Node,
    targetNode: Node,
    trainrunSection: TrainrunSection,
    sourceIsNonStop = false,
    targetIsNonStop = false,
    enforceUpdate = true
  ) {
    this.nodeService.addPortsToNodes(
      sourceNode.getId(),
      targetNode.getId(),
      trainrunSection,
    );
    this.nodeService.addTransitionToNodes(
      sourceNode.getId(),
      targetNode.getId(),
      trainrunSection,
      sourceIsNonStop,
      targetIsNonStop,
    );
    if (enforceUpdate) {
      this.nodeService.nodesUpdated();
      this.nodeService.transitionsUpdated();
    }
    trainrunSection.routeEdgeAndPlaceText();
    this.reRouteAffectedTrainrunSections(
      sourceNode.getId(),
      targetNode.getId(),
    );
  }

  private createNewTrainrunSectionFromDto(
    trainrunSection: TrainrunSectionDto,
    nodeMap: Map<number, number>,
    trainrunMap: Map<number, number>,
    nodes: NodeDto[],
    enforceUpdate = true
  ) {
    const trainrunId = trainrunMap.get(trainrunSection.trainrunId);
    const trainrun = this.trainrunService.getTrainrunFromId(trainrunId);

    const newTrainrunSection: TrainrunSection = new TrainrunSection();
    newTrainrunSection.setTrainrun(trainrun);

    const sourceNodeId = nodeMap.get(trainrunSection.sourceNodeId);
    const sourceNode = this.nodeService.getNodeFromId(sourceNodeId);
    const targetNodeId = nodeMap.get(trainrunSection.targetNodeId);
    const targetNode = this.nodeService.getNodeFromId(targetNodeId);
    newTrainrunSection.setSourceAndTargetNodeReference(sourceNode, targetNode);

    newTrainrunSection.setSourceArrivalDto(trainrunSection.sourceArrival);
    newTrainrunSection.setTargetArrivalDto(trainrunSection.targetArrival);
    newTrainrunSection.setSourceDepartureDto(trainrunSection.sourceDeparture);
    newTrainrunSection.setTargetDepartureDto(trainrunSection.targetDeparture);
    newTrainrunSection.setTravelTimeDto(trainrunSection.travelTime);
    newTrainrunSection.setNumberOfStops(trainrunSection.numberOfStops);
    this.trainrunSectionsStore.trainrunSections.push(newTrainrunSection);
    const sourceIsNonStop = this.getIsNonStop(
      trainrunSection.sourceNodeId,
      trainrunSection.sourcePortId,
      nodes,
    );
    const targetIsNonStop = this.getIsNonStop(
      trainrunSection.targetNodeId,
      trainrunSection.targetPortId,
      nodes,
    );
    this.handleNodeAndTrainrunSectionDetails(
      sourceNode,
      targetNode,
      newTrainrunSection,
      sourceIsNonStop,
      targetIsNonStop,
      enforceUpdate
    );
    return newTrainrunSection;
  }

  private getIsNonStop(nodeId: number, portId: number, nodes: NodeDto[]) {
    let returnValue = false;
    const filtertNodes = nodes.filter((n) => n.id === nodeId);
    filtertNodes.forEach((node) => {
      const filtertTransitions = node.transitions.filter(
        (transition) =>
          transition.port1Id === portId || transition.port2Id === portId,
      );
      filtertTransitions.forEach((transition) => {
        if (transition.isNonStopTransit === true) {
          returnValue = true;
        }
      });
    });
    return returnValue;
  }
}