Add support for file transfers (#39)

Author: fabOnReact

README.md

@@ -71,6 +71,14 @@ const unsubscribe = watchEvents.on('message', (message) => {
 });
 ```
 
+### Send Files
+
+```js
+import { sendFile } from 'react-native-wear-connectivity';
+
+await sendFile(filePath);
+```
+
 ## Jetpack Compose API Documentation
 
 ### Send Messages

android/src/main/java/com/wearconnectivity/WearConnectivityDataClient.java

@@ -0,0 +1,74 @@
+package com.wearconnectivity;
+
+import android.util.Log;
+import com.facebook.common.logging.FLog;
+import com.facebook.react.bridge.Promise;
+import com.google.android.gms.tasks.Task;
+import com.google.android.gms.wearable.Asset;
+import com.google.android.gms.wearable.DataClient;
+import com.google.android.gms.wearable.DataItem;
+import com.google.android.gms.wearable.PutDataMapRequest;
+import com.google.android.gms.wearable.PutDataRequest;
+import com.google.android.gms.wearable.Wearable;
+import com.facebook.react.bridge.ReactApplicationContext;
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.FileOutputStream;
+import java.io.IOException;
+
+public class WearConnectivityDataClient {
+    private static final String TAG = "WearConnectivityDataClient";
+    private DataClient dataClient;
+    private static ReactApplicationContext reactContext;
+
+    public WearConnectivityDataClient(ReactApplicationContext context) {
+        dataClient = Wearable.getDataClient(context);
+        reactContext = context;
+    }
+
+    /**
+     * Sends a file (as an Asset) using the DataClient API.
+     * @param path to the file to be sent.
+     */
+    public void sendFile(String uri, Promise promise) {
+        File file = new File(uri);
+        Asset asset = createAssetFromFile(file);
+        if (asset == null) {
+            FLog.w(TAG, "Failed to create asset from file.");
+            return;
+        }
+        // Create a DataMapRequest with a defined path.
+        PutDataMapRequest dataMapRequest = PutDataMapRequest.create("/file_transfer");
+        dataMapRequest.getDataMap().putAsset("file", asset);
+        dataMapRequest.getDataMap().putLong("timestamp", System.currentTimeMillis());
+        PutDataRequest request = dataMapRequest.asPutDataRequest();
+        Task<DataItem> task = dataClient.putDataItem(request);
+        task.addOnSuccessListener(dataItem -> {
+            promise.resolve("File sent successfully via DataClient.");
+        }).addOnFailureListener(e -> {
+            promise.reject("File sending failed: " + e);
+        });
+    }
+
+    /**
+     * Helper method to create an Asset from a file.
+     * @param file the file to convert.
+     * @return the resulting Asset, or null if an error occurred.
+     */
+    private Asset createAssetFromFile(File file) {
+        try {
+            FileInputStream fileInputStream = new FileInputStream(file);
+            byte[] byteArray = new byte[(int) file.length()];
+            fileInputStream.read(byteArray);
+            fileInputStream.close();
+            return Asset.createFromBytes(byteArray);
+        } catch (IOException e) {
+            e.printStackTrace();
+            return null;
+        }
+    }
+
+    private static ReactApplicationContext getReactContext() {
+        return reactContext;
+    }
+}

android/src/main/java/com/wearconnectivity/WearConnectivityModule.java

@@ -1,22 +1,18 @@
 package com.wearconnectivity;
 
-import android.app.ActivityManager;
-import android.content.Context;
 import android.os.Build;
 import android.util.Log;
 import androidx.annotation.NonNull;
-import androidx.annotation.Nullable;
 import com.facebook.common.logging.FLog;
 import com.facebook.react.bridge.Arguments;
 import com.facebook.react.bridge.Callback;
 import com.facebook.react.bridge.JSONArguments;
 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.ReadableMap;
 import com.facebook.react.bridge.WritableMap;
-import com.facebook.react.modules.core.DeviceEventManagerModule;
 import com.google.android.gms.common.ConnectionResult;
 import com.google.android.gms.tasks.OnFailureListener;
 import com.google.android.gms.tasks.OnSuccessListener;
@@ -27,6 +23,7 @@
 import com.google.android.gms.wearable.Node;
 import com.google.android.gms.wearable.NodeClient;
 import com.google.android.gms.wearable.Wearable;
+
 import java.util.List;
 import org.json.JSONException;
 import org.json.JSONObject;
@@ -43,7 +40,10 @@ public class WearConnectivityModule extends WearConnectivitySpec
   private static ReactApplicationContext reactContext;
   public static final String NAME = "WearConnectivity";
   private static final String TAG = "react-native-wear-connectivity ";
-  private final MessageClient client;
+  private final MessageClient messageClient;
+  private final WearConnectivityDataClient dataClient;
+  private boolean isListenerAdded = false;
+
   private String CLIENT_ADDED =
       TAG + "onMessageReceived listener added when activity is created. Client receives messages.";
   private String NO_NODES_FOUND = TAG + "sendMessage failed. No connected nodes found.";
@@ -61,9 +61,10 @@ public class WearConnectivityModule extends WearConnectivitySpec
     super(context);
     reactContext = context;
     context.addLifecycleEventListener(this);
-    client = Wearable.getMessageClient(context);
+    messageClient = Wearable.getMessageClient(context);
+    dataClient = new WearConnectivityDataClient(context);
     Log.d(TAG, CLIENT_ADDED);
-    client.addListener(this);
+    messageClient.addListener(this);
   }
 
   @Override
@@ -72,32 +73,19 @@ public String getName() {
     return NAME;
   }
 
-  private List<Node> retrieveNodes(Callback errorCb) {
-    try {
-      int result = GoogleApiAvailability.getInstance().isGooglePlayServicesAvailable(getReactApplicationContext());
-      ConnectionResult connectionResult = new ConnectionResult(result);
-      if (!connectionResult.isSuccess()) {
-        errorCb.invoke( MISSING_GOOGLE_PLAY_SERVICES + connectionResult.getErrorMessage());
-        return null;
-      }
-      NodeClient nodeClient = Wearable.getNodeClient(getReactApplicationContext());
-      try {
-        Tasks.await(GoogleApiAvailability.getInstance().checkApiAvailability(nodeClient));
-      } catch (Exception e) {
-        errorCb.invoke(INSTALL_GOOGLE_PLAY_WEARABLE + e);
-        return null;
-      }
-      return Tasks.await(nodeClient.getConnectedNodes());
-    } catch (Exception e) {
-      errorCb.invoke(RETRIEVE_NODES_FAILED + e);
-      return null;
+  @ReactMethod
+  public void sendFile(String fileName, Promise promise) {
+    if (dataClient != null) {
+      dataClient.sendFile(fileName, promise);
+    } else {
+      promise.reject("E_SEND_FAILED", "Failed to send file");
     }
   }
 
   @ReactMethod
   public void sendMessage(ReadableMap messageData, Callback replyCb, Callback errorCb) {
     List<Node> connectedNodes = retrieveNodes(errorCb);
-    if (connectedNodes != null && connectedNodes.size() > 0 && client != null) {
+    if (connectedNodes != null && connectedNodes.size() > 0 && messageClient != null) {
       for (Node connectedNode : connectedNodes) {
         if (connectedNode.isNearby()) {
           sendMessageToClient(messageData, connectedNode, replyCb, errorCb);
@@ -122,7 +110,7 @@ private void sendMessageToClient(
     try {
       // the last parameter is for file transfer (for ex. audio)
       JSONObject messageJSON = new JSONObject(messageData.toHashMap());
-      Task<Integer> sendTask = client.sendMessage(node.getId(), messageJSON.toString(), null);
+      Task<Integer> sendTask = messageClient.sendMessage(node.getId(), messageJSON.toString(), null);
       sendTask.addOnSuccessListener(onSuccessListener);
       sendTask.addOnFailureListener(onFailureListener);
     } catch (Exception e) {
@@ -155,28 +143,52 @@ public void onMessageReceived(MessageEvent messageEvent) {
     }
   }
 
-  public static ReactApplicationContext getReactContext() {
-    return reactContext;
-  }
-
   @Override
   public void onHostResume() {
-    if (client != null) {
-      Log.d(TAG, ADD_CLIENT);
-      client.addListener(this);
+    if (messageClient != null && !isListenerAdded) {
+      Log.d(TAG, "Adding listener on host resume");
+      messageClient.addListener(this);
+      isListenerAdded = true;
     }
   }
 
   @Override
   public void onHostPause() {
-    // Log.d(TAG, REMOVE_CLIENT);
-    // removed this to allow to send updates when app is in the background
-    // client.removeListener(this);
+    Log.d(TAG, "onHostPause: leaving listener active for background events");
   }
 
   @Override
   public void onHostDestroy() {
-    Log.d(TAG, REMOVE_CLIENT);
-    client.removeListener(this);
+    if (messageClient != null && isListenerAdded) {
+      Log.d(TAG, "Removing listener on host destroy");
+      messageClient.removeListener(this);
+      isListenerAdded = false;
+    }
+  }
+
+  private List<Node> retrieveNodes(Callback errorCb) {
+    try {
+      int result = GoogleApiAvailability.getInstance().isGooglePlayServicesAvailable(getReactContext());
+      ConnectionResult connectionResult = new ConnectionResult(result);
+      if (!connectionResult.isSuccess()) {
+        errorCb.invoke( MISSING_GOOGLE_PLAY_SERVICES + connectionResult.getErrorMessage());
+        return null;
+      }
+      NodeClient nodeClient = Wearable.getNodeClient(getReactContext());
+      try {
+        Tasks.await(GoogleApiAvailability.getInstance().checkApiAvailability(nodeClient));
+      } catch (Exception e) {
+        errorCb.invoke(INSTALL_GOOGLE_PLAY_WEARABLE + e);
+        return null;
+      }
+      return Tasks.await(nodeClient.getConnectedNodes());
+    } catch (Exception e) {
+      errorCb.invoke(RETRIEVE_NODES_FAILED + e);
+      return null;
+    }
+  }
+
+  private static ReactApplicationContext getReactContext() {
+    return reactContext;
   }
 }

example/package.json

@@ -11,7 +11,8 @@
   },
   "dependencies": {
     "react": "18.3.1",
-    "react-native": "^0.77.0"
+    "react-native": "^0.77.1",
+    "react-native-image-picker": "^8.1.0"
   },
   "devDependencies": {
     "@babel/core": "^7.25.2",

example/src/CounterScreen/index.android.tsx

@@ -1,6 +1,11 @@
 import React, { useEffect } from 'react';
-import { View, StyleSheet, Text, Button } from 'react-native';
-import { sendMessage, watchEvents } from 'react-native-wear-connectivity';
+import { View, StyleSheet, Text, Button, Image } from 'react-native';
+import { launchImageLibrary } from 'react-native-image-picker';
+import {
+  sendFile,
+  sendMessage,
+  watchEvents,
+} from 'react-native-wear-connectivity';
 import type {
   ReplyCallback,
   ErrorCallback,
@@ -32,6 +37,24 @@ function CounterScreen() {
     sendMessage(json, onSuccess, onError);
   };
 
+  const sendFileToWear = async () => {
+    try {
+      // @ts-ignore
+      const result = await launchImageLibrary();
+      if (!result.assets || result.assets.length === 0) {
+        console.log('No asset selected');
+        return;
+      }
+      const asset = result.assets[0] || { uri: undefined };
+      if (asset.uri) {
+        const filePath = asset.uri.replace('file://', '');
+        await sendFile(filePath);
+      }
+    } catch (error) {
+      console.error('Error in sendFileToWear:', error);
+    }
+  };
+
   return (
     <View style={styles.container}>
       <Text style={styles.counter}>{count}</Text>
@@ -40,6 +63,7 @@ function CounterScreen() {
         title="increase counter"
         onPress={sendMessageToWear}
       />
+      <Button title="send file" onPress={sendFileToWear} />
     </View>
   );
 }

src/NativeWearConnectivity.ts

@@ -12,8 +12,11 @@ export type SendMessage = (
   errCb: ErrorCallback
 ) => void;
 
+export type SendFile = (file: string) => Promise<any>;
+
 export interface Spec extends TurboModule {
   sendMessage: SendMessage;
+  sendFile: SendFile;
 }
 
 export default TurboModuleRegistry.getEnforcing<Spec>('WearConnectivity');

src/index.tsx

@@ -2,7 +2,11 @@ import { AppRegistry } from 'react-native';
 import { NativeModules, Platform } from 'react-native';
 import { watchEvents } from './subscriptions';
 import { sendMessage } from './messages';
-import type { ReplyCallback, ErrorCallback } from './NativeWearConnectivity';
+import type {
+  ReplyCallback,
+  ErrorCallback,
+  SendFile,
+} from './NativeWearConnectivity';
 import { DeviceEventEmitter } from 'react-native';
 
 const LINKING_ERROR =
@@ -29,7 +33,11 @@ const WearConnectivity = WearConnectivityModule
       }
     );
 
-export { sendMessage, watchEvents, WearConnectivity };
+const sendFile: SendFile = (file) => {
+  return WearConnectivity.sendFile(file);
+};
+
+export { sendFile, sendMessage, watchEvents, WearConnectivity };
 export type { ReplyCallback, ErrorCallback };
 
 type WearParameters = {