AN_Cloud Function: Firebase Messaging Service for processing the notifications.

FCMService.kt

class FCMService : FirebaseMessagingService() {
    companion object {
        private const val TAG = "FCMService"
        private const val RECEIVER_TAG = "Receiver:"

        const val IN_AP_EX_STR_TITLE = "in_ap_ex_str_title"
        const val IN_AP_EX_STR_BODY = "in_ap_ex_str_body"
    }

    @SuppressLint("TimberArgCount")
    override fun onNewToken(token: String?) {
        super.onNewToken(token)
        Timber.tag(TAG).i("token refreshed: ", token)
    }

    override fun onMessageReceived(remoteMessage: RemoteMessage?) {
        super.onMessageReceived(remoteMessage)
        remoteMessage?.let { msg ->
            Timber.tag(TAG).i("Config state update: ${msg.from}")
            msg.from?.contains(PUSH_RC)?.takeIf { it }?.let {
                sendRcMessage(this)
            } ?: sendInAppNotification(msg, this)
        }
    }

    private fun sendInAppNotification(remoteMessage: RemoteMessage,
    context: Context) {
        val fcmIntent = Intent(INTENT_FCM)
        remoteMessage.notification?.let { not ->
            not.title?.let { title ->
                not.body?.let { body ->
                    fcmIntent.putExtra(IN_AP_EX_STR_TITLE, title)
                    fcmIntent.putExtra(IN_AP_EX_STR_BODY, body)
                    Timber.tag(RECEIVER_TAG).i("Broadcasting message was send.")
                    LocalBroadcastManager.getInstance(context).sendBroadcast(fcmIntent)
                }
            }
        }
    }

    private fun sendRcMessage(context: Context) {
        Timber.tag(RECEIVER_TAG).i("Broadcasting message was send.")
      LocalBroadcastManager.getInstance(context).sendBroadcast(Intent(INTENT_FCM))
    }
}