From 9c9ea4a01c7ad4ee8b6f7a2e12006706bdcac78c Mon Sep 17 00:00:00 2001 From: SeniorZhai Date: Wed, 27 Nov 2024 18:44:53 +0800 Subject: [PATCH] Job inject --- .../java/one/mixin/android/db/DaoExtension.kt | 6 +- .../one/mixin/android/db/MixinDatabase.kt | 2 +- .../one/mixin/android/di/DatabaseModule.kt | 2 +- .../java/one/mixin/android/job/BaseJob.kt | 234 ++++++------------ .../one/mixin/android/job/ConversationJob.kt | 2 +- .../one/mixin/android/job/ConvertDataJob.kt | 2 +- .../one/mixin/android/job/MessageDeleteJob.kt | 2 +- .../android/job/RefreshConversationJob.kt | 2 +- .../one/mixin/android/job/RefreshDappJob.kt | 4 +- .../one/mixin/android/job/RefreshTokensJob.kt | 6 +- .../one/mixin/android/job/RefreshUserJob.kt | 4 +- .../android/job/RestoreTransactionJob.kt | 4 +- .../android/job/SendProcessSignalKeyJob.kt | 2 +- .../mixin/android/job/SendTranscriptJob.kt | 2 +- .../android/job/UpdateRelationshipJob.kt | 4 +- 15 files changed, 96 insertions(+), 182 deletions(-) diff --git a/app/src/main/java/one/mixin/android/db/DaoExtension.kt b/app/src/main/java/one/mixin/android/db/DaoExtension.kt index b550e68fb1..06477802e6 100644 --- a/app/src/main/java/one/mixin/android/db/DaoExtension.kt +++ b/app/src/main/java/one/mixin/android/db/DaoExtension.kt @@ -194,7 +194,7 @@ suspend fun OutputDao.insertUnspentOutputs(outputs: List) = fun MixinDatabase.deleteMessageById(messageId: String) { runInTransaction { pinMessageDao().deleteByMessageId(messageId) - mentionMessageDao().deleteMessage(messageId) + messageMentionDao().deleteMessage(messageId) messageDao().deleteMessageById(messageId) remoteMessageStatusDao().deleteByMessageId(messageId) expiredMessageDao().deleteByMessageId(messageId) @@ -207,7 +207,7 @@ fun MixinDatabase.deleteMessageById( ) { runInTransaction { pinMessageDao().deleteByMessageId(messageId) - mentionMessageDao().deleteMessage(messageId) + messageMentionDao().deleteMessage(messageId) messageDao().deleteMessageById(messageId) conversationExtDao().decrement(conversationId) remoteMessageStatusDao().deleteByMessageId(messageId) @@ -219,7 +219,7 @@ fun MixinDatabase.deleteMessageById( fun MixinDatabase.deleteMessageByIds(messageIds: List) { runInTransaction { pinMessageDao().deleteByIds(messageIds) - mentionMessageDao().deleteMessage(messageIds) + messageMentionDao().deleteMessage(messageIds) messageDao().deleteMessageById(messageIds) remoteMessageStatusDao().deleteByMessageIds(messageIds) expiredMessageDao().deleteByMessageId(messageIds) diff --git a/app/src/main/java/one/mixin/android/db/MixinDatabase.kt b/app/src/main/java/one/mixin/android/db/MixinDatabase.kt index 9fc4122c34..e068769a4a 100644 --- a/app/src/main/java/one/mixin/android/db/MixinDatabase.kt +++ b/app/src/main/java/one/mixin/android/db/MixinDatabase.kt @@ -236,7 +236,7 @@ abstract class MixinDatabase : RoomDatabase() { abstract fun favoriteAppDao(): FavoriteAppDao - abstract fun mentionMessageDao(): MessageMentionDao + abstract fun messageMentionDao(): MessageMentionDao abstract fun circleDao(): CircleDao diff --git a/app/src/main/java/one/mixin/android/di/DatabaseModule.kt b/app/src/main/java/one/mixin/android/di/DatabaseModule.kt index 12ff7b7026..e21d64da45 100644 --- a/app/src/main/java/one/mixin/android/di/DatabaseModule.kt +++ b/app/src/main/java/one/mixin/android/di/DatabaseModule.kt @@ -122,7 +122,7 @@ internal object DatabaseModule { fun providesFavoriteAppDao(db: MixinDatabase) = db.favoriteAppDao() @Provides - fun providesMentionMessageDao(db: MixinDatabase) = db.mentionMessageDao() + fun providesMentionMessageDao(db: MixinDatabase) = db.messageMentionDao() @Provides fun providesCircleDao(db: MixinDatabase) = db.circleDao() diff --git a/app/src/main/java/one/mixin/android/job/BaseJob.kt b/app/src/main/java/one/mixin/android/job/BaseJob.kt index 69caed646f..1f6edf7fc0 100644 --- a/app/src/main/java/one/mixin/android/job/BaseJob.kt +++ b/app/src/main/java/one/mixin/android/job/BaseJob.kt @@ -40,6 +40,7 @@ import one.mixin.android.db.CircleConversationDao import one.mixin.android.db.CircleDao import one.mixin.android.db.ConversationDao import one.mixin.android.db.ConversationExtDao +import one.mixin.android.db.DatabaseProvider import one.mixin.android.db.ExpiredMessageDao import one.mixin.android.db.FavoriteAppDao import one.mixin.android.db.HistoryPriceDao @@ -100,15 +101,7 @@ abstract class BaseJob(params: Params) : Job(params) { @Inject @Transient - lateinit var ftsDatabase: FtsDatabase - - @Inject - @Transient - lateinit var mixinDatabase: MixinDatabase - - @Inject - @Transient - lateinit var pendingDatabase: PendingDatabase + lateinit var databaseProvider: DatabaseProvider @Inject @Transient @@ -160,224 +153,144 @@ abstract class BaseJob(params: Params) : Job(params) { @Inject @Transient - lateinit var messageDao: MessageDao + lateinit var chatWebSocket: ChatWebSocket - @Inject - @Transient - lateinit var messageHistoryDao: MessageHistoryDao + // @Inject + // @Transient + // lateinit var conversationRepo: ConversationRepository - @Inject - @Transient - lateinit var userDao: UserDao + // @Inject + // @Transient + // lateinit var userRepo: UserRepository - @Inject - @Transient - lateinit var conversationDao: ConversationDao + // @Inject + // @Transient + // lateinit var assetRepo: TokenRepository @Inject @Transient - lateinit var conversationExtDao: ConversationExtDao + lateinit var signalProtocol: SignalProtocol @Inject @Transient - lateinit var participantDao: ParticipantDao + lateinit var encryptedProtocol: EncryptedProtocol - @Inject @Transient - lateinit var participantSessionDao: ParticipantSessionDao - @Inject - @Transient - lateinit var offsetDao: OffsetDao + lateinit var linkState: LinkState - @Inject @Transient - lateinit var assetDao: AssetDao - @Inject - @Transient - lateinit var tokenDao: TokenDao + lateinit var tip: Tip - @Inject @Transient - lateinit var tokensExtraDao: TokensExtraDao - @Inject - @Transient - lateinit var snapshotDao: SnapshotDao + lateinit var tipCounterSynced: TipCounterSyncedLiveData @Inject @Transient - lateinit var chainDao: ChainDao + lateinit var tipService: TipService @Inject @Transient - lateinit var chatWebSocket: ChatWebSocket + lateinit var web3Service: Web3Service - @Inject + @ApplicationScope @Transient - lateinit var conversationRepo: ConversationRepository - @Inject - @Transient - lateinit var userRepo: UserRepository + lateinit var applicationScope: CoroutineScope - @Inject @Transient - lateinit var assetRepo: TokenRepository - @Inject - @Transient - lateinit var stickerDao: StickerDao + lateinit var jobSenderKey: JobSenderKey - @Inject - @Transient - lateinit var hyperlinkDao: HyperlinkDao + val mixinDatabase: MixinDatabase by lazy { databaseProvider.getMixinDatabase() } - @Inject - @Transient - lateinit var stickerAlbumDao: StickerAlbumDao + val ftsDatabase: FtsDatabase by lazy { databaseProvider.getFtsDatabase() } - @Inject - @Transient - lateinit var stickerRelationshipDao: StickerRelationshipDao + val pendingDatabase: PendingDatabase by lazy { databaseProvider.getPendingDatabase() } - @Inject - @Transient - lateinit var addressDao: AddressDao + val messageDao: MessageDao by lazy { databaseProvider.getMixinDatabase().messageDao() } - @Inject - @Transient - lateinit var topAssetDao: TopAssetDao + val messageHistoryDao: MessageHistoryDao by lazy { databaseProvider.getMixinDatabase().messageHistoryDao() } - @Inject - @Transient - lateinit var jobDao: JobDao + val userDao: UserDao by lazy { databaseProvider.getMixinDatabase().userDao() } - @Inject - @Transient - lateinit var favoriteAppDao: FavoriteAppDao + val conversationDao: ConversationDao by lazy { databaseProvider.getMixinDatabase().conversationDao() } - @Inject - @Transient - lateinit var messageMentionDao: MessageMentionDao + val conversationExtDao: ConversationExtDao by lazy { databaseProvider.getMixinDatabase().conversationExtDao() } - @Inject - @Transient - lateinit var appDao: AppDao + val participantDao: ParticipantDao by lazy { databaseProvider.getMixinDatabase().participantDao() } - @Inject - @Transient - lateinit var circleDao: CircleDao + val participantSessionDao: ParticipantSessionDao by lazy { databaseProvider.getMixinDatabase().participantSessionDao() } - @Inject - @Transient - lateinit var circleConversationDao: CircleConversationDao + val offsetDao: OffsetDao by lazy { databaseProvider.getMixinDatabase().offsetDao() } - @Inject - @Transient - lateinit var transcriptMessageDao: TranscriptMessageDao + val assetDao: AssetDao by lazy { databaseProvider.getMixinDatabase().assetDao() } - @Inject - @Transient - lateinit var pinMessageDao: PinMessageDao + val tokenDao: TokenDao by lazy { databaseProvider.getMixinDatabase().tokenDao() } - @Inject - @Transient - lateinit var propertyDao: PropertyDao + val tokensExtraDao: TokensExtraDao by lazy { databaseProvider.getMixinDatabase().tokensExtraDao() } - @Inject - @Transient - lateinit var remoteMessageStatusDao: RemoteMessageStatusDao + val snapshotDao: SnapshotDao by lazy { databaseProvider.getMixinDatabase().snapshotDao() } - @Inject - @Transient - lateinit var expiredMessageDao: ExpiredMessageDao + val chainDao: ChainDao by lazy { databaseProvider.getMixinDatabase().chainDao() } - @Inject - @Transient - lateinit var outputDao: OutputDao + val stickerDao: StickerDao by lazy { databaseProvider.getMixinDatabase().stickerDao() } - @Inject - @Transient - lateinit var rawTransactionDao: RawTransactionDao + val hyperlinkDao: HyperlinkDao by lazy { databaseProvider.getMixinDatabase().hyperlinkDao() } - @Inject - @Transient - lateinit var safeSnapshotDao: SafeSnapshotDao + val stickerAlbumDao: StickerAlbumDao by lazy { databaseProvider.getMixinDatabase().stickerAlbumDao() } - @Inject - @Transient - lateinit var inscriptionDao: InscriptionDao + val stickerRelationshipDao: StickerRelationshipDao by lazy { databaseProvider.getMixinDatabase().stickerRelationshipDao() } - @Inject - @Transient - lateinit var marketDao: MarketDao + val addressDao: AddressDao by lazy { databaseProvider.getMixinDatabase().addressDao() } - @Inject - @Transient - lateinit var marketFavoredDao: MarketFavoredDao + val topAssetDao: TopAssetDao by lazy { databaseProvider.getMixinDatabase().topAssetDao() } - @Inject - @Transient - lateinit var alertDao: AlertDao + val jobDao: JobDao by lazy { databaseProvider.getMixinDatabase().jobDao() } - @Inject - @Transient - lateinit var marketCapRankDao: MarketCapRankDao + val favoriteAppDao: FavoriteAppDao by lazy { databaseProvider.getMixinDatabase().favoriteAppDao() } - @Inject - @Transient - lateinit var marketCoinDao: MarketCoinDao + val messageMentionDao: MessageMentionDao by lazy { databaseProvider.getMixinDatabase().messageMentionDao() } - @Inject - @Transient - lateinit var historyPriceDao: HistoryPriceDao + val appDao: AppDao by lazy { databaseProvider.getMixinDatabase().appDao() } - @Inject - @Transient - lateinit var inscriptionCollectionDao: InscriptionCollectionDao + val circleDao: CircleDao by lazy { databaseProvider.getMixinDatabase().circleDao() } - @Inject - @Transient - lateinit var signalProtocol: SignalProtocol + val circleConversationDao: CircleConversationDao by lazy { databaseProvider.getMixinDatabase().circleConversationDao() } - @Inject - @Transient - lateinit var encryptedProtocol: EncryptedProtocol + val transcriptMessageDao: TranscriptMessageDao by lazy { databaseProvider.getMixinDatabase().transcriptDao() } - @Transient - @Inject - lateinit var appDatabase: MixinDatabase + val pinMessageDao: PinMessageDao by lazy { databaseProvider.getMixinDatabase().pinMessageDao() } - @Transient - @Inject - lateinit var linkState: LinkState + val propertyDao: PropertyDao by lazy { databaseProvider.getMixinDatabase().propertyDao() } - @Transient - @Inject - lateinit var tip: Tip + val remoteMessageStatusDao: RemoteMessageStatusDao by lazy { databaseProvider.getMixinDatabase().remoteMessageStatusDao() } - @Transient - @Inject - lateinit var tipCounterSynced: TipCounterSyncedLiveData + val expiredMessageDao: ExpiredMessageDao by lazy { databaseProvider.getMixinDatabase().expiredMessageDao() } - @Inject - @Transient - lateinit var tipService: TipService + val outputDao: OutputDao by lazy { databaseProvider.getMixinDatabase().outputDao() } - @Inject - @Transient - lateinit var web3Service: Web3Service + val rawTransactionDao: RawTransactionDao by lazy { databaseProvider.getMixinDatabase().rawTransactionDao() } - @ApplicationScope - @Transient - @Inject - lateinit var applicationScope: CoroutineScope + val safeSnapshotDao: SafeSnapshotDao by lazy { databaseProvider.getMixinDatabase().safeSnapshotDao() } - @Transient - @Inject - lateinit var jobSenderKey: JobSenderKey + val inscriptionDao: InscriptionDao by lazy { databaseProvider.getMixinDatabase().inscriptionDao() } + + val marketDao: MarketDao by lazy { databaseProvider.getMixinDatabase().marketDao() } + + val marketFavoredDao: MarketFavoredDao by lazy { databaseProvider.getMixinDatabase().marketFavoredDao() } + + val alertDao: AlertDao by lazy { databaseProvider.getMixinDatabase().alertDao() } + + val marketCapRankDao: MarketCapRankDao by lazy { databaseProvider.getMixinDatabase().marketCapRankDao() } + + val marketCoinDao: MarketCoinDao by lazy { databaseProvider.getMixinDatabase().marketCoinDao() } + + val historyPriceDao: HistoryPriceDao by lazy { databaseProvider.getMixinDatabase().historyPriceDao() } + + val inscriptionCollectionDao: InscriptionCollectionDao by lazy { databaseProvider.getMixinDatabase().inscriptionCollectionDao() } open fun shouldRetry(throwable: Throwable): Boolean { if (throwable is SocketTimeoutException) { @@ -419,6 +332,7 @@ abstract class BaseJob(params: Params) : Job(params) { } override fun onAdded() { + databaseProvider.initAllDatabases() } override fun onCancel( diff --git a/app/src/main/java/one/mixin/android/job/ConversationJob.kt b/app/src/main/java/one/mixin/android/job/ConversationJob.kt index 9803704396..6f4362455c 100644 --- a/app/src/main/java/one/mixin/android/job/ConversationJob.kt +++ b/app/src/main/java/one/mixin/android/job/ConversationJob.kt @@ -131,7 +131,7 @@ class ConversationJob( if (r != null && r.isSuccess && r.data != null) { val cr = r.data!! if (type == TYPE_CREATE) { - conversationRepo.insertOrUpdateConversation(cr) + // conversationRepo.insertOrUpdateConversation(cr) val participants = mutableListOf() cr.participants.mapTo(participants) { Participant(cr.conversationId, it.userId, it.role, cr.createdAt) diff --git a/app/src/main/java/one/mixin/android/job/ConvertDataJob.kt b/app/src/main/java/one/mixin/android/job/ConvertDataJob.kt index 50b02c68d2..d8f5ebc9f1 100644 --- a/app/src/main/java/one/mixin/android/job/ConvertDataJob.kt +++ b/app/src/main/java/one/mixin/android/job/ConvertDataJob.kt @@ -24,7 +24,7 @@ class ConvertDataJob( } override fun onAdded() { - appDatabase.insertMessage(message) + mixinDatabase.insertMessage(message) MessageFlow.insert(message.conversationId, message.messageId) } diff --git a/app/src/main/java/one/mixin/android/job/MessageDeleteJob.kt b/app/src/main/java/one/mixin/android/job/MessageDeleteJob.kt index 173482a0f8..ecb04d3ee2 100644 --- a/app/src/main/java/one/mixin/android/job/MessageDeleteJob.kt +++ b/app/src/main/java/one/mixin/android/job/MessageDeleteJob.kt @@ -32,7 +32,7 @@ class MessageDeleteJob( DB_DELETE_LIMIT, ) ftsDatabase.deleteByMessageIds(ids) - appDatabase.deleteMessageByIds(ids) + mixinDatabase.deleteMessageByIds(ids) MessageFlow.delete(conversationId, ids) } val currentRowId = messageDao.findLastMessageRowId(conversationId) diff --git a/app/src/main/java/one/mixin/android/job/RefreshConversationJob.kt b/app/src/main/java/one/mixin/android/job/RefreshConversationJob.kt index 2a27f3ce92..08ccf64b46 100644 --- a/app/src/main/java/one/mixin/android/job/RefreshConversationJob.kt +++ b/app/src/main/java/one/mixin/android/job/RefreshConversationJob.kt @@ -31,7 +31,7 @@ class RefreshConversationJob(val conversationId: String, private val skipRefresh val response = call.body() if (response != null && response.isSuccess) { response.data?.let { data -> - conversationRepo.insertOrUpdateConversation(data) + // conversationRepo.insertOrUpdateConversation(data) val participants = mutableListOf() val conversationUserIds = mutableListOf() for (p in data.participants) { diff --git a/app/src/main/java/one/mixin/android/job/RefreshDappJob.kt b/app/src/main/java/one/mixin/android/job/RefreshDappJob.kt index 46db59d3a3..0d693fb3b7 100644 --- a/app/src/main/java/one/mixin/android/job/RefreshDappJob.kt +++ b/app/src/main/java/one/mixin/android/job/RefreshDappJob.kt @@ -28,7 +28,7 @@ class RefreshDappJob : BaseJob( override fun onRun(): Unit = runBlocking { - userRepo.getBotPublicKey(WEB3_BOT_USER_ID, false) + // userRepo.getBotPublicKey(WEB3_BOT_USER_ID, false) val response = web3Service.dapps() if (response.isSuccess && response.data != null) { val gson = GsonHelper.customGson @@ -59,7 +59,7 @@ class RefreshDappJob : BaseJob( } RxBus.publish(WCChangeEvent()) } else if (response.errorCode == 401) { - userRepo.getBotPublicKey(WEB3_BOT_USER_ID, true) + // userRepo.getBotPublicKey(WEB3_BOT_USER_ID, true) } else { delay(3000) jobManager.addJobInBackground(RefreshDappJob()) diff --git a/app/src/main/java/one/mixin/android/job/RefreshTokensJob.kt b/app/src/main/java/one/mixin/android/job/RefreshTokensJob.kt index 1d28f8d9df..94392d6c63 100644 --- a/app/src/main/java/one/mixin/android/job/RefreshTokensJob.kt +++ b/app/src/main/java/one/mixin/android/job/RefreshTokensJob.kt @@ -26,7 +26,7 @@ class RefreshTokensJob( val response = tokenService.getAssetByIdSuspend(assetId) if (response.isSuccess && response.data != null) { response.data?.let { - assetRepo.insert(it) + // assetRepo.insert(it) refreshChainById(it.chainId) } if (conversationId != null && messageId != null) { @@ -39,7 +39,7 @@ class RefreshTokensJob( val response = tokenService.fetchTokenSuspend(tokenIds) if (response.isSuccess && response.data != null) { val list = response.data as List - assetRepo.insertList(list) + // assetRepo.insertList(list) } refreshChains() refreshFiats() @@ -50,7 +50,7 @@ class RefreshTokensJob( val response = tokenService.fetchAllTokenSuspend() if (response.isSuccess && response.data != null) { val list = response.data as List - assetRepo.insertList(list) + // assetRepo.insertList(list) } } diff --git a/app/src/main/java/one/mixin/android/job/RefreshUserJob.kt b/app/src/main/java/one/mixin/android/job/RefreshUserJob.kt index f1189e071b..e86b99bcea 100644 --- a/app/src/main/java/one/mixin/android/job/RefreshUserJob.kt +++ b/app/src/main/java/one/mixin/android/job/RefreshUserJob.kt @@ -44,7 +44,7 @@ class RefreshUserJob( val response = userService.getUserById(userIds[0]).execute().body() if (response != null && response.isSuccess) { response.data?.let { data -> - userRepo.upsert(data) + // userRepo.upsert(data) refreshConversationAvatar() } } @@ -52,7 +52,7 @@ class RefreshUserJob( val response = userService.getUsers(userIds).execute().body() if (response != null && response.isSuccess) { response.data?.let { data -> - userRepo.upsertList(data) + // userRepo.upsertList(data) refreshConversationAvatar() } } diff --git a/app/src/main/java/one/mixin/android/job/RestoreTransactionJob.kt b/app/src/main/java/one/mixin/android/job/RestoreTransactionJob.kt index bbfe64785d..f7ffdf0369 100644 --- a/app/src/main/java/one/mixin/android/job/RestoreTransactionJob.kt +++ b/app/src/main/java/one/mixin/android/job/RestoreTransactionJob.kt @@ -133,7 +133,7 @@ class RestoreTransactionJob : BaseJob( MessageCategory.SYSTEM_SAFE_SNAPSHOT.name } val message = createMessage(UUID.randomUUID().toString(), conversationId, data.userId, category, inscriptionHash ?: "", data.createdAt, MessageStatus.DELIVERED.name, SafeSnapshotType.snapshot.name, null, data.getSnapshotId) - appDatabase.insertMessage(message) + mixinDatabase.insertMessage(message) if (inscriptionHash != null) { jobManager.addJobInBackground(SyncInscriptionMessageJob(conversationId, message.messageId, inscriptionHash, data.getSnapshotId)) } @@ -161,7 +161,7 @@ class RestoreTransactionJob : BaseJob( Participant(conversationId, senderId, "", createdAt), Participant(conversationId, recipientId, "", createdAt), ) - appDatabase.runInTransaction { + mixinDatabase.runInTransaction { conversationDao.upsert(conversation) participantDao.insertList(participants) } diff --git a/app/src/main/java/one/mixin/android/job/SendProcessSignalKeyJob.kt b/app/src/main/java/one/mixin/android/job/SendProcessSignalKeyJob.kt index d9eaed6b4d..fac7e7fd1e 100644 --- a/app/src/main/java/one/mixin/android/job/SendProcessSignalKeyJob.kt +++ b/app/src/main/java/one/mixin/android/job/SendProcessSignalKeyJob.kt @@ -30,7 +30,7 @@ class SendProcessSignalKeyJob( } } else if (action == ProcessSignalKeyAction.REMOVE_PARTICIPANT) { Session.getAccountId()?.let { - appDatabase.clearParticipant(data.conversationId, participantId!!) + mixinDatabase.clearParticipant(data.conversationId, participantId!!) signalProtocol.clearSenderKey(data.conversationId, it) RxBus.publish(SenderKeyChange(data.conversationId)) } diff --git a/app/src/main/java/one/mixin/android/job/SendTranscriptJob.kt b/app/src/main/java/one/mixin/android/job/SendTranscriptJob.kt index 16a9d1beea..ad4ee0c1a6 100644 --- a/app/src/main/java/one/mixin/android/job/SendTranscriptJob.kt +++ b/app/src/main/java/one/mixin/android/job/SendTranscriptJob.kt @@ -59,7 +59,7 @@ class SendTranscriptJob( } } ftsDatabase.insertFts4(stringBuffer.toString(), message.conversationId, message.messageId, message.category, message.userId, message.createdAt) - appDatabase.insertMessage(message) + mixinDatabase.insertMessage(message) MessageFlow.insert(message.conversationId, message.messageId) transcriptMessages.forEach { transcript -> if (transcript.isAttachment()) { diff --git a/app/src/main/java/one/mixin/android/job/UpdateRelationshipJob.kt b/app/src/main/java/one/mixin/android/job/UpdateRelationshipJob.kt index ce59ce9f6b..c7f2351df2 100644 --- a/app/src/main/java/one/mixin/android/job/UpdateRelationshipJob.kt +++ b/app/src/main/java/one/mixin/android/job/UpdateRelationshipJob.kt @@ -75,8 +75,8 @@ class UpdateRelationshipJob( private suspend fun updateUser(u: User) { if (u.app != null) { u.appId = u.app!!.appId - userRepo.insertApp(u.app!!) + // userRepo.insertApp(u.app!!) } - userRepo.upsert(u) + // userRepo.upsert(u) } }