Fix job inject

Author: SeniorZhai

app/src/main/java/one/mixin/android/job/BaseJob.kt

@@ -242,7 +242,7 @@ abstract class BaseJob(params: Params) : Job(params) {
 
     fun topAssetDao(): TopAssetDao = database().topAssetDao()
 
-    fun jobDao(): JobDao = database().jobDao()
+    fun jobDao(): JobDao = pendingDatabase().jobDao()
 
     fun favoriteAppDao(): FavoriteAppDao = database().favoriteAppDao()
 

app/src/main/java/one/mixin/android/job/Injector.kt

@@ -103,7 +103,7 @@ open class Injector {
     fun messageHistoryDao(): MessageHistoryDao = databaseProvider.getMixinDatabase().messageHistoryDao()
     fun userDao(): UserDao = databaseProvider.getMixinDatabase().userDao()
     fun appDao(): AppDao = databaseProvider.getMixinDatabase().appDao()
-    fun jobDao(): JobDao = databaseProvider.getMixinDatabase().jobDao()
+    fun jobDao(): JobDao = databaseProvider.getPendingDatabase().jobDao()
     fun conversationDao(): ConversationDao = databaseProvider.getMixinDatabase().conversationDao()
     fun conversationExtDao(): ConversationExtDao = databaseProvider.getMixinDatabase().conversationExtDao()
     fun participantDao(): ParticipantDao = databaseProvider.getMixinDatabase().participantDao()

app/src/main/java/one/mixin/android/websocket/ChatWebSocket.kt

@@ -302,7 +302,7 @@ class ChatWebSocket(
                     val jsonData = gson.toJson(data)
                     if (jsonData.isNullOrBlank()) {
                         reportException(IllegalArgumentException("Error flood data: ${blazeMessage.id} ${blazeMessage.action}"))
-                        databaseProvider.getMixinDatabase().jobDao().insertNoReplace(createAckJob(ACKNOWLEDGE_MESSAGE_RECEIPTS, BlazeAckMessage(data.messageId, MessageStatus.DELIVERED.name)))
+                        databaseProvider.getPendingDatabase().jobDao().insertNoReplace(createAckJob(ACKNOWLEDGE_MESSAGE_RECEIPTS, BlazeAckMessage(data.messageId, MessageStatus.DELIVERED.name)))
                         return@launch
                     }
                     databaseProvider.getPendingDatabase().insertFloodMessage(FloodMessage(data.messageId, jsonData, data.createdAt))