Fix ReplayRouteSession route state

Author: kmadsen

CHANGELOG.md

@@ -29,6 +29,7 @@ This release depends on, and has been tested with, the following Mapbox dependen
 - Mapbox Java `v6.9.0` ([release notes](https://github.com/mapbox/mapbox-java/releases/tag/v6.9.0))
 - Mapbox Android Core `v5.0.2` ([release notes](https://github.com/mapbox/mapbox-events-android/releases/tag/core-5.0.2))
 
+- Fixed issues in `ReplayRouteSession`. The routes observer was never unregistered. Alternative route selection resets replay to the beginning. DropInUi changing portrait and landscape modes resets replay to the beginning. [#6675](https://github.com/mapbox/mapbox-navigation-android/pull/6675)
 
 ## Mapbox Navigation SDK 2.10.0-beta.2 - 01 December, 2022
 ### Changelog

libnavigation-core/src/main/java/com/mapbox/navigation/core/replay/route/ReplayPolylineDecodeStream.kt

@@ -94,4 +94,15 @@ class ReplayPolylineDecodeStream(
         }
         return points
     }
+
+    /**
+     * Skip the next [count] points of the geometry. Less points are skipped if there are less than
+     * [count] points left in the iterator.
+     *
+     * @param count the number of points to skip.
+     */
+    fun skip(count: Int) {
+        var skipped = 0
+        while (skipped++ <= count && hasNext()) { next() }
+    }
 }

libnavigation-core/src/main/java/com/mapbox/navigation/core/replay/route/ReplayRouteSession.kt

@@ -9,6 +9,7 @@ import com.mapbox.android.core.permissions.PermissionsManager
 import com.mapbox.api.directions.v5.DirectionsCriteria
 import com.mapbox.navigation.base.ExperimentalPreviewMapboxNavigationAPI
 import com.mapbox.navigation.base.route.NavigationRoute
+import com.mapbox.navigation.base.trip.model.RouteProgress
 import com.mapbox.navigation.core.MapboxNavigation
 import com.mapbox.navigation.core.directions.session.RoutesObserver
 import com.mapbox.navigation.core.lifecycle.MapboxNavigationApp
@@ -17,6 +18,7 @@ import com.mapbox.navigation.core.replay.MapboxReplayer
 import com.mapbox.navigation.core.replay.history.ReplayEventBase
 import com.mapbox.navigation.core.replay.history.ReplayEventUpdateLocation
 import com.mapbox.navigation.core.replay.history.ReplayEventsObserver
+import com.mapbox.navigation.core.trip.session.RouteProgressObserver
 import com.mapbox.navigation.utils.internal.logW
 import java.util.Collections
 
@@ -58,11 +60,23 @@ class ReplayRouteSession : MapboxNavigationObserver {
     private lateinit var replayRouteMapper: ReplayRouteMapper
     private var mapboxNavigation: MapboxNavigation? = null
     private var lastLocationEvent: ReplayEventUpdateLocation? = null
-    private var routesObserver: RoutesObserver? = null
-    private var currentRouteId: String? = null
+    private var currentRoute: NavigationRoute? = null
+
+    private val routeProgressObserver = RouteProgressObserver { routeProgress ->
+        if (currentRoute?.id != routeProgress.navigationRoute.id) {
+            currentRoute = routeProgress.navigationRoute
+            onRouteChanged(routeProgress)
+        }
+    }
+
+    private val routesObserver = RoutesObserver { result ->
+        if (result.navigationRoutes.isEmpty()) {
+            mapboxNavigation?.resetReplayLocation()
+        }
+    }
 
     private val replayEventsObserver = ReplayEventsObserver { events ->
-        if (isLastEventPlayed(events)) {
+        if (currentRoute != null && isLastEventPlayed(events)) {
             pushMorePoints()
         }
     }
@@ -92,17 +106,10 @@ class ReplayRouteSession : MapboxNavigationObserver {
         this.mapboxNavigation = mapboxNavigation
         mapboxNavigation.stopTripSession()
         mapboxNavigation.startReplayTripSession()
-
-        routesObserver = RoutesObserver { result ->
-            if (result.navigationRoutes.isEmpty()) {
-                currentRouteId = null
-                mapboxNavigation.resetReplayLocation()
-            } else if (result.navigationRoutes.first().id != currentRouteId) {
-                onRouteChanged(result.navigationRoutes.first())
-            }
-        }.also { mapboxNavigation.registerRoutesObserver(it) }
+        mapboxNavigation.registerRouteProgressObserver(routeProgressObserver)
+        mapboxNavigation.registerRoutesObserver(routesObserver)
         mapboxNavigation.mapboxReplayer.registerObserver(replayEventsObserver)
-        mapboxNavigation.resetReplayLocation()
+        mapboxNavigation.mapboxReplayer.play()
     }
 
     private fun MapboxNavigation.resetReplayLocation() {
@@ -123,14 +130,18 @@ class ReplayRouteSession : MapboxNavigationObserver {
     }
 
     override fun onDetached(mapboxNavigation: MapboxNavigation) {
-        this.mapboxNavigation = null
+        mapboxNavigation.unregisterRoutesObserver(routesObserver)
+        mapboxNavigation.unregisterRouteProgressObserver(routeProgressObserver)
         mapboxNavigation.mapboxReplayer.unregisterObserver(replayEventsObserver)
         mapboxNavigation.mapboxReplayer.stop()
         mapboxNavigation.mapboxReplayer.clearEvents()
         mapboxNavigation.stopTripSession()
+        this.mapboxNavigation = null
+        this.currentRoute = null
     }
 
-    private fun onRouteChanged(navigationRoute: NavigationRoute) {
+    private fun onRouteChanged(routeProgress: RouteProgress) {
+        val navigationRoute = routeProgress.navigationRoute
         val mapboxReplayer = mapboxNavigation?.mapboxReplayer ?: return
         mapboxReplayer.clearEvents()
         mapboxReplayer.play()
@@ -144,9 +155,12 @@ class ReplayRouteSession : MapboxNavigationObserver {
             }
             return
         }
-        currentRouteId = navigationRoute.id
         polylineDecodeStream = ReplayPolylineDecodeStream(geometry, 6)
-        mapboxNavigation?.resetTripSession()
+
+        // Skip up to the current geometry index. There is some imprecision here because the
+        // distance traveled is not equal to a route index.
+        polylineDecodeStream.skip(routeProgress.currentRouteGeometryIndex)
+
         pushMorePoints()
     }