feat(dashmate): configure proposer and tx limits

packages/dashmate/configs/defaults/getBaseConfigFactory.js

@@ -298,6 +298,9 @@ export default function getBaseConfigFactory(homeDir) {
               host: '127.0.0.1',
               port: 8083,
             },
+            proposer: {
+              txProcessingTimeLimit: null,
+            },
             epochTime: 788400,
           },
           tenderdash: {
@@ -341,6 +344,8 @@ export default function getBaseConfigFactory(homeDir) {
               txSendRateLimit: 10,
               txRecvRateLimit: 12,
               maxConcurrentCheckTx: 250,
+              ttlDuration: '0s',
+              ttlNumBlocks: 0,
             },
             consensus: {
               createEmptyBlocks: true,

packages/dashmate/configs/defaults/getMainnetConfigFactory.js

@@ -67,12 +67,19 @@ export default function getMainnetConfigFactory(homeDir, getBaseConfig) {
               txEnqueueTimeout: '30ms',
               txSendRateLimit: 100,
               txRecvRateLimit: 120,
+              ttlDuration: '24h',
+              ttlNumBlocks: 0,
             },
             genesis: {
               chain_id: 'dash-1',
               validator_quorum_type: 4,
             },
           },
+          abci: {
+            proposer: {
+              txProcessingTimeLimit: 5000,
+            },
+          },
         },
       },
     };

packages/dashmate/configs/defaults/getTestnetConfigFactory.js

@@ -74,6 +74,9 @@ export default function getTestnetConfigFactory(homeDir, getBaseConfig) {
                 rotation: true,
               },
             },
+            proposer: {
+              txProcessingTimeLimit: 5000,
+            },
           },
           tenderdash: {
             p2p: {
@@ -91,6 +94,14 @@ export default function getTestnetConfigFactory(homeDir, getBaseConfig) {
               ],
               port: 36656,
             },
+            mempool: {
+              timeoutCheckTx: '3s',
+              txEnqueueTimeout: '30ms',
+              txSendRateLimit: 100,
+              txRecvRateLimit: 120,
+              ttlDuration: '24h',
+              ttlNumBlocks: 0,
+            },
             rpc: {
               port: 36657,
               timeoutBroadcastTx: '1s',

packages/dashmate/configs/getConfigFileMigrationsFactory.js

@@ -790,6 +790,35 @@ export default function getConfigFileMigrationsFactory(homeDir, defaultConfigs)
           });
         return configFile;
       },
+      '1.1.0-dev.2': (configFile) => {
+        Object.entries(configFile.configs)
+          .forEach(([name, options]) => {
+            if (options.network === NETWORK_TESTNET) {
+              options.platform.drive.abci.proposer = {
+                txProcessingTimeLimit: 5000,
+              };
+              options.platform.drive.tenderdash.mempool.timeoutCheckTx = '3s';
+              options.platform.drive.tenderdash.mempool.txEnqueueTimeout = '30ms';
+              options.platform.drive.tenderdash.mempool.txSendRateLimit = 100;
+              options.platform.drive.tenderdash.mempool.txRecvRateLimit = 120;
+              options.platform.drive.tenderdash.mempool.ttlDuration = '24h';
+              options.platform.drive.tenderdash.mempool.ttlNumBlocks = 0;
+            } else if (options.network === NETWORK_MAINNET && name !== 'base') {
+              options.platform.drive.abci.proposer = {
+                txProcessingTimeLimit: 5000,
+              };
+              options.platform.drive.tenderdash.mempool.ttlDuration = '24h';
+              options.platform.drive.tenderdash.mempool.ttlNumBlocks = 0;
+            } else {
+              options.platform.drive.tenderdash.mempool.ttlDuration = '0s';
+              options.platform.drive.tenderdash.mempool.ttlNumBlocks = 0;
+              options.platform.drive.abci.proposer = {
+                txProcessingTimeLimit: null,
+              };
+            }
+          });
+        return configFile;
+      },
     };
   }
 

packages/dashmate/docker-compose.yml

