added checks to fix crash
This commit is contained in:
@@ -47,27 +47,35 @@ class FireStoreDataProvider @Inject constructor(
|
||||
}
|
||||
|
||||
override fun listenToLiveMessages(senderName: String, latestMessageTimeStamp: Timestamp?) {
|
||||
chatFireStoreDatabase.listenToFirestoreChanges(
|
||||
path = fireStoreDataProviderModel.readPath,
|
||||
latestMessageTimeStamp = latestMessageTimeStamp,
|
||||
messageOperation = messageOperation
|
||||
)
|
||||
if (::chatFireStoreDatabase.isInitialized) {
|
||||
chatFireStoreDatabase.listenToFirestoreChanges(
|
||||
path = fireStoreDataProviderModel.readPath,
|
||||
latestMessageTimeStamp = latestMessageTimeStamp,
|
||||
messageOperation = messageOperation
|
||||
)
|
||||
}
|
||||
}
|
||||
|
||||
override fun writeMessage(naviChatWidget: NaviChatWidget) {
|
||||
chatFireStoreDatabase.writeToFireStore(
|
||||
path = fireStoreDataProviderModel.writePath,
|
||||
naviChatWidget = naviChatWidget,
|
||||
messageOperation = messageOperation
|
||||
)
|
||||
if (::chatFireStoreDatabase.isInitialized) {
|
||||
chatFireStoreDatabase.writeToFireStore(
|
||||
path = fireStoreDataProviderModel.writePath,
|
||||
naviChatWidget = naviChatWidget,
|
||||
messageOperation = messageOperation
|
||||
)
|
||||
}
|
||||
}
|
||||
|
||||
fun removeFirestoreListener() {
|
||||
chatFireStoreDatabase.removeFireStoreListener()
|
||||
if (::chatFireStoreDatabase.isInitialized) {
|
||||
chatFireStoreDatabase.removeFireStoreListener()
|
||||
}
|
||||
}
|
||||
|
||||
@OnLifecycleEvent(Lifecycle.Event.ON_DESTROY)
|
||||
fun onDestroy() {
|
||||
chatFireStoreDatabase.removeFireStoreListener()
|
||||
if (::chatFireStoreDatabase.isInitialized) {
|
||||
chatFireStoreDatabase.removeFireStoreListener()
|
||||
}
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user