[Essentials] Geolocation foreground listening

src/Essentials/samples/Samples/View/GeolocationPage.xaml

@@ -27,6 +27,16 @@
                         IsEnabled="{Binding IsNotBusy}"
                         HorizontalOptions="FillAndExpand" />
                 <Button Text="Refresh" Command="{Binding GetCurrentLocationCommand}" IsEnabled="{Binding IsNotBusy}" />
+
+                <Label Text="Foreground listener for Location:" FontAttributes="Bold" Margin="0,6,0,0" />
+                <StackLayout Orientation="Horizontal" Spacing="6">
+                    <Button Text="Start Listening" HorizontalOptions="FillAndExpand"
+                            Command="{Binding StartListeningCommand}" IsEnabled="{Binding IsNotListening}" />
+                    <Button Text="Stop listening" HorizontalOptions="FillAndExpand"
+                            Command="{Binding StopListeningCommand}" IsEnabled="{Binding IsListening}" />
+                </StackLayout>
+                <Label Text="{Binding ListeningLocationStatus}" />
+                <Label Text="{Binding ListeningLocation}" />
             </StackLayout>
         </ScrollView>
     </Grid>

src/Essentials/samples/Samples/ViewModel/GeolocationViewModel.cs

@@ -13,17 +13,25 @@ public class GeolocationViewModel : BaseViewModel
 		string currentLocation;
 		int accuracy = (int)GeolocationAccuracy.Default;
 		CancellationTokenSource cts;
+		string listeningLocation;
+		string listeningLocationStatus;
 
 		public GeolocationViewModel()
 		{
 			GetLastLocationCommand = new Command(OnGetLastLocation);
 			GetCurrentLocationCommand = new Command(OnGetCurrentLocation);
+			StartListeningCommand = new Command(OnStartListening);
+			StopListeningCommand = new Command(OnStopListening);
 		}
 
 		public ICommand GetLastLocationCommand { get; }
 
 		public ICommand GetCurrentLocationCommand { get; }
 
+		public ICommand StartListeningCommand { get; }
+
+		public ICommand StopListeningCommand { get; }
+
 		public string LastLocation
 		{
 			get => lastLocation;
@@ -45,6 +53,22 @@ public int Accuracy
 			set => SetProperty(ref accuracy, value);
 		}
 
+		public bool IsListening => Geolocation.IsListeningForeground;
+
+		public bool IsNotListening => !IsListening;
+
+		public string ListeningLocation
+		{
+			get => listeningLocation;
+			set => SetProperty(ref listeningLocation, value);
+		}
+
+		public string ListeningLocationStatus
+		{
+			get => listeningLocationStatus;
+			set => SetProperty(ref listeningLocationStatus, value);
+		}
+
 		async void OnGetLastLocation()
 		{
 			if (IsBusy)
@@ -88,6 +112,53 @@ async void OnGetCurrentLocation()
 			IsBusy = false;
 		}
 
+		async void OnStartListening()
+		{
+			try
+			{
+				Geolocation.LocationChanged += Geolocation_LocationChanged;
+
+				var request = new GeolocationListeningRequest((GeolocationAccuracy)Accuracy);
+
+				var success = await Geolocation.StartListeningForegroundAsync(request);
+
+				ListeningLocationStatus = success
+					? "Started listening for foreground location updates"
+					: "Couldn't start listening";
+			}
+			catch (Exception ex)
+			{
+				ListeningLocationStatus = FormatLocation(null, ex);
+			}
+
+			OnPropertyChanged(nameof(IsListening));
+			OnPropertyChanged(nameof(IsNotListening));
+		}
+
+		void Geolocation_LocationChanged(object sender, LocationEventArgs e)
+		{
+			ListeningLocation = FormatLocation(e.Location);
+		}
+
+		void OnStopListening()
+		{
+			try
+			{
+				Geolocation.LocationChanged -= Geolocation_LocationChanged;
+
+				Geolocation.StopListeningForeground();
+
+				ListeningLocationStatus = "Stopped listening for foreground location updates";
+			}
+			catch (Exception ex)
+			{
+				ListeningLocationStatus = FormatLocation(null, ex);
+			}
+
+			OnPropertyChanged(nameof(IsListening));
+			OnPropertyChanged(nameof(IsNotListening));
+		}
+
 		string FormatLocation(Location location, Exception ex = null)
 		{
 			if (location == null)
@@ -116,6 +187,9 @@ public override void OnDisappearing()
 				if (cts != null && !cts.IsCancellationRequested)
 					cts.Cancel();
 			}
+
+			OnStopListening();
+
 			base.OnDisappearing();
 		}
 	}

src/Essentials/src/Geolocation/Geolocation.android.cs

@@ -18,11 +18,16 @@ partial class GeolocationImplementation : IGeolocation
 		const long twoMinutes = 120000;
 		static readonly string[] ignoredProviders = new string[] { LocationManager.PassiveProvider, "local_database" };
 
+		static ContinuousLocationListener continuousListener;
+		static List<string> listeningProviders;
+
 		static LocationManager locationManager;
 
 		static LocationManager LocationManager =>
 			locationManager ??= Application.Context.GetSystemService(Context.LocationService) as LocationManager;
 