@@ -80,6 +80,7 @@ services:
       - TOKIO_CONSOLE_RETENTION_SECS=${PLATFORM_DRIVE_ABCI_TOKIO_CONSOLE_RETENTION:?err}
       - GROVEDB_VISUALIZER_ENABLED=${PLATFORM_DRIVE_ABCI_GROVEDB_VISUALIZER_ENABLED:?err}
       - GROVEDB_VISUALIZER_ADDRESS=0.0.0.0:${PLATFORM_DRIVE_ABCI_GROVEDB_VISUALIZER_PORT:?err}
+      - PROPOSER_TX_PROCESSING_TIME_LIMIT=${PLATFORM_DRIVE_ABCI_PROPOSER_TX_PROCESSING_TIME_LIMIT}
       - NETWORK=${NETWORK:?err}
     stop_grace_period: 30s
     expose:

packages/dashmate/src/config/configJsonSchema.js

@@ -895,9 +895,20 @@ export default {
                 grovedbVisualizer: {
                   $ref: '#/definitions/enabledHostPort',
                 },
+                proposer: {
+                  type: 'object',
+                  properties: {
+                    txProcessingTimeLimit: {
+                      type: ['null', 'integer'],
+                      minimum: 0,
+                    },
+                  },
+                  required: ['txProcessingTimeLimit'],
+                  additionalProperties: false,
+                },
               },
               additionalProperties: false,
-              required: ['docker', 'logs', 'tokioConsole', 'validatorSet', 'chainLock', 'epochTime', 'metrics', 'grovedbVisualizer'],
+              required: ['docker', 'logs', 'tokioConsole', 'validatorSet', 'chainLock', 'epochTime', 'metrics', 'grovedbVisualizer', 'proposer'],
             },
             tenderdash: {
               type: 'object',
@@ -992,9 +1003,16 @@ export default {
                       type: 'integer',
                       minimum: 0,
                     },
+                    ttlDuration: {
+                      $ref: '#/definitions/duration',
+                    },
+                    ttlNumBlocks: {
+                      type: 'integer',
+                      minimum: 0,
+                    },
                   },
                   additionalProperties: false,
-                  required: ['size', 'maxTxsBytes', 'cacheSize', 'timeoutCheckTx', 'txEnqueueTimeout', 'txSendRateLimit', 'txRecvRateLimit', 'maxConcurrentCheckTx'],
+                  required: ['size', 'maxTxsBytes', 'cacheSize', 'timeoutCheckTx', 'txEnqueueTimeout', 'txSendRateLimit', 'txRecvRateLimit', 'maxConcurrentCheckTx', 'ttlDuration', 'ttlNumBlocks'],
                 },
                 consensus: {
                   type: 'object',

packages/dashmate/templates/platform/drive/tenderdash/config.toml.dot

@@ -395,15 +395,15 @@ max-batch-bytes = 0
 # Note, if ttl-num-blocks is also defined, a transaction will be removed if it
 # has existed in the mempool at least ttl-num-blocks number of blocks or if it's
 # insertion time into the mempool is beyond ttl-duration.
-ttl-duration = "0s"
+ttl-duration = "{{=it.platform.drive.tenderdash.mempool.ttlDuration}}"
 
 # ttl-num-blocks, if non-zero, defines the maximum number of blocks a transaction
 # can exist for in the mempool.
 #
 # Note, if ttl-duration is also defined, a transaction will be removed if it
 # has existed in the mempool at least ttl-num-blocks number of blocks or if
 # it's insertion time into the mempool is beyond ttl-duration.
-ttl-num-blocks = 0
+ttl-num-blocks = {{=it.platform.drive.tenderdash.mempool.ttlNumBlocks}}
 
 #######################################################
 ###         State Sync Configuration Options        ###

packages/rs-drive-abci/.env.mainnet

@@ -89,4 +89,6 @@ TOKIO_CONSOLE_RETENTION_SECS=180
 GROVEDB_VISUALIZER_ENABLED=false
 GROVEDB_VISUALIZER_ADDRESS=127.0.0.1:8083
 
+PROPOSER_TX_PROCESSING_TIME_LIMIT=5000
+
 NETWORK=mainnet

packages/rs-drive-abci/.env.testnet

@@ -89,4 +89,6 @@ TOKIO_CONSOLE_RETENTION_SECS=180
 GROVEDB_VISUALIZER_ENABLED=false
 GROVEDB_VISUALIZER_ADDRESS=127.0.0.1:8083
 
+PROPOSER_TX_PROCESSING_TIME_LIMIT=5000
+
 NETWORK=testnet

packages/rs-drive-abci/src/abci/config.rs

@@ -1,5 +1,6 @@
 //! Configuration of ABCI Application server
 
+use crate::utils::from_opt_str_or_number;
 use dpp::prelude::TimestampMillis;
 use serde::{Deserialize, Serialize};
 
@@ -34,9 +35,9 @@ pub struct AbciConfig {
     #[serde(default)]
     pub log: crate::logging::LogConfigs,
 
-    /// Maximum time limit (in ms) to process state transitions in block proposals
-    #[serde(default = "AbciConfig::default_tx_processing_time_limit")]
-    pub tx_processing_time_limit: TimestampMillis,
+    /// Maximum time limit (in ms) to process state transitions to prepare proposal
+    #[serde(default, deserialize_with = "from_opt_str_or_number")]
+    pub proposer_tx_processing_time_limit: Option<TimestampMillis>,
 }
 
 impl AbciConfig {
@@ -47,10 +48,6 @@ impl AbciConfig {
     pub(crate) fn default_genesis_core_height() -> u32 {
         1
     }
-
-    pub(crate) fn default_tx_processing_time_limit() -> TimestampMillis {
-        8000
-    }
 }
 
 impl Default for AbciConfig {
@@ -61,7 +58,7 @@ impl Default for AbciConfig {
             genesis_core_height: AbciConfig::default_genesis_core_height(),
             chain_id: "chain_id".to_string(),
             log: Default::default(),
-            tx_processing_time_limit: AbciConfig::default_tx_processing_time_limit(),
+            proposer_tx_processing_time_limit: Default::default(),
         }
     }
 }

packages/rs-drive-abci/src/config.rs

@@ -1,4 +1,5 @@
 use crate::logging::LogConfigs;
+use crate::utils::from_str_or_number;
 use crate::{abci::config::AbciConfig, error::Error};
 use bincode::{Decode, Encode};
 use dashcore_rpc::json::QuorumType;
@@ -82,14 +83,14 @@
     pub check_tx_rpc: CheckTxCoreRpcConfig,
 }
 
 impl Default for CoreConfig {
     fn default() -> Self {
         Self {
             consensus_rpc: Default::default(),
             check_tx_rpc: Default::default(),
         }
     }
 }
 
 /// Configuration of the execution part of Dash Platform.
 #[derive(Clone, Debug, Serialize, Deserialize)]
