[Feature] - Implement background job (#37)

Author: fabOnReact

README.md

@@ -31,6 +31,26 @@ or
 npm install react-native-wear-connectivity
 ```
 
+Add the following entry to your `android/app/src/main/AndroidManifest.xml` (full example of AndroidManifest available [here](example/android/app/src/main/AndroidManifest.xml)):
+
+```xml
+<manifest xmlns:android="http://schemas.android.com/apk/res/android">
+    <uses-permission android:name="android.permission.INTERNET" />
+    <!-- ADD THIS PERMISSIONS -->
+    <uses-permission android:name="android.permission.WAKE_LOCK"/>
+    <uses-permission android:name="android.permission.FOREGROUND_SERVICE" />
+    <!-- END OF THE CHANGES -->
+
+    <application>
+        <!-- ADD THIS SERVICE -->
+        <service android:name="com.wearconnectivity.WearConnectivityTask"
+          android:permission="android.permission.BIND_JOB_SERVICE"
+          android:exported="true" />
+        <!-- END OF THE CHANGES -->
+    </application>
+</manifest>
+```
+
 ## React Native API Documentation
 
 ### Send Messages

android/src/main/AndroidManifest.xml

@@ -1,3 +1,12 @@
 <manifest xmlns:android="http://schemas.android.com/apk/res/android"
           package="com.wearconnectivity">
+    <uses-permission android:name="android.permission.INTERNET" />
+    <uses-permission android:name="android.permission.WAKE_LOCK"/>
+    <uses-permission android:name="android.permission.FOREGROUND_SERVICE" />
+    <service android:name="com.wearconnectivity.WearConnectivityTask"
+        android:permission="android.permission.BIND_JOB_SERVICE"
+        android:exported="true"  />
+    <intent-filter>
+      <action android:name="com.facebook.react.HeadlessJsTaskService" />
+    </intent-filter>
 </manifest>

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

@@ -1,9 +1,13 @@
 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;
@@ -28,8 +32,15 @@
 import org.json.JSONObject;
 import com.google.android.gms.common.GoogleApiAvailability;
 
+import androidx.annotation.RequiresApi;
+import com.facebook.react.HeadlessJsTaskService;
+import android.content.Intent;
+import android.os.Bundle;
+
 public class WearConnectivityModule extends WearConnectivitySpec
     implements MessageClient.OnMessageReceivedListener, LifecycleEventListener {
+
+  private static ReactApplicationContext reactContext;
   public static final String NAME = "WearConnectivity";
   private static final String TAG = "react-native-wear-connectivity ";
   private final MessageClient client;
@@ -48,6 +59,7 @@ public class WearConnectivityModule extends WearConnectivitySpec
 
   WearConnectivityModule(ReactApplicationContext context) {
     super(context);
+    reactContext = context;
     context.addLifecycleEventListener(this);
     client = Wearable.getMessageClient(context);
     Log.d(TAG, CLIENT_ADDED);
@@ -118,29 +130,33 @@ private void sendMessageToClient(
     }
   }
 
+  @RequiresApi(api = Build.VERSION_CODES.O)
+  @Override
   public void onMessageReceived(MessageEvent messageEvent) {
+    ReactApplicationContext context = getReactContext();
     try {
       JSONObject jsonObject = new JSONObject(messageEvent.getPath());
       WritableMap messageAsWritableMap = (WritableMap) JSONArguments.fromJSONObject(jsonObject);
       String event = jsonObject.getString("event");
       FLog.w(TAG, TAG + " event: " + event + " message: " + messageAsWritableMap);
-      sendEvent(getReactApplicationContext(), event, messageAsWritableMap);
+      Intent service = new Intent(getReactContext(), com.wearconnectivity.WearConnectivityTask.class);
+      Bundle bundle = Arguments.toBundle(messageAsWritableMap);
+      service.putExtras(bundle);
+      getReactContext().startForegroundService(service);
+      HeadlessJsTaskService.acquireWakeLockNow(getReactContext());
     } catch (JSONException e) {
       FLog.w(
-          TAG,
-          TAG
-              + "onMessageReceived with message: "
-              + messageEvent.getPath()
-              + " failed with error: "
-              + e);
+              TAG,
+              TAG
+                      + "onMessageReceived with message: "
+                      + messageEvent.getPath()
+                      + " failed with error: "
+                      + e);
     }
   }
 
-  private void sendEvent(
-      ReactContext reactContext, String eventName, @Nullable WritableMap params) {
-    reactContext
-        .getJSModule(DeviceEventManagerModule.RCTDeviceEventEmitter.class)
-        .emit(eventName, params);
+  public static ReactApplicationContext getReactContext() {
+    return reactContext;
   }
 
   @Override
@@ -153,8 +169,9 @@ public void onHostResume() {
 
   @Override
   public void onHostPause() {
-    Log.d(TAG, REMOVE_CLIENT);
-    client.removeListener(this);
+    // Log.d(TAG, REMOVE_CLIENT);
+    // removed this to allow to send updates when app is in the background
+    // client.removeListener(this);
   }
 
   @Override

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

@@ -0,0 +1,60 @@
+package com.wearconnectivity;
+
+import android.app.Notification;
+import android.app.NotificationChannel;
+import android.app.NotificationManager;
+import android.content.Intent;
+import android.os.Build;
+import android.os.Bundle;
+import androidx.core.app.NotificationCompat;
+import com.facebook.react.HeadlessJsTaskService;
+import com.facebook.react.bridge.Arguments;
+import com.facebook.react.jstasks.HeadlessJsTaskConfig;
+import javax.annotation.Nullable;
+
+public class WearConnectivityTask extends HeadlessJsTaskService {
+
+  private static final int NOTIFICATION_ID = 1337;
+  private static final String CHANNEL_ID = "wear_connectivity_channel";
+
+  @Override
+  public void onCreate() {
+    super.onCreate();
+    if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
+      NotificationChannel channel = new NotificationChannel(
+              CHANNEL_ID,
+              "Wear Connectivity",
+              NotificationManager.IMPORTANCE_LOW
+      );
+      NotificationManager manager = (NotificationManager) getSystemService(NOTIFICATION_SERVICE);
+      if (manager != null) {
+        manager.createNotificationChannel(channel);
+      }
+    }
+  }
+
+  @Override
+  public int onStartCommand(Intent intent, int flags, int startId) {
+    Notification notification = new NotificationCompat.Builder(this, CHANNEL_ID)
+            .setContentTitle("Wear Connectivity")
+            .setContentText("Processing background task")
+            .setSmallIcon(android.R.drawable.ic_popup_sync)
+            .build();
+    startForeground(NOTIFICATION_ID, notification);
+    return super.onStartCommand(intent, flags, startId);
+  }
+
+  @Override
+  protected @Nullable HeadlessJsTaskConfig getTaskConfig(Intent intent) {
+    Bundle extras = intent.getExtras();
+    if (extras != null) {
+      return new HeadlessJsTaskConfig(
+              "WearConnectivityTask",
+              Arguments.fromBundle(extras),
+              5000,
+              true
+      );
+    }
+    return null;
+  }
+}

example/android/app/src/main/AndroidManifest.xml

@@ -2,6 +2,11 @@
 
     <uses-permission android:name="android.permission.INTERNET" />
 
+    <!-- ADD THIS PERMISSIONS -->
+    <uses-permission android:name="android.permission.WAKE_LOCK"/>
+    <uses-permission android:name="android.permission.FOREGROUND_SERVICE" />
+    <!-- END OF THE CHANGES -->
+
     <application
       android:name=".MainApplication"
       android:label="@string/app_name"
@@ -22,5 +27,12 @@
             <category android:name="android.intent.category.LAUNCHER" />
         </intent-filter>
       </activity>
+
+      <!-- ADD THIS SERVICE -->
+      <service android:name="com.wearconnectivity.WearConnectivityTask"
+          android:permission="android.permission.BIND_JOB_SERVICE"
+          android:exported="true" />
+      <!-- END OF THE CHANGES -->
+
     </application>
 </manifest>

src/index.tsx

@@ -1,7 +1,9 @@
+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 { DeviceEventEmitter } from 'react-native';
 
 const LINKING_ERROR =
   `The package 'react-native-wear-connectivity' doesn't seem to be linked. Make sure: \n\n` +
@@ -29,3 +31,15 @@ const WearConnectivity = WearConnectivityModule
 
 export { sendMessage, watchEvents, WearConnectivity };
 export type { ReplyCallback, ErrorCallback };
+
+// Define the headless task
+const WearConnectivityTask = async (taskData) => {
+  // Emit an event or process the message as needed
+  DeviceEventEmitter.emit('message', taskData);
+};
+
+// Register the headless task with React Native
+AppRegistry.registerHeadlessTask(
+  'WearConnectivityTask',
+  () => WearConnectivityTask
+);