+		public bool IsListeningForeground { get => continuousListener != null; }
+
 		public async Task<Location> GetLastKnownLocationAsync()
 		{
 			await Permissions.EnsureGrantedOrRestrictedAsync<Permissions.LocationWhenInUse>();
@@ -112,6 +117,84 @@ void RemoveUpdates()
 			}
 		}
 
+		public async Task<bool> StartListeningForegroundAsync(GeolocationListeningRequest request)
+		{
+			_ = request ?? throw new ArgumentNullException(nameof(request));
+
+			if (IsListeningForeground)
+				throw new InvalidOperationException("Already listening to location changes.");
+
+			await Permissions.EnsureGrantedOrRestrictedAsync<Permissions.LocationWhenInUse>();
+
+			var enabledProviders = LocationManager.GetProviders(true);
+			var hasProviders = enabledProviders.Any(p => !ignoredProviders.Contains(p));
+
+			if (!hasProviders)
+				throw new FeatureNotEnabledException("Location services are not enabled on device.");
+
+			// get the best possible provider for the requested accuracy
+			var providerInfo = GetBestProvider(LocationManager, request.DesiredAccuracy);
+
+			// if no providers exist, we can't listen for locations
+			if (string.IsNullOrEmpty(providerInfo.Provider))
+				return false;
+
+			var allProviders = LocationManager.GetProviders(false);
+
+			listeningProviders = new List<string>();
+			if (allProviders.Contains(Android.Locations.LocationManager.GpsProvider))
+				listeningProviders.Add(Android.Locations.LocationManager.GpsProvider);
+			if (allProviders.Contains(Android.Locations.LocationManager.NetworkProvider))
+				listeningProviders.Add(Android.Locations.LocationManager.NetworkProvider);
+
+			if (listeningProviders.Count == 0)
+				listeningProviders.Add(providerInfo.Provider);
+
+			var continuousListener = new ContinuousLocationListener(LocationManager, providerInfo.Accuracy, listeningProviders);
+			continuousListener.LocationHandler = HandleLocation;
+			continuousListener.ErrorHandler = HandleError;
+
+			// start getting location updates
+			// make sure to use a thread with a looper
+			var looper = Looper.MyLooper() ?? Looper.MainLooper;
+
+			var minTimeMilliseconds = (long)request.MinimumTime.TotalMilliseconds;
+
+			foreach (var provider in listeningProviders)
+				LocationManager.RequestLocationUpdates(provider, minTimeMilliseconds, providerInfo.Accuracy, continuousListener, looper);
+
+			return true;
+
+			void HandleLocation(AndroidLocation location)
+			{
+				OnLocationChanged(location.ToLocation());
+			}
+
+			void HandleError(GeolocationError geolocationError)
+			{
+				OnLocationError(geolocationError);
+			}
+		}
+
+		public void StopListeningForeground()
+		{
+			if (continuousListener == null)
+				return;
+
+			continuousListener.LocationHandler = null;
+			continuousListener.ErrorHandler = null;
+
+			if (listeningProviders == null)
+				return;
+
+			for (var i = 0; i < listeningProviders.Count; i++)
+			{
+				LocationManager.RemoveUpdates(continuousListener);
+			}
+
+			continuousListener = null;
+		}
+
 		static (string Provider, float Accuracy) GetBestProvider(LocationManager locationManager, GeolocationAccuracy accuracy)
 		{
 			// Criteria: https://developer.android.com/reference/android/location/Criteria
@@ -276,4 +359,68 @@ void ILocationListener.OnStatusChanged(string provider, Availability status, Bun
 			}
 		}
 	}
+
+	class ContinuousLocationListener : Java.Lang.Object, ILocationListener
+	{
+		readonly LocationManager manager;
+
+		float desiredAccuracy;
+
+		HashSet<string> activeProviders = new HashSet<string>();
+
+		internal Action<AndroidLocation> LocationHandler { get; set; }
+
+		internal Action<GeolocationError> ErrorHandler { get; set; }
+
+		internal ContinuousLocationListener(LocationManager manager, float desiredAccuracy, IEnumerable<string> providers)
+		{
+			this.manager = manager;
+			this.desiredAccuracy = desiredAccuracy;
+
+			foreach (var provider in providers)
+			{
+				if (manager.IsProviderEnabled(provider))
+					activeProviders.Add(provider);
+			}
+		}
+
+		void ILocationListener.OnLocationChanged(AndroidLocation location)
+		{
+			if (location.Accuracy <= desiredAccuracy)
+			{
+				LocationHandler?.Invoke(location);
+				return;
+			}
+		}
+
+		void ILocationListener.OnProviderDisabled(string provider)
+		{
+			lock (activeProviders)
+			{
+				if (activeProviders.Remove(provider) &&
+					activeProviders.Count == 0)
+					ErrorHandler?.Invoke(GeolocationError.PositionUnavailable);
+			}
+		}
+
+		void ILocationListener.OnProviderEnabled(string provider)
+		{
+			lock (activeProviders)
+				activeProviders.Add(provider);
+		}
+
+		void ILocationListener.OnStatusChanged(string provider, Availability status, Bundle extras)
+		{
+			switch (status)
+			{
+				case Availability.Available:
+					((ILocationListener)this).OnProviderEnabled(provider);
+					break;
+
+				case Availability.OutOfService:
+					((ILocationListener)this).OnProviderDisabled(provider);
+					break;
+			}
+		}
+	}
 }