From 529e0bdd47d505bb599cfa62a5bbf12b542c2063 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Nicol=C3=A1s=20S=C3=A1nchez?= <nicolassanchez@tutanota.com>
Date: Wed, 18 Dec 2024 11:50:46 -0300
Subject: [PATCH] fetchWorkerData, but using handlers

---
 .idea/deploymentTargetSelector.xml            |  4 +--
 .../example/dcav2gui/InstanceInterface.java   | 10 -------
 .../ui/exchanges/BinanceViewModel.java        | 28 +++++++++++++------
 .../ui/exchanges/GateioViewModel.java         | 26 ++++++++++++-----
 .../ui/exchanges/KucoinViewModel.java         | 26 ++++++++++++-----
 .../dcav2gui/ui/exchanges/OkxViewModel.java   | 26 ++++++++++++-----
 6 files changed, 78 insertions(+), 42 deletions(-)

diff --git a/.idea/deploymentTargetSelector.xml b/.idea/deploymentTargetSelector.xml
index aaacefd..6c70bfb 100644
--- a/.idea/deploymentTargetSelector.xml
+++ b/.idea/deploymentTargetSelector.xml
@@ -4,10 +4,10 @@
     <selectionStates>
       <SelectionState runConfigName="app">
         <option name="selectionMode" value="DROPDOWN" />
-        <DropdownSelection timestamp="2024-12-18T13:29:16.439093075Z">
+        <DropdownSelection timestamp="2024-12-18T13:48:59.828906476Z">
           <Target type="DEFAULT_BOOT">
             <handle>
-              <DeviceId pluginId="LocalEmulator" identifier="path=/home/nicolas/.android/avd/Pixel_6_Pro_API_34.avd" />
+              <DeviceId pluginId="PhysicalDevice" identifier="serial=ZY22FN7MHQ" />
             </handle>
           </Target>
         </DropdownSelection>
diff --git a/app/src/main/java/com/example/dcav2gui/InstanceInterface.java b/app/src/main/java/com/example/dcav2gui/InstanceInterface.java
index 8801352..bfc2888 100644
--- a/app/src/main/java/com/example/dcav2gui/InstanceInterface.java
+++ b/app/src/main/java/com/example/dcav2gui/InstanceInterface.java
@@ -651,16 +651,6 @@ public class InstanceInterface {
 
     }
 
