Added alerts for when the WiFire leaves the geofence

Author: Simon Pinfold

app/src/main/java/com/imgtec/hobbyist/flow/AlertListener.java

@@ -0,0 +1,8 @@
+package com.imgtec.hobbyist.flow;
+
+/**
+ * Created by simon.pinfold on 09/02/2015.
+ */
+public interface AlertListener {
+  void onAlertReceived(AsyncMessage asyncMsg);
+}

app/src/main/java/com/imgtec/hobbyist/flow/AsyncMessage.java

@@ -31,7 +31,7 @@
 public class AsyncMessage {
 
   public enum MessageType {
-    COMMAND("command"), RESPONSE("response"), MESSAGE("message"), EMPTY("");
+    COMMAND("command"), RESPONSE("response"), MESSAGE("message"), ALERT("alert"), EMPTY("");
 
     String string;
 
@@ -122,15 +122,15 @@ public void setNodesFromXml(String xml) {
       }
     } catch (XmlPullParserException | IOException e) {
       DebugLogger.log(getClass().getSimpleName(), "parsing xml failed");
-        e.printStackTrace();
+      e.printStackTrace();
     }
   }
 
   public void setType(MessageType type) {
-    if (type.equals(MessageType.COMMAND) || type.equals(MessageType.RESPONSE) || type.equals(MessageType.MESSAGE)) {
+    if (type.equals(MessageType.COMMAND) || type.equals(MessageType.RESPONSE) || type.equals(MessageType.MESSAGE) || type.equals(MessageType.ALERT)) {
       this.type = type;
     } else {
-      throw new IllegalArgumentException("Message must have a type of COMMAND, RESPONSE or MESSAGE");
+      throw new IllegalArgumentException("Message must have a type of COMMAND, RESPONSE, ALERT or MESSAGE");
     }
   }
 

app/src/main/java/com/imgtec/hobbyist/flow/FlowEntities.java

@@ -61,6 +61,7 @@ public class FlowEntities {
    * Listeners which inform appropriate parts of app UI about changes in flow.
    */
   private AsyncMessageListener asyncMessageListener;
+  private AlertListener alertListener;
   private List<DevicePresenceListener> devicePresenceListeners = new ArrayList<>();
   private List<DeviceToFlowConnectionListener> deviceToFlowConnectionListeners = new ArrayList<>();
   private List<DeviceOnlineInFlowListener> deviceOnlineInFlowListeners = new ArrayList<>();
@@ -90,6 +91,14 @@ public void handleMessage(Message msg) {
             case COMMAND:
               asyncMessageListener.onCommandMessageReceived(asyncMsg);
               break;
+            case ALERT:
+              new Thread(new Runnable() {
+                public void run() {
+                  if (alertListener != null) {
+                    alertListener.onAlertReceived(asyncMsg);
+                  }
+                }
+              }).start();
             case RESPONSE:
               new Thread(new Runnable() {
                 public void run() {
@@ -458,4 +467,8 @@ public WifireDevice getCurrentDevice() {
   public void setCurrentDevice(WifireDevice currentDevice) {
     this.currentDevice = currentDevice;
   }
+
+  public void setAlertListener(AlertListener alertListener) {
+    this.alertListener = alertListener;
+  }
 }

app/src/main/java/com/imgtec/hobbyist/flow/FlowHelper.java

@@ -40,6 +40,7 @@
 import com.imgtec.flow.client.users.UserHelper;
 import com.imgtec.hobbyist.R;
 import com.imgtec.hobbyist.activities.ActivitiesAndFragmentsHelper;
+import com.imgtec.hobbyist.fragments.menu.InteractiveModeFragment;
 import com.imgtec.hobbyist.utils.Constants;
 import com.imgtec.hobbyist.utils.DateFormatter;
 import com.imgtec.hobbyist.utils.DebugLogger;
@@ -481,4 +482,8 @@ public void addDeviceOnlineInFlowListener(DeviceOnlineInFlowListener listener) {
   public void removeDeviceOnlineInFlowListener(DeviceOnlineInFlowListener listener) {
     flowEntities.removeDeviceOnlineInFlowListener(listener);
   }
+
+  public void setAlertListener(AlertListener alertListener) {
+    flowEntities.setAlertListener(alertListener);
+  }
 }

app/src/main/java/com/imgtec/hobbyist/fragments/menu/InteractiveModeFragment.java

@@ -15,7 +15,9 @@
 package com.imgtec.hobbyist.fragments.menu;
 
 import android.app.Activity;
+import android.app.AlertDialog;
 import android.content.Context;
+import android.content.DialogInterface;
 import android.content.Intent;
 import android.content.IntentFilter;
 import android.graphics.Color;
@@ -60,16 +62,19 @@
 import com.google.android.gms.maps.model.MarkerOptions;
 import com.google.android.gms.maps.model.Polyline;
 import com.google.android.gms.maps.model.PolylineOptions;
+import com.imgtec.flow.Flow;
 import com.imgtec.flow.MessagingEvent;
 import com.imgtec.flow.client.users.DataStore;
 import com.imgtec.flow.client.users.DataStoreItem;
 import com.imgtec.flow.client.users.DataStoreItems;
 import com.imgtec.hobbyist.R;
 import com.imgtec.hobbyist.activities.ActivitiesAndFragmentsHelper;
 import com.imgtec.hobbyist.activities.FlowActivity;
+import com.imgtec.hobbyist.flow.AlertListener;
 import com.imgtec.hobbyist.flow.AsyncMessage;
 import com.imgtec.hobbyist.flow.AsyncMessageListener;
 import com.imgtec.hobbyist.flow.DevicePresenceListener;
+import com.imgtec.hobbyist.flow.FlowEntities;
 import com.imgtec.hobbyist.flow.FlowHelper;
 import com.imgtec.hobbyist.flow.GPSReading;
 import com.imgtec.hobbyist.flow.Geofence;
@@ -90,6 +95,9 @@
 import java.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Collections;
+import java.util.Comparator;
 import java.util.Date;
 import java.util.HashMap;
 import java.util.Iterator;
@@ -105,7 +113,7 @@
 public class InteractiveModeFragment extends NDListeningFragment implements
         BackgroundExecutor.Callbacks<List<GPSReading>>, GooglePlayServicesClient.ConnectionCallbacks,
         GooglePlayServicesClient.OnConnectionFailedListener,  LocationListener, AsyncMessageListener,
-        DevicePresenceListener {
+        DevicePresenceListener, AlertListener {
 
     // **************** Constants  *********************
     public static final String TAG = "InteractiveModeFragment";
@@ -244,6 +252,7 @@ public void onResume() {
         flowHelper.addDevicePresenceListener(this);
         connectionReceiver = new ConnectivityReceiver(new IntentFilter(ConnectivityManager.CONNECTIVITY_ACTION));
         connectionReceiver.register(appContext);
+
         //online = true;
         fetchWiFireLocation();
         sendCommand("GET GEOFENCE", null, new CommandResponseHandler() {
@@ -325,6 +334,7 @@ public void onPause() {
     private void initFlowHelper() {
         flowHelper = FlowHelper.getInstance(getActivity());
         flowHelper.setAsyncMessageListener(this);
+        flowHelper.setAlertListener(this);
     }
 
     public void initUI() {
@@ -602,7 +612,31 @@ public void run() {
         //fetchWiFireLocation();
     }
 
-    private interface CommandResponseHandler {
+  @Override
+  public void onAlertReceived(AsyncMessage asyncMsg) {
+    if (asyncMsg.getNode("type").equals("GEOFENCE ESCAPED")) {
+      getActivity().runOnUiThread(new Runnable() {
+        @Override
+        public void run() {
+          new AlertDialog.Builder(getActivity())
+                  .setTitle("Escaped Geofence")
+                  .setMessage("The GPS has been detected outside the geofence!")
+                  .setNeutralButton("OK",
+                    new DialogInterface.OnClickListener() {
+                      public void onClick(DialogInterface dialog, int id) {
+                        dialog.cancel();
+                      }
+                    })
+                  .setIcon(android.R.drawable.ic_dialog_alert)
+                  .show();
+        }
+      });
+    }
+    Log.e("onAlertReceived", asyncMsg.buildXml());
+    Log.e("onAlertReceived", asyncMsg.getNode("type"));
+  }
+
+  private interface CommandResponseHandler {
         void onCommandResponse(AsyncMessage response);
     }
     private void fetchWiFireLocation() {