Skip to content
This repository was archived by the owner on Jan 14, 2025. It is now read-only.

feat: multiple push providers #1445

Merged
merged 2 commits into from
May 19, 2020
Merged

feat: multiple push providers #1445

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
7e861c4
feat: multiple push providers
May 15, 2020
5716f1e
feat: explicitly override onNewToken
May 18, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
192 changes: 5 additions & 187 deletions ...java/com/dieam/reactnativepushnotification/modules/RNPushNotificationListenerService.java
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,203 +1,21 @@
package com.dieam.reactnativepushnotification.modules;

import java.util.Map;
import com.google.firebase.messaging.FirebaseMessagingService;
import com.google.firebase.messaging.RemoteMessage;

import android.app.ActivityManager;
import android.app.ActivityManager.RunningAppProcessInfo;
import android.app.Application;
import android.os.Bundle;
import android.os.Handler;
import android.os.Looper;
import android.util.Log;

import com.dieam.reactnativepushnotification.helpers.ApplicationBadgeHelper;
import com.facebook.react.ReactApplication;
import com.facebook.react.ReactInstanceManager;
import com.facebook.react.bridge.Arguments;
import com.facebook.react.bridge.ReactApplicationContext;
import com.facebook.react.bridge.ReactContext;
import com.facebook.react.bridge.WritableMap;

import org.json.JSONObject;

import java.util.List;
import java.util.Random;

import static com.dieam.reactnativepushnotification.modules.RNPushNotification.LOG_TAG;
import com.dieam.reactnativepushnotification.modules.RNReceivedMessageHandler;

