indexer/com.midnight.kuira.core.indexer.sync

Package-level declarations

Types

data class ChainCheckpoint(val height: Long, val hash: String)

A block pinned as a chain-instance identity: its height and hash. See SyncStateManager.

class ChainResetGuard(indexerClient: IndexerClient, shieldedRepository: ShieldedRepository, dustRepository: DustRepository, syncStateManager: SyncStateManager, utxoManager: UtxoManager, wipeOnResetEnabled: Boolean)

Detects a chain RESET — a localnet docker down/up replaces the chain with a fresh genesis — and wipes the stale wallet caches so they re-sync from the new chain.

DustSubscriptionManager

@Singleton

class DustSubscriptionManager @Inject constructor(indexerClient: IndexerClient, dustRepository: DustRepository)

Manages subscription to dust-related blockchain events and syncs them to DustLocalState.

ReorgDetectedException

class ReorgDetectedException(val address: String, val localHighest: Int, val serverMax: Int) : RuntimeException

Raised from inside the subscription flow when the indexer reports a highestTransactionId lower than what we have locally. Means the server's view of the chain went backwards (reorg, indexer DB wiped, dev localnet reset from genesis). SubscriptionManager catches this, wipes local state via performFullResync, and lets kotlinx.coroutines.flow.retryWhen restart the subscription cleanly from the new server truth.

SubscriptionManager

class SubscriptionManager(context: Context, indexerClient: IndexerClient, utxoManager: UtxoManager, syncStateManager: SyncStateManager, chainResetGuard: ChainResetGuard? = null)

Manages subscription lifecycle for UTXO syncing.

SyncState

sealed class SyncState

Sync state for UI/logging.

SyncStateManager

class SyncStateManager(context: Context)

Manages subscription sync state for resuming after app restarts.