Added #352 aggregate bonded announcing

Author: rg911

src/service/TransactionService.ts

@@ -42,13 +42,15 @@ export class TransactionService implements ITransactionService {
 
     private readonly transactionHttp: TransactionHttp;
     private readonly receiptHttp: ReceiptHttp;
+    private readonly listener: Listener;
     /**
      * Constructor
      * @param url Base catapult-rest url
      */
     constructor(url: string) {
         this.transactionHttp = new TransactionHttp(url);
         this.receiptHttp = new ReceiptHttp(url);
+        this.listener = new Listener(url);
     }
 
     /**
@@ -187,4 +189,39 @@ export class TransactionService implements ITransactionService {
             map((statement) => transaction.resolveAliases(statement, aggregateIndex)),
         );
     }
+
+    /**
+     * @param signedTransaction Signed transaction to be announced.
+     * @returns {Observable<Transaction>}
+     */
+    public announce(signedTransaction: SignedTransaction): Observable<Transaction> {
+        return this.transactionHttp.announce(signedTransaction).pipe(
+            flatMap(() => this.listener.confirmed(signedTransaction.getSignerAddress(), signedTransaction.hash)),
+        );
+    }
+
+    /**
+     * Announce aggregate transaction
+     * @param signedTransaction Signed aggregate bonded transaction.
+     * @returns {Observable<AggregateTransaction>}
+     */
+    public announceAggregateBonded(signedTransaction: SignedTransaction): Observable<AggregateTransaction> {
+        return this.transactionHttp.announceAggregateBonded(signedTransaction).pipe(
+            flatMap(() => this.listener.aggregateBondedAdded(signedTransaction.getSignerAddress(), signedTransaction.hash)),
+        );
+    }
+
+    /**
+     * Announce aggregate bonded transaction with lock fund
+     * @param signedHashLockTransaction Signed hash lock transaction.
+     * @param signedAggregateTransaction Signed aggregate bonded transaction.
+     * @returns {Observable<AggregateTransaction>}
+     */
+    public announceHashLockAggregateBonded(signedHashLockTransaction: SignedTransaction,
+                                           signedAggregateTransaction: SignedTransaction): Observable<AggregateTransaction> {
+        return this.announce(signedHashLockTransaction).pipe(
+            flatMap(() => this.announceAggregateBonded(signedAggregateTransaction)),
+        );
+
+    }
 }