Merge pull request #348 from Backendless/oleg.vyalyh/separate_fcm_gcm

BKNDLSS-17770 Separate GCM and FCM logic.

Author: ksv510

build.gradle

@@ -5,7 +5,7 @@ apply plugin: 'signing'
 
 
 group 'com.backendless'
-version '5.2.0'
+version '5.2.1'
 archivesBaseName='backendless'
 
 

src/com/backendless/Messaging.java

@@ -50,6 +50,7 @@
 import com.backendless.messaging.PublishStatusEnum;
 import com.backendless.messaging.PushBroadcastMask;
 import com.backendless.push.BackendlessPushService;
+import com.backendless.push.DeviceRegistrationResult;
 import com.backendless.push.FCMRegistration;
 import com.backendless.push.GCMRegistrar;
 import com.backendless.rt.messaging.Channel;
@@ -253,70 +254,70 @@ private synchronized void registerDeviceGCMSync( Context context, String GCMSend
   }
 
   /**
-   * For FireBase messaging only.
+   * For Firebase Cloud Messaging only
    */
   public void registerDevice()
   {
-    registerDevice( (AsyncCallback<String>) null );
+    registerDevice( Collections.singletonList( DEFAULT_CHANNEL_NAME ) );
   }
 
   /**
-   * For FireBase messaging only.
+   * For Firebase Cloud Messaging only
    */
-  public void registerDevice( AsyncCallback<String> callback )
+  public void registerDevice( List<String> channels )
   {
-    registerDevice( Collections.singletonList( DEFAULT_CHANNEL_NAME ), callback );
+    registerDevice( channels, (Date) null );
   }
 
   /**
-   * For FireBase messaging only.
+   * For Firebase Cloud Messaging only
    */
-  public void registerDevice( List<String> channels )
+  public void registerDevice( List<String> channels, Date expiration )
   {
-    registerDevice( Collections.singletonList( DEFAULT_CHANNEL_NAME ), (AsyncCallback<String>) null );
+    registerDevice( channels, expiration, (AsyncCallback<DeviceRegistrationResult>) null );
   }
 
   /**
-   * For FireBase messaging only.
+   * For Firebase Cloud Messaging only
    */
-  public void registerDevice( List<String> channels, AsyncCallback<String> callback )
+  public void registerDevice( AsyncCallback<DeviceRegistrationResult> callback )
   {
-    registerDevice( channels, (Date) null, callback );
+    registerDevice( Collections.singletonList( DEFAULT_CHANNEL_NAME ), (Date) null, callback );
   }
-
+  
   /**
-   * For FireBase messaging only.
+   * For Firebase Cloud Messaging only
    */
-  public void registerDevice( List<String> channels, Date expiration )
+  public void registerDevice( List<String> channels, AsyncCallback<DeviceRegistrationResult> callback )
   {
-    registerDevice( channels, expiration, (AsyncCallback<String>) null );
+    registerDevice( channels, (Date) null, callback );
   }
 
   /**
-   * For FireBase messaging only.
+   * For Firebase Cloud Messaging only
    */
-  public void registerDevice( List<String> channels, Date expiration, AsyncCallback<String> callback )
+  public void registerDevice( List<String> channels, Date expiration, AsyncCallback<DeviceRegistrationResult> callback )
   {
     if( !BackendlessPushService.isFCM( ContextHandler.getAppContext() ) )
       throw new IllegalStateException( "The method is intended only for FireBase messaging." );
 
     if( channels == null || channels.isEmpty() ||
             (channels.size() == 1 && (channels.get( 0 ) == null || channels.get( 0 ).isEmpty())) )
-    {
       channels = Collections.singletonList( DEFAULT_CHANNEL_NAME );
-    }
 
     for( String channel : channels )
       checkChannelName( channel );
 
     long expirationMs = 0;
+
     if( expiration != null)
     {
       if( expiration.before( Calendar.getInstance().getTime() ) )
         throw new IllegalArgumentException( ExceptionMessage.WRONG_EXPIRATION_DATE );
       else
         expirationMs = expiration.getTime();
     }
+
     FCMRegistration.registerDevice( ContextHandler.getAppContext(), channels, expirationMs, callback );
   }
 
