#314: Implement transaction nonces in the applicator

internal/node/node.go

@@ -247,14 +247,16 @@ func (n *KoinosP2PNode) handleBlockBroadcast(topic string, data []byte) {
 }
 
 func (n *KoinosP2PNode) handleTransactionBroadcast(topic string, data []byte) {
-	log.Debug("Received koinos.mempool.accept broadcast")
-	trxBroadcast := &broadcast.MempoolAccepted{}
+	log.Debug("Received koinos.chain.transaction_accepted")
+	trxBroadcast := &broadcast.TransactionAccepted{}
 	err := proto.Unmarshal(data, trxBroadcast)
 	if err != nil {
 		log.Warnf("Unable to parse koinos.transaction.accept broadcast: %v", err.Error())
 		return
 	}
 
+	n.Applicator.HandleTransactionBroadcast(trxBroadcast)
+
 	// If gossip is enabled publish the transaction
 	err = n.Gossip.PublishTransaction(context.Background(), trxBroadcast.Transaction)
 	if err != nil {

internal/options/applicator_options.go

@@ -16,33 +16,39 @@ func min(x, y int) int {
 const (
 	maxPendingBlocksDefault           = 2500
 	maxHeightDeltaDefault             = 60
+	maxPendingTransactionsDefault     = 100000
 	delayThresholdDefault             = time.Second * 4
 	delayTimeoutDefault               = time.Second * 60
 	applicationJobsDefault            = 8
 	forceChildRequestThresholdDefault = time.Minute
 	forceApplicationRetryDelayDefault = 50 * time.Millisecond
+	transactionExpirationDefault      = time.Second * 10
 )
 
 // ApplicatorOptions are options for Applicator
 type ApplicatorOptions struct {
 	MaxPendingBlocks           uint64
 	MaxHeightDelta             uint64
+	MaxPendingTransactions     uint64
 	DelayThreshold             time.Duration
 	DelayTimeout               time.Duration
 	ApplicationJobs            int
 	ForceChildRequestThreshold time.Duration
 	ForceApplicationRetryDelay time.Duration
+	TransactionExpiration      time.Duration
 }
 
 // NewApplicatorOptions returns default initialized ApplicatorOptions
 func NewApplicatorOptions() *ApplicatorOptions {
 	return &ApplicatorOptions{
 		MaxPendingBlocks:           maxPendingBlocksDefault,
 		MaxHeightDelta:             maxHeightDeltaDefault,
+		MaxPendingTransactions:     maxPendingTransactionsDefault,
 		DelayThreshold:             delayThresholdDefault,
 		DelayTimeout:               delayTimeoutDefault,
 		ApplicationJobs:            min(applicationJobsDefault, runtime.NumCPU()),
 		ForceChildRequestThreshold: forceChildRequestThresholdDefault,
 		ForceApplicationRetryDelay: forceApplicationRetryDelayDefault,
+		TransactionExpiration:      transactionExpirationDefault,
 	}
 }