1   /* Copyright 2002-2024 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       * Period 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) {
113                 return ((ChangesForwarder) observer).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         Collections.sort(delegating, new Comparator<DelegatingDriver>() {
167             /** {@inheritDoc} */
168             @Override
169             public int compare(final DelegatingDriver d1, final DelegatingDriver d2) {
170                 return d1.getName().compareTo(d2.getName());
171             }
172         });
173     }
174 
175     /** Filter parameters to keep only one type of selection status.
176      * @param selected if true, only {@link ParameterDriver#isSelected()
177      * selected} parameters will be kept, the other ones will be removed
178      */
179     public void filter(final boolean selected) {
180         for (final Iterator<DelegatingDriver> iterator = delegating.iterator(); iterator.hasNext();) {
181             final DelegatingDriver delegatingDriver = iterator.next();
182             if (delegatingDriver.isSelected() != selected) {
183                 iterator.remove();
184                 delegatingDriver.removeOwner(this);
185             }
186         }
187     }
188 
189     /** Get the number of parameters with different names.
190      * @return number of parameters with different names
191      */
192     public int getNbParams() {
193         return delegating.size();
194     }
195 
196     /** Get the number of values to estimate for parameters with different names.
197      * @return number of values to estimate for parameters with different names
198      */
199     public int getNbValuesToEstimate() {
200         int nbValuesToEstimate = 0;
201         for (DelegatingDriver driver : delegating) {
202             nbValuesToEstimate += driver.getNbOfValues();
203         }
204         return nbValuesToEstimate;
205     }
206 
207     /** Get delegating drivers for all parameters.
208      * <p>
209      * The delegating drivers are <em>not</em> the same as
210      * the drivers added to the list, but they delegate to them.
211      * </p>
212      * <p>
213      * All delegating drivers manage parameters with different names.
214      * </p>
215      * @return unmodifiable view of the list of delegating drivers
216      */
217     public List<DelegatingDriver> getDrivers() {
218         return Collections.unmodifiableList(delegating);
219     }
220 
221     /** Specialized driver delegating to several other managing
222      * the same parameter name.
223      */
224     public static class DelegatingDriver extends ParameterDriver {
225 
226         /** Lists owning this delegating driver. */
227         private final List<ParameterDriversList> owners;
228 
229         /** Observer for propagating changes between all drivers. */
230         private ChangesForwarder forwarder;
231 
232         /** Simple constructor.
233          * @param owner list owning this delegating driver
234          * @param driver first driver in the series
235          */
236         DelegatingDriver(final ParameterDriversList owner, final ParameterDriver driver) {
237             super(driver.getName(), driver.getNamesSpanMap(),
238                   driver.getValueSpanMap(), driver.getReferenceValue(),
239                   driver.getScale(), driver.getMinValue(), driver.getMaxValue());
240 
241             owners = new ArrayList<>();
242             addOwner(owner);
243 
244             setValueSpanMap(driver);
245             setReferenceDate(driver.getReferenceDate());
246             setSelected(driver.isSelected());
247 
248             // set up a change forwarder observing both the raw driver and the delegating driver
249             this.forwarder = new ChangesForwarder(this, driver);
250             addObserver(forwarder);
251             driver.addObserver(forwarder);
252 
253         }
254 
255         /** Add an owner for this delegating driver.
256          * @param owner owner to add
257          */
258         void addOwner(final ParameterDriversList owner) {
259             owners.add(owner);
260         }
261 
262         /** Remove one owner of this driver.
263          * @param owner owner to remove delegating driver from
264          * @since 10.1
265          */
266         private void removeOwner(final ParameterDriversList owner) {
267             for (final Iterator<ParameterDriversList> iterator = owners.iterator(); iterator.hasNext();) {
268                 if (iterator.next() == owner) {
269                     iterator.remove();
270                 }
271             }
272         }
273 
274         /** Add a driver. Warning, by doing this operation
275          * all the delegated drivers present in the parameterDriverList
276          * will be overwritten with the attributes of the driver given
277          * in argument.
278          * <p>
279          * </p>
280          * Warning if a driver is added and a driver with the same name
281          * was already added before, they should have the same validity
282          * Period (that is to say that the {@link ParameterDriver#setPeriods}
283          * method should have been called with same arguments for all drivers
284          * having the same name) to avoid surprises. Whatever, all driver having
285          * same name will have their valueSpanMap, nameSpanMap and validity period
286          * overwritten with the last driver added attributes.
287          * @param driver driver to add
288          */
289         private void add(final ParameterDriver driver) {
290 
291             setValueSpanMap(driver);
292             setReferenceDate(driver.getReferenceDate());
293 
294             // if any of the drivers is selected, all must be selected
295             if (isSelected()) {
296                 driver.setSelected(true);
297             } else {
298                 setSelected(driver.isSelected());
299             }
300 
301             driver.addObserver(forwarder);
302             forwarder.add(driver);
303 
304         }
305 
306         /** Merge another instance.
307          * <p>
308          * After merging, the other instance is merely empty and preserved
309          * only as a child of the current instance. Changes are therefore
310          * still forwarded to it, but it is itself not responsible anymore
311          * for forwarding change.
312          * <p>
313          * </p>
314          * Warning if a driver is added and a driver with the same name
315          * was already added before, they should have the same validity
316          * Period (that is to say that the {@link ParameterDriver#setPeriods}
317          * method should have been called with same arguments for all drivers
318          * having the same name) to avoid surprises. Whatever, all driver having
319          * same name will have their valueSpanMap, nameSpanMap and validity period
320          * overwritten with the last driver added attributes.
321          * </p>
322          * @param other instance to merge
323          */
324         private void merge(final DelegatingDriver other) {
325 
326             if (other.forwarder == forwarder) {
327                 // we are attempting to merge an instance with either itself
328                 // or an already embedded one, just ignore the request
329                 return;
330             }
331 
332             // synchronize parameter
333             setValueSpanMap(other);
334             //setValue(other.getValue());
335             setReferenceDate(other.getReferenceDate());
336             if (isSelected()) {
337                 other.setSelected(true);
338             } else {
339                 setSelected(other.isSelected());
340             }
341 
342             // move around drivers
343             for (final ParameterDriver otherDriver : other.forwarder.getDrivers()) {
344                 // as drivers are added one at a time and always refer back to a single
345                 // DelegatingDriver (through the ChangesForwarder), they cannot be
346                 // referenced by two different DelegatingDriver. We can blindly move
347                 // around all drivers, there cannot be any duplicates
348                 forwarder.add(otherDriver);
349                 otherDriver.replaceObserver(other.forwarder, forwarder);
350             }
351 
352             // forwarding is now delegated to current instance
353             other.replaceObserver(other.forwarder, forwarder);
354             other.forwarder = forwarder;
355 
356             // replace merged instance with current instance in former owners
357             for (final ParameterDriversList otherOwner : other.owners) {
358                 owners.add(otherOwner);
359                 otherOwner.replaceDelegating(other, this);
360             }
361 
362         }
363 
364         /** Get the raw drivers to which this one delegates.
365          * <p>
366          * These raw drivers all manage the same parameter name.
367          * </p>
368          * @return raw drivers to which this one delegates
369          */
370         public List<ParameterDriver> getRawDrivers() {
371             return Collections.unmodifiableList(forwarder.getDrivers());
372         }
373 
374     }
375 
376     /** Local observer for propagating changes, avoiding infinite recursion. */
377     private static class ChangesForwarder implements ParameterObserver {
378 
379         /** DelegatingDriver we are associated with. */
380         private final DelegatingDriver delegating;
381 
382         /** Drivers synchronized together by the instance. */
383         private final List<ParameterDriver> drivers;
384 
385         /** Root of the current update chain. */
386         private ParameterDriver root;
387 
388         /** Depth of the current update chain. */
389         private int depth;
390 
391         /** Simple constructor.
392          * @param delegating delegatingDriver we are associated with
393          * @param driver first driver in the series
394          */
395         ChangesForwarder(final DelegatingDriver delegating, final ParameterDriver driver) {
396             this.delegating = delegating;
397             this.drivers    = new ArrayList<>();
398             drivers.add(driver);
399         }
400 
401         /** Get the {@link DelegatingDriver} associated with this instance.
402          * @return {@link DelegatingDriver} associated with this instance
403          * @since 9.1
404          */
405         DelegatingDriver getDelegatingDriver() {
406             return delegating;
407         }
408 
409         /** Add a driver to the list synchronized together by the instance.
410          * @param driver driver to add
411          * @since 10.1
412          */
413         void add(final ParameterDriver driver) {
414             drivers.add(driver);
415         }
416 
417         /** Get the drivers synchronized together by the instance.
418          * @return drivers synchronized together by the instance.
419          * @since 10.1
420          */
421         public List<ParameterDriver> getDrivers() {
422             return drivers;
423         }
424 
425         /** {@inheritDoc} */
426         @Override
427         public void valueSpanMapChanged(final TimeSpanMap<Double> previousValueSpanMap, final ParameterDriver driver) {
428             updateAll(driver, d -> d.setValueSpanMap(driver));
429         }
430 
431         /** {@inheritDoc} */
432         @Override
433         public void valueChanged(final double previousValue, final ParameterDriver driver, final AbsoluteDate date) {
434             updateAll(driver, d -> d.setValue(driver.getValue(date), date));
435         }
436 
437         /** {@inheritDoc} */
438         @Override
439         public void referenceDateChanged(final AbsoluteDate previousReferenceDate, final ParameterDriver driver) {
440             updateAll(driver, d -> d.setReferenceDate(driver.getReferenceDate()));
441         }
442 
443         /** {@inheritDoc} */
444         @Override
445         public void nameChanged(final String previousName, final ParameterDriver driver) {
446             updateAll(driver, d -> d.setName(driver.getName()));
447         }
448 
449         /** {@inheritDoc} */
450         @Override
451         public void selectionChanged(final boolean previousSelection, final ParameterDriver driver) {
452             updateAll(driver, d -> d.setSelected(driver.isSelected()));
453         }
454 
455         /** {@inheritDoc} */
456         @Override
457         public void estimationTypeChanged(final boolean previousSelection, final ParameterDriver driver) {
458             updateAll(driver, d -> d.setContinuousEstimation(driver.isContinuousEstimation()));
459         }
460 
461         /** {@inheritDoc} */
462         @Override
463         public void referenceValueChanged(final double previousReferenceValue, final ParameterDriver driver) {
464             updateAll(driver, d -> d.setReferenceValue(driver.getReferenceValue()));
465         }
466 
467         /** {@inheritDoc} */
468         @Override
469         public void minValueChanged(final double previousMinValue, final ParameterDriver driver) {
470             updateAll(driver, d -> d.setMinValue(driver.getMinValue()));
471         }
472 
473         /** {@inheritDoc} */
474         @Override
475         public void maxValueChanged(final double previousMaxValue, final ParameterDriver driver) {
476             updateAll(driver, d -> d.setMaxValue(driver.getMaxValue()));
477         }
478 
479         /** {@inheritDoc} */
480         @Override
481         public void scaleChanged(final double previousScale, final ParameterDriver driver) {
482             updateAll(driver, d -> d.setScale(driver.getScale()));
483         }
484 
485         /** Update all bound parameters.
486          * @param driver driver triggering the update
487          * @param updater updater to use
488          */
489         private void updateAll(final ParameterDriver driver, final Updater updater) {
490 
491             final boolean firstCall = depth++ == 0;
492             if (firstCall) {
493                 root = driver;
494             }
495 
496             if (driver == getDelegatingDriver()) {
497                 // propagate change downwards, which will trigger recursive calls
498                 for (final ParameterDriver d : drivers) {
499                     if (d != root) {
500                         updater.update(d);
501                     }
502                 }
503             } else if (firstCall) {
504                 // first call started from an underlying driver, propagate change upwards
505                 updater.update(getDelegatingDriver());
506             }
507 
508             if (--depth == 0) {
509                 // this is the end of the root call
510                 root = null;
511             }
512 
513         }
514 
515     }
516 
517     /** Interface for updating parameters. */
518     @FunctionalInterface
519     private interface Updater {
520         /** Update a driver.
521          * @param driver driver to update
522          */
523         void update(ParameterDriver driver);
524     }
525 
526 }