Re-format code

Author: Mark-Simulacrum

src/agent/api.rs

@@ -8,13 +8,13 @@ use crate::results::TestResult;
 use crate::server::api_types::{AgentConfig, ApiResponse, CraterToken};
 use crate::toolchain::Toolchain;
 use crate::utils;
+use base64::Engine;
 use rand::Rng;
 use reqwest::blocking::RequestBuilder;
 use reqwest::header::AUTHORIZATION;
 use reqwest::{Method, StatusCode};
 use serde::de::DeserializeOwned;
 use serde_json::json;
-use base64::Engine;
 
 #[derive(Debug, thiserror::Error)]
 pub enum AgentApiError {

src/report/mod.rs

@@ -182,7 +182,10 @@ fn crate_to_path_fragment(
     path
 }
 
-fn get_crate_version_status(index: &GitIndex, krate: &Crate) -> Fallible<Option<CrateVersionStatus>> {
+fn get_crate_version_status(
+    index: &GitIndex,
+    krate: &Crate,
+) -> Fallible<Option<CrateVersionStatus>> {
     if let Crate::Registry(krate) = krate {
         let index_krate = index
             .crate_(&krate.name)

src/results/db.rs

@@ -90,7 +90,9 @@ impl<'a> DatabaseDB<'a> {
                 &result.krate,
                 &result.toolchain,
                 &result.result,
-                &base64::engine::general_purpose::STANDARD.decode(&result.log).with_context(|_| "invalid base64 log provided")?,
+                &base64::engine::general_purpose::STANDARD
+                    .decode(&result.log)
+                    .with_context(|_| "invalid base64 log provided")?,
                 encoding_type,
             )?;
 

src/server/metrics.rs

@@ -4,9 +4,7 @@ use crate::prelude::*;
 use crate::server::agents::Agent;
 use chrono::{DateTime, Utc};
 use prometheus::proto::{Metric, MetricFamily};
-use prometheus::{
-    HistogramVec, IntCounter, IntCounterVec, IntGauge, IntGaugeVec,
-};
+use prometheus::{HistogramVec, IntCounter, IntCounterVec, IntGauge, IntGaugeVec};
 
 const JOBS_METRIC: &str = "crater_completed_jobs_total";
 const AGENT_WORK_METRIC: &str = "crater_agent_supposed_to_work";

src/server/reports.rs

@@ -30,7 +30,9 @@ fn generate_report(data: &Data, ex: &Experiment, results: &DatabaseDB) -> Fallib
     config.set_credentials_provider(Some(data.tokens.reports_bucket.to_aws_credentials()));
     // https://github.com/awslabs/aws-sdk-rust/issues/586 -- without this, the
     // SDK will just completely not retry requests.
-    config.set_sleep_impl(Some(aws_sdk_s3::config::SharedAsyncSleep::new(aws_smithy_async::rt::sleep::TokioSleep::new())));
+    config.set_sleep_impl(Some(aws_sdk_s3::config::SharedAsyncSleep::new(
+        aws_smithy_async::rt::sleep::TokioSleep::new(),
+    )));
     config.set_retry_config(Some(RetryConfig::standard()));
     let config = config.build();
     let client = aws_sdk_s3::Client::new(&config);

src/server/tokens.rs

@@ -30,14 +30,18 @@ pub struct ReportsBucket {
 }
 
 impl ReportsBucket {
-    pub(crate) fn to_aws_credentials(&self) -> aws_credential_types::provider::SharedCredentialsProvider {
-        aws_credential_types::provider::SharedCredentialsProvider::new(aws_sdk_s3::config::Credentials::new(
-            self.access_key.clone(),
-            self.secret_key.clone(),
-            None,
-            None,
-            "crater-credentials"
-        ))
+    pub(crate) fn to_aws_credentials(
+        &self,
+    ) -> aws_credential_types::provider::SharedCredentialsProvider {
+        aws_credential_types::provider::SharedCredentialsProvider::new(
+            aws_sdk_s3::config::Credentials::new(
+                self.access_key.clone(),
+                self.secret_key.clone(),
+                None,
+                None,
+                "crater-credentials",
+            ),
+        )
     }
 }