@@ -397,12 +398,12 @@ public void unregisterDevice( List<String> channels )
     unregisterDevice( channels, null );
   }
 
-  public void unregisterDevice( AsyncCallback<Void> callback )
+  public void unregisterDevice( AsyncCallback<Integer> callback )
   {
     unregisterDevice( null, callback );
   }
 
-  public void unregisterDevice( final List<String> channels, final AsyncCallback<Void> callback )
+  public void unregisterDevice( final List<String> channels, final AsyncCallback<Integer> callback )
   {
     new AsyncTask<Void, Void, RuntimeException>()
     {
@@ -415,7 +416,7 @@ protected RuntimeException doInBackground( Void... params )
 
           if ( BackendlessPushService.isFCM( context ) )
           {
-            FCMRegistration.unregisterDevice( context, channels );
+            FCMRegistration.unregisterDevice( context, channels, callback );
           }
           else
           {
@@ -442,11 +443,6 @@ protected void onPostExecute( RuntimeException result )
 
           callback.handleFault( new BackendlessFault( result ) );
         }
-        else
-        {
-          if( callback != null )
-            callback.handleResponse( null );
-        }
       }
     }.execute();
   }

src/com/backendless/push/BackendlessFCMService.java

@@ -1,30 +1,80 @@
 package com.backendless.push;
 
+import android.app.Notification;
+import android.app.NotificationChannel;
+import android.app.NotificationManager;
+import android.app.PendingIntent;
+import android.content.Context;
 import android.content.Intent;
+import android.media.AudioAttributes;
+import android.media.AudioManager;
+import android.os.Handler;
+import android.os.Looper;
+import android.support.v4.app.NotificationCompat;
+import android.support.v4.app.NotificationManagerCompat;
 import android.util.Log;
+import com.backendless.Backendless;
+import com.backendless.ContextHandler;
+import com.backendless.async.callback.AsyncCallback;
+import com.backendless.exceptions.BackendlessFault;
+import com.backendless.messaging.AndroidPushTemplate;
+import com.backendless.messaging.PublishOptions;
 import com.google.firebase.messaging.FirebaseMessagingService;
 import com.google.firebase.messaging.RemoteMessage;
 
+import java.util.concurrent.atomic.AtomicInteger;
+
 
 public class BackendlessFCMService extends FirebaseMessagingService
 {
+  private static final String IMMEDIATE_MESSAGE = "ImmediateMessage";
   private static final String TAG = BackendlessFCMService.class.getSimpleName();
+  private static AtomicInteger notificationIdGenerator;
+
+  /**
+   * <p>This method is intended for overriding.
+   * <p>The notification payload can be found within intent extras: intent.getStringExtra(PublishOptions.<CONSTANT_VALUE>).
+   * @param appContext Application context of current android app.
+   * @param msgIntent Contains all notification data.
+   * @return Return 'true' if you want backendless library to continue processing, 'false' otherwise.
+   */
+  public boolean onMessage( Context appContext, Intent msgIntent )
+  {
+    Log.i( TAG, "Notification has been received by default 'BackendlessFCMService' class. You may override this method in a custom fcm service class which extends from 'com.backendless.push.BackendlessFCMService'. The notification payload can be found within intent extras: msgIntent.getStringExtra(PublishOptions.<CONSTANT_VALUE>)." );
+    return true;
+  }
+
+  public BackendlessFCMService()
+  {
+    if( BackendlessFCMService.notificationIdGenerator == null )
+      BackendlessFCMService.notificationIdGenerator = new AtomicInteger( Backendless.getNotificationIdGeneratorInitValue() );
+  }
+
+  @Override
+  public final void onDestroy()
+  {
+    super.onDestroy();
+    Backendless.saveNotificationIdGeneratorState( BackendlessFCMService.notificationIdGenerator.get() );
+  }
 
   @Override
   public final void onNewToken( String token )
   {
     super.onNewToken( token );
-    Intent msgWork = new Intent( BackendlessPushService.ACTION_FCM_REFRESH_TOKEN );
-    msgWork.putExtra( BackendlessPushService.KEY_DEVICE_TOKEN, token );
-    BackendlessPushService.enqueueWork( this.getApplicationContext(), msgWork );
+    Context appContext = ContextHandler.getAppContext();
+    this.refreshTokenOnBackendless( appContext, token );
   }
 
   @Override
   public final void onMessageReceived( RemoteMessage remoteMessage )
   {
-    Intent msgWork = remoteMessage.toIntent();
-    msgWork.setAction( BackendlessPushService.ACTION_FCM_ONMESSAGE );
-    BackendlessPushService.enqueueWork( this.getApplicationContext(), msgWork );
+    Intent msgIntent = remoteMessage.toIntent();
+    Context appContext = ContextHandler.getAppContext();
+
+    boolean showPushNotification = this.onMessage( appContext, msgIntent );
+
+    if( showPushNotification )
+      this.handleMessage( appContext, msgIntent );
   }
 
   @Override
@@ -33,4 +83,147 @@ public void onDeletedMessages()
     super.onDeletedMessages();
     Log.w( TAG, "there are too many messages (>100) pending for this app or your device hasn't connected to FCM in more than one month." );
   }
