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

DustSubscriptionManager

@Singleton

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

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

Workflow:

Indexer (GraphQL) → Subscribe to events → Filter dust events → Replay into DustLocalState → Update database cache

Event Processing:

Subscribe to zswap ledger events (all blockchain events)
Filter for dust-specific events (DustInitialUtxo, DustSpendProcessed, etc.)
Batch events and replay into DustLocalState
Save updated state to persistent storage
Sync UTXOs to database cache

Usage:

@Inject lateinit var dustSubscriptionManager: DustSubscriptionManager

dustSubscriptionManager.startDustSync(
    address = userAddress,
    seed = userSeed
).collect { state ->
    when (state) {
        is DustSyncState.Syncing -> updateUI("Syncing dust: ${state.progress}%")
        is DustSyncState.Synced -> updateUI("Dust synced: ${state.balance}")
        is DustSyncState.Error -> showError(state.message)
    }
}