Monitor transaction status

monitor_transaction_status.ts

import {
    Account,
    Address,
    Deadline,
    Listener,
    NetworkType,
    PlainMessage,
    TransactionHttp,
    TransferTransaction
} from "nem2-sdk";
import {filter} from "rxjs/operators";


// 01 - Create Transaction
const recipientAddress = Address.createFromRawAddress("SD5DT3-CH4BLA-BL5HIM-EKP2TA-PUKF4N-Y3L5HR-IR54");
const transferTransaction = TransferTransaction.create(
    Deadline.create(),
    recipientAddress,
    [],
    PlainMessage.create('Test'),
    NetworkType.MIJIN_TEST);

// 02 - Sign Transaction
const signer = Account.createFromPrivateKey(process.env.PRIVATE_KEY, NetworkType.MIJIN_TEST);
const signedTransaction = signer.sign(transferTransaction);

// 03 - Announce and monitor the transaction status

const url = 'http://localhost:3000';
const listener = new Listener(url);
const transactionHttp = new TransactionHttp(url);

listener.open().then(() => {

    listener
        .status(signer.address)
        .pipe(filter(error => error.hash === signedTransaction.hash))
        .subscribe(error => console.log("❌:" + error.status),
                err => console.error(err));

    listener
        .unconfirmedAdded(signer.address)
        .pipe(filter(transaction => (transaction.transactionInfo !== undefined
            && transaction.transactionInfo.hash === signedTransaction.hash)))
        .subscribe(ignored => console.log("⏳: Transaction status changed to unconfirmed"),
                err => console.error(err));

    listener
        .confirmed(signer.address)
        .pipe(filter(transaction =>(transaction.transactionInfo !== undefined
            && transaction.transactionInfo.hash === signedTransaction.hash)))
        .subscribe(ignored => console.log("✅: Transaction confirmed"),
                err => console.error(err));

    transactionHttp
        .announce(signedTransaction)
        .subscribe(x => console.log(x),
                err => console.error(err));
});