+
+  private void handleMessage( final Context context, Intent intent )
+  {
+    int notificationId = BackendlessFCMService.notificationIdGenerator.getAndIncrement();
+
+    try
+    {
+      String immediatePush = intent.getStringExtra( PublishOptions.ANDROID_IMMEDIATE_PUSH );
+      if( immediatePush != null )
+      {
+        AndroidPushTemplate androidPushTemplate = (AndroidPushTemplate) weborb.util.io.Serializer.fromBytes( immediatePush.getBytes(), weborb.util.io.Serializer.JSON, false );
+
+        if( androidPushTemplate.getContentAvailable() != null && androidPushTemplate.getContentAvailable() == 1 )
+          return;
+
+        if( androidPushTemplate.getName() == null || androidPushTemplate.getName().isEmpty() )
+          androidPushTemplate.setName( BackendlessFCMService.IMMEDIATE_MESSAGE );
+
+        if( android.os.Build.VERSION.SDK_INT > 25 )
+        {
+          if( PushTemplateHelper.getNotificationChannel( context, androidPushTemplate.getName() ) == null )
+            androidPushTemplate.setName( BackendlessFCMService.IMMEDIATE_MESSAGE );
+        }
+
+        Notification notification = PushTemplateHelper.convertFromTemplate( context, androidPushTemplate, intent.getExtras().deepCopy(), notificationId );
+        PushTemplateHelper.showNotification( context, notification, androidPushTemplate.getName(), notificationId );
+        return;
+      }
+
+      final String templateName = intent.getStringExtra( PublishOptions.TEMPLATE_NAME );
+      if( templateName != null )
+      {
+        AndroidPushTemplate androidPushTemplate = PushTemplateHelper.getPushNotificationTemplates().get( templateName );
+        if( androidPushTemplate != null )
+        {
+          if( androidPushTemplate.getContentAvailable() != null && androidPushTemplate.getContentAvailable() == 1 )
+            return;
+
+          Notification notification = PushTemplateHelper.convertFromTemplate( context, androidPushTemplate, intent.getExtras().deepCopy(), notificationId );
+          intent.getExtras().deepCopy();
+          PushTemplateHelper.showNotification( context, notification, androidPushTemplate.getName(), notificationId );
+        }
+        return;
+      }
+
+
+      final String message = intent.getStringExtra( PublishOptions.MESSAGE_TAG );
+      final String contentTitle = intent.getStringExtra( PublishOptions.ANDROID_CONTENT_TITLE_TAG );
+      final String summarySubText = intent.getStringExtra( PublishOptions.ANDROID_SUMMARY_SUBTEXT_TAG );
+      String soundResource = intent.getStringExtra( PublishOptions.ANDROID_CONTENT_SOUND_TAG );
+      fallBackMode( context, message, contentTitle, summarySubText, soundResource, notificationId );
+    }
+    catch ( Throwable throwable )
+    {
+      Log.e( TAG, "Error processing push notification", throwable );
+    }
+  }
+
+  private void fallBackMode( Context context, String message, String contentTitle, String summarySubText, String soundResource, final int notificationId )
+  {
+    final String channelName = "Fallback";
+    final NotificationCompat.Builder notificationBuilder;
+
+    // android.os.Build.VERSION_CODES.O == 26
+    if( android.os.Build.VERSION.SDK_INT > 25 )
+    {
+      final String channelId = Backendless.getApplicationId() + ":" + channelName;
+      NotificationManager notificationManager = (NotificationManager) context.getSystemService( Context.NOTIFICATION_SERVICE );
+      NotificationChannel notificationChannel = notificationManager.getNotificationChannel( channelId );
+
+      if( notificationChannel == null )
+      {
+        notificationChannel = new NotificationChannel( channelId, channelName, NotificationManager.IMPORTANCE_DEFAULT );
+
+        AudioAttributes audioAttributes = new AudioAttributes.Builder()
+                .setUsage( AudioAttributes.USAGE_NOTIFICATION_RINGTONE )
+                .setContentType( AudioAttributes.CONTENT_TYPE_SONIFICATION )
+                .setFlags( AudioAttributes.FLAG_AUDIBILITY_ENFORCED )
+                .setLegacyStreamType( AudioManager.STREAM_NOTIFICATION )
+                .build();
+
+        notificationChannel.setSound( PushTemplateHelper.getSoundUri( context, soundResource ), audioAttributes );
+        notificationManager.createNotificationChannel( notificationChannel );
+      }
+
+      notificationBuilder = new NotificationCompat.Builder( context, notificationChannel.getId() );
+    }
+    else
+      notificationBuilder = new NotificationCompat.Builder( context );
+
+    notificationBuilder.setSound( PushTemplateHelper.getSoundUri( context, soundResource ), AudioManager.STREAM_NOTIFICATION );
+
+    int appIcon = context.getApplicationInfo().icon;
+    if( appIcon == 0 )
+      appIcon = android.R.drawable.sym_def_app_icon;
+
+    Intent notificationIntent = context.getPackageManager().getLaunchIntentForPackage( context.getApplicationInfo().packageName );
+    PendingIntent contentIntent = PendingIntent.getActivity( context, 0, notificationIntent, 0 );
+
+    notificationBuilder.setContentIntent( contentIntent )
+            .setSmallIcon( appIcon )
+            .setContentTitle( contentTitle )
+            .setSubText( summarySubText )
+            .setContentText( message )
+            .setWhen( System.currentTimeMillis() )
+            .setAutoCancel( true )
+            .build();
+
+    final NotificationManagerCompat notificationManager = NotificationManagerCompat.from( context );
+    Handler handler = new Handler( Looper.getMainLooper() );
+    handler.post( new Runnable()
+    {
+      @Override
+      public void run()
+      {
+        notificationManager.notify( channelName, notificationId, notificationBuilder.build() );
+      }
+    } );
+  }
+
+  private void refreshTokenOnBackendless( final Context context, String newDeviceToken )
+  {
+    Backendless.Messaging.refreshDeviceToken( newDeviceToken, new AsyncCallback<Boolean>()
+    {
+      @Override
+      public void handleResponse( Boolean response )
+      {
+        if( response )
+          Log.d( TAG, "Device token refreshed successfully." );
+        else
+        {
+          Log.d( TAG, "Device is not registered on any channel." );
+          FCMRegistration.unregisterDeviceOnFCM( context, null );
+        }
+      }
+
+      @Override
+      public void handleFault( BackendlessFault fault )
+      {
+        Log.e( TAG, "Can not refresh device token on Backendless. " + fault.getMessage() );
+      }
+    } );
+  }
 }