Don't push full RBF-transactions to prevent old states.
This commit is contained in:
		
							parent
							
								
									b15de021f7
								
							
						
					
					
						commit
						8267344cdc
					
				@ -355,17 +355,9 @@ class WebsocketHandler {
 | 
				
			|||||||
        if (rbfTransactions[client['track-tx']]) {
 | 
					        if (rbfTransactions[client['track-tx']]) {
 | 
				
			||||||
          for (const rbfTransaction in rbfTransactions) {
 | 
					          for (const rbfTransaction in rbfTransactions) {
 | 
				
			||||||
            if (client['track-tx'] === rbfTransaction) {
 | 
					            if (client['track-tx'] === rbfTransaction) {
 | 
				
			||||||
              const rbfTx = rbfTransactions[rbfTransaction];
 | 
					              response['rbfTransaction'] = {
 | 
				
			||||||
              if (config.MEMPOOL.BACKEND !== 'esplora') {
 | 
					                txid: rbfTransactions[rbfTransaction].txid,
 | 
				
			||||||
                try {
 | 
					              };
 | 
				
			||||||
                  const fullTx = await transactionUtils.$getTransactionExtended(rbfTx.txid, true);
 | 
					 | 
				
			||||||
                  response['rbfTransaction'] = fullTx;
 | 
					 | 
				
			||||||
                } catch (e) {
 | 
					 | 
				
			||||||
                  logger.debug('Error finding transaction in mempool: ' + (e instanceof Error ? e.message : e));
 | 
					 | 
				
			||||||
                }
 | 
					 | 
				
			||||||
              } else {
 | 
					 | 
				
			||||||
                response['rbfTransaction'] = rbfTx;
 | 
					 | 
				
			||||||
              }
 | 
					 | 
				
			||||||
              break;
 | 
					              break;
 | 
				
			||||||
            }
 | 
					            }
 | 
				
			||||||
          }
 | 
					          }
 | 
				
			||||||
 | 
				
			|||||||
@ -235,7 +235,7 @@ export class TransactionComponent implements OnInit, OnDestroy {
 | 
				
			|||||||
    });
 | 
					    });
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    this.txReplacedSubscription = this.stateService.txReplaced$.subscribe((rbfTransaction) => {
 | 
					    this.txReplacedSubscription = this.stateService.txReplaced$.subscribe((rbfTransaction) => {
 | 
				
			||||||
      if (!rbfTransaction.size) {
 | 
					      if (!this.tx) {
 | 
				
			||||||
        this.error = new Error();
 | 
					        this.error = new Error();
 | 
				
			||||||
        this.waitingForTransaction = false;
 | 
					        this.waitingForTransaction = false;
 | 
				
			||||||
      }
 | 
					      }
 | 
				
			||||||
 | 
				
			|||||||
		Loading…
	
	
			
			x
			
			
		
	
		Reference in New Issue
	
	Block a user