fix(runtime,core-db): wait for chain sync and include empty-asset chains; add ChainRegistry diagnostics

Author: WRRicht3r

core-db/build.gradle

@@ -32,7 +32,7 @@ android {
     sourceSets {
         androidTest.assets.srcDirs += files("$projectDir/schemas".toString())
     }
-    namespace 'jp.co.soramitsu.core_db'
+    namespace = 'jp.co.soramitsu.core_db'
 }
 
 ksp {

core-db/src/main/java/jp/co/soramitsu/coredb/dao/ChainDao.kt

@@ -164,7 +164,7 @@ abstract class ChainDao {
 
     @Query("SELECT * FROM chains WHERE id = :chainId")
     @Transaction
-    abstract suspend fun getJoinChainInfo(chainId: String): JoinedChainInfo
+    abstract suspend fun getJoinChainInfo(chainId: String): JoinedChainInfo?
 
     @Query("SELECT * FROM chains")
     @Transaction

runtime/src/main/java/jp/co/soramitsu/runtime/multiNetwork/chain/ChainSyncService.kt

@@ -1,5 +1,6 @@
 package jp.co.soramitsu.runtime.multiNetwork.chain
 
+import android.util.Log
 import jp.co.soramitsu.common.resources.ContextManager
 import jp.co.soramitsu.coredb.dao.AssetDao
 import jp.co.soramitsu.coredb.dao.ChainDao
@@ -32,19 +33,21 @@ class ChainSyncService(
     }
 
     private suspend fun configChainsSyncUp(): List<Chain> = supervisorScope {
+        val tag = "ChainRegistry"
         val localChainsJoinedInfo = dao.getJoinChainInfo()
         val localChainsJoinedInfoMap = localChainsJoinedInfo.associateBy { it.chain.id }
 
         val remoteChains = chainFetcher.getChains()
-            .filter {
-                !it.disabled && (it.assets?.isNotEmpty() == true)
-            }
+            .filter { !it.disabled }
             .map {
                 it.toChain()
             }
 
         val remoteMapping = remoteChains.associateBy(Chain::id)
 
+        Log.d(tag, "remote chains fetched: ${remoteChains.size}")
+        remoteChains.take(5).forEach { Log.d(tag, "remote chain id: ${it.id}") }
+
         val mappedRemoteChains = remoteChains.map { mapChainToChainLocal(it) }
         val chainsSyncDeferred = async {
             val chainsToUpdate: MutableList<ChainLocal> = mutableListOf()
@@ -162,6 +165,10 @@ class ChainSyncService(
 
         dao.deleteChains(chainsToDelete)
 
+        val postLocal = dao.getJoinChainInfo()
+        Log.d(tag, "local chains after sync: ${postLocal.size}")
+        postLocal.take(5).forEach { Log.d(tag, "local chain id: ${it.chain.id}") }
+
         remoteChains
     }
 }

runtime/src/main/java/jp/co/soramitsu/runtime/multiNetwork/chain/ChainsRepository.kt

@@ -46,7 +46,7 @@ class ChainsRepository(private val chainDao: ChainDao) {
 
     suspend fun getChain(chainId: ChainId): Chain = withContext(Dispatchers.IO) {
         // Be resilient on fresh installs/after data clears: wait briefly for chain sync
-        repeat(50) { // ~15s at 300ms per attempt
+        repeat(200) { // ~60s at 300ms per attempt
             val local = chainDao.getJoinChainInfo()
             val found = local.firstOrNull { it.chain.id == chainId }
             if (found != null) return@withContext mapChainLocalToChain(found)