GPS: event-based using Raw.

Part of #1424.

src/androidTest/java/de/dennisguse/opentracks/io/file/importer/ExportImportTest.java

@@ -65,6 +65,7 @@
 import de.dennisguse.opentracks.sensors.sensorData.AggregatorCyclingDistanceSpeed;
 import de.dennisguse.opentracks.sensors.sensorData.AggregatorCyclingPower;
 import de.dennisguse.opentracks.sensors.sensorData.AggregatorHeartRate;
+import de.dennisguse.opentracks.sensors.sensorData.Raw;
 import de.dennisguse.opentracks.sensors.sensorData.SensorDataSet;
 import de.dennisguse.opentracks.services.TrackRecordingService;
 import de.dennisguse.opentracks.services.handlers.TrackPointCreator;
@@ -604,6 +605,6 @@ private void sendLocation(TrackPointCreator trackPointCreator, String time, doub
         mockAltitudeChange(trackPointCreator, altitudeGain);
 
         trackPointCreator.setClock(time);
-        trackPointCreator.onChange(location);
+        trackPointCreator.getSensorManager().onChanged(new Raw<>(location));
     }
 }

src/main/java/de/dennisguse/opentracks/sensors/SensorManager.java

@@ -30,7 +30,7 @@ public class SensorManager implements SharedPreferences.OnSharedPreferenceChange
         @Override
         public void onConnect(Aggregator<?, ?> aggregator) {
             sensorDataSet.add(aggregator);
-            observer.onChange(new SensorDataSet(sensorDataSet));
+//            observer.onChange(new SensorDataSet(sensorDataSet));
         }
 
         @Override
@@ -42,13 +42,13 @@ public void onChange(Raw<?> data) {
         @Override
         public void onDisconnect(Aggregator<?, ?> aggregator) {
             sensorDataSet.add(aggregator);
-            observer.onChange(new SensorDataSet(sensorDataSet));
+//            observer.onChange(new SensorDataSet(sensorDataSet));
         }
 
         @Override
         public void onRemove(Aggregator<?, ?> aggregator) {
             sensorDataSet.remove(aggregator);
-            observer.onChange(new SensorDataSet(sensorDataSet));
+//            observer.onChange(new SensorDataSet(sensorDataSet));
         }
     };
 
@@ -67,7 +67,7 @@ public void start(Context context, Handler handler) {
             throw new RuntimeException("SensorManager cannot be started twice; stop first.");
         }
 
-        gpsManager = new GPSManager(observer); //TODO Pass listener
+        gpsManager = new GPSManager(observer, listener);
         altitudeSumManager = new GainManager(listener);
         bluetoothSensorManager = new BluetoothRemoteSensorManager(context, handler, listener);
 
@@ -104,7 +104,6 @@ public void reset() {
         sensorDataSet.reset();
     }
 
