-
public interface Synchronizer
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description public enumSynchronizer.StatusRepresents the status of this Synchronizer, which is useful for communicating to the user.
public enumSynchronizer.InitializationErrorpublic classSynchronizer.Companion
-
Method Summary
Modifier and Type Method Description abstract List<Account>getAccounts()Returns all the wallet accounts or throws InitializeException.GetAccountsException abstract AccountimportAccountByUfvk(AccountImportSetup setup)Tells the wallet to track an account using a unified full viewing key. abstract Flow<FastestServersResult>getFastestServers(List<LightWalletEndpoint> servers)Adds the next available account-level spend authority, given the current set of ZIP 316 account identifiers known, to the wallet database. abstract StringgetUnifiedAddress(Account account)Gets the current unified address for the given account. abstract StringgetCustomUnifiedAddress(Account account, UnifiedAddressRequest request)Gets a new unified address that conforms to the specified request. abstract StringgetSaplingAddress(Account account)Gets the legacy Sapling address corresponding to the current unified address for the given account. abstract StringgetTransparentAddress(Account account)Gets the legacy transparent address corresponding to the current unified address for the given account. abstract UnitrefreshExchangeRateUsd()Refreshes exchangeRateUsd. abstract ProposalproposeTransfer(Account account, String recipient, Zatoshi amount, String memo)Creates a proposal for transferring funds to the given recipient. abstract ProposalproposeFulfillingPaymentUri(Account account, String uri)Creates a proposal for fulfilling a payment ZIP-321 URI abstract ProposalproposeShielding(Account account, Zatoshi shieldingThreshold, String memo, String transparentReceiver)Creates a proposal for shielding any transparent funds received by the given account. abstract Flow<TransactionSubmitResult>createProposedTransactions(Proposal proposal, UnifiedSpendingKey usk)Creates the transactions in the given proposal. abstract PcztcreatePcztFromProposal(AccountUuid accountUuid, Proposal proposal)Creates a partially-created (unsigned without proofs) transaction from the given proposal. abstract PcztredactPcztForSigner(Pczt pczt)Redacts information from the given PCZT that is unnecessary for the Signer role. abstract BooleanpcztRequiresSaplingProofs(Pczt pczt)Checks whether the caller needs to have downloaded the Sapling parameters. abstract PcztaddProofsToPczt(Pczt pczt)Adds proofs to the given PCZT. abstract Flow<TransactionSubmitResult>createTransactionFromPczt(Pczt pcztWithProofs, Pczt pcztWithSignatures)Takes a PCZT that has been separately proven and signed, finalizes it, and stores it in the wallet. abstract BooleanisValidShieldedAddr(String address)Returns true when the given address is a valid z-addr. abstract BooleanisValidTransparentAddr(String address)Returns true when the given address is a valid t-addr. abstract BooleanisValidUnifiedAddr(String address)Returns true when the given address is a valid ZIP 316 unified address. abstract BooleanisValidTexAddr(String address)Returns true when the given address is a valid ZIP 320 TEX address. abstract ConsensusMatchTypevalidateConsensusBranch()Validate whether the server and this SDK share the same consensus branch. abstract ServerValidationvalidateServerEndpoint(Context context, LightWalletEndpoint endpoint)This function checks whether the provided server endpoint is valid. abstract AddressTypevalidateAddress(String address)Validates the given address, returning information about why it is invalid. abstract IntegerrefreshUtxos(Account account, BlockHeight since)Download all UTXOs for the given account addresses and store any new ones in the database. abstract ZatoshigetTransparentBalance(String tAddr)Returns the balance that the wallet knows about. abstract BlockHeightrewindToNearestHeight(BlockHeight height)Rewinds to the safest height to which we can rewind, given a desire to rewind to the height provided. abstract Flow<String>getMemos(TransactionOverview transactionOverview)Returns a stream of memos for a transaction. abstract Flow<List<TransactionId>>getTransactionsByMemoSubstring(String query)Filters the current transactions based on their memos. abstract Flow<TransactionRecipient>getRecipients(TransactionOverview transactionOverview)Returns a list of recipients for a transaction. abstract StringgetExistingDataDbFilePath(Context context, ZcashNetwork network, String alias)Checks and provides file path to the existing data database file for the given input parameters or throws InitializeException.MissingDatabaseException if the database does not exist yet. abstract List<TransactionOutput>getTransactionOutputs(TransactionOverview transactionOverview)Returns a list of all transaction outputs for a transaction. abstract Flow<List<TransactionOverview>>getTransactions(AccountUuid accountUuid)Returns all transactions belonging to the given account UUID abstract SingleUseTransparentAddressgetSingleUseTransparentAddress(AccountUuid accountUuid)Generates and returns an ephemeral address for one-time use, such as when receiving a swap from a decentralized exchange. abstract BooleancheckSingleUseTransparentAddress(AccountUuid accountUuid)Checks to find any single-use ephemeral addresses exposed in the past day that have not yet received funds, excluding any whose next check time is in the future. abstract BooleanfetchUtxosByAddress(AccountUuid accountUuid, String address)Queries the light wallet server to find any UTXOs associated with the given transparent address, and adds any UTXOs discovered to the wallet. abstract UnitenhanceTransaction(TransactionId txId)Requests to enhance transaction enhancement for the txId. abstract UnitonBackground()abstract UnitonForeground()abstract HttpClientgetTorHttpClient(Function1<HttpClientConfig<HttpClientEngineConfig>, Unit> config)abstract StringdebugQuery(String query)abstract ZcashNetworkgetNetwork()The network to which this synchronizer is connected and from which it is processing blocks. abstract Flow<Synchronizer.Status>getStatus()A flow of values representing the Status of this Synchronizer. abstract Flow<PercentDecimal>getProgress()Indicates the download progress of the Synchronizer. abstract Flow<Boolean>getAreFundsSpendable()Indicates whether are the shielded wallet balances spendable or not during the block synchronization process. abstract Flow<CompactBlockProcessor.ProcessorInfo>getProcessorInfo()A flow of processor details, updated every time blocks are processed to include the latest block height, blocks downloaded and blocks scanned. abstract StateFlow<BlockHeight>getNetworkHeight()The latest height observed on the network, which does not necessarily correspond to the latest downloaded height or scanned height. abstract StateFlow<Map<AccountUuid, AccountBalance>>getWalletBalances()A stream of wallet balances abstract StateFlow<ObserveFiatCurrencyResult>getExchangeRateUsd()The latest known USD/ZEC exchange rate, paired with the time it was queried. abstract Flow<List<TransactionOverview>>getAllTransactions()A flow of all the transactions that are on the blockchain. abstract BlockHeightgetLatestHeight()An in-memory reference to the latest height seen on the network. abstract BlockHeightgetLatestBirthdayHeight()An in-memory reference to the best known birthday height, which can change if the first transaction has not yet occurred. abstract Flow<List<Account>>getAccountsFlow()Returns all the wallet accounts or throws InitializeException.GetAccountsExceptionIt's a Flow version of getAccounts abstract Synchronizer.InitializationErrorgetInitializationError()Emits error states of the synchronizer. abstract Function1<Throwable, Boolean>getOnCriticalErrorHandler()Gets or sets a global error handler. abstract UnitsetOnCriticalErrorHandler(Function1<Throwable, Boolean> onCriticalErrorHandler)Gets or sets a global error handler. abstract Function1<Throwable, Boolean>getOnProcessorErrorHandler()An error handler for exceptions during processing. abstract UnitsetOnProcessorErrorHandler(Function1<Throwable, Boolean> onProcessorErrorHandler)An error handler for exceptions during processing. abstract Function0<Unit>getOnProcessorErrorResolved()abstract UnitsetOnProcessorErrorResolved(Function0<Unit> onProcessorErrorResolved)abstract Function1<Throwable, Boolean>getOnSetupErrorHandler()Callback for setup errors that occur prior to processing compact blocks. abstract UnitsetOnSetupErrorHandler(Function1<Throwable, Boolean> onSetupErrorHandler)Callback for setup errors that occur prior to processing compact blocks. abstract Function2<BlockHeight, BlockHeight, Object>getOnChainErrorHandler()A callback to invoke whenever a chain error is encountered. abstract UnitsetOnChainErrorHandler(Function2<BlockHeight, BlockHeight, Object> onChainErrorHandler)A callback to invoke whenever a chain error is encountered. -
-
Method Detail
-
getAccounts
abstract List<Account> getAccounts()
Returns all the wallet accounts or throws InitializeException.GetAccountsException
-
importAccountByUfvk
abstract Account importAccountByUfvk(AccountImportSetup setup)
Tells the wallet to track an account using a unified full viewing key.
Returns details about the imported account, including the unique account identifier for the newly-created wallet database entry. Unlike the other account creation APIs, no spending key is returned because the wallet has no information about the mnemonic phrase from which the UFVK was derived.
- Parameters:
setup- The account's setup information.
-
getFastestServers
abstract Flow<FastestServersResult> getFastestServers(List<LightWalletEndpoint> servers)
Adds the next available account-level spend authority, given the current set of ZIP 316 account identifiers known, to the wallet database.
The caller should store the byte encoding of the returned spending key in a secure fashion. This encoding MUST NOT be exposed to users. It is an internal encoding that is inherently unstable, and only intended to be passed between the SDK and the storage backend. The caller MUST NOT allow this encoding to be exported or imported.
If
seedwas imported from a backup and this method is being used to restore a previous wallet state, you should use this method to add all of the desired accounts before scanning the chain from the seed's birthday height.By convention, wallets should only allow a new account to be generated after funds have been received by the currently-available account (in order to enable automated account recovery).
-
getUnifiedAddress
abstract String getUnifiedAddress(Account account)
Gets the current unified address for the given account.
- Parameters:
account- the account whose address is of interest.
-
getCustomUnifiedAddress
abstract String getCustomUnifiedAddress(Account account, UnifiedAddressRequest request)
Gets a new unified address that conforms to the specified request.
- Parameters:
account- the account whose address is of interest.request- a description of the receivers to create in the newly generated address.
-
getSaplingAddress
abstract String getSaplingAddress(Account account)
Gets the legacy Sapling address corresponding to the current unified address for the given account.
- Parameters:
account- the account whose address is of interest.
-
getTransparentAddress
abstract String getTransparentAddress(Account account)
Gets the legacy transparent address corresponding to the current unified address for the given account.
- Parameters:
account- the account whose address is of interest.
-
refreshExchangeRateUsd
abstract Unit refreshExchangeRateUsd()
Refreshes exchangeRateUsd.
-
proposeTransfer
abstract Proposal proposeTransfer(Account account, String recipient, Zatoshi amount, String memo)
Creates a proposal for transferring funds to the given recipient.
- Parameters:
account- the account from which to transfer funds.recipient- the recipient's address.amount- the amount of zatoshi to send.memo- the optional memo to include as part of the proposal's transactions.
-
proposeFulfillingPaymentUri
abstract Proposal proposeFulfillingPaymentUri(Account account, String uri)
Creates a proposal for fulfilling a payment ZIP-321 URI
- Parameters:
account- the account from which to transfer funds.uri- a ZIP-321 compliant payment URI String
-
proposeShielding
abstract Proposal proposeShielding(Account account, Zatoshi shieldingThreshold, String memo, String transparentReceiver)
Creates a proposal for shielding any transparent funds received by the given account.
- Parameters:
account- the account for which to shield funds.shieldingThreshold- the minimum transparent balance required before a proposal will be created.memo- the optional memo to include as part of the proposal's transactions.transparentReceiver- a specific transparent receiver within the account that should be the source of transparent funds.
-
createProposedTransactions
abstract Flow<TransactionSubmitResult> createProposedTransactions(Proposal proposal, UnifiedSpendingKey usk)
Creates the transactions in the given proposal.
- Parameters:
proposal- the proposal for which to create transactions.usk- the unified spending key associated with the account for which the proposal was created.
-
createPcztFromProposal
abstract Pczt createPcztFromProposal(AccountUuid accountUuid, Proposal proposal)
Creates a partially-created (unsigned without proofs) transaction from the given proposal.
Do not call this multiple times in parallel, or you will generate PCZT instances that, if finalized, would double-spend the same notes.
- Parameters:
accountUuid- The account for which the proposal was created.proposal- The proposal for which to create the transaction.
-
redactPcztForSigner
abstract Pczt redactPcztForSigner(Pczt pczt)
Redacts information from the given PCZT that is unnecessary for the Signer role.
- Parameters:
pczt- The partially created transaction in its serialized format.
-
pcztRequiresSaplingProofs
abstract Boolean pcztRequiresSaplingProofs(Pczt pczt)
Checks whether the caller needs to have downloaded the Sapling parameters.
- Parameters:
pczt- The partially created transaction in its serialized format.
-
addProofsToPczt
abstract Pczt addProofsToPczt(Pczt pczt)
Adds proofs to the given PCZT.
- Parameters:
pczt- The partially created transaction in its serialized format.
-
createTransactionFromPczt
abstract Flow<TransactionSubmitResult> createTransactionFromPczt(Pczt pcztWithProofs, Pczt pcztWithSignatures)
Takes a PCZT that has been separately proven and signed, finalizes it, and stores it in the wallet. Internally, this logic also submits and checks the newly stored and encoded transaction.
-
isValidShieldedAddr
abstract Boolean isValidShieldedAddr(String address)
Returns true when the given address is a valid z-addr. Invalid addresses will throw an exception. See valid z-addresses characteristics in related ZIP.
- Parameters:
address- the address to validate.
-
isValidTransparentAddr
abstract Boolean isValidTransparentAddr(String address)
Returns true when the given address is a valid t-addr. Invalid addresses will throw an exception. See valid t-addresses characteristics in related ZIP.
- Parameters:
address- the address to validate.
-
isValidUnifiedAddr
abstract Boolean isValidUnifiedAddr(String address)
Returns true when the given address is a valid ZIP 316 unified address.
This method is intended for type checking (e.g. form validation). Invalid addresses will throw an exception.
- Parameters:
address- the address to validate.
-
isValidTexAddr
abstract Boolean isValidTexAddr(String address)
Returns true when the given address is a valid ZIP 320 TEX address.
This method is intended for type checking (e.g. form validation). Invalid addresses will throw an exception. See valid t-addresses characteristics in the related ZIP.
- Parameters:
address- the address to validate.
-
validateConsensusBranch
abstract ConsensusMatchType validateConsensusBranch()
Validate whether the server and this SDK share the same consensus branch. This is particularly important to check around network updates so that any wallet that's connected to an incompatible server can surface that information effectively. For the SDK, the consensus branch is used when creating transactions as each one needs to target a specific branch. This function compares the server's branch id to this SDK's and returns information that helps determine whether they match.
-
validateServerEndpoint
abstract ServerValidation validateServerEndpoint(Context context, LightWalletEndpoint endpoint)
This function checks whether the provided server endpoint is valid. The validation is based on comparing:
network types,
sapling activation heights
consensus branches
- Parameters:
context- Contextendpoint- LightWalletEndpoint data to be validated
-
validateAddress
abstract AddressType validateAddress(String address)
Validates the given address, returning information about why it is invalid. This is a convenience method that combines the behavior of isValidShieldedAddr, isValidTransparentAddr, and isValidUnifiedAddr into one call so that the developer doesn't have to worry about handling the exceptions that they throw. Rather, exceptions are converted to AddressType.Invalid which has a
reasonproperty describing why it is invalid.- Parameters:
address- the address to validate.
-
refreshUtxos
abstract Integer refreshUtxos(Account account, BlockHeight since)
Download all UTXOs for the given account addresses and store any new ones in the database.
- Parameters:
account- The Account, for which all addresses blocks will be downloaded.since- The BlockHeight, from which blocks will be downloaded.
-
getTransparentBalance
abstract Zatoshi getTransparentBalance(String tAddr)
Returns the balance that the wallet knows about. This should be called after refreshUtxos.
-
rewindToNearestHeight
abstract BlockHeight rewindToNearestHeight(BlockHeight height)
Rewinds to the safest height to which we can rewind, given a desire to rewind to the height provided.
Due to how witness incrementing works, a wallet cannot simply rewind to any arbitrary height. This handles all that complexity yet remains flexible in the future as improvements are made.
Returns the height to which we actually rewound, or
nullif the rewind failed.
-
getMemos
abstract Flow<String> getMemos(TransactionOverview transactionOverview)
Returns a stream of memos for a transaction. It works for both received and sent transaction.
Note that this function internally resolves any error which comes, logs it, and then transforms it to an empty string.
- Parameters:
transactionOverview- For which the memos will be queried
-
getTransactionsByMemoSubstring
abstract Flow<List<TransactionId>> getTransactionsByMemoSubstring(String query)
Filters the current transactions based on their memos. It returns the transaction ID of those transactions whose memo contains the given query or its part. Note that white space trimming or normalization is the client's responsibility.
- Parameters:
query- Memo or its substring
-
getRecipients
abstract Flow<TransactionRecipient> getRecipients(TransactionOverview transactionOverview)
Returns a list of recipients for a transaction.
-
getExistingDataDbFilePath
abstract String getExistingDataDbFilePath(Context context, ZcashNetwork network, String alias)
Checks and provides file path to the existing data database file for the given input parameters or throws InitializeException.MissingDatabaseException if the database does not exist yet.
Note that it's the caller's responsibility to provide a network and alias to an existing database. Otherwise InitializeException.MissingDatabaseException is thrown.
-
getTransactionOutputs
abstract List<TransactionOutput> getTransactionOutputs(TransactionOverview transactionOverview)
Returns a list of all transaction outputs for a transaction.
-
getTransactions
abstract Flow<List<TransactionOverview>> getTransactions(AccountUuid accountUuid)
Returns all transactions belonging to the given account UUID
- Parameters:
accountUuid- The given account UUID
-
getSingleUseTransparentAddress
abstract SingleUseTransparentAddress getSingleUseTransparentAddress(AccountUuid accountUuid)
Generates and returns an ephemeral address for one-time use, such as when receiving a swap from a decentralized exchange.
-
checkSingleUseTransparentAddress
abstract Boolean checkSingleUseTransparentAddress(AccountUuid accountUuid)
Checks to find any single-use ephemeral addresses exposed in the past day that have not yet received funds, excluding any whose next check time is in the future. This will then choose the address that is most overdue for checking, retrieve any UTXOs for that address over Tor, and add them to the wallet database. If no such UTXOs are found, the check will be rescheduled following an expoential-backoff-with-jitter algorithm.
-
fetchUtxosByAddress
abstract Boolean fetchUtxosByAddress(AccountUuid accountUuid, String address)
Queries the light wallet server to find any UTXOs associated with the given transparent address, and adds any UTXOs discovered to the wallet.
This check will cover the block range starting at the exposure height for that address, if known, or otherwise at the birthday height of the specified account.
-
enhanceTransaction
abstract Unit enhanceTransaction(TransactionId txId)
Requests to enhance transaction enhancement for the txId.
-
onBackground
abstract Unit onBackground()
-
onForeground
abstract Unit onForeground()
-
getTorHttpClient
abstract HttpClient getTorHttpClient(Function1<HttpClientConfig<HttpClientEngineConfig>, Unit> config)
- Parameters:
config- to configure HttpClient
-
debugQuery
abstract String debugQuery(String query)
-
getNetwork
abstract ZcashNetwork getNetwork()
The network to which this synchronizer is connected and from which it is processing blocks.
-
getStatus
abstract Flow<Synchronizer.Status> getStatus()
A flow of values representing the Status of this Synchronizer. As the status changes, a new value will be emitted by this flow.
-
getProgress
abstract Flow<PercentDecimal> getProgress()
Indicates the download progress of the Synchronizer.
When progress reaches
PercentDecimal.ONE_HUNDRED_PERCENT, it signals that the Synchronizer is up-to-date with the network's current chain tip. Balances should be considered inaccurate and outbound transactions should be prevented until this sync is complete.
-
getAreFundsSpendable
abstract Flow<Boolean> getAreFundsSpendable()
Indicates whether are the shielded wallet balances spendable or not during the block synchronization process.
-
getProcessorInfo
abstract Flow<CompactBlockProcessor.ProcessorInfo> getProcessorInfo()
A flow of processor details, updated every time blocks are processed to include the latest block height, blocks downloaded and blocks scanned. Similar to the progress flow but with a lot more detail.
-
getNetworkHeight
abstract StateFlow<BlockHeight> getNetworkHeight()
The latest height observed on the network, which does not necessarily correspond to the latest downloaded height or scanned height. Although this is present in processorInfo, it is such a frequently used value that it is convenient to have the real-time value by itself.
-
getWalletBalances
abstract StateFlow<Map<AccountUuid, AccountBalance>> getWalletBalances()
A stream of wallet balances
-
getExchangeRateUsd
abstract StateFlow<ObserveFiatCurrencyResult> getExchangeRateUsd()
The latest known USD/ZEC exchange rate, paired with the time it was queried.
The rate can be initialized and refreshed by calling refreshExchangeRateUsd.
-
getAllTransactions
abstract Flow<List<TransactionOverview>> getAllTransactions()
A flow of all the transactions that are on the blockchain.
-
getLatestHeight
abstract BlockHeight getLatestHeight()
An in-memory reference to the latest height seen on the network.
-
getLatestBirthdayHeight
abstract BlockHeight getLatestBirthdayHeight()
An in-memory reference to the best known birthday height, which can change if the first transaction has not yet occurred.
-
getAccountsFlow
abstract Flow<List<Account>> getAccountsFlow()
Returns all the wallet accounts or throws InitializeException.GetAccountsException
It's a Flow version of getAccounts
-
getInitializationError
abstract Synchronizer.InitializationError getInitializationError()
Emits error states of the synchronizer.
-
getOnCriticalErrorHandler
abstract Function1<Throwable, Boolean> getOnCriticalErrorHandler()
Gets or sets a global error handler. This is a useful hook for handling unexpected critical errors.
-
setOnCriticalErrorHandler
abstract Unit setOnCriticalErrorHandler(Function1<Throwable, Boolean> onCriticalErrorHandler)
Gets or sets a global error handler. This is a useful hook for handling unexpected critical errors.
-
getOnProcessorErrorHandler
abstract Function1<Throwable, Boolean> getOnProcessorErrorHandler()
An error handler for exceptions during processing. For instance, a block might be missing or a reorg may get mishandled or the database may get corrupted.
-
setOnProcessorErrorHandler
abstract Unit setOnProcessorErrorHandler(Function1<Throwable, Boolean> onProcessorErrorHandler)
An error handler for exceptions during processing. For instance, a block might be missing or a reorg may get mishandled or the database may get corrupted.
-
getOnProcessorErrorResolved
abstract Function0<Unit> getOnProcessorErrorResolved()
-
setOnProcessorErrorResolved
abstract Unit setOnProcessorErrorResolved(Function0<Unit> onProcessorErrorResolved)
-
getOnSetupErrorHandler
abstract Function1<Throwable, Boolean> getOnSetupErrorHandler()
Callback for setup errors that occur prior to processing compact blocks. Can be used to override any errors encountered during setup. When this listener is missing then all setup errors will result in the synchronizer not starting. This is particularly useful for wallets to receive a callback right before the SDK will reject a lightwalletd server because it appears not to match.
-
setOnSetupErrorHandler
abstract Unit setOnSetupErrorHandler(Function1<Throwable, Boolean> onSetupErrorHandler)
Callback for setup errors that occur prior to processing compact blocks. Can be used to override any errors encountered during setup. When this listener is missing then all setup errors will result in the synchronizer not starting. This is particularly useful for wallets to receive a callback right before the SDK will reject a lightwalletd server because it appears not to match.
-
getOnChainErrorHandler
abstract Function2<BlockHeight, BlockHeight, Object> getOnChainErrorHandler()
A callback to invoke whenever a chain error is encountered. These occur whenever the processor detects a missing or non-chain-sequential block (i.e. a reorg). At a minimum, it is best to log these errors because they are the most common source of bugs and unexpected behavior in wallets, due to the chain data mutating and wallets becoming out of sync.
-
setOnChainErrorHandler
abstract Unit setOnChainErrorHandler(Function2<BlockHeight, BlockHeight, Object> onChainErrorHandler)
A callback to invoke whenever a chain error is encountered. These occur whenever the processor detects a missing or non-chain-sequential block (i.e. a reorg). At a minimum, it is best to log these errors because they are the most common source of bugs and unexpected behavior in wallets, due to the chain data mutating and wallets becoming out of sync.
-
-
-
-