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.drivers;
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  
27  /** Class managing several {@link ParameterDriver parameter drivers},
28   * taking care of duplicated names.
29   * <p>
30   * Once parameter drivers sharing the same name have been added to
31   * an instance of this class, they are permanently bound together and
32   * also bound to the {@link #getDrivers() delegating driver} that
33   * manages them. This means that if drivers {@code d1}, {@code d2}...
34   * {@code dn} are added to the list and both correspond to parameter
35   * name "P", then {@link #getDrivers()} will return a list containing
36   * a delegating driver {@code delegateD} for the same name "P".
37   * Afterwards, whenever either {@link ParameterDriver#setValue(double)}
38   * or {@link ParameterDriver#setReferenceDate(AbsoluteDate)} is called
39   * on any of the {@code n+1} instances {@code d1}, {@code d2}... {@code dn}
40   * or {@code delegateD}, the call will be automatically forwarded to the
41   * {@code n} remaining instances, hence ensuring they remain consistent
42   * with each other.
43   * </p>
44   * @author Luc Maisonobe
45   * @author Mélina Vanel
46   * @since 8.0
47   */
48  public class ParameterDriversList {
49  
50      /** Managed drivers. */
51      private final List<DelegatingDriver> delegating;
52  
53      /** Creates an empty list.
54       */
55      public ParameterDriversList() {
56          this.delegating = new ArrayList<>();
57      }
58  
59      /** Add a driver.
60       * <p>
61       * If the driver is already present, it will not be added.
62       * If another driver managing the same parameter is present,
63       * both drivers will be managed together, existing drivers
64       * being set to the value of the last driver added (i.e.
65       * each addition overrides the parameter value).
66       * </p>
67       * @param driver driver to add
68       */
69      public void add(final ParameterDriver driver) {
70  
71          final DelegatingDriver existingHere = findByName(driver.getName());
72          final DelegatingDriver alreadyBound = getAssociatedDelegatingDriver(driver);
73  
74          if (existingHere != null) {
75              if (alreadyBound != null) {
76                  // merge the two delegating drivers
77                  existingHere.merge(alreadyBound);
78              } else {
79                  // this is a new driver for an already managed parameter
80                  existingHere.add(driver);
81              }
82          } else {
83              if (alreadyBound != null) {
84                  // the driver is new here, but already bound to other drivers in other lists
85                  delegating.add(alreadyBound);
86                  alreadyBound.addOwner(this);
87              } else {
88                  // this is the first driver we have for this parameter name
89                  delegating.add(new DelegatingDriver(this, driver));
90              }
91          }
92  
93      }
94  
95      /** Get a {@link DelegatingDriver delegating driver} bound to a driver.
96       * @param driver driver to check
97       * @return a {@link DelegatingDriver delegating driver} bound to a driver, or
98       * null if this driver is not associated with any {@link DelegatingDriver delegating driver}
99       * @since 9.1
100      */
101     private DelegatingDriver getAssociatedDelegatingDriver(final ParameterDriver driver) {
102         for (final ParameterObserver observer : driver.getObservers()) {
103             if (observer instanceof ChangesForwarder forwarder) {
104                 return forwarder.getDelegatingDriver();
105             }
106         }
107         return null;
108     }
109 
110     /** Replace a {@link DelegatingDriver delegating driver}.
111      * @param oldDelegating delegating driver to replace
112      * @param newDelegating new delegating driver to use
113      * @since 10.1
114      */
115     private void replaceDelegating(final DelegatingDriver oldDelegating, final DelegatingDriver newDelegating) {
116         for (int i = 0; i < delegating.size(); ++i) {
117             if (delegating.get(i) == oldDelegating) {
118                 delegating.set(i, newDelegating);
119             }
120         }
121     }
122 
123     /** Find  a {@link DelegatingDriver delegating driver} by name.
124      * @param name name to check
125      * @return a {@link DelegatingDriver delegating driver} managing this parameter name
126      * @since 9.1
127      */
128     public DelegatingDriver findByName(final String name) {
129         for (final DelegatingDriver d : delegating) {
130             if (d.getName().equals(name)) {
131                 return d;
132             }
133         }
134         return null;
135     }
136 
137     /** Sort the parameters lexicographically.
138      */
139     public void sort() {
140         delegating.sort(Comparator.comparing(ParameterDriver::getName));
141     }
142 
143     /** Filter parameters to keep only one type of selection status.
144      * @param selected if true, only {@link ParameterDriver#isSelected()
145      * selected} parameters will be kept, the other ones will be removed
146      */
147     public void filter(final boolean selected) {
148         for (final Iterator<DelegatingDriver> iterator = delegating.iterator(); iterator.hasNext();) {
149             final DelegatingDriver delegatingDriver = iterator.next();
150             if (delegatingDriver.isSelected() != selected) {
151                 iterator.remove();
152                 delegatingDriver.removeOwner(this);
153             }
154         }
155     }
156 
157     /** Get the number of parameters with different names.
158      * @return number of parameters with different names
159      */
160     public int getNbParams() {
161         return delegating.size();
162     }
163 
164     /** Get delegating drivers for all parameters.
165      * <p>
166      * The delegating drivers are <em>not</em> the same as
167      * the drivers added to the list, but they delegate to them.
168      * </p>
169      * <p>
170      * All delegating drivers manage parameters with different names.
171      * </p>
172      * @return unmodifiable view of the list of delegating drivers
173      */
174     public List<DelegatingDriver> getDrivers() {
175         return Collections.unmodifiableList(delegating);
176     }
177 
178     /** Specialized driver delegating to several other managing
179      * the same parameter name.
180      */
181     public static class DelegatingDriver extends ParameterDriver {
182 
183         /** Lists owning this delegating driver. */
184         private final List<ParameterDriversList> owners;
185 
186         /** Observer for propagating changes between all drivers. */
187         private ChangesForwarder forwarder;
188 
189         /** Simple constructor.
190          * @param owner list owning this delegating driver
191          * @param driver first driver in the series
192          */
193         DelegatingDriver(final ParameterDriversList owner, final ParameterDriver driver) {
194             super(driver.getName(), driver.getReferenceValue(),
195                   driver.getScale(), driver.getMinValue(), driver.getMaxValue(),
196                   driver.getValidity());
197 
198             owners = new ArrayList<>();
199             addOwner(owner);
200 
201             setValue(driver.getValue());
202             setReferenceDate(driver.getReferenceDate());
203             setSelected(driver.isSelected());
204 
205             // set up a change forwarder observing both the raw driver and the delegating driver
206             this.forwarder = new ChangesForwarder(this, driver);
207             addObserver(forwarder);
208             driver.addObserver(forwarder);
209 
210         }
211 
212         /** Add an owner for this delegating driver.
213          * @param owner owner to add
214          */
215         void addOwner(final ParameterDriversList owner) {
216             owners.add(owner);
217         }
218 
219         /** Remove one owner of this driver.
220          * @param owner owner to remove delegating driver from
221          * @since 10.1
222          */
223         private void removeOwner(final ParameterDriversList owner) {
224             owners.removeIf(parameterDriversList -> parameterDriversList == owner);
225         }
226 
227         /** Add a driver.
228          * <p>
229          * Warning, by doing this operation all the delegated drivers present in the
230          * parameterDriverList will be overwritten with the attributes of the driver
231          * given in argument.
232          * <p>
233          * @param driver driver to add
234          */
235         private void add(final ParameterDriver driver) {
236 
237             setValue(driver.getValue());
238             setReferenceDate(driver.getReferenceDate());
239 
240             // if any of the drivers is selected, all must be selected
241             if (isSelected()) {
242                 driver.setSelected(true);
243             } else {
244                 setSelected(driver.isSelected());
245             }
246 
247             driver.addObserver(forwarder);
248             forwarder.add(driver);
249 
250         }
251 
252         /** Merge another instance.
253          * <p>
254          * After merging, the other instance is merely empty and preserved
255          * only as a child of the current instance. Changes are therefore
256          * still forwarded to it, but it is itself not responsible anymore
257          * for forwarding change.
258          * <p>
259          * @param other instance to merge
260          */
261         private void merge(final DelegatingDriver other) {
262 
263             if (other.forwarder == forwarder) {
264                 // we are attempting to merge an instance with either itself
265                 // or an already embedded one, just ignore the request
266                 return;
267             }
268 
269             // synchronize parameter
270             setReferenceDate(other.getReferenceDate());
271             if (isSelected()) {
272                 other.setSelected(true);
273             } else {
274                 setSelected(other.isSelected());
275             }
276 
277             // move around drivers
278             for (final ParameterDriver otherDriver : other.forwarder.getDrivers()) {
279                 // as drivers are added one at a time and always refer back to a single
280                 // DelegatingDriver (through the ChangesForwarder), they cannot be
281                 // referenced by two different DelegatingDriver. We can blindly move
282                 // around all drivers, there cannot be any duplicates
283                 forwarder.add(otherDriver);
284                 otherDriver.replaceObserver(other.forwarder, forwarder);
285             }
286 
287             // forwarding is now delegated to current instance
288             other.replaceObserver(other.forwarder, forwarder);
289             other.forwarder = forwarder;
290 
291             // replace merged instance with current instance in former owners
292             for (final ParameterDriversList otherOwner : other.owners) {
293                 owners.add(otherOwner);
294                 otherOwner.replaceDelegating(other, this);
295             }
296 
297         }
298 
299         /** Get the raw drivers to which this one delegates.
300          * <p>
301          * These raw drivers all manage the same parameter name.
302          * </p>
303          * @return raw drivers to which this one delegates
304          */
305         public List<ParameterDriver> getRawDrivers() {
306             return Collections.unmodifiableList(forwarder.getDrivers());
307         }
308 
309     }
310 
311     /** Local observer for propagating changes, avoiding infinite recursion. */
312     private static class ChangesForwarder implements ParameterObserver {
313 
314         /** DelegatingDriver we are associated with. */
315         private final DelegatingDriver delegating;
316 
317         /** Drivers synchronized together by the instance. */
318         private final List<ParameterDriver> drivers;
319 
320         /** Root of the current update chain. */
321         private ParameterDriver root;
322 
323         /** Depth of the current update chain. */
324         private int depth;
325 
326         /** Simple constructor.
327          * @param delegating delegatingDriver we are associated with
328          * @param driver first driver in the series
329          */
330         ChangesForwarder(final DelegatingDriver delegating, final ParameterDriver driver) {
331             this.delegating = delegating;
332             this.drivers    = new ArrayList<>();
333             drivers.add(driver);
334         }
335 
336         /** Get the {@link DelegatingDriver} associated with this instance.
337          * @return {@link DelegatingDriver} associated with this instance
338          * @since 9.1
339          */
340         DelegatingDriver getDelegatingDriver() {
341             return delegating;
342         }
343 
344         /** Add a driver to the list synchronized together by the instance.
345          * @param driver driver to add
346          * @since 10.1
347          */
348         void add(final ParameterDriver driver) {
349             drivers.add(driver);
350         }
351 
352         /** Get the drivers synchronized together by the instance.
353          * @return drivers synchronized together by the instance.
354          * @since 10.1
355          */
356         public List<ParameterDriver> getDrivers() {
357             return drivers;
358         }
359 
360         /** {@inheritDoc} */
361         @Override
362         public void valueChanged(final double previousValue, final ParameterDriver driver) {
363             updateAll(driver, d -> d.setValue(driver.getValue()));
364         }
365 
366         /** {@inheritDoc} */
367         @Override
368         public void referenceDateChanged(final AbsoluteDate previousReferenceDate, final ParameterDriver driver) {
369             updateAll(driver, d -> d.setReferenceDate(driver.getReferenceDate()));
370         }
371 
372         /** {@inheritDoc} */
373         @Override
374         public void nameChanged(final String previousName, final ParameterDriver driver) {
375             updateAll(driver, d -> d.setName(driver.getName()));
376         }
377 
378         /** {@inheritDoc} */
379         @Override
380         public void selectionChanged(final boolean previousSelection, final ParameterDriver driver) {
381             updateAll(driver, d -> d.setSelected(driver.isSelected()));
382         }
383 
384         /** {@inheritDoc} */
385         @Override
386         public void referenceValueChanged(final double previousReferenceValue, final ParameterDriver driver) {
387             updateAll(driver, d -> d.setReferenceValue(driver.getReferenceValue()));
388         }
389 
390         /** {@inheritDoc} */
391         @Override
392         public void minValueChanged(final double previousMinValue, final ParameterDriver driver) {
393             updateAll(driver, d -> d.setMinValue(driver.getMinValue()));
394         }
395 
396         /** {@inheritDoc} */
397         @Override
398         public void maxValueChanged(final double previousMaxValue, final ParameterDriver driver) {
399             updateAll(driver, d -> d.setMaxValue(driver.getMaxValue()));
400         }
401 
402         /** {@inheritDoc} */
403         @Override
404         public void scaleChanged(final double previousScale, final ParameterDriver driver) {
405             updateAll(driver, d -> d.setScale(driver.getScale()));
406         }
407 
408         /** Update all bound parameters.
409          * @param driver driver triggering the update
410          * @param updater updater to use
411          */
412         private void updateAll(final ParameterDriver driver, final Updater updater) {
413 
414             final boolean firstCall = depth++ == 0;
415             if (firstCall) {
416                 root = driver;
417             }
418 
419             if (driver == getDelegatingDriver()) {
420                 // propagate change downwards, which will trigger recursive calls
421                 for (final ParameterDriver d : drivers) {
422                     if (d != root) {
423                         updater.update(d);
424                     }
425                 }
426             } else if (firstCall) {
427                 // first call started from an underlying driver, propagate change upwards
428                 updater.update(getDelegatingDriver());
429             }
430 
431             if (--depth == 0) {
432                 // this is the end of the root call
433                 root = null;
434             }
435 
436         }
437 
438     }
439 
440     /** Interface for updating parameters. */
441     @FunctionalInterface
442     private interface Updater {
443         /** Update a driver.
444          * @param driver driver to update
445          */
446         void update(ParameterDriver driver);
447     }
448 
449 }