[23125] Support real time vehicle location indicator

TripKitAndroidUI/src/main/java/com/skedgo/tripkit/ui/map/servicestop/ServiceStopMapViewModel.kt

@@ -1,8 +1,10 @@
 package com.skedgo.tripkit.ui.map.servicestop
 
+import android.annotation.SuppressLint
 import android.content.Context
 import com.google.android.gms.maps.model.MarkerOptions
 import com.jakewharton.rxrelay2.BehaviorRelay
+import com.jakewharton.rxrelay2.PublishRelay
 import com.skedgo.tripkit.common.model.realtimealert.RealTimeStatus
 import com.skedgo.tripkit.common.model.region.Region
 import com.skedgo.tripkit.common.model.stop.ScheduledStop
@@ -24,8 +26,10 @@ import io.reactivex.android.schedulers.AndroidSchedulers
 import io.reactivex.functions.BiFunction
 import io.reactivex.rxkotlin.Observables
 import io.reactivex.schedulers.Schedulers
+import timber.log.Timber
 import javax.inject.Inject
 
+@SuppressLint("CheckResult")
 class ServiceStopMapViewModel @Inject constructor(
     val context: Context,
     val fetchAndLoadServices: FetchAndLoadServices,
@@ -34,9 +38,10 @@ class ServiceStopMapViewModel @Inject constructor(
 ) : RxViewModel() {
 
     val service = BehaviorRelay.create<TimetableEntry>()
-
     val stop = BehaviorRelay.create<ScheduledStop>()
 
+    private val stopRealtimeRelay = PublishRelay.create<Unit>() // To stop real-time updates
+
     private val serviceStop = Observable
         .combineLatest(
             stop.hide(),
@@ -49,6 +54,43 @@ class ServiceStopMapViewModel @Inject constructor(
     lateinit var realtimeViewModel: RealTimeChoreographerViewModel
     lateinit var serviceStopMarkerCreator: ServiceStopMarkerCreator
 
+    init {
+        Observables.combineLatest(
+            service,
+            serviceStop.hide().flatMap { regionService.getRegionByLocationAsync(it) }
+        ) { service, region -> service to region }
+            .distinctUntilChanged()
+            .observeOn(Schedulers.io())
+            .switchMap { (service, region) ->
+                if (service.realTimeStatus in listOf(
+                        RealTimeStatus.IS_REAL_TIME,
+                        RealTimeStatus.CAPABLE
+                    )
+                ) {
+                    realtimeViewModel.getRealTimeVehicles(region, listOf(service))
+                        .takeUntil(stopRealtimeRelay) // Stop when stopRealtimeRelay emits
+                        .doOnNext { vehicles ->
+                            Timber.d("Fetched real-time vehicles: $vehicles")
+                        }
+                        .onErrorResumeNext { throwable: Throwable ->
+                            Timber.e(throwable, "Error fetching real-time vehicles")
+                            Observable.empty() // Emit nothing in case of an error
+                        }
+                } else {
+                    Timber.d("Service not real-time capable")
+                    Observable.just(service to region)
+                }
+            }
+            .replay(1)
+            .refCount()
+            .subscribe()
+            .autoClear()
+    }
+
+    fun stopRealtimeUpdates() {
+        stopRealtimeRelay.accept(Unit)
+    }
+
     private val serviceStopsAndLines =
         Observable.combineLatest(
             service,
@@ -138,4 +180,5 @@ class ServiceStopMapViewModel @Inject constructor(
         }
         return stop
     }
+
 }

TripKitAndroidUI/src/main/java/com/skedgo/tripkit/ui/servicedetail/ServiceDetailFragment.kt

@@ -105,6 +105,19 @@ class ServiceDetailFragment : BaseTripKitFragment() {
             mapContributor.setStop(stop)
             mapContributor.setService(timetableEntry)
         }
+
+        (mapContributor as? TimetableMapContributor)?.let { contributor ->
+            contributor.formattedElapsedTime.observe(viewLifecycleOwner) { formattedTime ->
+                // Handle the formatted time in the fragment
+                handleFormattedElapsedTime(formattedTime)
+            }
+        }
+    }
+
+    private fun handleFormattedElapsedTime(formattedTime: String) {
+        viewModel.apply {
+            lastUpdatedText.set(formattedTime)
+        }
     }
 
     class Builder {

TripKitAndroidUI/src/main/java/com/skedgo/tripkit/ui/servicedetail/ServiceDetailViewModel.kt

@@ -66,6 +66,8 @@ class ServiceDetailViewModel @Inject constructor(
 
     val showOccupancyInfo = ObservableBoolean(false)
 
+    val lastUpdatedText = ObservableField<String>()
+
     val itemBinding = ItemBinding.of<ServiceDetailItemViewModel>(
         BR.viewModel,
         R.layout.service_detail_fragment_list_item