1 files changed, 33 insertions, 23 deletions

diff --git a/main/src/cgeo/geocaching/network/StatusUpdater.java b/main/src/cgeo/geocaching/network/StatusUpdater.java
index cb4c7f4..4055f01 100644
--- a/main/src/cgeo/geocaching/network/StatusUpdater.java
+++ b/main/src/cgeo/geocaching/network/StatusUpdater.java
@@ -1,21 +1,22 @@
 package cgeo.geocaching.network;
 
 import cgeo.geocaching.CgeoApplication;
-import cgeo.geocaching.utils.MemorySubject;
-import cgeo.geocaching.utils.PeriodicHandler;
-import cgeo.geocaching.utils.PeriodicHandler.PeriodicHandlerListener;
 import cgeo.geocaching.utils.Version;
 
 import org.json.JSONException;
 import org.json.JSONObject;
+import rx.Scheduler;
+import rx.schedulers.Schedulers;
+import rx.subjects.BehaviorSubject;
+import rx.functions.Action1;
 
 import android.os.Build.VERSION;
 import android.os.Build.VERSION_CODES;
-import android.os.Looper;
 
 import java.util.Locale;
+import java.util.concurrent.TimeUnit;
 
-public class StatusUpdater extends MemorySubject<StatusUpdater.Status> implements Runnable, PeriodicHandlerListener {
+public class StatusUpdater {
 
     static public class Status {
         final public String message;
@@ -30,24 +31,40 @@ public class StatusUpdater extends MemorySubject<StatusUpdater.Status> implement
             this.url = url;
         }
 
+        Status(final JSONObject response) {
+            message = get(response, "message");
+            messageId = get(response, "message_id");
+            icon = get(response, "icon");
+            url = get(response, "url");
+        }
+
         final static public Status closeoutStatus =
                 new Status("", "status_closeout_warning", "attribute_abandonedbuilding", "http://faq.cgeo.org/#7_69");
 
-        final static public Status defaultStatus() {
+        final static public Status defaultStatus(final Status upToDate) {
+            if (upToDate != null && upToDate.message != null) {
+                return upToDate;
+            }
             return VERSION.SDK_INT < VERSION_CODES.ECLAIR_MR1 ? closeoutStatus : null;
         }
     }
 
-    @Override
-    public void onPeriodic() {
-        final JSONObject response =
-                Network.requestJSON("http://status.cgeo.org/api/status.json",
-                        new Parameters("version_code", String.valueOf(Version.getVersionCode(CgeoApplication.getInstance())),
-                                "version_name", Version.getVersionName(CgeoApplication.getInstance()),
-                                "locale", Locale.getDefault().toString()));
-        if (response != null) {
-            notifyObservers(new Status(get(response, "message"), get(response, "message_id"), get(response, "icon"), get(response, "url")));
-        }
+    final static public BehaviorSubject<Status> latestStatus = BehaviorSubject.create(Status.defaultStatus(null));
+
+    static {
+        Schedulers.io().schedulePeriodically(new Action1<Scheduler.Inner>() {
+            @Override
+            public void call(final Scheduler.Inner inner) {
+                final JSONObject response =
+                        Network.requestJSON("http://status.cgeo.org/api/status.json",
+                                new Parameters("version_code", String.valueOf(Version.getVersionCode(CgeoApplication.getInstance())),
+                                        "version_name", Version.getVersionName(CgeoApplication.getInstance()),
+                                        "locale", Locale.getDefault().toString()));
+                if (response != null) {
+                    latestStatus.onNext(Status.defaultStatus(new Status(response)));
+                }
+            }
+        }, 0, 1800, TimeUnit.SECONDS);
     }
 
     private static String get(final JSONObject json, final String key) {
@@ -58,11 +75,4 @@ public class StatusUpdater extends MemorySubject<StatusUpdater.Status> implement
         }
     }
 
-    @Override
-    public void run() {
-        Looper.prepare();
-        new PeriodicHandler(1800000L, this).start();
-        Looper.loop();
-    }
-
 }