1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
|
package cgeo.geocaching.network;
import cgeo.geocaching.CgeoApplication;
import cgeo.geocaching.utils.RxUtils;
import cgeo.geocaching.utils.Version;
import com.fasterxml.jackson.databind.node.ObjectNode;
import rx.functions.Action0;
import rx.subjects.BehaviorSubject;
import android.os.Build.VERSION;
import android.os.Build.VERSION_CODES;
import java.util.Locale;
import java.util.concurrent.TimeUnit;
public class StatusUpdater {
static public class Status {
final public String message;
final public String messageId;
final public String icon;
final public String url;
Status(final String message, final String messageId, final String icon, final String url) {
this.message = message;
this.messageId = messageId;
this.icon = icon;
this.url = url;
}
Status(final ObjectNode response) {
message = response.path("message").asText(null);
messageId = response.path("message_id").asText(null);
icon = response.path("icon").asText(null);
url = response.path("url").asText(null);
}
final static public Status closeoutStatus =
new Status("", "status_closeout_warning", "attribute_abandonedbuilding", "http://faq.cgeo.org/#7_69");
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;
}
}
final static public BehaviorSubject<Status> latestStatus = BehaviorSubject.create(Status.defaultStatus(null));
static {
RxUtils.networkScheduler.createWorker().schedulePeriodically(new Action0() {
@Override
public void call() {
final ObjectNode 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);
}
}
|
