fix(data): implement data threads

Signed-off-by: Rafa Hernandez <[email protected]>
flyve-mdm · Jul 6, 2018 · 29380e4 · 29380e4
1 parent 4bfa08b
commit 29380e4
Showing 1 changed file with 30 additions and 12 deletions.
diff --git a/app/src/main/java/org/flyve/mdm/agent/data/database/MqttData.java b/app/src/main/java/org/flyve/mdm/agent/data/database/MqttData.java
@@ -28,9 +28,12 @@
  */
 
 import android.content.Context;
+import android.os.Handler;
+import android.os.HandlerThread;
+import android.os.Looper;
 
-import org.flyve.mdm.agent.data.database.setup.AppDataBase;
 import org.flyve.mdm.agent.data.database.entity.MQTT;
+import org.flyve.mdm.agent.data.database.setup.AppDataBase;
 
 import java.util.List;
 
@@ -57,6 +60,15 @@ public class MqttData {
 
     private AppDataBase dataBase;
 
+    private static Handler uiHandler;
+
+    static {
+        uiHandler = new Handler(Looper.getMainLooper());
+    }
+    private static void runOnUI(Runnable runnable) {
+        uiHandler.post(runnable);
+    }
+
     public MqttData(Context context) {
         dataBase = AppDataBase.getAppDatabase(context);
     }
@@ -218,16 +230,22 @@ private String getStringValue(String name) {
         }
     }
 
-    private void setStringValue(String name, String value) {
-        if(dataBase.MQTTDao().getByName(name).isEmpty()) {
-            MQTT mqtt = new MQTT();
-            mqtt.name = name;
-            mqtt.value = value;
-            dataBase.MQTTDao().insert(mqtt);
-        } else {
-            MQTT mqtt = dataBase.MQTTDao().getByName(name).get(0);
-            mqtt.value = value;
-            dataBase.MQTTDao().update(mqtt);
-        }
+    private void setStringValue(final String name, final String value) {
+        Thread t = new HandlerThread("UIHandler") {
+            @Override
+            public void run() {
+                if (dataBase.MQTTDao().getByName(name).isEmpty()) {
+                    MQTT mqtt = new MQTT();
+                    mqtt.name = name;
+                    mqtt.value = value;
+                    dataBase.MQTTDao().insert(mqtt);
+                } else {
+                    MQTT mqtt = dataBase.MQTTDao().getByName(name).get(0);
+                    mqtt.value = value;
+                    dataBase.MQTTDao().update(mqtt);
+                }
+            }
+        };
+        t.start();
     }
 }