Method apply_run_command_transformations

src/instruments/mongo_tracer.rs:196–226

Applies the necessary transformations to the command to run the benchmark TODO: move this to a `Instrument` trait, refactor and implement it for valgring as well

(&self, command: &mut Command)

    /// Applies the necessary transformations to the command to run the benchmark
    /// TODO: move this to a `Instrument` trait, refactor and implement it for valgring as well
    pub fn apply_run_command_transformations(&self, command: &mut Command) -> Result<()> {
        let mut envs = vec![(
            "CODSPEED_MONGO_INSTR_SERVER_ADDRESS",
            self.server_address.as_str(),
        )];

        let mut new_uri = Url::from_str(&self.proxy_mongo_uri)?;
        if let Some(user_input) = &self.user_input {
            let destination_uri = Url::parse(&user_input.mongo_uri)?;
            new_uri.set_path(destination_uri.path());
            let cleaned_query_pairs = destination_uri
                .query_pairs()
                .filter(|(k, _)| {
                    if k == "directConnection" {
                        info!("Overriding directionConnection to true. This is necessary to make the MongoDB tracer work.");
                        return false;
                    }
                    true
                });
            new_uri
                .query_pairs_mut()
                .extend_pairs(cleaned_query_pairs)
                .append_pair("directConnection", "true");

            envs.push((user_input.uri_env_name.as_str(), new_uri.as_str()));
        }

        command.envs(envs);

        Ok(())
    }
}

pub async fn install_mongodb_tracer() -> Result<()> {