CodeMirror/ntfy-android
1
0
Fork 0
mirror of https://github.com/binwiederhier/ntfy-android.git synced 2024-06-28 03:00:33 +12:00
Code Issues Projects Releases Wiki Activity

Make sure Firebase crash does not crash the app or coroutine

Browse source
This commit is contained in:
Philipp Heckel 2022-02-07 22:04:16 -05:00
parent e6c3a2e2bd
commit 42188d5152
1 changed files with 15 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
app/src/play/java/io/heckel/ntfy/firebase/FirebaseMessenger.kt
View file

@ -5,21 +5,29 @@ import io.heckel.ntfy.log.Log
class FirebaseMessenger { class FirebaseMessenger {
fun subscribe(topic: String) { fun subscribe(topic: String) {
FirebaseMessaging val firebase = maybeInstance() ?: return
.getInstance() firebase
.subscribeToTopic(topic) .subscribeToTopic(topic)
.addOnCompleteListener { .addOnCompleteListener {
Log.d(TAG, "Subscribing to topic $topic complete: result=${it.result}, exception=${it.exception}, successful=${it.isSuccessful}") Log.d(TAG, "Subscribing to topic $topic complete: result=${it.result}, exception=${it.exception}, successful=${it.isSuccessful}")
} }
.addOnFailureListener { .addOnFailureListener { e ->
Log.e(TAG, "Subscribing to topic $topic failed: $it") Log.e(TAG, "Subscribing to topic $topic failed: ${e.message}", e)
} }
} }
fun unsubscribe(topic: String) { fun unsubscribe(topic: String) {
FirebaseMessaging val firebase = maybeInstance() ?: return
.getInstance() firebase.unsubscribeFromTopic(topic)
.unsubscribeFromTopic(topic) }
private fun maybeInstance(): FirebaseMessaging? {
return try {
FirebaseMessaging.getInstance()
} catch (e: Exception) {
Log.e(TAG, "Firebase instance unavailable: ${e.message}", e)
null
}
} }
companion object { companion object {