add enable_event_processing option (MystenLabs#2462)

crates/sui-config/src/builder.rs

@@ -190,6 +190,7 @@ impl<R: ::rand::RngCore + ::rand::CryptoRng> ConfigBuilder<R> {
                     metrics_address: utils::available_local_socket_address(),
                     json_rpc_address: utils::available_local_socket_address(),
                     consensus_config: Some(consensus_config),
+                    enable_event_processing: false,
                     genesis: crate::node::Genesis::new(genesis.clone()),
                 }
             })

crates/sui-config/src/node.rs

@@ -33,6 +33,9 @@ pub struct NodeConfig {
     #[serde(skip_serializing_if = "Option::is_none")]
     pub consensus_config: Option<ConsensusConfig>,
 
+    #[serde(default)]
+    pub enable_event_processing: bool,
+
     pub genesis: Genesis,
 }
 

crates/sui-config/src/swarm.rs

@@ -68,9 +68,8 @@ impl NetworkConfig {
             network_address: utils::new_network_address(),
             metrics_address: utils::available_local_socket_address(),
             json_rpc_address: utils::available_local_socket_address(),
-
             consensus_config: None,
-
+            enable_event_processing: true,
             genesis: validator_config.genesis.clone(),
         }
     }

crates/sui-core/src/authority.rs

@@ -781,6 +781,7 @@ impl AuthorityState {
         indexes: Option<Arc<IndexStore>>,
         checkpoints: Option<Arc<Mutex<CheckpointStore>>>,
         genesis: &Genesis,
+        enable_event_processing: bool,
     ) -> Self {
         let (tx, _rx) = tokio::sync::broadcast::channel(BROADCAST_CAPACITY);
         let native_functions =
@@ -825,6 +826,11 @@ impl AuthorityState {
             .get_last_epoch_info()
             .expect("Fail to load the current epoch info");
 
+        let event_handler = if enable_event_processing {
+            Some(Arc::new(EventHandler::new(store.clone())))
+        } else {
+            None
+        };
         let mut state = AuthorityState {
             name,
             secret,
@@ -834,10 +840,10 @@ impl AuthorityState {
             move_vm,
             database: store.clone(),
             indexes,
-            module_cache: SyncModuleCache::new(AuthorityStoreWrapper(store.clone())),
-            // `event_handler` uses a separate in-mem cache from `module_cache`
+            // `module_cache` uses a separate in-mem cache from `event_handler`
             // this is because they largely deal with different types of MoveStructs
-            event_handler: Some(Arc::new(EventHandler::new(store.clone()))),
+            module_cache: SyncModuleCache::new(AuthorityStoreWrapper(store.clone())),
+            event_handler,
             checkpoints,
             batch_channels: tx,
             batch_notifier: Arc::new(

crates/sui-core/src/authority_active/gossip/configurable_batch_action_client.rs

@@ -76,6 +76,7 @@ impl ConfigurableBatchActionClient {
             None,
             None,
             &sui_config::genesis::Genesis::get_default_genesis(),
+            false,
         )
         .await;
 

crates/sui-core/src/authority_client.rs

@@ -352,6 +352,7 @@ impl LocalAuthorityClient {
             None,
             Some(Arc::new(Mutex::new(checkpoints))),
             genesis,
+            false,
         )
         .await;
         Self {

crates/sui-core/src/checkpoints/tests/checkpoint_tests.rs

@@ -732,6 +732,7 @@ async fn test_batch_to_checkpointing() {
         None,
         Some(checkpoints.clone()),
         &sui_config::genesis::Genesis::get_default_genesis(),
+        false,
     )
     .await;
     let authority_state = Arc::new(state);
@@ -820,6 +821,7 @@ async fn test_batch_to_checkpointing_init_crash() {
             None,
             None,
             &sui_config::genesis::Genesis::get_default_genesis(),
+            false,
         )
         .await;
         let authority_state = Arc::new(state);
@@ -900,6 +902,7 @@ async fn test_batch_to_checkpointing_init_crash() {
             None,
             Some(checkpoints.clone()),
             &sui_config::genesis::Genesis::get_default_genesis(),
+            false,
         )
         .await;
         let authority_state = Arc::new(state);
@@ -1388,6 +1391,7 @@ pub async fn checkpoint_tests_setup(num_objects: usize, batch_interval: Duration
             None,
             Some(checkpoint.clone()),
             &genesis,
+            false,
         )
         .await;
 

crates/sui-core/src/unit_tests/authority_tests.rs

@@ -1326,6 +1326,7 @@ pub async fn init_state() -> AuthorityState {
         None,
         None,
         &sui_config::genesis::Genesis::get_default_genesis(),
+        false,
     )
     .await
 }

crates/sui-core/src/unit_tests/batch_tests.rs

@@ -57,6 +57,7 @@ pub(crate) async fn init_state(
         None,
         None,
         &sui_config::genesis::Genesis::get_default_genesis(),
+        false,
     )
     .await
 }
@@ -770,6 +771,7 @@ async fn test_safe_batch_stream() {
         None,
         None,
         &sui_config::genesis::Genesis::get_default_genesis(),
+        false,
     )
     .await;
 
@@ -815,6 +817,7 @@ async fn test_safe_batch_stream() {
         None,
         None,
         &sui_config::genesis::Genesis::get_default_genesis(),
+        false,
     )
     .await;
     let auth_client_from_byzantine = ByzantineAuthorityClient::new(state_b);

crates/sui-node/src/lib.rs

@@ -69,6 +69,7 @@ impl SuiNode {
                 index_store,
                 checkpoint_store,
                 genesis,
+                config.enable_event_processing,
             )
             .await,
         );

crates/sui/src/benchmark/validator_preparer.rs

@@ -290,6 +290,7 @@ fn make_authority_state(
                 None,
                 None,
                 &sui_config::genesis::Genesis::get_default_genesis(),
+                false,
             )
             .await
         }),