diff --git a/src/bot.ts b/src/bot.ts index 8d5a296b317cec7fa12cdb60e213ae5f837c9bf7..7e7e59e2f22ea062f7cf22c331d4100d1421a737 100644 --- a/src/bot.ts +++ b/src/bot.ts @@ -95,7 +95,13 @@ export class WorkerBee implements IWorkerBee { return { subscribe: observer => { - const listener = this.observe.onTransactionId(apiTx.id).provideBlockHeaderData().subscribe({ + const txId = apiTx.id; + let txObserver = this.observe.onTransactionId(txId); + const legacyId = apiTx.legacy_id; + if(legacyId !== apiTx.id) + txObserver = txObserver.or.onTransactionId(legacyId); + + const listener = txObserver.provideBlockHeaderData().subscribe({ next(val) { observer.next?.({ transaction: val.transactions[apiTx.id]!,