adding a method retrieveNodes

fabOnReact · Feb 9, 2024 · 1b3552c · 1b3552c
1 parent e27b204
commit 1b3552c
Show file tree

Hide file tree

Showing 2 changed files with 53 additions and 43 deletions.
diff --git a/android/src/main/java/com/wearconnectivity/WearConnectivityModule.java b/android/src/main/java/com/wearconnectivity/WearConnectivityModule.java
@@ -1,21 +1,15 @@
 package com.wearconnectivity;
 
-import static com.google.android.gms.common.api.GoogleApiClient.ConnectionCallbacks.CAUSE_NETWORK_LOST;
-
 import android.util.Log;
-import android.widget.Toast;
 import androidx.annotation.NonNull;
 import androidx.annotation.Nullable;
-
-import com.facebook.common.logging.FLog;
 import com.facebook.react.bridge.LifecycleEventListener;
 import com.facebook.react.bridge.Promise;
 import com.facebook.react.bridge.ReactApplicationContext;
 import com.facebook.react.bridge.ReactContext;
 import com.facebook.react.bridge.ReactMethod;
 import com.facebook.react.bridge.WritableMap;
 import com.facebook.react.modules.core.DeviceEventManagerModule;
-import com.facebook.react.util.RNLog;
 import com.google.android.gms.tasks.OnFailureListener;
 import com.google.android.gms.tasks.OnSuccessListener;
 import com.google.android.gms.tasks.Task;
@@ -37,7 +31,10 @@ public class WearConnectivityModule extends WearConnectivitySpec
     super(context);
     context.addLifecycleEventListener(this);
     client = Wearable.getMessageClient(context);
-    Log.d(TAG, TAG + "onMessageReceived listener added when activity is created. Client receives messages.");
+    Log.d(
+        TAG,
+        TAG
+            + "onMessageReceived listener added when activity is created. Client receives messages.");
     client.addListener(this);
   }
 
@@ -54,47 +51,49 @@ public void multiply(double a, double b, Promise promise) {
     promise.resolve(a * b);
   }
 
-  @ReactMethod
-  public void sendMessage(String path, Promise promise) {
+  private List<Node> retrieveNodes(Promise promise) {
     try {
       NodeClient nodeClient = Wearable.getNodeClient(getReactApplicationContext());
-      List<Node> nodes = Tasks.await(nodeClient.getConnectedNodes());
-      if (nodes.size() > 0) {
-        for (Node node : nodes) {
-          // TODO: Add check that node is listening (companion app activity is used)
-          // https://developers.google.com/android/reference/com/google/android/gms/wearable/Node
-          if (node.isNearby()) {
-            sendMessageToClient(path, node, promise);
-          }
-        }
-      } else {
-        promise.reject(TAG, TAG + "sendMessage failed. No connected nodes found.");
-      }
+      // TODO: implement Runnable to run task in the background thread
+      // https://stackoverflow.com/a/64969640/7295772
+      return Tasks.await(nodeClient.getConnectedNodes());
     } catch (Exception e) {
       promise.reject(TAG, TAG + "sendMessage failed with exception: " + e);
+      return null;
+    }
+  }
+
+  @ReactMethod
+  public void sendMessage(String path, Promise promise) {
+    List<Node> connectedNodes = retrieveNodes(promise);
+    if (connectedNodes != null && connectedNodes.size() > 0 && client != null) {
+      for (Node connectedNode : connectedNodes) {
+        if (connectedNode.isNearby()) {
+          sendMessageToClient(path, connectedNode, promise);
+        }
+      }
+    } else {
+      promise.reject(
+          TAG,
+          TAG
+              + "sendMessage failed. No connected nodes found. client: "
+              + client
+              + " connectedNodes: "
+              + connectedNodes);
     }
   }
 
   private void sendMessageToClient(String path, Node node, Promise promise) {
     try {
-      Task<Integer> sendTask =
-          Wearable.getMessageClient(getReactApplicationContext())
-              .sendMessage(node.getId(), path, null);
+      // the last parameter is for file transfer (for ex. audio)
+      Task<Integer> sendTask = client.sendMessage(node.getId(), path, null);
       OnSuccessListener<Object> onSuccessListener =
-          new OnSuccessListener<Object>() {
-            @Override
-            public void onSuccess(Object object) {
+          object ->
               promise.resolve(TAG + "message sent to client with nodeID: " + object.toString());
-            }
-          };
-      sendTask.addOnSuccessListener(onSuccessListener);
       OnFailureListener onFailureListener =
-          new OnFailureListener() {
-            @Override
-            public void onFailure(@NonNull Exception e) {
-              promise.reject(TAG, TAG + "sendMessage failed: " + e);
-            }
-          };
+          object ->
+              promise.resolve(TAG + "message sent to client with nodeID: " + object.toString());
+      sendTask.addOnSuccessListener(onSuccessListener);
       sendTask.addOnFailureListener(onFailureListener);
     } catch (Exception e) {
       promise.reject(TAG, TAG + "sendMessage failed: " + e);
@@ -116,20 +115,29 @@ private void sendEvent(
   @Override
   public void onHostResume() {
     if (client != null) {
-      Log.d(TAG, TAG + "onMessageReceived listener added when activity is resumed. Client receives messages.");
+      Log.d(
+          TAG,
+          TAG
+              + "onMessageReceived listener added when activity is resumed. Client receives messages.");
       client.addListener(this);
     }
   }
 
   @Override
   public void onHostPause() {
-    Log.d(TAG, TAG + "onMessageReceived listener removed when the activity paused. Client does not receive messages.");
+    Log.d(
+        TAG,
+        TAG
+            + "onMessageReceived listener removed when the activity paused. Client does not receive messages.");
     client.removeListener(this);
   }
 
   @Override
   public void onHostDestroy() {
-    Log.d(TAG, TAG + "onMessageReceived listener removed when activity is destroyed. Client does not receive messages.");
+    Log.d(
+        TAG,
+        TAG
+            + "onMessageReceived listener removed when activity is destroyed. Client does not receive messages.");
     client.removeListener(this);
   }
 }
diff --git a/watch-example/src/App.tsx b/watch-example/src/App.tsx
@@ -37,13 +37,15 @@ export default function App() {
     };
   }, []);
 
+  const sendMessageToPhone = async () => {
+    const result = await sendMessage(INCREASE_PHONE_COUNTER_EVENT);
+    console.log(result);
+  };
+
   return (
     <View style={styles.container}>
       <Text>count is: {count}</Text>
-      <TouchableOpacity
-        onPress={() => sendMessage(INCREASE_PHONE_COUNTER_EVENT)}
-        style={styles.button}
-      />
+      <TouchableOpacity onPress={sendMessageToPhone} style={styles.button} />
     </View>
   );
 }