1   /* Copyright 2002-2026 CS GROUP
2    * Licensed to CS GROUP (CS) under one or more
3    * contributor license agreements.  See the NOTICE file distributed with
4    * this work for additional information regarding copyright ownership.
5    * CS licenses this file to You under the Apache License, Version 2.0
6    * (the "License"); you may not use this file except in compliance with
7    * the License.  You may obtain a copy of the License at
8    *
9    *   http://www.apache.org/licenses/LICENSE-2.0
10   *
11   * Unless required by applicable law or agreed to in writing, software
12   * distributed under the License is distributed on an "AS IS" BASIS,
13   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14   * See the License for the specific language governing permissions and
15   * limitations under the License.
16   */
17  package org.orekit.utils;
18  
19  import java.util.ArrayList;
20  import java.util.Collections;
21  import java.util.Comparator;
22  import java.util.Iterator;
23  import java.util.List;
24  
25  import org.orekit.time.AbsoluteDate;
26  import org.orekit.utils.TimeSpanMap.Span;
27  
28  
29  /** Class managing several {@link ParameterDriver parameter drivers},
30   * taking care of duplicated names.
31   * <p>
32   * Once parameter drivers sharing the same name have been added to
33   * an instance of this class, they are permanently bound together and
34   * also bound to the {@link #getDrivers() delegating driver} that
35   * manages them. This means that if drivers {@code d1}, {@code d2}...
36   * {@code dn} are added to the list and both correspond to parameter
37   * name "P", then {@link #getDrivers()} will return a list containing
38   * a delegating driver {@code delegateD} for the same name "P".
39   * Afterwards, whenever either {@link ParameterDriver#setValue(double)}
40   * or {@link ParameterDriver#setReferenceDate(AbsoluteDate)} is called
41   * on any of the {@code n+1} instances {@code d1}, {@code d2}... {@code dn}
42   * or {@code delegateD}, the call will be automatically forwarded to the
43   * {@code n} remaining instances, hence ensuring they remain consistent
44   * with each other.
45   * </p>
46   * @author Luc Maisonobe
47   * @author Mélina Vanel
48   * @since 8.0
49   */
50  public class ParameterDriversList {
51  
52      /** Managed drivers. */
53      private final List<DelegatingDriver> delegating;
54  
55      /** Creates an empty list.
56       */
57      public ParameterDriversList() {
58          this.delegating = new ArrayList<>();
59      }
60  
61      /** Add a driver.
62       * <p>
63       * If the driver is already present, it will not be added.
64       * If another driver managing the same parameter is present,
65       * both drivers will be managed together, existing drivers
66       * being set to the value of the last driver added (i.e.
67       * each addition overrides the parameter value).
68       * </p>
69       * <p>
70       * Warning if a driver is added and a driver with the same name
71       * was already added before, they should have the same validity
72       * periods to avoid surprises. Whatever, all driver having
73       * same name will have their valueSpanMap, nameSpanMap and validity period
74       * overwritten with the last driver added attributes.
75       * </p>
76       * @param driver driver to add
77       */
78      public void add(final ParameterDriver driver) {
79  
80          final DelegatingDriver existingHere = findByName(driver.getName());
81          final DelegatingDriver alreadyBound = getAssociatedDelegatingDriver(driver);
82  
83          if (existingHere != null) {
84              if (alreadyBound != null) {
85                  // merge the two delegating drivers
86                  existingHere.merge(alreadyBound);
87              } else {
88                  // this is a new driver for an already managed parameter
89                  existingHere.add(driver);
90              }
91          } else {
92              if (alreadyBound != null) {
93                  // the driver is new here, but already bound to other drivers in other lists
94                  delegating.add(alreadyBound);
95                  alreadyBound.addOwner(this);
96              } else {
97                  // this is the first driver we have for this parameter name
98                  delegating.add(new DelegatingDriver(this, driver));
99              }
100         }
101 
102     }
103 
104     /** Get a {@link DelegatingDriver delegating driver} bound to a driver.
105      * @param driver driver to check
106      * @return a {@link DelegatingDriver delegating driver} bound to a driver, or
107      * null if this driver is not associated with any {@link DelegatingDriver delegating driver}
108      * @since 9.1
109      */
110     private DelegatingDriver getAssociatedDelegatingDriver(final ParameterDriver driver) {
111         for (final ParameterObserver observer : driver.getObservers()) {
112             if (observer instanceof ChangesForwarder forwarder) {
113                 return forwarder.getDelegatingDriver();
114             }
115         }
116         return null;
117     }
118 
119     /** Replace a {@link DelegatingDriver delegating driver}.
120      * @param oldDelegating delegating driver to replace
121      * @param newDelegating new delegating driver to use
122      * @since 10.1
123      */
124     private void replaceDelegating(final DelegatingDriver oldDelegating, final DelegatingDriver newDelegating) {
125         for (int i = 0; i < delegating.size(); ++i) {
126             if (delegating.get(i) == oldDelegating) {
127                 delegating.set(i, newDelegating);
128             }
129         }
130     }
131 
132     /** Find  a {@link DelegatingDriver delegating driver} by name.
133      * @param name name to check
134      * @return a {@link DelegatingDriver delegating driver} managing this parameter name
135      * @since 9.1
136      */
137     public DelegatingDriver findByName(final String name) {
138         for (final DelegatingDriver d : delegating) {
139             if (d.getName().equals(name)) {
140                 return d;
141             }
142         }
143         return null;
144     }
145 
146     /** Find  a {@link DelegatingDriver delegating driver} by name.
147      * @param name name to check
148      * @return a {@link DelegatingDriver delegating driver} managing this parameter name
149      * @since 9.1
150      */
151     public String findDelegatingSpanNameBySpanName(final String name) {
152         for (final DelegatingDriver d : delegating) {
153             for (Span<String> span = d.getNamesSpanMap().getFirstSpan(); span != null; span = span.next()) {
154                 if (span.getData().equals(name)) {
155                     return span.getData();
156                 }
157             }
158         }
159         return null;
160     }
161 
162 
163     /** Sort the parameters lexicographically.
164      */
165     public void sort() {
166         delegating.sort(Comparator.comparing(ParameterDriver::getName));
167     }
168 
169     /** Filter parameters to keep only one type of selection status.
170      * @param selected if true, only {@link ParameterDriver#isSelected()
171      * selected} parameters will be kept, the other ones will be removed
172      */
173     public void filter(final boolean selected) {
174         for (final Iterator<DelegatingDriver> iterator = delegating.iterator(); iterator.hasNext();) {
175             final DelegatingDriver delegatingDriver = iterator.next();
176             if (delegatingDriver.isSelected() != selected) {
177                 iterator.remove();
178                 delegatingDriver.removeOwner(this);
179             }
180         }
181     }
182 
183     /** Get the number of parameters with different names.
184      * @return number of parameters with different names
185      */
186     public int getNbParams() {
187         return delegating.size();
188     }
189 
190     /** Get the number of values to estimate for parameters with different names.
191      * @return number of values to estimate for parameters with different names
192      */
193     public int getNbValuesToEstimate() {
194         int nbValuesToEstimate = 0;
195         for (DelegatingDriver driver : delegating) {
196             nbValuesToEstimate += driver.getNbOfValues();
197         }
198         return nbValuesToEstimate;
199     }
200 
201     /** Get delegating drivers for all parameters.
202      * <p>
203      * The delegating drivers are <em>not</em> the same as
204      * the drivers added to the list, but they delegate to them.
205      * </p>
206      * <p>
207      * All delegating drivers manage parameters with different names.
208      * </p>
209      * @return unmodifiable view of the list of delegating drivers
210      */
211     public List<DelegatingDriver> getDrivers() {
212         return Collections.unmodifiableList(delegating);
213     }
214 
215     /** Specialized driver delegating to several other managing
216      * the same parameter name.
217      */
218     public static class DelegatingDriver extends ParameterDriver {
219 
220         /** Lists owning this delegating driver. */
221         private final List<ParameterDriversList> owners;
222 
223         /** Observer for propagating changes between all drivers. */
224         private ChangesForwarder forwarder;
225 
226         /** Simple constructor.
227          * @param owner list owning this delegating driver
228          * @param driver first driver in the series
229          */
230         DelegatingDriver(final ParameterDriversList owner, final ParameterDriver driver) {
231             super(driver.getName(), driver.getNamesSpanMap(),
232                   driver.getValueSpanMap(), driver.getReferenceValue(),
233                   driver.getScale(), driver.getMinValue(), driver.getMaxValue());
234 
235             owners = new ArrayList<>();
236             addOwner(owner);
237 
238             setValueSpanMap(driver);
239             setReferenceDate(driver.getReferenceDate());
240             setSelected(driver.isSelected());
241 
242             // set up a change forwarder observing both the raw driver and the delegating driver
243             this.forwarder = new ChangesForwarder(this, driver);
244             addObserver(forwarder);
245             driver.addObserver(forwarder);
246 
247         }
248 
249         /** Add an owner for this delegating driver.
250          * @param owner owner to add
251          */
252         void addOwner(final ParameterDriversList owner) {
253             owners.add(owner);
254         }
255 
256         /** Remove one owner of this driver.
257          * @param owner owner to remove delegating driver from
258          * @since 10.1
259          */
260         private void removeOwner(final ParameterDriversList owner) {
261             owners.removeIf(parameterDriversList -> parameterDriversList == owner);
262         }
263 
264         /** Add a driver. Warning, by doing this operation
265          * all the delegated drivers present in the parameterDriverList
266          * will be overwritten with the attributes of the driver given
267          * in argument.
268          * <p>
269          * </p>
270          * Warning if a driver is added and a driver with the same name
271          * was already added before, they should have the same validity
272          * Period (that is to say that the {@link
273          * ParameterDriver#addSpans(AbsoluteDate, AbsoluteDate, double)}
274          * and {@link ParameterDriver#addSpanAtDate(AbsoluteDate)} methods
275          * should have been called with the same arguments for all drivers
276          * having the same name) to avoid surprises. Whatever, all driver having
277          * same name will have their valueSpanMap, nameSpanMap and validity period
278          * overwritten with the last driver added attributes.
279          * @param driver driver to add
280          */
281         private void add(final ParameterDriver driver) {
282 
283             setValueSpanMap(driver);
284             setReferenceDate(driver.getReferenceDate());
285 
286             // if any of the drivers is selected, all must be selected
287             if (isSelected()) {
288                 driver.setSelected(true);
289             } else {
290                 setSelected(driver.isSelected());
291             }
292 
293             driver.addObserver(forwarder);
294             forwarder.add(driver);
295 
296         }
297 
298         /** Merge another instance.
299          * <p>
300          * After merging, the other instance is merely empty and preserved
301          * only as a child of the current instance. Changes are therefore
302          * still forwarded to it, but it is itself not responsible anymore
303          * for forwarding change.
304          * <p>
305          * </p>
306          * Warning if a driver is added and a driver with the same name
307          * was already added before, they should have the same validity
308          * periods (that is to say that the {@link
309          * ParameterDriver#addSpans(AbsoluteDate, AbsoluteDate, double)}
310          * and {@link ParameterDriver#addSpanAtDate(AbsoluteDate)} methods
311          * should have been called with same arguments for all drivers
312          * having the same name) to avoid surprises. Whatever, all driver having
313          * same name will have their valueSpanMap, nameSpanMap and validity period
314          * overwritten with the last driver added attributes.
315          * </p>
316          * @param other instance to merge
317          */
318         private void merge(final DelegatingDriver other) {
319 
320             if (other.forwarder == forwarder) {
321                 // we are attempting to merge an instance with either itself
322                 // or an already embedded one, just ignore the request
323                 return;
324             }
325 
326             // synchronize parameter
327             setValueSpanMap(other);
328             setReferenceDate(other.getReferenceDate());
329             if (isSelected()) {
330                 other.setSelected(true);
331             } else {
332                 setSelected(other.isSelected());
333             }
334 
335             // move around drivers
336             for (final ParameterDriver otherDriver : other.forwarder.getDrivers()) {
337                 // as drivers are added one at a time and always refer back to a single
338                 // DelegatingDriver (through the ChangesForwarder), they cannot be
339                 // referenced by two different DelegatingDriver. We can blindly move
340                 // around all drivers, there cannot be any duplicates
341                 forwarder.add(otherDriver);
342                 otherDriver.replaceObserver(other.forwarder, forwarder);
343             }
344 
345             // forwarding is now delegated to current instance
346             other.replaceObserver(other.forwarder, forwarder);
347             other.forwarder = forwarder;
348 
349             // replace merged instance with current instance in former owners
350             for (final ParameterDriversList otherOwner : other.owners) {
351                 owners.add(otherOwner);
352                 otherOwner.replaceDelegating(other, this);
353             }
354 
355         }
356 
357         /** Get the raw drivers to which this one delegates.
358          * <p>
359          * These raw drivers all manage the same parameter name.
360          * </p>
361          * @return raw drivers to which this one delegates
362          */
363         public List<ParameterDriver> getRawDrivers() {
364             return Collections.unmodifiableList(forwarder.getDrivers());
365         }
366 
367     }
368 
369     /** Local observer for propagating changes, avoiding infinite recursion. */
370     private static class ChangesForwarder implements ParameterObserver {
371 
372         /** DelegatingDriver we are associated with. */
373         private final DelegatingDriver delegating;
374 
375         /** Drivers synchronized together by the instance. */
376         private final List<ParameterDriver> drivers;
377 
378         /** Root of the current update chain. */
379         private ParameterDriver root;
380 
381         /** Depth of the current update chain. */
382         private int depth;
383 
384         /** Simple constructor.
385          * @param delegating delegatingDriver we are associated with
386          * @param driver first driver in the series
387          */
388         ChangesForwarder(final DelegatingDriver delegating, final ParameterDriver driver) {
389             this.delegating = delegating;
390             this.drivers    = new ArrayList<>();
391             drivers.add(driver);
392         }
393 
394         /** Get the {@link DelegatingDriver} associated with this instance.
395          * @return {@link DelegatingDriver} associated with this instance
396          * @since 9.1
397          */
398         DelegatingDriver getDelegatingDriver() {
399             return delegating;
400         }
401 
402         /** Add a driver to the list synchronized together by the instance.
403          * @param driver driver to add
404          * @since 10.1
405          */
406         void add(final ParameterDriver driver) {
407             drivers.add(driver);
408         }
409 
410         /** Get the drivers synchronized together by the instance.
411          * @return drivers synchronized together by the instance.
412          * @since 10.1
413          */
414         public List<ParameterDriver> getDrivers() {
415             return drivers;
416         }
417 
418         /** {@inheritDoc} */
419         @Override
420         public void valueSpanMapChanged(final TimeSpanMap<Double> previousValueSpanMap, final ParameterDriver driver) {
421             updateAll(driver, d -> d.setValueSpanMap(driver));
422         }
423 
424         /** {@inheritDoc} */
425         @Override
426         public void valueChanged(final double previousValue, final ParameterDriver driver, final AbsoluteDate date) {
427             updateAll(driver, d -> d.setValue(driver.getValue(date), date));
428         }
429 
430         /** {@inheritDoc} */
431         @Override
432         public void referenceDateChanged(final AbsoluteDate previousReferenceDate, final ParameterDriver driver) {
433             updateAll(driver, d -> d.setReferenceDate(driver.getReferenceDate()));
434         }
435 
436         /** {@inheritDoc} */
437         @Override
438         public void nameChanged(final String previousName, final ParameterDriver driver) {
439             updateAll(driver, d -> d.setName(driver.getName()));
440         }
441 
442         /** {@inheritDoc} */
443         @Override
444         public void selectionChanged(final boolean previousSelection, final ParameterDriver driver) {
445             updateAll(driver, d -> d.setSelected(driver.isSelected()));
446         }
447 
448         /** {@inheritDoc} */
449         @Override
450         public void estimationTypeChanged(final boolean previousSelection, final ParameterDriver driver) {
451             updateAll(driver, d -> d.setContinuousEstimation(driver.isContinuousEstimation()));
452         }
453 
454         /** {@inheritDoc} */
455         @Override
456         public void referenceValueChanged(final double previousReferenceValue, final ParameterDriver driver) {
457             updateAll(driver, d -> d.setReferenceValue(driver.getReferenceValue()));
458         }
459 
460         /** {@inheritDoc} */
461         @Override
462         public void minValueChanged(final double previousMinValue, final ParameterDriver driver) {
463             updateAll(driver, d -> d.setMinValue(driver.getMinValue()));
464         }
465 
466         /** {@inheritDoc} */
467         @Override
468         public void maxValueChanged(final double previousMaxValue, final ParameterDriver driver) {
469             updateAll(driver, d -> d.setMaxValue(driver.getMaxValue()));
470         }
471 
472         /** {@inheritDoc} */
473         @Override
474         public void scaleChanged(final double previousScale, final ParameterDriver driver) {
475             updateAll(driver, d -> d.setScale(driver.getScale()));
476         }
477 
478         /** Update all bound parameters.
479          * @param driver driver triggering the update
480          * @param updater updater to use
481          */
482         private void updateAll(final ParameterDriver driver, final Updater updater) {
483 
484             final boolean firstCall = depth++ == 0;
485             if (firstCall) {
486                 root = driver;
487             }
488 
489             if (driver == getDelegatingDriver()) {
490                 // propagate change downwards, which will trigger recursive calls
491                 for (final ParameterDriver d : drivers) {
492                     if (d != root) {
493                         updater.update(d);
494                     }
495                 }
496             } else if (firstCall) {
497                 // first call started from an underlying driver, propagate change upwards
498                 updater.update(getDelegatingDriver());
499             }
500 
501             if (--depth == 0) {
502                 // this is the end of the root call
503                 root = null;
504             }
505 
506         }
507 
508     }
509 
510     /** Interface for updating parameters. */
511     @FunctionalInterface
512     private interface Updater {
513         /** Update a driver.
514          * @param driver driver to update
515          */
516         void update(ParameterDriver driver);
517     }
518 
519 }