BroadcastTx to return mempoolErr if mempool is full

kwilteam · Feb 21, 2025 · 18cf2fc · 18cf2fc
1 parent a43523e
commit 18cf2fc
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 2 deletions.
diff --git a/core/types/results.go b/core/types/results.go
@@ -43,6 +43,7 @@ var (
 	ErrInvalidNonce        = errors.New("invalid nonce")
 	ErrInvalidAmount       = errors.New("invalid amount")
 	ErrInsufficientBalance = errors.New("insufficient balance")
+	ErrMempoolFull         = errors.New("mempool is full")
 )
 
 // TxResult is the result of a transaction execution on chain.

diff --git a/node/consensus/block.go b/node/consensus/block.go
@@ -138,7 +138,7 @@ func (ce *ConsensusEngine) BroadcastTx(ctx context.Context, tx *ktypes.Transacti
 	if rejected {
 		return &ktypes.ResultBroadcastTx{
 			Hash: txHash,
-		}, types.ErrMempoolFull
+		}, ktypes.ErrMempoolFull
 	}
 
 	// Announce the transaction to the network only if not previously announced

diff --git a/node/types/interfaces.go b/node/types/interfaces.go
@@ -17,7 +17,6 @@ var (
 	ErrStillProcessing = errors.New("block still being executed")
 	ErrNoResponse      = errors.New("stream closed without response")
 	ErrPeersNotFound   = errors.New("no peers available")
-	ErrMempoolFull     = errors.New("mempool is full")
 )
 
 const HashLen = types.HashLen