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

Package-level declarations

Types

@Singleton

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

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

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)

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.