-    public static List<WorkerData> fetchWorkersDataForCards(String exchange) throws IOException {
-        // Implement this method to fetch actual data
-        // call List<WorkerStatsData> getAllWorkersStats from InstanceInterface and
-        // translate all the WorkerStatsData objects to WorkerData objects!
-        // Example implementation:
-        List<InstanceInterface.WorkerStatsData> workerStatsDataList = InstanceInterface.getAllWorkersStats(exchange, true);
-        return translateToWorkerData(workerStatsDataList);
-    }
-
-
     public static class DealData {
         private final double timestamp;
         private final String pair;
diff --git a/app/src/main/java/com/example/dcav2gui/ui/exchanges/BinanceViewModel.java b/app/src/main/java/com/example/dcav2gui/ui/exchanges/BinanceViewModel.java
index ca9128e..ebf0f43 100644
--- a/app/src/main/java/com/example/dcav2gui/ui/exchanges/BinanceViewModel.java
+++ b/app/src/main/java/com/example/dcav2gui/ui/exchanges/BinanceViewModel.java
@@ -1,6 +1,8 @@
 package com.example.dcav2gui.ui.exchanges;
 import android.app.Application;
-import android.util.Log;
+import android.os.Handler;
+import android.os.HandlerThread;
+import android.os.Looper;
 
 import androidx.annotation.NonNull;
 import androidx.lifecycle.AndroidViewModel;
@@ -34,19 +36,27 @@ public class BinanceViewModel extends AndroidViewModel {
     }
 
     private void fetchWorkerData() {
-        new Thread(() -> {
-            while (true) {
+        HandlerThread handlerThread = new HandlerThread("FetchWorkerDataThread");
+        handlerThread.start();
+        Handler handler = new Handler(handlerThread.getLooper());
+        handler.post(new Runnable() {
+            @Override
+            public void run() {
                 try {
-                    Thread.sleep((long) settingsData.timeBetweenQueries*1000);
                     // Fetch and update the data
-                    List<WorkerData> newData = InstanceInterface.fetchWorkersDataForCards("binance");
-                    //System.err.println(newData.toString());
+                    List<WorkerData> newData = InstanceInterface.translateToWorkerData(InstanceInterface.getAllWorkersStats("binance", true));
                     workerDataList.postValue(newData);
-                } catch (InterruptedException | IOException e) {
+                } catch (IOException e) {
                     e.printStackTrace();
                 }
+                // Schedule the next execution
+                new Handler(Looper.getMainLooper()).postDelayed(new Runnable() {
+                    @Override
+                    public void run() {
+                        fetchWorkerData();
+                    }
+                }, (long) settingsData.timeBetweenQueries * 1000);
             }
-        }).start();
+        });
     }
-
 }
\ No newline at end of file
diff --git a/app/src/main/java/com/example/dcav2gui/ui/exchanges/GateioViewModel.java b/app/src/main/java/com/example/dcav2gui/ui/exchanges/GateioViewModel.java
index d5609da..8ce9b29 100644
--- a/app/src/main/java/com/example/dcav2gui/ui/exchanges/GateioViewModel.java
+++ b/app/src/main/java/com/example/dcav2gui/ui/exchanges/GateioViewModel.java
@@ -1,5 +1,8 @@
 package com.example.dcav2gui.ui.exchanges;
 import android.app.Application;
+import android.os.Handler;
+import android.os.HandlerThread;
+import android.os.Looper;
 
 import androidx.annotation.NonNull;
 import androidx.lifecycle.AndroidViewModel;
@@ -33,19 +36,28 @@ public class GateioViewModel extends AndroidViewModel {
     }
 
     private void fetchWorkerData() {
-        new Thread(() -> {
-            while (true) {
+        HandlerThread handlerThread = new HandlerThread("FetchWorkerDataThread");
+        handlerThread.start();
+        Handler handler = new Handler(handlerThread.getLooper());
+        handler.post(new Runnable() {
+            @Override
+            public void run() {
                 try {
-                    Thread.sleep((long) settingsData.timeBetweenQueries*1000);
                     // Fetch and update the data
-                    List<WorkerData> newData = InstanceInterface.fetchWorkersDataForCards("gateio");
-                    //System.err.println(newData.toString());
+                    List<WorkerData> newData = InstanceInterface.translateToWorkerData(InstanceInterface.getAllWorkersStats("gateio", true));
                     workerDataList.postValue(newData);
-                } catch (InterruptedException | IOException e) {
+                } catch (IOException e) {
                     e.printStackTrace();
                 }
+                // Schedule the next execution
+                new Handler(Looper.getMainLooper()).postDelayed(new Runnable() {
+                    @Override
+                    public void run() {
+                        fetchWorkerData();
+                    }
+                }, (long) settingsData.timeBetweenQueries * 1000);
             }
-        }).start();
+        });
     }
 
 }
\ No newline at end of file
diff --git a/app/src/main/java/com/example/dcav2gui/ui/exchanges/KucoinViewModel.java b/app/src/main/java/com/example/dcav2gui/ui/exchanges/KucoinViewModel.java
index 72a2661..3d7481a 100644
--- a/app/src/main/java/com/example/dcav2gui/ui/exchanges/KucoinViewModel.java
+++ b/app/src/main/java/com/example/dcav2gui/ui/exchanges/KucoinViewModel.java
@@ -1,5 +1,8 @@
 package com.example.dcav2gui.ui.exchanges;
 import android.app.Application;
+import android.os.Handler;
+import android.os.HandlerThread;
+import android.os.Looper;
 
 import androidx.annotation.NonNull;
 import androidx.lifecycle.AndroidViewModel;
@@ -33,19 +36,28 @@ public class KucoinViewModel extends AndroidViewModel {
     }
 
     private void fetchWorkerData() {
-        new Thread(() -> {
-            while (true) {
+        HandlerThread handlerThread = new HandlerThread("FetchWorkerDataThread");
+        handlerThread.start();
+        Handler handler = new Handler(handlerThread.getLooper());
+        handler.post(new Runnable() {
+            @Override
+            public void run() {
                 try {
-                    Thread.sleep((long) settingsData.timeBetweenQueries*1000);
                     // Fetch and update the data
-                    List<WorkerData> newData = InstanceInterface.fetchWorkersDataForCards("kucoin");
-                    //System.err.println(newData.toString());
+                    List<WorkerData> newData = InstanceInterface.translateToWorkerData(InstanceInterface.getAllWorkersStats("kucoin", true));
                     workerDataList.postValue(newData);
-                } catch (InterruptedException | IOException e) {
+                } catch (IOException e) {
                     e.printStackTrace();
                 }
+                // Schedule the next execution
+                new Handler(Looper.getMainLooper()).postDelayed(new Runnable() {
+                    @Override
+                    public void run() {
+                        fetchWorkerData();
+                    }
+                }, (long) settingsData.timeBetweenQueries * 1000);
             }
-        }).start();
+        });
     }
 
 }
\ No newline at end of file
diff --git a/app/src/main/java/com/example/dcav2gui/ui/exchanges/OkxViewModel.java b/app/src/main/java/com/example/dcav2gui/ui/exchanges/OkxViewModel.java
index 9fc75d0..5e43807 100644
--- a/app/src/main/java/com/example/dcav2gui/ui/exchanges/OkxViewModel.java
+++ b/app/src/main/java/com/example/dcav2gui/ui/exchanges/OkxViewModel.java
@@ -1,5 +1,8 @@
 package com.example.dcav2gui.ui.exchanges;
 import android.app.Application;
+import android.os.Handler;
+import android.os.HandlerThread;
+import android.os.Looper;
 
 import androidx.annotation.NonNull;
 import androidx.lifecycle.AndroidViewModel;
@@ -33,19 +36,28 @@ public class OkxViewModel extends AndroidViewModel {
     }
 
     private void fetchWorkerData() {
-        new Thread(() -> {
-            while (true) {
+        HandlerThread handlerThread = new HandlerThread("FetchWorkerDataThread");
+        handlerThread.start();
+        Handler handler = new Handler(handlerThread.getLooper());
+        handler.post(new Runnable() {
+            @Override
+            public void run() {
                 try {
-                    Thread.sleep((long) settingsData.timeBetweenQueries*1000);
                     // Fetch and update the data
-                    List<WorkerData> newData = InstanceInterface.fetchWorkersDataForCards("okex");
-                    //System.err.println(newData.toString());
+                    List<WorkerData> newData = InstanceInterface.translateToWorkerData(InstanceInterface.getAllWorkersStats("okex", true));
                     workerDataList.postValue(newData);
-                } catch (InterruptedException | IOException e) {
+                } catch (IOException e) {
                     e.printStackTrace();
                 }
+                // Schedule the next execution
+                new Handler(Looper.getMainLooper()).postDelayed(new Runnable() {
+                    @Override
+                    public void run() {
+                        fetchWorkerData();
+                    }
+                }, (long) settingsData.timeBetweenQueries * 1000);
             }
-        }).start();
+        });
     }
 
 }
\ No newline at end of file