public class RNPushNotificationListenerService extends FirebaseMessagingService {

private RNReceivedMessageHandler mMessageReceivedHandler = new RNReceivedMessageHandler(this);

@Override
public void onNewToken(String token) {
final String deviceToken = token;
Log.d(LOG_TAG, "Refreshed token: " + deviceToken);

Handler handler = new Handler(Looper.getMainLooper());
handler.post(new Runnable() {
public void run() {
// Construct and load our normal React JS code bundle
ReactInstanceManager mReactInstanceManager = ((ReactApplication) getApplication()).getReactNativeHost().getReactInstanceManager();
ReactContext context = mReactInstanceManager.getCurrentReactContext();
// If it's constructed, send a notificationre
if (context != null) {
handleNewToken((ReactApplicationContext) context, deviceToken);
} else {
// Otherwise wait for construction, then send the notification
mReactInstanceManager.addReactInstanceEventListener(new ReactInstanceManager.ReactInstanceEventListener() {
public void onReactContextInitialized(ReactContext context) {
handleNewToken((ReactApplicationContext) context, deviceToken);
}
});
if (!mReactInstanceManager.hasStartedCreatingInitialContext()) {
// Construct it in the background
mReactInstanceManager.createReactContextInBackground();
}
}
}
});
mMessageReceivedHandler.onNewToken(token);
}

private void handleNewToken(ReactApplicationContext context, String token) {
RNPushNotificationJsDelivery jsDelivery = new RNPushNotificationJsDelivery(context);

WritableMap params = Arguments.createMap();
params.putString("deviceToken", token);
jsDelivery.sendEvent("remoteNotificationsRegistered", params);
}


@Override
public void onMessageReceived(RemoteMessage message) {
String from = message.getFrom();
RemoteMessage.Notification remoteNotification = message.getNotification();
final Bundle bundle = new Bundle();
// Putting it from remoteNotification first so it can be overriden if message
// data has it
if (remoteNotification != null) {
// ^ It's null when message is from GCM
bundle.putString("title", remoteNotification.getTitle());
bundle.putString("message", remoteNotification.getBody());
bundle.putString("sound", remoteNotification.getSound());
bundle.putString("color", remoteNotification.getColor());
}

Map<String, String> notificationData = message.getData();

// Copy `twi_body` to `message` to support Twilio
if (notificationData.containsKey("twi_body")) {
bundle.putString("message", notificationData.get("twi_body"));
}
JSONObject data = getPushData(notificationData.get("data"));

if (data != null) {
if (!bundle.containsKey("message")) {
bundle.putString("message", data.optString("alert", null));
}
if (!bundle.containsKey("title")) {
bundle.putString("title", data.optString("title", null));
}
if (!bundle.containsKey("sound")) {
bundle.putString("soundName", data.optString("sound", null));
}
if (!bundle.containsKey("color")) {
bundle.putString("color", data.optString("color", null));
}

final int badge = data.optInt("badge", -1);
if (badge >= 0) {
ApplicationBadgeHelper.INSTANCE.setApplicationIconBadgeNumber(this, badge);
}
}

Bundle dataBundle = new Bundle();
for(Map.Entry<String, String> entry : notificationData.entrySet()) {
dataBundle.putString(entry.getKey(), entry.getValue());
}
bundle.putParcelable("data", dataBundle);

Log.v(LOG_TAG, "onMessageReceived: " + bundle);

// We need to run this on the main thread, as the React code assumes that is true.
// Namely, DevServerHelper constructs a Handler() without a Looper, which triggers:
// "Can't create handler inside thread that has not called Looper.prepare()"
Handler handler = new Handler(Looper.getMainLooper());
handler.post(new Runnable() {
public void run() {
// Construct and load our normal React JS code bundle
ReactInstanceManager mReactInstanceManager = ((ReactApplication) getApplication()).getReactNativeHost().getReactInstanceManager();
ReactContext context = mReactInstanceManager.getCurrentReactContext();
// If it's constructed, send a notificationre
if (context != null) {
handleRemotePushNotification((ReactApplicationContext) context, bundle);
} else {
// Otherwise wait for construction, then send the notification
mReactInstanceManager.addReactInstanceEventListener(new ReactInstanceManager.ReactInstanceEventListener() {
public void onReactContextInitialized(ReactContext context) {
handleRemotePushNotification((ReactApplicationContext) context, bundle);
}
});
if (!mReactInstanceManager.hasStartedCreatingInitialContext()) {
// Construct it in the background
mReactInstanceManager.createReactContextInBackground();
}
}
}
});
}

private JSONObject getPushData(String dataString) {
try {
return new JSONObject(dataString);
} catch (Exception e) {
return null;
}
}

private void handleRemotePushNotification(ReactApplicationContext context, Bundle bundle) {

// If notification ID is not provided by the user for push notification, generate one at random
if (bundle.getString("id") == null) {
Random randomNumberGenerator = new Random(System.currentTimeMillis());
bundle.putString("id", String.valueOf(randomNumberGenerator.nextInt()));
}

RNPushNotificationConfig config = new RNPushNotificationConfig(getApplication());

Boolean isForeground = isApplicationInForeground();

RNPushNotificationJsDelivery jsDelivery = new RNPushNotificationJsDelivery(context);
bundle.putBoolean("foreground", isForeground);
bundle.putBoolean("userInteraction", false);
jsDelivery.notifyNotification(bundle);

// If contentAvailable is set to true, then send out a remote fetch event
if (bundle.getString("contentAvailable", "false").equalsIgnoreCase("true")) {
jsDelivery.notifyRemoteFetch(bundle);
}

Log.v(LOG_TAG, "sendNotification: " + bundle);

if (config.getNotificationForeground() || !isForeground) {
Application applicationContext = (Application) context.getApplicationContext();
RNPushNotificationHelper pushNotificationHelper = new RNPushNotificationHelper(applicationContext);
pushNotificationHelper.sendToNotificationCentre(bundle);
}
}

private boolean isApplicationInForeground() {
ActivityManager activityManager = (ActivityManager) this.getSystemService(ACTIVITY_SERVICE);
List<RunningAppProcessInfo> processInfos = activityManager.getRunningAppProcesses();
if (processInfos != null) {
for (RunningAppProcessInfo processInfo : processInfos) {
if (processInfo.processName.equals(getApplication().getPackageName())
&& processInfo.importance == RunningAppProcessInfo.IMPORTANCE_FOREGROUND
&& processInfo.pkgList.length > 0) {
return true;
}
}
}
return false;
mMessageReceivedHandler.handleReceivedMessage(message);
}
}
Loading