1 files changed, 67 insertions, 0 deletions
diff --git a/main/src/cgeo/geocaching/sensors/OrientationProvider.java b/main/src/cgeo/geocaching/sensors/OrientationProvider.java
new file mode 100644
index 0000000..83e0638
--- /dev/null
+++ b/main/src/cgeo/geocaching/sensors/OrientationProvider.java
@@ -0,0 +1,67 @@
+package cgeo.geocaching.sensors;
+
+import cgeo.geocaching.utils.Log;
+import cgeo.geocaching.utils.RxUtils.LooperCallbacks;
+
+import rx.Observable;
+
+import android.content.Context;
+import android.hardware.Sensor;
+import android.hardware.SensorEvent;
+import android.hardware.SensorEventListener;
+import android.hardware.SensorManager;
+
+public class OrientationProvider extends LooperCallbacks<Float> implements SensorEventListener {
+
+    private final SensorManager sensorManager;
+    private final Sensor orientationSensor;
+
+    @SuppressWarnings("deprecation")
+    protected OrientationProvider(final Context context) {
+        sensorManager = (SensorManager) context.getSystemService(Context.SENSOR_SERVICE);
+        orientationSensor = sensorManager.getDefaultSensor(Sensor.TYPE_ORIENTATION);
+        if (orientationSensor != null) {
+            Log.d("OrientationProvider: sensor found");
+        } else {
+            Log.w("OrientationProvider: no orientation sensor on this device");
+        }
+    }
+
+    @Override
+    public void onSensorChanged(final SensorEvent event) {
+            subscriber.onNext(event.values[0]);
+    }
+
+    @Override
+    public void onAccuracyChanged(final Sensor sensor, final int accuracy) {
+        /*
+         * There is a bug in Android, which apparently causes this method to be called every
+         * time the sensor _value_ changed, even if the _accuracy_ did not change. Do not have any code in here.
+         *
+         * See for example https://code.google.com/p/android/issues/detail?id=14792
+         */
+    }
+
+    @Override
+    public void onStart() {
+        if (orientationSensor != null) {
+            Log.d("OrientationProvider: starting the orientation provider");
+            sensorManager.registerListener(this, orientationSensor, SensorManager.SENSOR_DELAY_NORMAL);
+        } else {
+            subscriber.onError(new RuntimeException("orientation sensor is absent on this device"));
+        }
+    }
+
+    @Override
+    public void onStop() {
+        if (orientationSensor != null) {
+            Log.d("OrientationProvider: stopping the orientation provider");
+            sensorManager.unregisterListener(this);
+        }
+    }
+
+    public static Observable<Float> create(final Context context) {
+        return Observable.create(new OrientationProvider(context));
+    }
+
+}