|
9 | 9 | createManyTransactions, |
10 | 10 | deleteTransactions, |
11 | 11 | fetchUnconfirmedTransactions, |
12 | | - createTransaction, |
| 12 | + upsertTransaction, |
13 | 13 | getSimplifiedTransactions, |
14 | 14 | getSimplifiedTrasaction, |
15 | 15 | connectAllTransactionsToPrices |
@@ -417,7 +417,7 @@ export class ChronikBlockchainClient { |
417 | 417 | const addressesWithTransactions = await this.getAddressesForTransaction(transaction) |
418 | 418 | const inputAddresses = this.getSortedInputAddresses(transaction) |
419 | 419 | for (const addressWithTransaction of addressesWithTransactions) { |
420 | | - const { created, tx } = await createTransaction(addressWithTransaction.transaction) |
| 420 | + const { created, tx } = await upsertTransaction(addressWithTransaction.transaction) |
421 | 421 | if (tx !== undefined) { |
422 | 422 | const broadcastTxData = this.broadcastIncomingTx(addressWithTransaction.address.address, tx, inputAddresses) |
423 | 423 | if (created) { // only execute trigger for newly added txs |
@@ -470,7 +470,7 @@ export class ChronikBlockchainClient { |
470 | 470 | const inputAddresses = this.getSortedInputAddresses(transaction) |
471 | 471 |
|
472 | 472 | for (const addressWithTransaction of addressesWithTransactions) { |
473 | | - const { created, tx } = await createTransaction(addressWithTransaction.transaction) |
| 473 | + const { created, tx } = await upsertTransaction(addressWithTransaction.transaction) |
474 | 474 | if (tx !== undefined) { |
475 | 475 | const broadcastTxData = this.broadcastIncomingTx(addressWithTransaction.address.address, tx, inputAddresses) |
476 | 476 | if (created) { // only execute trigger for newly added txs |
|
0 commit comments