io.nem.symbol.sdk.infrastructure

Class TransactionServiceImpl

java.lang.Object

io.nem.symbol.sdk.infrastructure.TransactionServiceImpl

All Implemented Interfaces:

TransactionService

public class TransactionServiceImpl
extends java.lang.Object
implements TransactionService

Implementation of TransactionService. It uses the repository interfaces. It works for the different low level implementations like Vertx and Okhttp.

Constructor Summary

Constructors

Constructor and Description
TransactionServiceImpl(RepositoryFactory repositoryFactory) The constructor

Method Summary

Modifier and Type	Method and Description
io.reactivex.Observable<Transaction>	announce(Listener listener, SignedTransaction signedTransaction) This method announces a transaction while waiting for being completed by listing to the /completed web socket.
io.reactivex.Observable<AggregateTransaction>	announceAggregateBonded(Listener listener, SignedTransaction signedAggregateTransaction) This method announces an aggregate bonded transaction while waiting for being added by listing to the /aggregateBondedAdded web socket.
io.reactivex.Observable<AggregateTransaction>	announceHashLockAggregateBonded(Listener listener, SignedTransaction signedHashLockTransaction, SignedTransaction signedAggregateTransaction) This method announces an a hash lock transaction followed by a aggregate bonded transaction while waiting for being completed by listing to the /completed and /aggregateBondedAdded web socket.
io.reactivex.Observable<java.util.List<Transaction>>	resolveAliases(java.util.List<java.lang.String> transactionHashes) This method loads all transactions with the given hashes from the catapult server where all the aliases have been resolved.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TransactionServiceImpl

public TransactionServiceImpl(RepositoryFactory repositoryFactory)

The constructor

Parameters:

repositoryFactory - the RepositoryFactory with the catapult server connection.

Method Detail

announce

public io.reactivex.Observable<Transaction> announce(Listener listener,
                                                     SignedTransaction signedTransaction)

Description copied from interface: TransactionService

This method announces a transaction while waiting for being completed by listing to the /completed web socket. If an error to the given transaction is sent to the /status web socket, a TransactionStatusException is raised.

Steps:

1) It announces the transaction to the TransactionRepository

2) It calls the Listener's completed method waiting for the transaction to be completed.

3) It class the Listener's status method waiting for an error to occurred.

Specified by:

announce in interface TransactionService

Parameters:

listener - the web socket listener used to detect completed transaction or status errors coming from the catapult server.

signedTransaction - the signed transaction to be announced.

Returns:

an Observable of the completed transaction or an observable that raises a TransactionStatusException if the transaction has failed.

announceAggregateBonded

public io.reactivex.Observable<AggregateTransaction> announceAggregateBonded(Listener listener,
                                                                             SignedTransaction signedAggregateTransaction)

Description copied from interface: TransactionService

This method announces an aggregate bonded transaction while waiting for being added by listing to the /aggregateBondedAdded web socket. If an error to the given transaction is sent to the /status web socket, a TransactionStatusException is raised.

Steps:

1) It announceAggregateBonded the transaction to the TransactionRepository

2) It calls the Listener's aggregateBondedAdded method waiting for the transaction to be completed.

3) It class the Listener's status method waiting for an error to occurred.

Specified by:

announceAggregateBonded in interface TransactionService

Parameters:

listener - the web socket listener used to detect aggregateBondedAdded transaction or status errors coming from the catapult server.

signedAggregateTransaction - the signed aggregate bonded transaction to be announced.

Returns:

an Observable of the added aggregate bonded transaction or an observable that raises a TransactionStatusException if the transaction has failed.

announceHashLockAggregateBonded

public io.reactivex.Observable<AggregateTransaction> announceHashLockAggregateBonded(Listener listener,
                                                                                     SignedTransaction signedHashLockTransaction,
                                                                                     SignedTransaction signedAggregateTransaction)

Description copied from interface: TransactionService

This method announces an a hash lock transaction followed by a aggregate bonded transaction while waiting for being completed by listing to the /completed and /aggregateBondedAdded web socket. If an error is sent while processing any of the given transaction a TransactionStatusException is raised.

Specified by:

announceHashLockAggregateBonded in interface TransactionService

Parameters:

listener - the web socket listener used to detect completed, aggregateBondedAdded transaction or status errors coming from the catapult server.

signedHashLockTransaction - the signed hash lock transaction

signedAggregateTransaction - the signed aggregate bonded transaction that will be announced after the signed hash lock transaction is completed

Returns:

an Observable of the added aggregate bonded (second) transaction or an observable that raises a TransactionStatusException if any transaction has failed.

resolveAliases

public io.reactivex.Observable<java.util.List<Transaction>> resolveAliases(java.util.List<java.lang.String> transactionHashes)

Description copied from interface: TransactionService

This method loads all transactions with the given hashes from the catapult server where all the aliases have been resolved.

For example, if a TransferTransaction's recipient was 'customerone' NamespaceId, this method will return the same TransferTransaction where the recipient is the real Address.

Similarly, if MosaicMetadataTransaction was announced using the NamespaceId alias of the mosaic, the returned MosaicMetadataTransaction will reference the real MosaicId.

All the UnresolvedMosaicId and UnresolvedAddress in the returned transaction should be instances of MosaicId and Address

Specified by:

resolveAliases in interface TransactionService

Parameters:

transactionHashes - the transaction hashes of all the transaction that you want to load and resolve.

Returns:

an Observable list of Transaction where all the aliases have been resolved.