-    @Deprecated
     @VisibleForTesting
     public void onChanged(Raw<?> data) {
         listener.onChange(data);

src/main/java/de/dennisguse/opentracks/sensors/sensorData/Aggregator.java

@@ -6,7 +6,7 @@
 
 import de.dennisguse.opentracks.sensors.BluetoothRemoteSensorManager;
 
-public abstract class Aggregator<Input extends Record, Output> {
+public abstract class Aggregator<Input, Output> {
 
     protected Raw<Input> previous;
 

src/main/java/de/dennisguse/opentracks/sensors/sensorData/AggregatorGPS.java

@@ -0,0 +1,28 @@
+package de.dennisguse.opentracks.sensors.sensorData;
+
+import android.location.Location;
+
+import androidx.annotation.NonNull;
+
+public class AggregatorGPS extends Aggregator<Location, Location> {
+
+    public AggregatorGPS(String sensorAddress) {
+        super(sensorAddress);
+    }
+
+    @Override
+    protected void computeValue(Raw<Location> current) {
+        value = current.value();
+    }
+
+    @Override
+    public void reset() {
+        value = null;
+    }
+
+    @NonNull
+    @Override
+    protected Location getNoneValue() {
+        return new Location("none");
+    }
+}

src/main/java/de/dennisguse/opentracks/sensors/sensorData/Raw.java

@@ -5,7 +5,7 @@
 
 import java.time.Instant;
 
-public record Raw<T extends Record>(
+public record Raw<T>(
         @NonNull T value,
 
         @NonNull Instant time

src/main/java/de/dennisguse/opentracks/sensors/sensorData/SensorDataSet.java

@@ -1,6 +1,7 @@
 package de.dennisguse.opentracks.sensors.sensorData;
 
 import android.util.Log;
+import android.location.Location;
 import android.util.Pair;
 
 import androidx.annotation.NonNull;
@@ -40,16 +41,20 @@ public final class SensorDataSet {
     @VisibleForTesting
     public AggregatorBarometer barometer;
 
+    public AggregatorGPS gps;
+
     public SensorDataSet() {
     }
 
     public SensorDataSet(SensorDataSet toCopy) {
+        //TODO This is not a copy constructor anymore, but it should be - aggregators are no value objects
         this.heartRate = toCopy.heartRate;
         this.cyclingCadence = toCopy.cyclingCadence;
         this.cyclingDistanceSpeed = toCopy.cyclingDistanceSpeed;
         this.cyclingPower = toCopy.cyclingPower;
         this.runningDistanceSpeedCadence = toCopy.runningDistanceSpeedCadence;
         this.barometer = toCopy.barometer;
+        this.gps = toCopy.gps;
     }
 
     public Pair<HeartRate, String> getHeartRate() {
@@ -93,7 +98,7 @@ public void add(@NonNull Aggregator<?, ?> data) {
     }
 
     public void update(@NonNull Raw<?> data) {
-        Record value = data.value();
+        Object value = data.value();
 
         if (value instanceof HeartRate) {
             this.heartRate.add((Raw<HeartRate>) data);
@@ -122,6 +127,10 @@ public void update(@NonNull Raw<?> data) {
             this.barometer.add((Raw<AtmosphericPressure>) data);
             return;
         }
+        if (value instanceof Location) {
+            this.gps.add((Raw<Location>) data);
+            return;
+        }
 
         throw new UnsupportedOperationException(data.getClass().getCanonicalName() + " " + data.value().getClass().getCanonicalName());
     }
@@ -138,6 +147,7 @@ public void clear() {
         this.cyclingPower = null;
         this.runningDistanceSpeedCadence = null;
         this.barometer = null;
+        this.gps = null;
     }
 
     public void fillTrackPoint(TrackPoint trackPoint) {
@@ -169,6 +179,10 @@ public void fillTrackPoint(TrackPoint trackPoint) {
             trackPoint.setAltitudeGain(barometer.getValue().gain_m());
             trackPoint.setAltitudeLoss(barometer.getValue().loss_m());
         }
+
+        if (gps != null && gps.hasValue()) {
+            trackPoint.setLocation(gps.getValue());
+        }
     }
 
     public void reset() {
@@ -180,6 +194,7 @@ public void reset() {
         if (cyclingPower != null) cyclingPower.reset();
         if (runningDistanceSpeedCadence != null) runningDistanceSpeedCadence.reset();
         if (barometer != null) barometer.reset();
+        if (gps != null) gps.reset();
     }
 
     private void set(@NonNull Aggregator<?, ?> type, @Nullable Aggregator<?, ?> sensorData) {
@@ -209,6 +224,10 @@ private void set(@NonNull Aggregator<?, ?> type, @Nullable Aggregator<?, ?> sens
             barometer = (AggregatorBarometer) sensorData;
             return;
         }
+        if (type instanceof AggregatorGPS) {
+            gps = (AggregatorGPS) sensorData;
+            return;
+        }
 
         throw new UnsupportedOperationException(type.getClass().getCanonicalName());
     }

src/main/java/de/dennisguse/opentracks/services/handlers/GPSManager.java

@@ -20,6 +20,9 @@
 import de.dennisguse.opentracks.data.models.Distance;
 import de.dennisguse.opentracks.data.models.TrackPoint;
 import de.dennisguse.opentracks.sensors.SensorConnector;
+import de.dennisguse.opentracks.sensors.SensorManager;
+import de.dennisguse.opentracks.sensors.sensorData.AggregatorGPS;
+import de.dennisguse.opentracks.sensors.sensorData.Raw;
 import de.dennisguse.opentracks.settings.PreferencesUtils;
 import de.dennisguse.opentracks.util.LocationUtils;
 import de.dennisguse.opentracks.util.PermissionRequester;
@@ -32,6 +35,8 @@ public class GPSManager implements SensorConnector, LocationListenerCompat, GpsS
     private static final String LOCATION_PROVIDER = LocationManager.GPS_PROVIDER;
 
     private TrackPointCreator trackPointCreator;
+
+    private SensorManager.SensorDataChangedObserver listener;
     private Context context;
     private Handler handler;
 
@@ -40,8 +45,9 @@ public class GPSManager implements SensorConnector, LocationListenerCompat, GpsS
     private Duration gpsInterval;
     private Distance thresholdHorizontalAccuracy;
 
-    public GPSManager(TrackPointCreator trackPointCreator) {
+    public GPSManager(TrackPointCreator trackPointCreator, SensorManager.SensorDataChangedObserver listener) {
         this.trackPointCreator = trackPointCreator;
+        this.listener = listener;
     }
 
     public void start(@NonNull Context context, @NonNull Handler handler) {
@@ -52,6 +58,9 @@ public void start(@NonNull Context context, @NonNull Handler handler) {
 
         gpsStatusManager = new GpsStatusManager(context, this, handler);
         locationManager = (LocationManager) context.getSystemService(Context.LOCATION_SERVICE);
+
+        listener.onConnect(new AggregatorGPS("internal"));
+
         registerLocationListener();
         gpsStatusManager.start();
     }
@@ -72,6 +81,9 @@ public void stop(Context context) {
         gpsStatusManager.stop();
         gpsStatusManager = null;
 
+        listener.onDisconnect(new AggregatorGPS("internal"));
+        listener = null;
+
         trackPointCreator = null;
     }
 
@@ -126,7 +138,7 @@ public void onLocationChanged(@NonNull Location location) {
             return;
         }
 
-        trackPointCreator.onChange(location);
+        listener.onChange(new Raw<>(location));
     }
 
     @Override

src/main/java/de/dennisguse/opentracks/services/handlers/TrackPointCreator.java

@@ -2,7 +2,6 @@
 
 import android.content.Context;
 import android.content.SharedPreferences;
-import android.location.Location;
 import android.os.Handler;
 import android.util.Log;
 import android.util.Pair;
@@ -69,10 +68,6 @@ public void stop() {
         this.context = null;
     }
 
-    public synchronized void onChange(@NonNull Location location) {
-        onNewTrackPoint(new TrackPoint(location, createNow()));
-    }
-
     /**
      * Got a new TrackPoint from Bluetooth only; contains no GPS location.
      */