@@ -113,18 +114,6 @@
     pub epoch_time_length_s: u64,
 }
 
-fn from_str_or_number<'de, D, T>(deserializer: D) -> Result<T, D::Error>
-where
-    D: serde::Deserializer<'de>,
-    T: serde::Deserialize<'de> + std::str::FromStr,
-    <T as std::str::FromStr>::Err: std::fmt::Display,
-{
-    use serde::de::Error;
-
-    let s = String::deserialize(deserializer)?;
-    s.parse::<T>().map_err(Error::custom)
-}
-
 /// Configuration of Dash Platform.
 ///
 /// All fields in this struct can be configured using environment variables.

packages/rs-drive-abci/src/execution/platform_events/state_transition_processing/process_raw_state_transitions/v0/mod.rs

@@ -83,10 +83,16 @@ where
         let mut processing_result = StateTransitionsProcessingResult::default();
 
         for decoded_state_transition in state_transition_container.into_iter() {
+            // If we propose state transitions, we need to check if we have a time limit for processing
+            // set and if we have exceeded it.
             let execution_result = if proposing_state_transitions
                 && timer.map_or(false, |timer| {
                     timer.elapsed().as_millis() as TimestampMillis
-                        > self.config.abci.tx_processing_time_limit
+                        > self
+                            .config
+                            .abci
+                            .proposer_tx_processing_time_limit
+                            .unwrap_or(TimestampMillis::MAX)
                 }) {
                 StateTransitionExecutionResult::NotExecuted(NotExecutedReason::ProposerRanOutOfTime)
             } else {

packages/rs-drive-abci/src/execution/validation/state_transition/state_transitions/documents_batch/transformer/v0/mod.rs

@@ -233,23 +233,22 @@ impl DocumentsBatchTransitionInternalTransformerV0 for DocumentsBatchTransition
         };
 
         let validation_result = document_transitions
-        .iter()
-        .map(|(document_type_name, document_transitions)| {
-            Self::transform_document_transitions_within_document_type_v0(
-                platform,
-                block_info,
-                validate_against_state,
-                data_contract_fetch_info.clone(),
-                document_type_name,
-                owner_id,
-                document_transitions,
-                execution_context,
-                transaction,
-                platform_version,
-            )
-        })
-        .collect::<Result<Vec<ConsensusValidationResult<Vec<DocumentTransitionAction>>>, Error>>(
-        )?;
+            .iter()
+            .map(|(document_type_name, document_transitions)| {
+                Self::transform_document_transitions_within_document_type_v0(
+                    platform,
+                    block_info,
+                    validate_against_state,
+                    data_contract_fetch_info.clone(),
+                    document_type_name,
+                    owner_id,
+                    document_transitions,
+                    execution_context,
+                    transaction,
+                    platform_version,
+                )
+            })
+            .collect::<Result<Vec<ConsensusValidationResult<Vec<DocumentTransitionAction>>>, Error>>()?;
         Ok(ConsensusValidationResult::flatten(validation_result))
     }
 
