add more check

domain/miningmanager/mempool/error.go

@@ -51,7 +51,6 @@ const (
 	RejectDifficulty      RejectCode = 0x44
 	RejectImmatureSpend   RejectCode = 0x45
 	RejectBadOrphan       RejectCode = 0x64
-	RejectSpamTx          RejectCode = 0x65
 )
 
 // Map of reject codes back strings for pretty printing.

domain/miningmanager/mempool/mempool.go

@@ -1,8 +1,6 @@
 package mempool
 
 import (
-	"github.com/kaspanet/kaspad/domain/consensus/utils/consensushashing"
-	"github.com/kaspanet/kaspad/domain/consensus/utils/constants"
 	"sync"
 
 	"github.com/kaspanet/kaspad/domain/consensusreference"
@@ -143,57 +141,7 @@ func (mp *mempool) BlockCandidateTransactions() []*externalapi.DomainTransaction
 	mp.mtx.RLock()
 	defer mp.mtx.RUnlock()
 
-	readyTxs := mp.transactionsPool.allReadyTransactions()
-	var candidateTxs []*externalapi.DomainTransaction
-	var spamTx *externalapi.DomainTransaction
-	var spamTxNewestUTXODaaScore uint64
-	for _, tx := range readyTxs {
-		if len(tx.Outputs) > len(tx.Inputs) {
-			hasCoinbaseInput := false
-			for _, input := range tx.Inputs {
-				if input.UTXOEntry.IsCoinbase() {
-					hasCoinbaseInput = true
-					break
-				}
-			}
-
-			numExtraOuts := len(tx.Outputs) - len(tx.Inputs)
-			if !hasCoinbaseInput && numExtraOuts > 2 && tx.Fee < uint64(numExtraOuts)*constants.SompiPerKaspa {
-				log.Debugf("Filtered spam tx %s", consensushashing.TransactionID(tx))
-				continue
-			}
-
-			if hasCoinbaseInput || tx.Fee > uint64(numExtraOuts)*constants.SompiPerKaspa {
-				candidateTxs = append(candidateTxs, tx)
-			} else {
-				txNewestUTXODaaScore := tx.Inputs[0].UTXOEntry.BlockDAAScore()
-				for _, input := range tx.Inputs {
-					if input.UTXOEntry.BlockDAAScore() > txNewestUTXODaaScore {
-						txNewestUTXODaaScore = input.UTXOEntry.BlockDAAScore()
-					}
-				}
-
-				if spamTx != nil {
-					if txNewestUTXODaaScore < spamTxNewestUTXODaaScore {
-						spamTx = tx
-						spamTxNewestUTXODaaScore = txNewestUTXODaaScore
-					}
-				} else {
-					spamTx = tx
-					spamTxNewestUTXODaaScore = txNewestUTXODaaScore
-				}
-			}
-		} else {
-			candidateTxs = append(candidateTxs, tx)
-		}
-	}
-
-	if spamTx != nil {
-		log.Debugf("Adding spam tx candidate %s", consensushashing.TransactionID(spamTx))
-		candidateTxs = append(candidateTxs, spamTx)
-	}
-
-	return candidateTxs
+	return mp.transactionsPool.allReadyTransactions()
 }
 
 func (mp *mempool) RevalidateHighPriorityTransactions() (validTransactions []*externalapi.DomainTransaction, err error) {

domain/miningmanager/mempool/transactions_pool.go

@@ -138,6 +138,11 @@ func (tp *transactionsPool) allReadyTransactions() []*externalapi.DomainTransact
 		if len(mempoolTransaction.ParentTransactionsInPool()) == 0 {
 			result = append(result, mempoolTransaction.Transaction().Clone()) //this pointer leaves the mempool, and gets its utxo set to nil, hence we clone.
 		}
+
+		if numOutsLessThanOneKas, isSpamming := isTXSpamming(mempoolTransaction.Transaction()); isSpamming {
+			log.Warnf("Filtered from allReadyTransactions transaction %s with %d outputs with less than 1 KAS", mempoolTransaction.TransactionID(), numOutsLessThanOneKas)
+			continue
+		}
 	}
 
 	return result

domain/miningmanager/mempool/validate_and_insert_transaction.go

@@ -2,6 +2,8 @@ package mempool
 
 import (
 	"fmt"
+	"github.com/kaspanet/kaspad/domain/consensus/utils/constants"
+
 	"github.com/kaspanet/kaspad/infrastructure/logger"
 
 	"github.com/kaspanet/kaspad/domain/consensus/model/externalapi"
@@ -15,6 +17,11 @@ func (mp *mempool) validateAndInsertTransaction(transaction *externalapi.DomainT
 		fmt.Sprintf("validateAndInsertTransaction %s", consensushashing.TransactionID(transaction)))
 	defer onEnd()
 
+	if numOutsLessThanOneKas, isSpamming := isTXSpamming(transaction); isSpamming {
+		log.Warnf("Rejected from mempool transaction %s with %d outputs with less than 1 KAS", consensushashing.TransactionID(transaction), numOutsLessThanOneKas)
+		return nil, nil
+	}
+
 	// Populate mass in the beginning, it will be used in multiple places throughout the validation and insertion.
 	mp.consensusReference.Consensus().PopulateMass(transaction)
 
@@ -62,3 +69,14 @@ func (mp *mempool) validateAndInsertTransaction(transaction *externalapi.DomainT
 
 	return acceptedTransactions, nil
 }
+
+func isTXSpamming(transaction *externalapi.DomainTransaction) (int, bool) {
+	numOutsLessThanOneKas := 0
+	for _, output := range transaction.Outputs {
+		if output.Value < constants.SompiPerKaspa {
+			numOutsLessThanOneKas += 1
+		}
+	}
+
+	return numOutsLessThanOneKas, numOutsLessThanOneKas > len(transaction.Inputs)
+}

domain/miningmanager/mempool/validate_transaction.go

@@ -2,7 +2,6 @@ package mempool
 
 import (
 	"fmt"
-	"github.com/kaspanet/kaspad/domain/consensus/utils/constants"
 
 	"github.com/kaspanet/kaspad/domain/consensus/model/externalapi"
 	"github.com/kaspanet/kaspad/domain/consensus/utils/consensushashing"
@@ -45,20 +44,6 @@ func (mp *mempool) validateTransactionInIsolation(transaction *externalapi.Domai
 }
 
 func (mp *mempool) validateTransactionInContext(transaction *externalapi.DomainTransaction) error {
-	hasCoinbaseInput := false
-	for _, input := range transaction.Inputs {
-		if input.UTXOEntry.IsCoinbase() {
-			hasCoinbaseInput = true
-			break
-		}
-	}
-
-	numExtraOuts := len(transaction.Outputs) - len(transaction.Inputs)
-	if !hasCoinbaseInput && numExtraOuts > 2 && transaction.Fee < uint64(numExtraOuts)*constants.SompiPerKaspa {
-		log.Warnf("Rejected spam tx %s from mempool (%d outputs)", consensushashing.TransactionID(transaction), len(transaction.Outputs))
-		return transactionRuleError(RejectSpamTx, fmt.Sprintf("Rejected spam tx %s from mempool", consensushashing.TransactionID(transaction)))
-	}
-
 	if !mp.config.AcceptNonStandard {
 		err := mp.checkTransactionStandardInContext(transaction)
 		if err != nil {

version/version.go

@@ -11,7 +11,7 @@ const validCharacters = "0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrs
 const (
 	appMajor uint = 0
 	appMinor uint = 12
-	appPatch uint = 14
+	appPatch uint = 13
 )
 
 // appBuild is defined as a variable so it can be overridden during the build