588 lines
27 KiB
Java
588 lines
27 KiB
Java
package info.nightscout.androidaps.Services;
|
|
|
|
import android.app.IntentService;
|
|
import android.content.Intent;
|
|
import android.content.pm.PackageManager;
|
|
import android.os.Bundle;
|
|
import android.provider.Telephony;
|
|
|
|
import org.json.JSONArray;
|
|
import org.json.JSONException;
|
|
import org.json.JSONObject;
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
import info.nightscout.androidaps.Config;
|
|
import info.nightscout.androidaps.MainApp;
|
|
import info.nightscout.androidaps.R;
|
|
import info.nightscout.androidaps.data.ProfileStore;
|
|
import info.nightscout.androidaps.db.BgReading;
|
|
import info.nightscout.androidaps.db.CareportalEvent;
|
|
import info.nightscout.androidaps.events.EventNsFood;
|
|
import info.nightscout.androidaps.plugins.ConfigBuilder.ConfigBuilderPlugin;
|
|
import info.nightscout.androidaps.plugins.ConstraintsObjectives.ObjectivesPlugin;
|
|
import info.nightscout.androidaps.plugins.NSClientInternal.data.NSDeviceStatus;
|
|
import info.nightscout.androidaps.plugins.NSClientInternal.data.NSMbg;
|
|
import info.nightscout.androidaps.plugins.NSClientInternal.data.NSSettingsStatus;
|
|
import info.nightscout.androidaps.plugins.NSClientInternal.data.NSSgv;
|
|
import info.nightscout.androidaps.plugins.Overview.OverviewPlugin;
|
|
import info.nightscout.androidaps.plugins.Overview.events.EventDismissNotification;
|
|
import info.nightscout.androidaps.plugins.Overview.events.EventNewNotification;
|
|
import info.nightscout.androidaps.plugins.Overview.notifications.Notification;
|
|
import info.nightscout.androidaps.plugins.ProfileNS.NSProfilePlugin;
|
|
import info.nightscout.androidaps.plugins.ProfileNS.events.EventNSProfileUpdateGUI;
|
|
import info.nightscout.androidaps.plugins.PumpDanaR.activities.DanaRNSHistorySync;
|
|
import info.nightscout.androidaps.plugins.SmsCommunicator.events.EventNewSMS;
|
|
import info.nightscout.androidaps.plugins.Source.SourceDexcomG5Plugin;
|
|
import info.nightscout.androidaps.plugins.Source.SourceGlimpPlugin;
|
|
import info.nightscout.androidaps.plugins.Source.SourceMM640gPlugin;
|
|
import info.nightscout.androidaps.plugins.Source.SourceNSClientPlugin;
|
|
import info.nightscout.androidaps.plugins.Source.SourceXdripPlugin;
|
|
import info.nightscout.androidaps.receivers.DataReceiver;
|
|
import info.nightscout.utils.BundleLogger;
|
|
import info.nightscout.utils.NSUpload;
|
|
import info.nightscout.utils.SP;
|
|
|
|
|
|
public class DataService extends IntentService {
|
|
private static Logger log = LoggerFactory.getLogger(DataService.class);
|
|
|
|
boolean xDripEnabled = false;
|
|
boolean nsClientEnabled = true;
|
|
boolean mm640gEnabled = false;
|
|
boolean glimpEnabled = false;
|
|
boolean dexcomG5Enabled = false;
|
|
|
|
public DataService() {
|
|
super("DataService");
|
|
registerBus();
|
|
}
|
|
|
|
@Override
|
|
protected void onHandleIntent(final Intent intent) {
|
|
if (Config.logFunctionCalls)
|
|
log.debug("onHandleIntent " + BundleLogger.log(intent.getExtras()));
|
|
if (ConfigBuilderPlugin.getPlugin().getActiveBgSource() == null) {
|
|
xDripEnabled = true;
|
|
nsClientEnabled = false;
|
|
mm640gEnabled = false;
|
|
glimpEnabled = false;
|
|
dexcomG5Enabled = false;
|
|
} else if (ConfigBuilderPlugin.getPlugin().getActiveBgSource().getClass().equals(SourceXdripPlugin.class)) {
|
|
xDripEnabled = true;
|
|
nsClientEnabled = false;
|
|
mm640gEnabled = false;
|
|
glimpEnabled = false;
|
|
dexcomG5Enabled = false;
|
|
} else if (ConfigBuilderPlugin.getPlugin().getActiveBgSource().getClass().equals(SourceNSClientPlugin.class)) {
|
|
xDripEnabled = false;
|
|
nsClientEnabled = true;
|
|
mm640gEnabled = false;
|
|
glimpEnabled = false;
|
|
dexcomG5Enabled = false;
|
|
} else if (ConfigBuilderPlugin.getPlugin().getActiveBgSource().getClass().equals(SourceMM640gPlugin.class)) {
|
|
xDripEnabled = false;
|
|
nsClientEnabled = false;
|
|
mm640gEnabled = true;
|
|
glimpEnabled = false;
|
|
dexcomG5Enabled = false;
|
|
} else if (ConfigBuilderPlugin.getPlugin().getActiveBgSource().getClass().equals(SourceGlimpPlugin.class)) {
|
|
xDripEnabled = false;
|
|
nsClientEnabled = false;
|
|
mm640gEnabled = false;
|
|
glimpEnabled = true;
|
|
dexcomG5Enabled = false;
|
|
} else if (ConfigBuilderPlugin.getPlugin().getActiveBgSource().getClass().equals(SourceDexcomG5Plugin.class)) {
|
|
xDripEnabled = false;
|
|
nsClientEnabled = false;
|
|
mm640gEnabled = false;
|
|
glimpEnabled = false;
|
|
dexcomG5Enabled = true;
|
|
}
|
|
|
|
boolean isNSProfile = MainApp.getConfigBuilder().getActiveProfileInterface() != null && MainApp.getConfigBuilder().getActiveProfileInterface().getClass().equals(NSProfilePlugin.class);
|
|
|
|
boolean acceptNSData = !SP.getBoolean(R.string.key_ns_upload_only, false);
|
|
Bundle bundles = intent.getExtras();
|
|
if (bundles != null && bundles.containsKey("islocal")) {
|
|
acceptNSData = acceptNSData || bundles.getBoolean("islocal");
|
|
}
|
|
|
|
|
|
if (intent != null) {
|
|
final String action = intent.getAction();
|
|
if (Intents.ACTION_NEW_BG_ESTIMATE.equals(action)) {
|
|
if (xDripEnabled) {
|
|
handleNewDataFromXDrip(intent);
|
|
}
|
|
} else if (Intents.NS_EMULATOR.equals(action)) {
|
|
if (mm640gEnabled) {
|
|
handleNewDataFromMM640g(intent);
|
|
}
|
|
} else if (Intents.GLIMP_BG.equals(action)) {
|
|
if (glimpEnabled) {
|
|
handleNewDataFromGlimp(intent);
|
|
}
|
|
} else if (Intents.DEXCOMG5_BG.equals(action)) {
|
|
if (dexcomG5Enabled) {
|
|
handleNewDataFromDexcomG5(intent);
|
|
}
|
|
} else if (Intents.ACTION_NEW_SGV.equals(action)) {
|
|
if (nsClientEnabled || SP.getBoolean(R.string.ns_autobackfill, true))
|
|
handleNewDataFromNSClient(intent);
|
|
// Objectives 0
|
|
ObjectivesPlugin.bgIsAvailableInNS = true;
|
|
ObjectivesPlugin.saveProgress();
|
|
} else if (isNSProfile && Intents.ACTION_NEW_PROFILE.equals(action) || Intents.ACTION_NEW_DEVICESTATUS.equals(action)) {
|
|
// always handle Profile if NSProfile is enabled without looking at nsUploadOnly
|
|
handleNewDataFromNSClient(intent);
|
|
} else if (acceptNSData &&
|
|
(Intents.ACTION_NEW_TREATMENT.equals(action) ||
|
|
Intents.ACTION_CHANGED_TREATMENT.equals(action) ||
|
|
Intents.ACTION_REMOVED_TREATMENT.equals(action) ||
|
|
Intents.ACTION_NEW_STATUS.equals(action) ||
|
|
Intents.ACTION_NEW_DEVICESTATUS.equals(action) ||
|
|
Intents.ACTION_NEW_FOOD.equals(action) ||
|
|
Intents.ACTION_CHANGED_FOOD.equals(action) ||
|
|
Intents.ACTION_REMOVED_FOOD.equals(action) ||
|
|
Intents.ACTION_NEW_CAL.equals(action) ||
|
|
Intents.ACTION_NEW_MBG.equals(action))
|
|
) {
|
|
handleNewDataFromNSClient(intent);
|
|
} else if (Telephony.Sms.Intents.SMS_RECEIVED_ACTION.equals(action)) {
|
|
handleNewSMS(intent);
|
|
}
|
|
}
|
|
if (Config.logFunctionCalls)
|
|
log.debug("onHandleIntent exit " + intent);
|
|
DataReceiver.completeWakefulIntent(intent);
|
|
}
|
|
|
|
/*
|
|
@Override
|
|
public int onStartCommand(Intent intent, int flags, int startId) {
|
|
super.onStartCommand(intent, flags, startId);
|
|
|
|
if (Config.logFunctionCalls)
|
|
log.debug("onStartCommand");
|
|
|
|
return START_STICKY;
|
|
}
|
|
*/
|
|
|
|
@Override
|
|
public void onDestroy() {
|
|
super.onDestroy();
|
|
MainApp.bus().unregister(this);
|
|
}
|
|
|
|
private void registerBus() {
|
|
try {
|
|
MainApp.bus().unregister(this);
|
|
} catch (RuntimeException x) {
|
|
// Ignore
|
|
}
|
|
MainApp.bus().register(this);
|
|
}
|
|
|
|
private void handleNewDataFromXDrip(Intent intent) {
|
|
Bundle bundle = intent.getExtras();
|
|
if (bundle == null) return;
|
|
|
|
BgReading bgReading = new BgReading();
|
|
|
|
bgReading.value = bundle.getDouble(Intents.EXTRA_BG_ESTIMATE);
|
|
bgReading.direction = bundle.getString(Intents.EXTRA_BG_SLOPE_NAME);
|
|
bgReading.date = bundle.getLong(Intents.EXTRA_TIMESTAMP);
|
|
bgReading.raw = bundle.getDouble(Intents.EXTRA_RAW);
|
|
|
|
MainApp.getDbHelper().createIfNotExists(bgReading, "XDRIP");
|
|
}
|
|
|
|
private void handleNewDataFromGlimp(Intent intent) {
|
|
Bundle bundle = intent.getExtras();
|
|
if (bundle == null) return;
|
|
|
|
BgReading bgReading = new BgReading();
|
|
|
|
bgReading.value = bundle.getDouble("mySGV");
|
|
bgReading.direction = bundle.getString("myTrend");
|
|
bgReading.date = bundle.getLong("myTimestamp");
|
|
bgReading.raw = 0;
|
|
|
|
MainApp.getDbHelper().createIfNotExists(bgReading, "GLIMP");
|
|
}
|
|
|
|
private void handleNewDataFromDexcomG5(Intent intent) {
|
|
// onHandleIntent Bundle{ data => [{"m_time":1511939180,"m_trend":"NotComputable","m_value":335}]; android.support.content.wakelockid => 95; }Bundle
|
|
|
|
Bundle bundle = intent.getExtras();
|
|
if (bundle == null) return;
|
|
|
|
BgReading bgReading = new BgReading();
|
|
|
|
String data = bundle.getString("data");
|
|
log.debug("Received Dexcom Data", data);
|
|
|
|
try {
|
|
JSONArray jsonArray = new JSONArray(data);
|
|
log.debug("Received Dexcom Data size:" + jsonArray.length());
|
|
for (int i = 0; i < jsonArray.length(); i++) {
|
|
JSONObject json = jsonArray.getJSONObject(i);
|
|
bgReading.value = json.getInt("m_value");
|
|
bgReading.direction = json.getString("m_trend");
|
|
bgReading.date = json.getLong("m_time") * 1000L;
|
|
bgReading.raw = 0;
|
|
boolean isNew = MainApp.getDbHelper().createIfNotExists(bgReading, "DexcomG5");
|
|
if (isNew && SP.getBoolean(R.string.key_dexcomg5_nsupload, false)) {
|
|
NSUpload.uploadBg(bgReading);
|
|
}
|
|
if (isNew && SP.getBoolean(R.string.key_dexcomg5_xdripupload, false)) {
|
|
NSUpload.sendToXdrip(bgReading);
|
|
}
|
|
}
|
|
|
|
} catch (JSONException e) {
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
|
|
private void handleNewDataFromMM640g(Intent intent) {
|
|
Bundle bundle = intent.getExtras();
|
|
if (bundle == null) return;
|
|
|
|
final String collection = bundle.getString("collection");
|
|
if (collection == null) return;
|
|
|
|
if (collection.equals("entries")) {
|
|
final String data = bundle.getString("data");
|
|
|
|
if ((data != null) && (data.length() > 0)) {
|
|
try {
|
|
final JSONArray json_array = new JSONArray(data);
|
|
for (int i = 0; i < json_array.length(); i++) {
|
|
final JSONObject json_object = json_array.getJSONObject(i);
|
|
final String type = json_object.getString("type");
|
|
switch (type) {
|
|
case "sgv":
|
|
BgReading bgReading = new BgReading();
|
|
|
|
bgReading.value = json_object.getDouble("sgv");
|
|
bgReading.direction = json_object.getString("direction");
|
|
bgReading.date = json_object.getLong("date");
|
|
bgReading.raw = json_object.getDouble("sgv");
|
|
|
|
MainApp.getDbHelper().createIfNotExists(bgReading, "MM640g");
|
|
break;
|
|
default:
|
|
log.debug("Unknown entries type: " + type);
|
|
}
|
|
}
|
|
} catch (JSONException e) {
|
|
log.error("Got JSON exception: " + e);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
private void handleNewDataFromNSClient(Intent intent) {
|
|
Bundle bundles = intent.getExtras();
|
|
if (bundles == null) return;
|
|
if (Config.logIncommingData)
|
|
log.debug("Got intent: " + intent.getAction());
|
|
|
|
|
|
if (intent.getAction().equals(Intents.ACTION_NEW_STATUS)) {
|
|
if (bundles.containsKey("nsclientversioncode")) {
|
|
ConfigBuilderPlugin.nightscoutVersionCode = bundles.getInt("nightscoutversioncode"); // for ver 1.2.3 contains 10203
|
|
ConfigBuilderPlugin.nightscoutVersionName = bundles.getString("nightscoutversionname");
|
|
ConfigBuilderPlugin.nsClientVersionCode = bundles.getInt("nsclientversioncode"); // for ver 1.17 contains 117
|
|
ConfigBuilderPlugin.nsClientVersionName = bundles.getString("nsclientversionname");
|
|
log.debug("Got versions: NSClient: " + ConfigBuilderPlugin.nsClientVersionName + " Nightscout: " + ConfigBuilderPlugin.nightscoutVersionName);
|
|
try {
|
|
if (ConfigBuilderPlugin.nsClientVersionCode < MainApp.instance().getPackageManager().getPackageInfo(MainApp.instance().getPackageName(), 0).versionCode) {
|
|
Notification notification = new Notification(Notification.OLD_NSCLIENT, MainApp.sResources.getString(R.string.unsupportedclientver), Notification.URGENT);
|
|
MainApp.bus().post(new EventNewNotification(notification));
|
|
} else {
|
|
MainApp.bus().post(new EventDismissNotification(Notification.OLD_NSCLIENT));
|
|
}
|
|
} catch (PackageManager.NameNotFoundException e) {
|
|
log.error("Unhandled exception", e);
|
|
}
|
|
if (ConfigBuilderPlugin.nightscoutVersionCode < Config.SUPPORTEDNSVERSION) {
|
|
Notification notification = new Notification(Notification.OLD_NS, MainApp.sResources.getString(R.string.unsupportednsversion), Notification.NORMAL);
|
|
MainApp.bus().post(new EventNewNotification(notification));
|
|
} else {
|
|
MainApp.bus().post(new EventDismissNotification(Notification.OLD_NS));
|
|
}
|
|
} else {
|
|
Notification notification = new Notification(Notification.OLD_NSCLIENT, MainApp.sResources.getString(R.string.unsupportedclientver), Notification.URGENT);
|
|
MainApp.bus().post(new EventNewNotification(notification));
|
|
}
|
|
if (bundles.containsKey("status")) {
|
|
try {
|
|
JSONObject statusJson = new JSONObject(bundles.getString("status"));
|
|
NSSettingsStatus.getInstance().setData(statusJson);
|
|
if (Config.logIncommingData)
|
|
log.debug("Received status: " + statusJson.toString());
|
|
Double targetHigh = NSSettingsStatus.getInstance().getThreshold("bgTargetTop");
|
|
Double targetlow = NSSettingsStatus.getInstance().getThreshold("bgTargetBottom");
|
|
if (targetHigh != null)
|
|
OverviewPlugin.bgTargetHigh = targetHigh;
|
|
if (targetlow != null)
|
|
OverviewPlugin.bgTargetLow = targetlow;
|
|
} catch (JSONException e) {
|
|
log.error("Unhandled exception", e);
|
|
}
|
|
}
|
|
}
|
|
if (intent.getAction().equals(Intents.ACTION_NEW_DEVICESTATUS)) {
|
|
try {
|
|
if (bundles.containsKey("devicestatus")) {
|
|
JSONObject devicestatusJson = new JSONObject(bundles.getString("devicestatus"));
|
|
NSDeviceStatus.getInstance().setData(devicestatusJson);
|
|
if (devicestatusJson.has("pump")) {
|
|
// Objectives 0
|
|
ObjectivesPlugin.pumpStatusIsAvailableInNS = true;
|
|
ObjectivesPlugin.saveProgress();
|
|
}
|
|
}
|
|
if (bundles.containsKey("devicestatuses")) {
|
|
String devicestatusesstring = bundles.getString("devicestatuses");
|
|
JSONArray jsonArray = new JSONArray(devicestatusesstring);
|
|
for (int i = 0; i < jsonArray.length(); i++) {
|
|
JSONObject devicestatusJson = jsonArray.getJSONObject(i);
|
|
NSDeviceStatus.getInstance().setData(devicestatusJson);
|
|
if (devicestatusJson.has("pump")) {
|
|
// Objectives 0
|
|
ObjectivesPlugin.pumpStatusIsAvailableInNS = true;
|
|
ObjectivesPlugin.saveProgress();
|
|
}
|
|
}
|
|
}
|
|
} catch (Exception e) {
|
|
log.error("Unhandled exception", e);
|
|
}
|
|
}
|
|
// Handle profile
|
|
if (intent.getAction().equals(Intents.ACTION_NEW_PROFILE)) {
|
|
try {
|
|
String activeProfile = bundles.getString("activeprofile");
|
|
String profile = bundles.getString("profile");
|
|
ProfileStore profileStore = new ProfileStore(new JSONObject(profile));
|
|
NSProfilePlugin.getPlugin().storeNewProfile(profileStore);
|
|
MainApp.bus().post(new EventNSProfileUpdateGUI());
|
|
if (Config.logIncommingData)
|
|
log.debug("Received profileStore: " + activeProfile + " " + profile);
|
|
} catch (JSONException e) {
|
|
log.error("Unhandled exception", e);
|
|
}
|
|
}
|
|
|
|
if (intent.getAction().equals(Intents.ACTION_NEW_TREATMENT) || intent.getAction().equals(Intents.ACTION_CHANGED_TREATMENT)) {
|
|
try {
|
|
if (bundles.containsKey("treatment")) {
|
|
String trstring = bundles.getString("treatment");
|
|
handleAddChangeDataFromNS(trstring);
|
|
}
|
|
if (bundles.containsKey("treatments")) {
|
|
String trstring = bundles.getString("treatments");
|
|
JSONArray jsonArray = new JSONArray(trstring);
|
|
for (int i = 0; i < jsonArray.length(); i++) {
|
|
JSONObject trJson = jsonArray.getJSONObject(i);
|
|
String trstr = trJson.toString();
|
|
handleAddChangeDataFromNS(trstr);
|
|
}
|
|
}
|
|
} catch (Exception e) {
|
|
log.error("Unhandled exception", e);
|
|
}
|
|
}
|
|
|
|
if (intent.getAction().equals(Intents.ACTION_REMOVED_TREATMENT)) {
|
|
try {
|
|
if (bundles.containsKey("treatment")) {
|
|
String trstring = bundles.getString("treatment");
|
|
JSONObject trJson = new JSONObject(trstring);
|
|
String _id = trJson.getString("_id");
|
|
handleRemovedRecordFromNS(_id);
|
|
}
|
|
|
|
if (bundles.containsKey("treatments")) {
|
|
String trstring = bundles.getString("treatments");
|
|
JSONArray jsonArray = new JSONArray(trstring);
|
|
for (int i = 0; i < jsonArray.length(); i++) {
|
|
JSONObject trJson = jsonArray.getJSONObject(i);
|
|
String _id = trJson.getString("_id");
|
|
handleRemovedRecordFromNS(_id);
|
|
}
|
|
}
|
|
} catch (Exception e) {
|
|
log.error("Unhandled exception", e);
|
|
}
|
|
}
|
|
|
|
if (intent.getAction().equals(Intents.ACTION_NEW_SGV)) {
|
|
try {
|
|
if (bundles.containsKey("sgv")) {
|
|
String sgvstring = bundles.getString("sgv");
|
|
JSONObject sgvJson = new JSONObject(sgvstring);
|
|
NSSgv nsSgv = new NSSgv(sgvJson);
|
|
BgReading bgReading = new BgReading(nsSgv);
|
|
MainApp.getDbHelper().createIfNotExists(bgReading, "NS");
|
|
}
|
|
|
|
if (bundles.containsKey("sgvs")) {
|
|
String sgvstring = bundles.getString("sgvs");
|
|
JSONArray jsonArray = new JSONArray(sgvstring);
|
|
for (int i = 0; i < jsonArray.length(); i++) {
|
|
JSONObject sgvJson = jsonArray.getJSONObject(i);
|
|
NSSgv nsSgv = new NSSgv(sgvJson);
|
|
BgReading bgReading = new BgReading(nsSgv);
|
|
MainApp.getDbHelper().createIfNotExists(bgReading, "NS");
|
|
}
|
|
}
|
|
} catch (Exception e) {
|
|
log.error("Unhandled exception", e);
|
|
}
|
|
}
|
|
|
|
if (intent.getAction().equals(Intents.ACTION_NEW_MBG)) {
|
|
try {
|
|
if (bundles.containsKey("mbg")) {
|
|
String mbgstring = bundles.getString("mbg");
|
|
JSONObject mbgJson = new JSONObject(mbgstring);
|
|
NSMbg nsMbg = new NSMbg(mbgJson);
|
|
CareportalEvent careportalEvent = new CareportalEvent(nsMbg);
|
|
MainApp.getDbHelper().createOrUpdate(careportalEvent);
|
|
if (Config.logIncommingData)
|
|
log.debug("Adding/Updating new MBG: " + careportalEvent.log());
|
|
}
|
|
|
|
if (bundles.containsKey("mbgs")) {
|
|
String sgvstring = bundles.getString("mbgs");
|
|
JSONArray jsonArray = new JSONArray(sgvstring);
|
|
for (int i = 0; i < jsonArray.length(); i++) {
|
|
JSONObject mbgJson = jsonArray.getJSONObject(i);
|
|
NSMbg nsMbg = new NSMbg(mbgJson);
|
|
CareportalEvent careportalEvent = new CareportalEvent(nsMbg);
|
|
MainApp.getDbHelper().createOrUpdate(careportalEvent);
|
|
if (Config.logIncommingData)
|
|
log.debug("Adding/Updating new MBG: " + careportalEvent.log());
|
|
}
|
|
}
|
|
} catch (Exception e) {
|
|
log.error("Unhandled exception", e);
|
|
}
|
|
}
|
|
|
|
if (intent.getAction().equals(Intents.ACTION_NEW_FOOD)
|
|
|| intent.getAction().equals(Intents.ACTION_CHANGED_FOOD)) {
|
|
int mode = Intents.ACTION_NEW_FOOD.equals(intent.getAction()) ? EventNsFood.ADD : EventNsFood.UPDATE;
|
|
EventNsFood evt = new EventNsFood(mode, bundles);
|
|
MainApp.bus().post(evt);
|
|
}
|
|
|
|
if (intent.getAction().equals(Intents.ACTION_REMOVED_FOOD)) {
|
|
EventNsFood evt = new EventNsFood(EventNsFood.REMOVE, bundles);
|
|
MainApp.bus().post(evt);
|
|
}
|
|
}
|
|
|
|
private void handleRemovedRecordFromNS(String _id) {
|
|
MainApp.getDbHelper().deleteTreatmentById(_id);
|
|
MainApp.getDbHelper().deleteTempTargetById(_id);
|
|
MainApp.getDbHelper().deleteTempBasalById(_id);
|
|
MainApp.getDbHelper().deleteExtendedBolusById(_id);
|
|
MainApp.getDbHelper().deleteCareportalEventById(_id);
|
|
MainApp.getDbHelper().deleteProfileSwitchById(_id);
|
|
}
|
|
|
|
private void handleAddChangeDataFromNS(String trstring) throws JSONException {
|
|
JSONObject trJson = new JSONObject(trstring);
|
|
handleDanaRHistoryRecords(trJson); // update record _id in history
|
|
handleAddChangeTempTargetRecord(trJson);
|
|
handleAddChangeTempBasalRecord(trJson);
|
|
handleAddChangeExtendedBolusRecord(trJson);
|
|
handleAddChangeCareportalEventRecord(trJson);
|
|
handleAddChangeTreatmentRecord(trJson);
|
|
handleAddChangeProfileSwitchRecord(trJson);
|
|
}
|
|
|
|
public void handleDanaRHistoryRecords(JSONObject trJson) {
|
|
if (trJson.has(DanaRNSHistorySync.DANARSIGNATURE)) {
|
|
MainApp.getDbHelper().updateDanaRHistoryRecordId(trJson);
|
|
}
|
|
}
|
|
|
|
public void handleAddChangeTreatmentRecord(JSONObject trJson) throws JSONException {
|
|
if (trJson.has("insulin") || trJson.has("carbs")) {
|
|
MainApp.getDbHelper().createTreatmentFromJsonIfNotExists(trJson);
|
|
return;
|
|
}
|
|
}
|
|
|
|
public void handleAddChangeTempTargetRecord(JSONObject trJson) throws JSONException {
|
|
if (trJson.has("eventType") && trJson.getString("eventType").equals(CareportalEvent.TEMPORARYTARGET)) {
|
|
MainApp.getDbHelper().createTemptargetFromJsonIfNotExists(trJson);
|
|
}
|
|
}
|
|
|
|
public void handleAddChangeTempBasalRecord(JSONObject trJson) throws JSONException {
|
|
if (trJson.has("eventType") && trJson.getString("eventType").equals(CareportalEvent.TEMPBASAL)) {
|
|
MainApp.getDbHelper().createTempBasalFromJsonIfNotExists(trJson);
|
|
}
|
|
}
|
|
|
|
public void handleAddChangeExtendedBolusRecord(JSONObject trJson) throws JSONException {
|
|
if (trJson.has("eventType") && trJson.getString("eventType").equals(CareportalEvent.COMBOBOLUS)) {
|
|
MainApp.getDbHelper().createExtendedBolusFromJsonIfNotExists(trJson);
|
|
}
|
|
}
|
|
|
|
public void handleAddChangeCareportalEventRecord(JSONObject trJson) throws JSONException {
|
|
if (trJson.has("insulin") && trJson.getDouble("insulin") > 0)
|
|
return;
|
|
if (trJson.has("carbs") && trJson.getDouble("carbs") > 0)
|
|
return;
|
|
if (trJson.has("eventType") && (
|
|
trJson.getString("eventType").equals(CareportalEvent.SITECHANGE) ||
|
|
trJson.getString("eventType").equals(CareportalEvent.INSULINCHANGE) ||
|
|
trJson.getString("eventType").equals(CareportalEvent.SENSORCHANGE) ||
|
|
trJson.getString("eventType").equals(CareportalEvent.BGCHECK) ||
|
|
trJson.getString("eventType").equals(CareportalEvent.NOTE) ||
|
|
trJson.getString("eventType").equals(CareportalEvent.NONE) ||
|
|
trJson.getString("eventType").equals(CareportalEvent.ANNOUNCEMENT) ||
|
|
trJson.getString("eventType").equals(CareportalEvent.QUESTION) ||
|
|
trJson.getString("eventType").equals(CareportalEvent.EXERCISE) ||
|
|
trJson.getString("eventType").equals(CareportalEvent.OPENAPSOFFLINE) ||
|
|
trJson.getString("eventType").equals(CareportalEvent.PUMPBATTERYCHANGE)
|
|
)) {
|
|
MainApp.getDbHelper().createCareportalEventFromJsonIfNotExists(trJson);
|
|
}
|
|
|
|
if (trJson.has("eventType") && trJson.getString("eventType").equals(CareportalEvent.ANNOUNCEMENT)) {
|
|
long date = trJson.getLong("mills");
|
|
long now = System.currentTimeMillis();
|
|
if (date > now - 15 * 60 * 1000L && trJson.has("notes")
|
|
&& !(trJson.has("enteredBy") && trJson.getString("enteredBy").equals(SP.getString("careportal_enteredby", "AndroidAPS")))) {
|
|
Notification announcement = new Notification(Notification.NSANNOUNCEMENT, trJson.getString("notes"), Notification.ANNOUNCEMENT, 60);
|
|
MainApp.bus().post(new EventNewNotification(announcement));
|
|
}
|
|
}
|
|
}
|
|
|
|
public void handleAddChangeProfileSwitchRecord(JSONObject trJson) throws JSONException {
|
|
if (trJson.has("eventType") && trJson.getString("eventType").equals(CareportalEvent.PROFILESWITCH)) {
|
|
MainApp.getDbHelper().createProfileSwitchFromJsonIfNotExists(trJson);
|
|
}
|
|
}
|
|
|
|
private void handleNewSMS(Intent intent) {
|
|
Bundle bundle = intent.getExtras();
|
|
if (bundle == null) return;
|
|
MainApp.bus().post(new EventNewSMS(bundle));
|
|
}
|
|
|
|
}
|