-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
[expo-notifications] Migrate FirebaseMessagingService to Kotlin (expo…
…#10556) # Why Prerequisite for single threaded notifications handling. # How Used Android Studio migration tool, then looked at the code trying to think of more kotlinish structures. Fixed nullabilities of arguments and return values in the `expoview` subclass. # Test Plan Code compiles, push notifications are received.
- Loading branch information
Showing
4 changed files
with
110 additions
and
116 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
113 changes: 0 additions & 113 deletions
113
...tifications/android/src/main/java/expo/modules/notifications/FirebaseListenerService.java
This file was deleted.
Oops, something went wrong.
101 changes: 101 additions & 0 deletions
101
...notifications/android/src/main/java/expo/modules/notifications/FirebaseListenerService.kt
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,101 @@ | ||
| package expo.modules.notifications | ||
|
|
||
| import com.google.firebase.messaging.FirebaseMessagingService | ||
| import com.google.firebase.messaging.RemoteMessage | ||
| import expo.modules.notifications.notifications.JSONNotificationContentBuilder | ||
| import expo.modules.notifications.notifications.interfaces.NotificationsScoper | ||
| import expo.modules.notifications.notifications.model.Notification | ||
| import expo.modules.notifications.notifications.model.NotificationContent | ||
| import expo.modules.notifications.notifications.model.NotificationRequest | ||
| import expo.modules.notifications.notifications.model.triggers.FirebaseNotificationTrigger | ||
| import expo.modules.notifications.notifications.service.NotificationsHelper | ||
| import expo.modules.notifications.tokens.interfaces.FirebaseTokenListener | ||
| import org.json.JSONObject | ||
| import java.lang.ref.WeakReference | ||
| import java.util.* | ||
|
|
||
| /** | ||
| * Subclass of FirebaseMessagingService responsible for dispatching new tokens and remote messages. | ||
| */ | ||
| open class FirebaseListenerService : FirebaseMessagingService() { | ||
| companion object { | ||
| // Unfortunately we cannot save state between instances of a service other way | ||
| // than by static properties. Fortunately, using weak references we can | ||
| // be somehow sure instances of PushTokenListeners won't be leaked by this component. | ||
| /** | ||
| * We store this value to be able to inform new listeners of last known token. | ||
| */ | ||
| private var sLastToken: String? = null | ||
|
|
||
| /** | ||
| * A weak map of listeners -> reference. Used to check quickly whether given listener | ||
| * is already registered and to iterate over when notifying of new token. | ||
| */ | ||
| private val sTokenListenersReferences = WeakHashMap<FirebaseTokenListener, WeakReference<FirebaseTokenListener?>?>() | ||
|
|
||
| /** | ||
| * Used only by [FirebaseTokenListener] instances. If you look for a place to register | ||
| * your listener, use [FirebaseTokenListener] singleton module. | ||
| * | ||
| * Purposefully the argument is expected to be a [FirebaseTokenListener] and just a listener. | ||
| * | ||
| * This class doesn't hold strong references to listeners, so you need to own your listeners. | ||
| * | ||
| * @param listener A listener instance to be informed of new push device tokens. | ||
| */ | ||
| @JvmStatic | ||
| fun addTokenListener(listener: FirebaseTokenListener) { | ||
| // Checks whether this listener has already been registered | ||
| if (!sTokenListenersReferences.containsKey(listener)) { | ||
| sTokenListenersReferences[listener] = WeakReference(listener) | ||
| // Since it's a new listener and we know of a last valid token, let's let them know. | ||
| if (sLastToken != null) { | ||
| listener.onNewToken(sLastToken) | ||
| } | ||
| } | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * Called on new token, dispatches it to [FirebaseListenerService.sTokenListenersReferences]. | ||
| * | ||
| * @param token New device push token. | ||
| */ | ||
| override fun onNewToken(token: String) { | ||
| super.onNewToken(token) | ||
| for (listenerReference in sTokenListenersReferences.values) { | ||
| listenerReference?.get()?.onNewToken(token) | ||
| } | ||
| sLastToken = token | ||
| } | ||
|
|
||
| override fun onMessageReceived(remoteMessage: RemoteMessage) { | ||
| super.onMessageReceived(remoteMessage) | ||
| createNotificationsHelper().notificationReceived(createNotification(remoteMessage)) | ||
| } | ||
|
|
||
| protected fun createNotificationsHelper(): NotificationsHelper { | ||
| return NotificationsHelper(this, NotificationsScoper.create(this).createReconstructor()) | ||
| } | ||
|
|
||
| protected fun createNotification(remoteMessage: RemoteMessage): Notification { | ||
| val identifier = remoteMessage.messageId ?: UUID.randomUUID().toString() | ||
| val payload = JSONObject(remoteMessage.data as Map<*, *>) | ||
| val content = JSONNotificationContentBuilder(this).setPayload(payload).build() | ||
| val request = createNotificationRequest(identifier, content, FirebaseNotificationTrigger(remoteMessage)) | ||
| return Notification(request, Date(remoteMessage.sentTime)) | ||
| } | ||
|
|
||
| protected open fun createNotificationRequest( | ||
| identifier: String, | ||
| content: NotificationContent, | ||
| notificationTrigger: FirebaseNotificationTrigger | ||
| ): NotificationRequest { | ||
| return NotificationRequest(identifier, content, notificationTrigger) | ||
| } | ||
|
|
||
| override fun onDeletedMessages() { | ||
| super.onDeletedMessages() | ||
| createNotificationsHelper().dropped(null) | ||
| } | ||
| } |