Update and make crash end to end test

Added a protocol parameters transition that make the test fail, when it should succeed.

Author: jpraynaud

mithril-test-lab/mithril-end-to-end/src/end_to_end_spec.rs

@@ -56,7 +56,18 @@ impl Spec {
         wait_for_target_epoch(
             self.infrastructure.chain_observer(),
             target_epoch,
-            "epoch after which the certificate chain will be long enough to catch most common troubles".to_string(),
+            "epoch after which the certificate chain will be long enough to catch most common troubles with stake distribution".to_string(),
+        )
+        .await?;
+
+        // Wait 5 epochs after updating protocol parameters, so that we make sure that we use new protool parameters a few times
+        update_protocol_parameters(self.infrastructure.aggregator_mut()).await?;
+        wait_for_epoch_settings(&aggregator_endpoint).await?;
+        target_epoch += 5;
+        wait_for_target_epoch(
+            self.infrastructure.chain_observer(),
+            target_epoch,
+            "epoch after which the certificate chain will be long enough to catch most common troubles with protocol parameters".to_string(),
         )
         .await?;
 
@@ -210,6 +221,19 @@ async fn delegate_stakes_to_pools(devnet: &Devnet) -> Result<(), String> {
     Ok(())
 }
 
+async fn update_protocol_parameters(aggregator: &mut Aggregator) -> Result<(), String> {
+    info!("Update protocol parameters");
+
+    info!("> stopping aggregator");
+    aggregator.stop().await?;
+    info!("> updating protocol parameters ...");
+    aggregator.update_protocol_parameters();
+    info!("> done, restarting aggregator");
+    aggregator.serve()?;
+
+    Ok(())
+}
+
 async fn assert_node_producing_snapshot(aggregator_endpoint: &str) -> Result<String, String> {
     let url = format!("{}/snapshots", aggregator_endpoint);
     info!("Waiting for the aggregator to produce a snapshot");

mithril-test-lab/mithril-end-to-end/src/mithril/aggregator.rs

@@ -105,6 +105,13 @@ impl Aggregator {
         Ok(())
     }
 
+    pub fn update_protocol_parameters(&mut self) {
+        self.command.set_env_var("PROTOCOL_PARAMETERS__K", "150");
+        self.command.set_env_var("PROTOCOL_PARAMETERS__M", "200");
+        self.command
+            .set_env_var("PROTOCOL_PARAMETERS__PHI_F", "0.95");
+    }
+
     pub async fn tail_logs(&self, number_of_line: u64) -> Result<(), String> {
         self.command.tail_logs(None, number_of_line).await
     }

mithril-test-lab/mithril-end-to-end/src/utils/mithril_command.rs

@@ -56,6 +56,10 @@ impl MithrilCommand {
         self.log_path = self.work_dir.join(format!("{}.log", name));
     }
 
+    pub fn set_env_var(&mut self, name: &str, value: &str) {
+        self.env_vars.insert(name.to_string(), value.to_string());
+    }
+
     pub fn start(&mut self, args: &[String]) -> Result<Child, String> {
         let args = [&self.default_args, args].concat();