@@ -327,7 +326,7 @@ impl DocumentsBatchTransitionInternalTransformerV0 for DocumentsBatchTransition
                 .map(|transition| {
                     // we validate every transition in this document type
                     Self::transform_transition_v0(
-                        &platform.drive,
+                        platform.drive,
                         transaction,
                         validate_against_state,
                         block_info,
@@ -376,7 +375,7 @@ impl DocumentsBatchTransitionInternalTransformerV0 for DocumentsBatchTransition
                     drive, transaction,
                     document_create_transition, block_info, |_identifier| {
                         Ok(data_contract_fetch_info.clone())
-                }, platform_version)?;
+                    }, platform_version)?;
 
                 execution_context
                     .add_operation(ValidationOperation::PrecalculatedOperation(fee_result));
@@ -475,9 +474,9 @@ impl DocumentsBatchTransitionInternalTransformerV0 for DocumentsBatchTransition
                 }
             }
             DocumentTransition::Delete(document_delete_transition) => {
-                let action = DocumentDeleteTransitionAction::from_document_borrowed_create_transition_with_contract_lookup(document_delete_transition,                      |_identifier| {
-                Ok(data_contract_fetch_info.clone())
-            })?;
+                let action = DocumentDeleteTransitionAction::from_document_borrowed_create_transition_with_contract_lookup(document_delete_transition, |_identifier| {
+                    Ok(data_contract_fetch_info.clone())
+                })?;
                 Ok(DocumentTransitionAction::DeleteAction(action).into())
             }
             DocumentTransition::Transfer(document_transfer_transition) => {

packages/rs-drive-abci/src/utils/mod.rs

@@ -1,3 +1,6 @@
+mod serialization;
 mod spawn;
 
+pub use serialization::from_opt_str_or_number;
+pub use serialization::from_str_or_number;
 pub use spawn::spawn_blocking_task_with_name_if_supported;

packages/rs-drive-abci/src/utils/serialization.rs

@@ -0,0 +1,36 @@
+use serde::Deserialize;
+
+/// Deserialize a value from a string or a number.
+pub fn from_str_or_number<'de, D, T>(deserializer: D) -> Result<T, D::Error>
+where
+    D: serde::Deserializer<'de>,
+    T: serde::Deserialize<'de> + std::str::FromStr,
+    <T as std::str::FromStr>::Err: std::fmt::Display,
+{
+    use serde::de::Error;
+
+    let s = String::deserialize(deserializer)?;
+    s.parse::<T>().map_err(Error::custom)
+}
+
+/// Deserialize a value from an optional string or a number
+pub fn from_opt_str_or_number<'de, D, T>(deserializer: D) -> Result<Option<T>, D::Error>
+where
+    D: serde::Deserializer<'de>,
+    T: serde::Deserialize<'de> + std::str::FromStr,
+    <T as std::str::FromStr>::Err: std::fmt::Display,
+{
+    use serde::de::Error;
+
+    let s = Option::<String>::deserialize(deserializer)?;
+    match s {
+        Some(s) => {
+            if s.is_empty() {
+                Ok(None)
+            } else {
+                s.parse::<T>().map(Some).map_err(Error::custom)
+            }
+        }
+        None => Ok(None),
+    }
+}