fix

AztecProtocol · Dec 13, 2024 · aaba427 · aaba427
1 parent e78a0dd
commit aaba427
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/yarn-project/p2p/src/services/libp2p/libp2p_service.ts b/yarn-project/p2p/src/services/libp2p/libp2p_service.ts
@@ -61,7 +61,6 @@ import {
 } from '../reqresp/interface.js';
 import { ReqResp } from '../reqresp/reqresp.js';
 import type { P2PService, PeerDiscoveryService } from '../service.js';
-import { Timer } from '@aztec/foundation/timer';
 
 /**
  * Lib P2P implementation of the P2PService interface.
@@ -480,9 +479,7 @@ export class LibP2PService<T extends P2PClientType> extends WithTracer implement
     const txHashString = txHash.toString();
     this.logger.verbose(`Received tx ${txHashString} from external peer.`);
 
-    const timer = new Timer();
     const isValidTx = await this.validatePropagatedTx(tx, peerId);
-    this.logger.info(`\n\n\n validatePropagatedTx took ${timer.ms()}ms`);
 
     if (isValidTx) {
       await this.mempools.txPool.addTxs([tx]);
@@ -503,6 +500,9 @@ export class LibP2PService<T extends P2PClientType> extends WithTracer implement
    * @param peerId - The peer ID of the peer that sent the tx.
    * @returns True if the tx is valid, false otherwise.
    */
+  @trackSpan('Libp2pService.validateRequestedTx', (requestedTxHash, _responseTx) => ({
+    [Attributes.TX_HASH]: requestedTxHash.toString(),
+  }))
   private async validateRequestedTx(requestedTxHash: TxHash, responseTx: Tx, peerId: PeerId): Promise<boolean> {
 
 
@@ -525,6 +525,9 @@ export class LibP2PService<T extends P2PClientType> extends WithTracer implement
     return true;
   }
 
+  @trackSpan('Libp2pService.validatePropagatedTx', tx => ({
+    [Attributes.TX_HASH]: tx.getTxHash().toString(),
+  }))
   private async validatePropagatedTx(tx: Tx, peerId: PeerId): Promise<boolean> {
     const blockNumber = (await this.l2BlockSource.getBlockNumber()) + 1;
     // basic data validation