SMS code cleanup
This commit is contained in:
Milos Kozak
parent
53721d5d2c
commit
f30f4cbee2
|
|
@ -4,6 +4,7 @@ import org.slf4j.Logger;
|
||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
|
|
||||||
import info.nightscout.androidaps.Constants;
|
import info.nightscout.androidaps.Constants;
|
||||||
|
import info.nightscout.androidaps.R;
|
||||||
import info.nightscout.androidaps.logging.L;
|
import info.nightscout.androidaps.logging.L;
|
||||||
import info.nightscout.androidaps.utils.DateUtil;
|
import info.nightscout.androidaps.utils.DateUtil;
|
||||||
|
|
||||||
|
|
@ -17,11 +18,13 @@ class AuthRequest {
|
||||||
private long date;
|
private long date;
|
||||||
|
|
||||||
private boolean processed;
|
private boolean processed;
|
||||||
|
private SmsCommunicatorPlugin plugin;
|
||||||
|
|
||||||
AuthRequest(SmsCommunicatorPlugin plugin, Sms requester, String requestText, String confirmCode, SmsAction action) {
|
AuthRequest(SmsCommunicatorPlugin plugin, Sms requester, String requestText, String confirmCode, SmsAction action) {
|
||||||
this.requester = requester;
|
this.requester = requester;
|
||||||
this.confirmCode = confirmCode;
|
this.confirmCode = confirmCode;
|
||||||
this.action = action;
|
this.action = action;
|
||||||
|
this.plugin = plugin;
|
||||||
|
|
||||||
this.date = DateUtil.now();
|
this.date = DateUtil.now();
|
||||||
|
|
||||||
|
|
@ -37,6 +40,7 @@ class AuthRequest {
|
||||||
if (!confirmCode.equals(codeReceived)) {
|
if (!confirmCode.equals(codeReceived)) {
|
||||||
if (L.isEnabled(L.SMS))
|
if (L.isEnabled(L.SMS))
|
||||||
log.debug("Wrong code");
|
log.debug("Wrong code");
|
||||||
|
plugin.sendSMS(new Sms(requester.phoneNumber, R.string.sms_wrongcode));
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
if (DateUtil.now() - date < Constants.SMS_CONFIRM_TIMEOUT) {
|
if (DateUtil.now() - date < Constants.SMS_CONFIRM_TIMEOUT) {
|
||||||
|
|
|
||||||
|
|
@ -2,6 +2,7 @@ package info.nightscout.androidaps.plugins.general.smsCommunicator;
|
||||||
|
|
||||||
import android.telephony.SmsMessage;
|
import android.telephony.SmsMessage;
|
||||||
|
|
||||||
|
import info.nightscout.androidaps.MainApp;
|
||||||
import info.nightscout.androidaps.utils.DateUtil;
|
import info.nightscout.androidaps.utils.DateUtil;
|
||||||
|
|
||||||
class Sms {
|
class Sms {
|
||||||
|
|
@ -27,6 +28,13 @@ class Sms {
|
||||||
sent = true;
|
sent = true;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Sms(String phoneNumber, int textId) {
|
||||||
|
this.phoneNumber = phoneNumber;
|
||||||
|
this.text = MainApp.gs(textId);
|
||||||
|
this.date = DateUtil.now();
|
||||||
|
sent = true;
|
||||||
|
}
|
||||||
|
|
||||||
public String toString() {
|
public String toString() {
|
||||||
return "SMS from " + phoneNumber + ": " + text;
|
return "SMS from " + phoneNumber + ": " + text;
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -46,6 +46,7 @@ import info.nightscout.androidaps.plugins.general.smsCommunicator.events.EventSm
|
||||||
import info.nightscout.androidaps.plugins.treatments.TreatmentsPlugin;
|
import info.nightscout.androidaps.plugins.treatments.TreatmentsPlugin;
|
||||||
import info.nightscout.androidaps.queue.Callback;
|
import info.nightscout.androidaps.queue.Callback;
|
||||||
import info.nightscout.androidaps.services.Intents;
|
import info.nightscout.androidaps.services.Intents;
|
||||||
|
import info.nightscout.androidaps.utils.DateUtil;
|
||||||
import info.nightscout.androidaps.utils.DecimalFormatter;
|
import info.nightscout.androidaps.utils.DecimalFormatter;
|
||||||
import info.nightscout.androidaps.utils.SP;
|
import info.nightscout.androidaps.utils.SP;
|
||||||
import info.nightscout.androidaps.utils.SafeParse;
|
import info.nightscout.androidaps.utils.SafeParse;
|
||||||
|
|
@ -149,466 +150,85 @@ public class SmsCommunicatorPlugin extends PluginBase {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
String reply = "";
|
|
||||||
|
|
||||||
messages.add(receivedSms);
|
messages.add(receivedSms);
|
||||||
log.debug(receivedSms.toString());
|
log.debug(receivedSms.toString());
|
||||||
|
|
||||||
String[] splited = receivedSms.text.split("\\s+");
|
String[] splitted = receivedSms.text.split("\\s+");
|
||||||
String passCode;
|
|
||||||
boolean remoteCommandsAllowed = SP.getBoolean(R.string.key_smscommunicator_remotecommandsallowed, false);
|
boolean remoteCommandsAllowed = SP.getBoolean(R.string.key_smscommunicator_remotecommandsallowed, false);
|
||||||
|
|
||||||
if (splited.length > 0) {
|
if (splitted.length > 0) {
|
||||||
switch (splited[0].toUpperCase()) {
|
switch (splitted[0].toUpperCase()) {
|
||||||
case "BG":
|
case "BG":
|
||||||
BgReading actualBG = DatabaseHelper.actualBg();
|
processBG(splitted, receivedSms);
|
||||||
BgReading lastBG = DatabaseHelper.lastBg();
|
|
||||||
|
|
||||||
String units = ProfileFunctions.getInstance().getProfileUnits();
|
|
||||||
|
|
||||||
if (actualBG != null) {
|
|
||||||
reply = MainApp.gs(R.string.sms_actualbg) + " " + actualBG.valueToUnitsToString(units) + ", ";
|
|
||||||
} else if (lastBG != null) {
|
|
||||||
Long agoMsec = System.currentTimeMillis() - lastBG.date;
|
|
||||||
int agoMin = (int) (agoMsec / 60d / 1000d);
|
|
||||||
reply = MainApp.gs(R.string.sms_lastbg) + " " + lastBG.valueToUnitsToString(units) + " " + String.format(MainApp.gs(R.string.sms_minago), agoMin) + ", ";
|
|
||||||
}
|
|
||||||
GlucoseStatus glucoseStatus = GlucoseStatus.getGlucoseStatusData();
|
|
||||||
if (glucoseStatus != null)
|
|
||||||
reply += MainApp.gs(R.string.sms_delta) + " " + Profile.toUnitsString(glucoseStatus.delta, glucoseStatus.delta * Constants.MGDL_TO_MMOLL, units) + " " + units + ", ";
|
|
||||||
|
|
||||||
TreatmentsPlugin.getPlugin().updateTotalIOBTreatments();
|
|
||||||
IobTotal bolusIob = TreatmentsPlugin.getPlugin().getLastCalculationTreatments().round();
|
|
||||||
TreatmentsPlugin.getPlugin().updateTotalIOBTempBasals();
|
|
||||||
IobTotal basalIob = TreatmentsPlugin.getPlugin().getLastCalculationTempBasals().round();
|
|
||||||
|
|
||||||
reply += MainApp.gs(R.string.sms_iob) + " " + DecimalFormatter.to2Decimal(bolusIob.iob + basalIob.basaliob) + "U ("
|
|
||||||
+ MainApp.gs(R.string.sms_bolus) + " " + DecimalFormatter.to2Decimal(bolusIob.iob) + "U "
|
|
||||||
+ MainApp.gs(R.string.sms_basal) + " " + DecimalFormatter.to2Decimal(basalIob.basaliob) + "U)";
|
|
||||||
|
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
receivedSms.processed = true;
|
|
||||||
break;
|
break;
|
||||||
case "LOOP":
|
case "LOOP":
|
||||||
if (splited.length > 1)
|
if (!remoteCommandsAllowed)
|
||||||
switch (splited[1].toUpperCase()) {
|
sendSMS(new Sms(receivedSms.phoneNumber, R.string.smscommunicator_remotecommandnotallowed));
|
||||||
case "DISABLE":
|
else if (splitted.length == 2)
|
||||||
case "STOP":
|
processLOOP(splitted, receivedSms);
|
||||||
LoopPlugin loopPlugin = MainApp.getSpecificPlugin(LoopPlugin.class);
|
else
|
||||||
if (loopPlugin != null && loopPlugin.isEnabled(PluginType.LOOP)) {
|
sendSMS(new Sms(receivedSms.phoneNumber, R.string.wrongformat));
|
||||||
loopPlugin.setPluginEnabled(PluginType.LOOP, false);
|
|
||||||
ConfigBuilderPlugin.getPlugin().getCommandQueue().cancelTempBasal(true, new Callback() {
|
|
||||||
@Override
|
|
||||||
public void run() {
|
|
||||||
MainApp.bus().post(new EventRefreshOverview("SMS_LOOP_STOP"));
|
|
||||||
String reply = MainApp.gs(R.string.smscommunicator_loophasbeendisabled) + " " +
|
|
||||||
MainApp.gs(result.success ? R.string.smscommunicator_tempbasalcanceled : R.string.smscommunicator_tempbasalcancelfailed);
|
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
receivedSms.processed = true;
|
|
||||||
break;
|
|
||||||
case "ENABLE":
|
|
||||||
case "START":
|
|
||||||
loopPlugin = MainApp.getSpecificPlugin(LoopPlugin.class);
|
|
||||||
if (loopPlugin != null && !loopPlugin.isEnabled(PluginType.LOOP)) {
|
|
||||||
loopPlugin.setPluginEnabled(PluginType.LOOP, true);
|
|
||||||
reply = MainApp.gs(R.string.smscommunicator_loophasbeenenabled);
|
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
MainApp.bus().post(new EventRefreshOverview("SMS_LOOP_START"));
|
|
||||||
}
|
|
||||||
receivedSms.processed = true;
|
|
||||||
break;
|
|
||||||
case "STATUS":
|
|
||||||
loopPlugin = MainApp.getSpecificPlugin(LoopPlugin.class);
|
|
||||||
if (loopPlugin != null) {
|
|
||||||
if (loopPlugin.isEnabled(PluginType.LOOP)) {
|
|
||||||
if (loopPlugin.isSuspended())
|
|
||||||
reply = String.format(MainApp.gs(R.string.loopsuspendedfor), loopPlugin.minutesToEndOfSuspend());
|
|
||||||
else
|
|
||||||
reply = MainApp.gs(R.string.smscommunicator_loopisenabled);
|
|
||||||
} else {
|
|
||||||
reply = MainApp.gs(R.string.smscommunicator_loopisdisabled);
|
|
||||||
}
|
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
}
|
|
||||||
receivedSms.processed = true;
|
|
||||||
break;
|
|
||||||
case "RESUME":
|
|
||||||
LoopPlugin.getPlugin().suspendTo(0);
|
|
||||||
MainApp.bus().post(new EventRefreshOverview("SMS_LOOP_RESUME"));
|
|
||||||
NSUpload.uploadOpenAPSOffline(0);
|
|
||||||
reply = MainApp.gs(R.string.smscommunicator_loopresumed);
|
|
||||||
sendSMSToAllNumbers(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
break;
|
|
||||||
case "SUSPEND":
|
|
||||||
int duration = 0;
|
|
||||||
if (splited.length >= 3)
|
|
||||||
duration = SafeParse.stringToInt(splited[2]);
|
|
||||||
duration = Math.max(0, duration);
|
|
||||||
duration = Math.min(180, duration);
|
|
||||||
if (duration == 0) {
|
|
||||||
reply = MainApp.gs(R.string.smscommunicator_wrongduration);
|
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
} else if (remoteCommandsAllowed) {
|
|
||||||
passCode = generatePasscode();
|
|
||||||
reply = String.format(MainApp.gs(R.string.smscommunicator_suspendreplywithcode), duration, passCode);
|
|
||||||
receivedSms.processed = true;
|
|
||||||
messageToConfirm = new AuthRequest(this, receivedSms, reply, passCode, new SmsAction(duration) {
|
|
||||||
@Override
|
|
||||||
public void run() {
|
|
||||||
ConfigBuilderPlugin.getPlugin().getCommandQueue().cancelTempBasal(true, new Callback() {
|
|
||||||
@Override
|
|
||||||
public void run() {
|
|
||||||
if (result.success) {
|
|
||||||
LoopPlugin.getPlugin().suspendTo(System.currentTimeMillis() + anInteger * 60L * 1000);
|
|
||||||
NSUpload.uploadOpenAPSOffline(anInteger * 60);
|
|
||||||
MainApp.bus().post(new EventRefreshOverview("SMS_LOOP_SUSPENDED"));
|
|
||||||
String reply = MainApp.gs(R.string.smscommunicator_loopsuspended) + " " +
|
|
||||||
MainApp.gs(result.success ? R.string.smscommunicator_tempbasalcanceled : R.string.smscommunicator_tempbasalcancelfailed);
|
|
||||||
sendSMSToAllNumbers(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
} else {
|
|
||||||
String reply = MainApp.gs(R.string.smscommunicator_tempbasalcancelfailed);
|
|
||||||
reply += "\n" + ConfigBuilderPlugin.getPlugin().getActivePump().shortStatus(true);
|
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
}
|
|
||||||
});
|
|
||||||
} else {
|
|
||||||
reply = MainApp.gs(R.string.smscommunicator_remotecommandnotallowed);
|
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
}
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
break;
|
break;
|
||||||
case "TREATMENTS":
|
case "TREATMENTS":
|
||||||
if (splited.length > 1)
|
if (splitted.length == 2)
|
||||||
switch (splited[1].toUpperCase()) {
|
processTREATMENTS(splitted, receivedSms);
|
||||||
case "REFRESH":
|
else
|
||||||
Intent restartNSClient = new Intent(Intents.ACTION_RESTART);
|
sendSMS(new Sms(receivedSms.phoneNumber, R.string.wrongformat));
|
||||||
TreatmentsPlugin.getPlugin().getService().resetTreatments();
|
|
||||||
MainApp.instance().getApplicationContext().sendBroadcast(restartNSClient);
|
|
||||||
List<ResolveInfo> q = MainApp.instance().getApplicationContext().getPackageManager().queryBroadcastReceivers(restartNSClient, 0);
|
|
||||||
reply = "TERATMENTS REFRESH " + q.size() + " receivers";
|
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
receivedSms.processed = true;
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
break;
|
break;
|
||||||
case "NSCLIENT":
|
case "NSCLIENT":
|
||||||
if (splited.length > 1)
|
if (splitted.length == 2)
|
||||||
switch (splited[1].toUpperCase()) {
|
processNSCLIENT(splitted, receivedSms);
|
||||||
case "RESTART":
|
else
|
||||||
Intent restartNSClient = new Intent(Intents.ACTION_RESTART);
|
sendSMS(new Sms(receivedSms.phoneNumber, R.string.wrongformat));
|
||||||
MainApp.instance().getApplicationContext().sendBroadcast(restartNSClient);
|
|
||||||
List<ResolveInfo> q = MainApp.instance().getApplicationContext().getPackageManager().queryBroadcastReceivers(restartNSClient, 0);
|
|
||||||
reply = "NSCLIENT RESTART " + q.size() + " receivers";
|
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
receivedSms.processed = true;
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
break;
|
break;
|
||||||
case "PUMP":
|
case "PUMP":
|
||||||
case "DANAR":
|
processPUMP(splitted, receivedSms);
|
||||||
ConfigBuilderPlugin.getPlugin().getCommandQueue().readStatus("SMS", new Callback() {
|
|
||||||
@Override
|
|
||||||
public void run() {
|
|
||||||
PumpInterface pump = ConfigBuilderPlugin.getPlugin().getActivePump();
|
|
||||||
if (result.success) {
|
|
||||||
if (pump != null) {
|
|
||||||
String reply = pump.shortStatus(true);
|
|
||||||
sendSMSToAllNumbers(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
String reply = MainApp.gs(R.string.readstatusfailed);
|
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
});
|
|
||||||
receivedSms.processed = true;
|
|
||||||
break;
|
break;
|
||||||
case "BASAL":
|
case "BASAL":
|
||||||
if (splited.length > 1) {
|
if (!remoteCommandsAllowed)
|
||||||
if (splited[1].toUpperCase().equals("CANCEL") || splited[1].toUpperCase().equals("STOP")) {
|
sendSMS(new Sms(receivedSms.phoneNumber, R.string.smscommunicator_remotecommandnotallowed));
|
||||||
if (remoteCommandsAllowed) {
|
else if (splitted.length == 2 || splitted.length == 3)
|
||||||
passCode = generatePasscode();
|
processBASAL(splitted, receivedSms);
|
||||||
reply = String.format(MainApp.gs(R.string.smscommunicator_basalstopreplywithcode), passCode);
|
else
|
||||||
receivedSms.processed = true;
|
sendSMS(new Sms(receivedSms.phoneNumber, R.string.wrongformat));
|
||||||
messageToConfirm = new AuthRequest(this, receivedSms, reply, passCode, new SmsAction() {
|
|
||||||
@Override
|
|
||||||
public void run() {
|
|
||||||
ConfigBuilderPlugin.getPlugin().getCommandQueue().cancelTempBasal(true, new Callback() {
|
|
||||||
@Override
|
|
||||||
public void run() {
|
|
||||||
if (result.success) {
|
|
||||||
String reply = MainApp.gs(R.string.smscommunicator_tempbasalcanceled);
|
|
||||||
reply += "\n" + ConfigBuilderPlugin.getPlugin().getActivePump().shortStatus(true);
|
|
||||||
sendSMSToAllNumbers(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
} else {
|
|
||||||
String reply = MainApp.gs(R.string.smscommunicator_tempbasalcancelfailed);
|
|
||||||
reply += "\n" + ConfigBuilderPlugin.getPlugin().getActivePump().shortStatus(true);
|
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
});
|
|
||||||
} else {
|
|
||||||
reply = MainApp.gs(R.string.smscommunicator_remotecommandnotallowed);
|
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
}
|
|
||||||
} else if (splited[1].endsWith("%")) {
|
|
||||||
int tempBasalPct = SafeParse.stringToInt(StringUtils.removeEnd(splited[1], "%"));
|
|
||||||
int duration = 30;
|
|
||||||
if (splited.length > 2)
|
|
||||||
duration = SafeParse.stringToInt(splited[2]);
|
|
||||||
Profile profile = ProfileFunctions.getInstance().getProfile();
|
|
||||||
if (profile == null) {
|
|
||||||
reply = MainApp.gs(R.string.noprofile);
|
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
} else if (tempBasalPct == 0 && !splited[1].equals("0%")) {
|
|
||||||
reply = MainApp.gs(R.string.wrongformat);
|
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
} else {
|
|
||||||
tempBasalPct = MainApp.getConstraintChecker().applyBasalPercentConstraints(new Constraint<>(tempBasalPct), profile).value();
|
|
||||||
if (remoteCommandsAllowed) {
|
|
||||||
passCode = generatePasscode();
|
|
||||||
reply = String.format(MainApp.gs(R.string.smscommunicator_basalpctreplywithcode), tempBasalPct, passCode);
|
|
||||||
receivedSms.processed = true;
|
|
||||||
messageToConfirm = new AuthRequest(this, receivedSms, reply, passCode, new SmsAction(tempBasalPct, duration) {
|
|
||||||
@Override
|
|
||||||
public void run() {
|
|
||||||
Profile profile = ProfileFunctions.getInstance().getProfile();
|
|
||||||
if (profile != null)
|
|
||||||
ConfigBuilderPlugin.getPlugin().getCommandQueue().tempBasalPercent(anInteger, secondInteger, true, profile, new Callback() {
|
|
||||||
@Override
|
|
||||||
public void run() {
|
|
||||||
if (result.success) {
|
|
||||||
String reply;
|
|
||||||
if (result.isPercent)
|
|
||||||
reply = String.format(MainApp.gs(R.string.smscommunicator_tempbasalset_percent), result.percent, result.duration);
|
|
||||||
else
|
|
||||||
reply = String.format(MainApp.gs(R.string.smscommunicator_tempbasalset), result.absolute, result.duration);
|
|
||||||
reply += "\n" + ConfigBuilderPlugin.getPlugin().getActivePump().shortStatus(true);
|
|
||||||
sendSMSToAllNumbers(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
} else {
|
|
||||||
String reply = MainApp.gs(R.string.smscommunicator_tempbasalfailed);
|
|
||||||
reply += "\n" + ConfigBuilderPlugin.getPlugin().getActivePump().shortStatus(true);
|
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
});
|
|
||||||
} else {
|
|
||||||
reply = MainApp.gs(R.string.smscommunicator_remotecommandnotallowed);
|
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
Double tempBasal = SafeParse.stringToDouble(splited[1]);
|
|
||||||
int duration = 30;
|
|
||||||
if (splited.length > 2)
|
|
||||||
duration = SafeParse.stringToInt(splited[2]);
|
|
||||||
Profile profile = ProfileFunctions.getInstance().getProfile();
|
|
||||||
if (profile == null) {
|
|
||||||
reply = MainApp.gs(R.string.noprofile);
|
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
} else {
|
|
||||||
tempBasal = MainApp.getConstraintChecker().applyBasalConstraints(new Constraint<>(tempBasal), profile).value();
|
|
||||||
if (remoteCommandsAllowed) {
|
|
||||||
passCode = generatePasscode();
|
|
||||||
reply = String.format(MainApp.gs(R.string.smscommunicator_basalreplywithcode), tempBasal, passCode);
|
|
||||||
receivedSms.processed = true;
|
|
||||||
messageToConfirm = new AuthRequest(this, receivedSms, reply, passCode, new SmsAction(tempBasal, duration) {
|
|
||||||
@Override
|
|
||||||
public void run() {
|
|
||||||
Profile profile = ProfileFunctions.getInstance().getProfile();
|
|
||||||
if (profile != null)
|
|
||||||
ConfigBuilderPlugin.getPlugin().getCommandQueue().tempBasalAbsolute(aDouble, secondInteger, true, profile, new Callback() {
|
|
||||||
@Override
|
|
||||||
public void run() {
|
|
||||||
if (result.success) {
|
|
||||||
String reply;
|
|
||||||
if (result.isPercent)
|
|
||||||
reply = String.format(MainApp.gs(R.string.smscommunicator_tempbasalset_percent), result.percent, result.duration);
|
|
||||||
else
|
|
||||||
reply = String.format(MainApp.gs(R.string.smscommunicator_tempbasalset), result.absolute, result.duration);
|
|
||||||
reply += "\n" + ConfigBuilderPlugin.getPlugin().getActivePump().shortStatus(true);
|
|
||||||
sendSMSToAllNumbers(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
} else {
|
|
||||||
String reply = MainApp.gs(R.string.smscommunicator_tempbasalfailed);
|
|
||||||
reply += "\n" + ConfigBuilderPlugin.getPlugin().getActivePump().shortStatus(true);
|
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
});
|
|
||||||
} else {
|
|
||||||
reply = MainApp.gs(R.string.smscommunicator_remotecommandnotallowed);
|
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
break;
|
break;
|
||||||
case "EXTENDED":
|
case "EXTENDED":
|
||||||
if (splited.length > 1) {
|
if (!remoteCommandsAllowed)
|
||||||
if (splited[1].toUpperCase().equals("CANCEL") || splited[1].toUpperCase().equals("STOP")) {
|
sendSMS(new Sms(receivedSms.phoneNumber, R.string.smscommunicator_remotecommandnotallowed));
|
||||||
if (remoteCommandsAllowed) {
|
else if (splitted.length == 3)
|
||||||
passCode = generatePasscode();
|
processEXTENDED(splitted, receivedSms);
|
||||||
reply = String.format(MainApp.gs(R.string.smscommunicator_extendedstopreplywithcode), passCode);
|
else
|
||||||
receivedSms.processed = true;
|
sendSMS(new Sms(receivedSms.phoneNumber, R.string.wrongformat));
|
||||||
messageToConfirm = new AuthRequest(this, receivedSms, reply, passCode, new SmsAction() {
|
|
||||||
@Override
|
|
||||||
public void run() {
|
|
||||||
ConfigBuilderPlugin.getPlugin().getCommandQueue().cancelExtended(new Callback() {
|
|
||||||
@Override
|
|
||||||
public void run() {
|
|
||||||
if (result.success) {
|
|
||||||
String reply = MainApp.gs(R.string.smscommunicator_extendedcanceled);
|
|
||||||
reply += "\n" + ConfigBuilderPlugin.getPlugin().getActivePump().shortStatus(true);
|
|
||||||
sendSMSToAllNumbers(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
} else {
|
|
||||||
String reply = MainApp.gs(R.string.smscommunicator_extendedcancelfailed);
|
|
||||||
reply += "\n" + ConfigBuilderPlugin.getPlugin().getActivePump().shortStatus(true);
|
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
});
|
|
||||||
} else {
|
|
||||||
reply = MainApp.gs(R.string.smscommunicator_remotecommandnotallowed);
|
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
if (splited.length < 3) {
|
|
||||||
reply = MainApp.gs(R.string.wrongformat);
|
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
} else {
|
|
||||||
Double extended = SafeParse.stringToDouble(splited[1]);
|
|
||||||
int duration = SafeParse.stringToInt(splited[2]);
|
|
||||||
extended = MainApp.getConstraintChecker().applyExtendedBolusConstraints(new Constraint<>(extended)).value();
|
|
||||||
if (remoteCommandsAllowed) {
|
|
||||||
passCode = generatePasscode();
|
|
||||||
reply = String.format(MainApp.gs(R.string.smscommunicator_extendedreplywithcode), extended, duration, passCode);
|
|
||||||
receivedSms.processed = true;
|
|
||||||
messageToConfirm = new AuthRequest(this, receivedSms, reply, passCode, new SmsAction(extended, duration) {
|
|
||||||
@Override
|
|
||||||
public void run() {
|
|
||||||
ConfigBuilderPlugin.getPlugin().getCommandQueue().extendedBolus(aDouble, secondInteger, new Callback() {
|
|
||||||
@Override
|
|
||||||
public void run() {
|
|
||||||
if (result.success) {
|
|
||||||
String reply = String.format(MainApp.gs(R.string.smscommunicator_extendedset), aDouble, duration);
|
|
||||||
reply += "\n" + ConfigBuilderPlugin.getPlugin().getActivePump().shortStatus(true);
|
|
||||||
sendSMSToAllNumbers(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
} else {
|
|
||||||
String reply = MainApp.gs(R.string.smscommunicator_extendedfailed);
|
|
||||||
reply += "\n" + ConfigBuilderPlugin.getPlugin().getActivePump().shortStatus(true);
|
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
});
|
|
||||||
} else {
|
|
||||||
reply = MainApp.gs(R.string.smscommunicator_remotecommandnotallowed);
|
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
break;
|
break;
|
||||||
case "BOLUS":
|
case "BOLUS":
|
||||||
if (System.currentTimeMillis() - lastRemoteBolusTime.getTime() < Constants.remoteBolusMinDistance) {
|
if (!remoteCommandsAllowed)
|
||||||
reply = MainApp.gs(R.string.smscommunicator_remotecommandnotallowed);
|
sendSMS(new Sms(receivedSms.phoneNumber, R.string.smscommunicator_remotecommandnotallowed));
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
else if (DateUtil.now() - lastRemoteBolusTime.getTime() < Constants.remoteBolusMinDistance)
|
||||||
} else if (ConfigBuilderPlugin.getPlugin().getActivePump().isSuspended()) {
|
sendSMS(new Sms(receivedSms.phoneNumber, R.string.smscommunicator_remotebolusnotallowed));
|
||||||
reply = MainApp.gs(R.string.pumpsuspended);
|
else if (ConfigBuilderPlugin.getPlugin().getActivePump().isSuspended())
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
sendSMS(new Sms(receivedSms.phoneNumber, R.string.pumpsuspended));
|
||||||
} else if (splited.length > 1) {
|
else if (splitted.length == 2)
|
||||||
Double bolus = SafeParse.stringToDouble(splited[1]);
|
processBOLUS(splitted, receivedSms);
|
||||||
bolus = MainApp.getConstraintChecker().applyBolusConstraints(new Constraint<>(bolus)).value();
|
else
|
||||||
if (bolus > 0d && remoteCommandsAllowed) {
|
sendSMS(new Sms(receivedSms.phoneNumber, R.string.wrongformat));
|
||||||
passCode = generatePasscode();
|
|
||||||
reply = String.format(MainApp.gs(R.string.smscommunicator_bolusreplywithcode), bolus, passCode);
|
|
||||||
receivedSms.processed = true;
|
|
||||||
messageToConfirm = new AuthRequest(this, receivedSms, reply, passCode, new SmsAction(bolus) {
|
|
||||||
@Override
|
|
||||||
public void run() {
|
|
||||||
DetailedBolusInfo detailedBolusInfo = new DetailedBolusInfo();
|
|
||||||
detailedBolusInfo.insulin = aDouble;
|
|
||||||
detailedBolusInfo.source = Source.USER;
|
|
||||||
ConfigBuilderPlugin.getPlugin().getCommandQueue().bolus(detailedBolusInfo, new Callback() {
|
|
||||||
@Override
|
|
||||||
public void run() {
|
|
||||||
PumpInterface pump = ConfigBuilderPlugin.getPlugin().getActivePump();
|
|
||||||
if (result.success) {
|
|
||||||
SystemClock.sleep(T.secs(15).msecs()); // wait some time to get history
|
|
||||||
String reply = String.format(MainApp.gs(R.string.smscommunicator_bolusdelivered), result.bolusDelivered);
|
|
||||||
if (pump != null)
|
|
||||||
reply += "\n" + pump.shortStatus(true);
|
|
||||||
lastRemoteBolusTime = new Date();
|
|
||||||
sendSMSToAllNumbers(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
} else {
|
|
||||||
SystemClock.sleep(T.secs(60).msecs()); // wait some time to get history
|
|
||||||
String reply = MainApp.gs(R.string.smscommunicator_bolusfailed);
|
|
||||||
if (pump != null)
|
|
||||||
reply += "\n" + pump.shortStatus(true);
|
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
});
|
|
||||||
} else {
|
|
||||||
reply = MainApp.gs(R.string.smscommunicator_remotecommandnotallowed);
|
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
break;
|
break;
|
||||||
case "CAL":
|
case "CAL":
|
||||||
if (splited.length > 1) {
|
if (!remoteCommandsAllowed)
|
||||||
Double cal = SafeParse.stringToDouble(splited[1]);
|
sendSMS(new Sms(receivedSms.phoneNumber, R.string.smscommunicator_remotecommandnotallowed));
|
||||||
if (cal > 0d && remoteCommandsAllowed) {
|
else if (splitted.length == 2)
|
||||||
passCode = generatePasscode();
|
processCAL(splitted, receivedSms);
|
||||||
reply = String.format(MainApp.gs(R.string.smscommunicator_calibrationreplywithcode), cal, passCode);
|
else
|
||||||
receivedSms.processed = true;
|
sendSMS(new Sms(receivedSms.phoneNumber, R.string.wrongformat));
|
||||||
messageToConfirm = new AuthRequest(this, receivedSms, reply, passCode, new SmsAction() {
|
|
||||||
@Override
|
|
||||||
public void run() {
|
|
||||||
boolean result = XdripCalibrations.sendIntent(aDouble);
|
|
||||||
if (result) {
|
|
||||||
String reply = MainApp.gs(R.string.smscommunicator_calibrationsent);
|
|
||||||
sendSMSToAllNumbers(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
} else {
|
|
||||||
String reply = MainApp.gs(R.string.smscommunicator_calibrationfailed);
|
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
});
|
|
||||||
} else {
|
|
||||||
reply = MainApp.gs(R.string.smscommunicator_remotecommandnotallowed);
|
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
break;
|
break;
|
||||||
default: // expect passCode here
|
default: // expect passCode here
|
||||||
if (!Character.isLetter(splited[0].charAt(0))) {
|
//noinspection StatementWithEmptyBody
|
||||||
|
if (!Character.isLetter(splitted[0].charAt(0))) {
|
||||||
// user text .... ignore
|
// user text .... ignore
|
||||||
} else if (messageToConfirm != null) {
|
} else if (messageToConfirm != null) {
|
||||||
messageToConfirm.action(splited[0]);
|
messageToConfirm.action(splitted[0]);
|
||||||
messageToConfirm = null;
|
messageToConfirm = null;
|
||||||
} else {
|
} else
|
||||||
sendSMS(new Sms(receivedSms.phoneNumber, MainApp.gs(R.string.smscommunicator_unknowncommand)));
|
sendSMS(new Sms(receivedSms.phoneNumber, MainApp.gs(R.string.smscommunicator_unknowncommand)));
|
||||||
}
|
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
@ -616,6 +236,406 @@ public class SmsCommunicatorPlugin extends PluginBase {
|
||||||
MainApp.bus().post(new EventSmsCommunicatorUpdateGui());
|
MainApp.bus().post(new EventSmsCommunicatorUpdateGui());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@SuppressWarnings("unused")
|
||||||
|
private void processBG(String[] splitted, Sms receivedSms) {
|
||||||
|
BgReading actualBG = DatabaseHelper.actualBg();
|
||||||
|
BgReading lastBG = DatabaseHelper.lastBg();
|
||||||
|
|
||||||
|
String reply = "";
|
||||||
|
|
||||||
|
String units = ProfileFunctions.getInstance().getProfileUnits();
|
||||||
|
|
||||||
|
if (actualBG != null) {
|
||||||
|
reply = MainApp.gs(R.string.sms_actualbg) + " " + actualBG.valueToUnitsToString(units) + ", ";
|
||||||
|
} else if (lastBG != null) {
|
||||||
|
Long agoMsec = System.currentTimeMillis() - lastBG.date;
|
||||||
|
int agoMin = (int) (agoMsec / 60d / 1000d);
|
||||||
|
reply = MainApp.gs(R.string.sms_lastbg) + " " + lastBG.valueToUnitsToString(units) + " " + String.format(MainApp.gs(R.string.sms_minago), agoMin) + ", ";
|
||||||
|
}
|
||||||
|
GlucoseStatus glucoseStatus = GlucoseStatus.getGlucoseStatusData();
|
||||||
|
if (glucoseStatus != null)
|
||||||
|
reply += MainApp.gs(R.string.sms_delta) + " " + Profile.toUnitsString(glucoseStatus.delta, glucoseStatus.delta * Constants.MGDL_TO_MMOLL, units) + " " + units + ", ";
|
||||||
|
|
||||||
|
TreatmentsPlugin.getPlugin().updateTotalIOBTreatments();
|
||||||
|
IobTotal bolusIob = TreatmentsPlugin.getPlugin().getLastCalculationTreatments().round();
|
||||||
|
TreatmentsPlugin.getPlugin().updateTotalIOBTempBasals();
|
||||||
|
IobTotal basalIob = TreatmentsPlugin.getPlugin().getLastCalculationTempBasals().round();
|
||||||
|
|
||||||
|
reply += MainApp.gs(R.string.sms_iob) + " " + DecimalFormatter.to2Decimal(bolusIob.iob + basalIob.basaliob) + "U ("
|
||||||
|
+ MainApp.gs(R.string.sms_bolus) + " " + DecimalFormatter.to2Decimal(bolusIob.iob) + "U "
|
||||||
|
+ MainApp.gs(R.string.sms_basal) + " " + DecimalFormatter.to2Decimal(basalIob.basaliob) + "U)";
|
||||||
|
|
||||||
|
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
||||||
|
receivedSms.processed = true;
|
||||||
|
}
|
||||||
|
|
||||||
|
private void processLOOP(String[] splitted, Sms receivedSms) {
|
||||||
|
String reply;
|
||||||
|
switch (splitted[1].toUpperCase()) {
|
||||||
|
case "DISABLE":
|
||||||
|
case "STOP":
|
||||||
|
LoopPlugin loopPlugin = MainApp.getSpecificPlugin(LoopPlugin.class);
|
||||||
|
if (loopPlugin != null && loopPlugin.isEnabled(PluginType.LOOP)) {
|
||||||
|
loopPlugin.setPluginEnabled(PluginType.LOOP, false);
|
||||||
|
ConfigBuilderPlugin.getPlugin().getCommandQueue().cancelTempBasal(true, new Callback() {
|
||||||
|
@Override
|
||||||
|
public void run() {
|
||||||
|
MainApp.bus().post(new EventRefreshOverview("SMS_LOOP_STOP"));
|
||||||
|
String reply = MainApp.gs(R.string.smscommunicator_loophasbeendisabled) + " " +
|
||||||
|
MainApp.gs(result.success ? R.string.smscommunicator_tempbasalcanceled : R.string.smscommunicator_tempbasalcancelfailed);
|
||||||
|
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
receivedSms.processed = true;
|
||||||
|
break;
|
||||||
|
case "ENABLE":
|
||||||
|
case "START":
|
||||||
|
loopPlugin = MainApp.getSpecificPlugin(LoopPlugin.class);
|
||||||
|
if (loopPlugin != null && !loopPlugin.isEnabled(PluginType.LOOP)) {
|
||||||
|
loopPlugin.setPluginEnabled(PluginType.LOOP, true);
|
||||||
|
sendSMS(new Sms(receivedSms.phoneNumber, R.string.smscommunicator_loophasbeenenabled));
|
||||||
|
MainApp.bus().post(new EventRefreshOverview("SMS_LOOP_START"));
|
||||||
|
}
|
||||||
|
receivedSms.processed = true;
|
||||||
|
break;
|
||||||
|
case "STATUS":
|
||||||
|
loopPlugin = MainApp.getSpecificPlugin(LoopPlugin.class);
|
||||||
|
if (loopPlugin != null) {
|
||||||
|
if (loopPlugin.isEnabled(PluginType.LOOP)) {
|
||||||
|
if (loopPlugin.isSuspended())
|
||||||
|
reply = String.format(MainApp.gs(R.string.loopsuspendedfor), loopPlugin.minutesToEndOfSuspend());
|
||||||
|
else
|
||||||
|
reply = MainApp.gs(R.string.smscommunicator_loopisenabled);
|
||||||
|
} else {
|
||||||
|
reply = MainApp.gs(R.string.smscommunicator_loopisdisabled);
|
||||||
|
}
|
||||||
|
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
||||||
|
}
|
||||||
|
receivedSms.processed = true;
|
||||||
|
break;
|
||||||
|
case "RESUME":
|
||||||
|
LoopPlugin.getPlugin().suspendTo(0);
|
||||||
|
MainApp.bus().post(new EventRefreshOverview("SMS_LOOP_RESUME"));
|
||||||
|
NSUpload.uploadOpenAPSOffline(0);
|
||||||
|
reply = MainApp.gs(R.string.smscommunicator_loopresumed);
|
||||||
|
sendSMSToAllNumbers(new Sms(receivedSms.phoneNumber, reply));
|
||||||
|
break;
|
||||||
|
case "SUSPEND":
|
||||||
|
int duration = 0;
|
||||||
|
if (splitted.length >= 3)
|
||||||
|
duration = SafeParse.stringToInt(splitted[2]);
|
||||||
|
duration = Math.max(0, duration);
|
||||||
|
duration = Math.min(180, duration);
|
||||||
|
if (duration == 0) {
|
||||||
|
reply = MainApp.gs(R.string.smscommunicator_wrongduration);
|
||||||
|
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
||||||
|
} else {
|
||||||
|
String passCode = generatePasscode();
|
||||||
|
reply = String.format(MainApp.gs(R.string.smscommunicator_suspendreplywithcode), duration, passCode);
|
||||||
|
receivedSms.processed = true;
|
||||||
|
messageToConfirm = new AuthRequest(this, receivedSms, reply, passCode, new SmsAction(duration) {
|
||||||
|
@Override
|
||||||
|
public void run() {
|
||||||
|
ConfigBuilderPlugin.getPlugin().getCommandQueue().cancelTempBasal(true, new Callback() {
|
||||||
|
@Override
|
||||||
|
public void run() {
|
||||||
|
if (result.success) {
|
||||||
|
LoopPlugin.getPlugin().suspendTo(System.currentTimeMillis() + anInteger * 60L * 1000);
|
||||||
|
NSUpload.uploadOpenAPSOffline(anInteger * 60);
|
||||||
|
MainApp.bus().post(new EventRefreshOverview("SMS_LOOP_SUSPENDED"));
|
||||||
|
String reply = MainApp.gs(R.string.smscommunicator_loopsuspended) + " " +
|
||||||
|
MainApp.gs(result.success ? R.string.smscommunicator_tempbasalcanceled : R.string.smscommunicator_tempbasalcancelfailed);
|
||||||
|
sendSMSToAllNumbers(new Sms(receivedSms.phoneNumber, reply));
|
||||||
|
} else {
|
||||||
|
String reply = MainApp.gs(R.string.smscommunicator_tempbasalcancelfailed);
|
||||||
|
reply += "\n" + ConfigBuilderPlugin.getPlugin().getActivePump().shortStatus(true);
|
||||||
|
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
default:
|
||||||
|
sendSMS(new Sms(receivedSms.phoneNumber, R.string.wrongformat));
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private void processTREATMENTS(String[] splitted, Sms receivedSms) {
|
||||||
|
if (splitted[1].toUpperCase().equals("REFRESH")) {
|
||||||
|
Intent restartNSClient = new Intent(Intents.ACTION_RESTART);
|
||||||
|
TreatmentsPlugin.getPlugin().getService().resetTreatments();
|
||||||
|
MainApp.instance().getApplicationContext().sendBroadcast(restartNSClient);
|
||||||
|
List<ResolveInfo> q = MainApp.instance().getApplicationContext().getPackageManager().queryBroadcastReceivers(restartNSClient, 0);
|
||||||
|
String reply = "TREATMENTS REFRESH " + q.size() + " receivers";
|
||||||
|
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
||||||
|
receivedSms.processed = true;
|
||||||
|
} else
|
||||||
|
sendSMS(new Sms(receivedSms.phoneNumber, R.string.wrongformat));
|
||||||
|
}
|
||||||
|
|
||||||
|
private void processNSCLIENT(String[] splitted, Sms receivedSms) {
|
||||||
|
if (splitted[2].toUpperCase().equals("RESTART")) {
|
||||||
|
Intent restartNSClient = new Intent(Intents.ACTION_RESTART);
|
||||||
|
MainApp.instance().getApplicationContext().sendBroadcast(restartNSClient);
|
||||||
|
List<ResolveInfo> q = MainApp.instance().getApplicationContext().getPackageManager().queryBroadcastReceivers(restartNSClient, 0);
|
||||||
|
String reply = "NSCLIENT RESTART " + q.size() + " receivers";
|
||||||
|
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
||||||
|
receivedSms.processed = true;
|
||||||
|
} else
|
||||||
|
sendSMS(new Sms(receivedSms.phoneNumber, R.string.wrongformat));
|
||||||
|
}
|
||||||
|
|
||||||
|
@SuppressWarnings("unused")
|
||||||
|
private void processPUMP(String[] splitted, Sms receivedSms) {
|
||||||
|
ConfigBuilderPlugin.getPlugin().getCommandQueue().readStatus("SMS", new Callback() {
|
||||||
|
@Override
|
||||||
|
public void run() {
|
||||||
|
PumpInterface pump = ConfigBuilderPlugin.getPlugin().getActivePump();
|
||||||
|
if (result.success) {
|
||||||
|
if (pump != null) {
|
||||||
|
String reply = pump.shortStatus(true);
|
||||||
|
sendSMSToAllNumbers(new Sms(receivedSms.phoneNumber, reply));
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
String reply = MainApp.gs(R.string.readstatusfailed);
|
||||||
|
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
});
|
||||||
|
receivedSms.processed = true;
|
||||||
|
}
|
||||||
|
|
||||||
|
private void processBASAL(String[] splitted, Sms receivedSms) {
|
||||||
|
if (splitted[1].toUpperCase().equals("CANCEL") || splitted[1].toUpperCase().equals("STOP")) {
|
||||||
|
String passCode = generatePasscode();
|
||||||
|
String reply = String.format(MainApp.gs(R.string.smscommunicator_basalstopreplywithcode), passCode);
|
||||||
|
receivedSms.processed = true;
|
||||||
|
messageToConfirm = new AuthRequest(this, receivedSms, reply, passCode, new SmsAction() {
|
||||||
|
@Override
|
||||||
|
public void run() {
|
||||||
|
ConfigBuilderPlugin.getPlugin().getCommandQueue().cancelTempBasal(true, new Callback() {
|
||||||
|
@Override
|
||||||
|
public void run() {
|
||||||
|
if (result.success) {
|
||||||
|
String reply = MainApp.gs(R.string.smscommunicator_tempbasalcanceled);
|
||||||
|
reply += "\n" + ConfigBuilderPlugin.getPlugin().getActivePump().shortStatus(true);
|
||||||
|
sendSMSToAllNumbers(new Sms(receivedSms.phoneNumber, reply));
|
||||||
|
} else {
|
||||||
|
String reply = MainApp.gs(R.string.smscommunicator_tempbasalcancelfailed);
|
||||||
|
reply += "\n" + ConfigBuilderPlugin.getPlugin().getActivePump().shortStatus(true);
|
||||||
|
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
});
|
||||||
|
} else if (splitted[1].endsWith("%")) {
|
||||||
|
int tempBasalPct = SafeParse.stringToInt(StringUtils.removeEnd(splitted[1], "%"));
|
||||||
|
int duration = 30;
|
||||||
|
if (splitted.length > 2)
|
||||||
|
duration = SafeParse.stringToInt(splitted[2]);
|
||||||
|
final Profile profile = ProfileFunctions.getInstance().getProfile();
|
||||||
|
|
||||||
|
if (profile == null)
|
||||||
|
sendSMS(new Sms(receivedSms.phoneNumber, R.string.noprofile));
|
||||||
|
else if (tempBasalPct == 0 && !splitted[1].equals("0%"))
|
||||||
|
sendSMS(new Sms(receivedSms.phoneNumber, R.string.wrongformat));
|
||||||
|
else if (duration == 0)
|
||||||
|
sendSMS(new Sms(receivedSms.phoneNumber, R.string.wrongformat));
|
||||||
|
else {
|
||||||
|
tempBasalPct = MainApp.getConstraintChecker().applyBasalPercentConstraints(new Constraint<>(tempBasalPct), profile).value();
|
||||||
|
String passCode = generatePasscode();
|
||||||
|
String reply = String.format(MainApp.gs(R.string.smscommunicator_basalpctreplywithcode), tempBasalPct, passCode);
|
||||||
|
receivedSms.processed = true;
|
||||||
|
messageToConfirm = new AuthRequest(this, receivedSms, reply, passCode, new SmsAction(tempBasalPct, duration) {
|
||||||
|
@Override
|
||||||
|
public void run() {
|
||||||
|
ConfigBuilderPlugin.getPlugin().getCommandQueue().tempBasalPercent(anInteger, secondInteger, true, profile, new Callback() {
|
||||||
|
@Override
|
||||||
|
public void run() {
|
||||||
|
if (result.success) {
|
||||||
|
String reply;
|
||||||
|
if (result.isPercent)
|
||||||
|
reply = String.format(MainApp.gs(R.string.smscommunicator_tempbasalset_percent), result.percent, result.duration);
|
||||||
|
else
|
||||||
|
reply = String.format(MainApp.gs(R.string.smscommunicator_tempbasalset), result.absolute, result.duration);
|
||||||
|
reply += "\n" + ConfigBuilderPlugin.getPlugin().getActivePump().shortStatus(true);
|
||||||
|
sendSMSToAllNumbers(new Sms(receivedSms.phoneNumber, reply));
|
||||||
|
} else {
|
||||||
|
String reply = MainApp.gs(R.string.smscommunicator_tempbasalfailed);
|
||||||
|
reply += "\n" + ConfigBuilderPlugin.getPlugin().getActivePump().shortStatus(true);
|
||||||
|
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
Double tempBasal = SafeParse.stringToDouble(splitted[1]);
|
||||||
|
int duration = 30;
|
||||||
|
if (splitted.length > 2)
|
||||||
|
duration = SafeParse.stringToInt(splitted[2]);
|
||||||
|
final Profile profile = ProfileFunctions.getInstance().getProfile();
|
||||||
|
if (profile == null)
|
||||||
|
sendSMS(new Sms(receivedSms.phoneNumber, R.string.noprofile));
|
||||||
|
else if (tempBasal == 0 && !splitted[1].equals("0"))
|
||||||
|
sendSMS(new Sms(receivedSms.phoneNumber, R.string.wrongformat));
|
||||||
|
else if (duration == 0)
|
||||||
|
sendSMS(new Sms(receivedSms.phoneNumber, R.string.wrongformat));
|
||||||
|
else {
|
||||||
|
tempBasal = MainApp.getConstraintChecker().applyBasalConstraints(new Constraint<>(tempBasal), profile).value();
|
||||||
|
String passCode = generatePasscode();
|
||||||
|
String reply = String.format(MainApp.gs(R.string.smscommunicator_basalreplywithcode), tempBasal, passCode);
|
||||||
|
receivedSms.processed = true;
|
||||||
|
messageToConfirm = new AuthRequest(this, receivedSms, reply, passCode, new SmsAction(tempBasal, duration) {
|
||||||
|
@Override
|
||||||
|
public void run() {
|
||||||
|
ConfigBuilderPlugin.getPlugin().getCommandQueue().tempBasalAbsolute(aDouble, secondInteger, true, profile, new Callback() {
|
||||||
|
@Override
|
||||||
|
public void run() {
|
||||||
|
if (result.success) {
|
||||||
|
String reply;
|
||||||
|
if (result.isPercent)
|
||||||
|
reply = String.format(MainApp.gs(R.string.smscommunicator_tempbasalset_percent), result.percent, result.duration);
|
||||||
|
else
|
||||||
|
reply = String.format(MainApp.gs(R.string.smscommunicator_tempbasalset), result.absolute, result.duration);
|
||||||
|
reply += "\n" + ConfigBuilderPlugin.getPlugin().getActivePump().shortStatus(true);
|
||||||
|
sendSMSToAllNumbers(new Sms(receivedSms.phoneNumber, reply));
|
||||||
|
} else {
|
||||||
|
String reply = MainApp.gs(R.string.smscommunicator_tempbasalfailed);
|
||||||
|
reply += "\n" + ConfigBuilderPlugin.getPlugin().getActivePump().shortStatus(true);
|
||||||
|
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private void processEXTENDED(String[] splitted, Sms receivedSms) {
|
||||||
|
if (splitted[1].toUpperCase().equals("CANCEL") || splitted[1].toUpperCase().equals("STOP")) {
|
||||||
|
String passCode = generatePasscode();
|
||||||
|
String reply = String.format(MainApp.gs(R.string.smscommunicator_extendedstopreplywithcode), passCode);
|
||||||
|
receivedSms.processed = true;
|
||||||
|
messageToConfirm = new AuthRequest(this, receivedSms, reply, passCode, new SmsAction() {
|
||||||
|
@Override
|
||||||
|
public void run() {
|
||||||
|
ConfigBuilderPlugin.getPlugin().getCommandQueue().cancelExtended(new Callback() {
|
||||||
|
@Override
|
||||||
|
public void run() {
|
||||||
|
if (result.success) {
|
||||||
|
String reply = MainApp.gs(R.string.smscommunicator_extendedcanceled);
|
||||||
|
reply += "\n" + ConfigBuilderPlugin.getPlugin().getActivePump().shortStatus(true);
|
||||||
|
sendSMSToAllNumbers(new Sms(receivedSms.phoneNumber, reply));
|
||||||
|
} else {
|
||||||
|
String reply = MainApp.gs(R.string.smscommunicator_extendedcancelfailed);
|
||||||
|
reply += "\n" + ConfigBuilderPlugin.getPlugin().getActivePump().shortStatus(true);
|
||||||
|
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
});
|
||||||
|
} else {
|
||||||
|
Double extended = SafeParse.stringToDouble(splitted[1]);
|
||||||
|
int duration = SafeParse.stringToInt(splitted[2]);
|
||||||
|
extended = MainApp.getConstraintChecker().applyExtendedBolusConstraints(new Constraint<>(extended)).value();
|
||||||
|
if (extended == 0 || duration == 0)
|
||||||
|
sendSMS(new Sms(receivedSms.phoneNumber, R.string.wrongformat));
|
||||||
|
else {
|
||||||
|
String passCode = generatePasscode();
|
||||||
|
String reply = String.format(MainApp.gs(R.string.smscommunicator_extendedreplywithcode), extended, duration, passCode);
|
||||||
|
receivedSms.processed = true;
|
||||||
|
messageToConfirm = new AuthRequest(this, receivedSms, reply, passCode, new SmsAction(extended, duration) {
|
||||||
|
@Override
|
||||||
|
public void run() {
|
||||||
|
ConfigBuilderPlugin.getPlugin().getCommandQueue().extendedBolus(aDouble, secondInteger, new Callback() {
|
||||||
|
@Override
|
||||||
|
public void run() {
|
||||||
|
if (result.success) {
|
||||||
|
String reply = String.format(MainApp.gs(R.string.smscommunicator_extendedset), aDouble, duration);
|
||||||
|
reply += "\n" + ConfigBuilderPlugin.getPlugin().getActivePump().shortStatus(true);
|
||||||
|
sendSMSToAllNumbers(new Sms(receivedSms.phoneNumber, reply));
|
||||||
|
} else {
|
||||||
|
String reply = MainApp.gs(R.string.smscommunicator_extendedfailed);
|
||||||
|
reply += "\n" + ConfigBuilderPlugin.getPlugin().getActivePump().shortStatus(true);
|
||||||
|
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
private void processBOLUS(String[] splitted, Sms receivedSms) {
|
||||||
|
Double bolus = SafeParse.stringToDouble(splitted[1]);
|
||||||
|
bolus = MainApp.getConstraintChecker().applyBolusConstraints(new Constraint<>(bolus)).value();
|
||||||
|
if (bolus > 0d) {
|
||||||
|
String passCode = generatePasscode();
|
||||||
|
String reply = String.format(MainApp.gs(R.string.smscommunicator_bolusreplywithcode), bolus, passCode);
|
||||||
|
receivedSms.processed = true;
|
||||||
|
messageToConfirm = new AuthRequest(this, receivedSms, reply, passCode, new SmsAction(bolus) {
|
||||||
|
@Override
|
||||||
|
public void run() {
|
||||||
|
DetailedBolusInfo detailedBolusInfo = new DetailedBolusInfo();
|
||||||
|
detailedBolusInfo.insulin = aDouble;
|
||||||
|
detailedBolusInfo.source = Source.USER;
|
||||||
|
ConfigBuilderPlugin.getPlugin().getCommandQueue().bolus(detailedBolusInfo, new Callback() {
|
||||||
|
@Override
|
||||||
|
public void run() {
|
||||||
|
PumpInterface pump = ConfigBuilderPlugin.getPlugin().getActivePump();
|
||||||
|
if (result.success) {
|
||||||
|
SystemClock.sleep(T.secs(15).msecs()); // wait some time to get history
|
||||||
|
String reply = String.format(MainApp.gs(R.string.smscommunicator_bolusdelivered), result.bolusDelivered);
|
||||||
|
if (pump != null)
|
||||||
|
reply += "\n" + pump.shortStatus(true);
|
||||||
|
lastRemoteBolusTime = new Date();
|
||||||
|
sendSMSToAllNumbers(new Sms(receivedSms.phoneNumber, reply));
|
||||||
|
} else {
|
||||||
|
SystemClock.sleep(T.secs(60).msecs()); // wait some time to get history
|
||||||
|
String reply = MainApp.gs(R.string.smscommunicator_bolusfailed);
|
||||||
|
if (pump != null)
|
||||||
|
reply += "\n" + pump.shortStatus(true);
|
||||||
|
sendSMS(new Sms(receivedSms.phoneNumber, reply));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
});
|
||||||
|
} else
|
||||||
|
sendSMS(new Sms(receivedSms.phoneNumber, R.string.wrongformat));
|
||||||
|
}
|
||||||
|
|
||||||
|
private void processCAL(String[] splitted, Sms receivedSms) {
|
||||||
|
Double cal = SafeParse.stringToDouble(splitted[1]);
|
||||||
|
if (cal > 0d) {
|
||||||
|
String passCode = generatePasscode();
|
||||||
|
String reply = String.format(MainApp.gs(R.string.smscommunicator_calibrationreplywithcode), cal, passCode);
|
||||||
|
receivedSms.processed = true;
|
||||||
|
messageToConfirm = new AuthRequest(this, receivedSms, reply, passCode, new SmsAction() {
|
||||||
|
@Override
|
||||||
|
public void run() {
|
||||||
|
boolean result = XdripCalibrations.sendIntent(aDouble);
|
||||||
|
if (result)
|
||||||
|
sendSMSToAllNumbers(new Sms(receivedSms.phoneNumber, R.string.smscommunicator_calibrationsent));
|
||||||
|
else
|
||||||
|
sendSMS(new Sms(receivedSms.phoneNumber, R.string.smscommunicator_calibrationfailed));
|
||||||
|
}
|
||||||
|
});
|
||||||
|
} else
|
||||||
|
sendSMS(new Sms(receivedSms.phoneNumber, R.string.wrongformat));
|
||||||
|
}
|
||||||
|
|
||||||
public void sendNotificationToAllNumbers(String text) {
|
public void sendNotificationToAllNumbers(String text) {
|
||||||
for (int i = 0; i < allowedNumbers.size(); i++) {
|
for (int i = 0; i < allowedNumbers.size(); i++) {
|
||||||
Sms sms = new Sms(allowedNumbers.get(i), text);
|
Sms sms = new Sms(allowedNumbers.get(i), text);
|
||||||
|
|
|
||||||
|
|
@ -366,6 +366,7 @@
|
||||||
<string name="valuelimitedto">%1$.2f limited to %2$.2f</string>
|
<string name="valuelimitedto">%1$.2f limited to %2$.2f</string>
|
||||||
<string name="valueoutofrange" formatted="false">Value %s is out of hard limits</string>
|
<string name="valueoutofrange" formatted="false">Value %s is out of hard limits</string>
|
||||||
<string name="smscommunicator_remotecommandnotallowed">Remote command is not allowed</string>
|
<string name="smscommunicator_remotecommandnotallowed">Remote command is not allowed</string>
|
||||||
|
<string name="smscommunicator_remotebolusnotallowed">Remote bolus not available. Try again later.</string>
|
||||||
<string name="smscommunicator_basalreplywithcode">To start basal %1$.2fU/h reply with code %2$s</string>
|
<string name="smscommunicator_basalreplywithcode">To start basal %1$.2fU/h reply with code %2$s</string>
|
||||||
<string name="smscommunicator_extendedreplywithcode">To start extended bolus %1$.2fU for %2$d min reply with code %3$s</string>
|
<string name="smscommunicator_extendedreplywithcode">To start extended bolus %1$.2fU for %2$d min reply with code %3$s</string>
|
||||||
<string name="smscommunicator_basalpctreplywithcode">To start basal %1$d%% reply with code %2$s</string>
|
<string name="smscommunicator_basalpctreplywithcode">To start basal %1$d%% reply with code %2$s</string>
|
||||||
|
|
@ -1320,6 +1321,7 @@
|
||||||
<string name="storage">internal storage constraint</string>
|
<string name="storage">internal storage constraint</string>
|
||||||
<string name="diskfull">Free at least %1$d MB from internal storage! Loop disabled!</string>
|
<string name="diskfull">Free at least %1$d MB from internal storage! Loop disabled!</string>
|
||||||
<string name="wrongformat">Wrong format</string>
|
<string name="wrongformat">Wrong format</string>
|
||||||
|
<string name="sms_wrongcode">Wrong code. Command cancelled.</string>
|
||||||
<plurals name="objective_days">
|
<plurals name="objective_days">
|
||||||
<item quantity="one">%1$d day</item>
|
<item quantity="one">%1$d day</item>
|
||||||
<item quantity="other">%1$d days</item>
|
<item quantity="other">%1$d days</item>
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue