fix formatting

Author: pietroalbini

src/bin/rla-server.rs

@@ -68,7 +68,7 @@ struct Cli {
     repo: String,
     #[structopt(
         long = "secondary-repo",
-        help="Secondary repositories to listen for builds.",
+        help = "Secondary repositories to listen for builds.",
         required = false,
         multiple = true
     )]

src/bin/server/worker.rs

@@ -95,7 +95,9 @@ impl Worker {
     fn process(&mut self, item: QueueItem) -> rla::Result<()> {
         let (repo, build_id, outcome) = match &item {
             QueueItem::GitHubStatus(ev) => match self.ci.build_id_from_github_status(&ev) {
-                Some(id) if self.is_repo_valid(&ev.repository.full_name) => (&ev.repository.full_name, id, None),
+                Some(id) if self.is_repo_valid(&ev.repository.full_name) => {
+                    (&ev.repository.full_name, id, None)
+                }
                 _ => {
                     info!(
                         "Ignoring invalid event (ctx: {:?}, url: {:?}).",
@@ -105,7 +107,9 @@ impl Worker {
                 }
             },
             QueueItem::GitHubCheckRun(ev) => match self.ci.build_id_from_github_check(&ev) {
-                Some(id) if self.is_repo_valid(&ev.repository.full_name) => (&ev.repository.full_name, id, Some(&ev.check_run.outcome)),
+                Some(id) if self.is_repo_valid(&ev.repository.full_name) => {
+                    (&ev.repository.full_name, id, Some(&ev.check_run.outcome))
+                }
                 _ => {
                     info!(
                         "Ignoring invalid event (app id: {:?}, url: {:?}).",
@@ -295,8 +299,10 @@ impl Worker {
             match ci::download_log(self.ci.as_ref(), *job, self.github.internal()) {
                 Some(Ok(log)) => {
                     for line in rla::sanitize::split_lines(&log) {
-                        self.index
-                            .learn(&rla::index::Sanitized(rla::sanitize::clean(self.ci.as_ref(), line)), 1);
+                        self.index.learn(
+                            &rla::index::Sanitized(rla::sanitize::clean(self.ci.as_ref(), line)),
+                            1,
+                        );
                     }
                 }
                 None => {

src/ci/actions.rs

@@ -1,10 +1,10 @@
 use crate::ci::{Build, BuildCommit, CiPlatform, Job, Outcome};
-use crate::github::{CheckRun, BuildOutcome};
+use crate::github::{BuildOutcome, CheckRun};
 use crate::Result;
 use regex::Regex;
 use reqwest::{Client as ReqwestClient, Method, RequestBuilder, Response};
-use std::collections::HashMap;
 use std::borrow::Cow;
+use std::collections::HashMap;
 
 #[derive(Deserialize)]
 struct ActionsRun {
@@ -241,10 +241,7 @@ impl CiPlatform for Client {
 
     fn query_build(&self, repo: &str, id: u64) -> Result<Box<dyn Build>> {
         let run: ActionsRun = self
-            .req(
-                Method::GET,
-                &format!("repos/{}/actions/runs/{}", repo, id),
-            )?
+            .req(Method::GET, &format!("repos/{}/actions/runs/{}", repo, id))?
             .error_for_status()?
             .json()?;
         Ok(GHABuild::new(self, repo, run)?)
@@ -267,7 +264,11 @@ impl CiPlatform for Client {
     }
 }
 
-fn fetch_workflow_run_id_from_check_run(client: &Client, repo: &str, run: &CheckRun) -> Result<u64> {
+fn fetch_workflow_run_id_from_check_run(
+    client: &Client,
+    repo: &str,
+    run: &CheckRun,
+) -> Result<u64> {
     #[derive(Deserialize)]
     struct ResponseRuns {
         total_count: usize,

src/ci/azure.rs

@@ -3,9 +3,9 @@ use crate::ci::{Build, BuildCommit, CiPlatform, Job, Outcome};
 use crate::Result;
 use failure::ResultExt;
 use reqwest::{Client as ReqwestClient, Method, Response, StatusCode};
+use std::borrow::Cow;
 use std::fmt;
 use std::io::Read;
-use std::borrow::Cow;
 
 #[derive(Debug, Eq, PartialEq, Deserialize)]
 #[serde(rename_all = "camelCase")]
@@ -99,7 +99,9 @@ impl Job for AzureJob {
     fn html_url(&self) -> String {
         format!(
             "https://dev.azure.com/{repo}/_build/results?buildId={build}&view=logs&jobId={job}",
-            repo = self.repo, build = self.build, job = self.record.id
+            repo = self.repo,
+            build = self.build,
+            job = self.record.id
         )
     }
 
@@ -340,7 +342,11 @@ impl CiPlatform for Client {
     }
 
     fn query_build(&self, repo: &str, id: u64) -> Result<Box<dyn Build>> {
-        let resp = self.req(Method::GET, repo, &format!("build/builds/{}?api-version=5.0", id))?;
+        let resp = self.req(
+            Method::GET,
+            repo,
+            &format!("build/builds/{}?api-version=5.0", id),
+        )?;
         let mut resp = resp.error_for_status()?;
         let data: AzureBuildData = resp.json()?;
         if let Some(build) = AzureBuild::new(&self, repo, data)? {

src/ci/mod.rs

@@ -1,6 +1,6 @@
 use reqwest::RequestBuilder;
-use std::io::Read;
 use std::borrow::Cow;
+use std::io::Read;
 
 mod actions;
 mod azure;

src/github.rs

@@ -150,9 +150,7 @@ impl Client {
             .timeout(Some(Duration::from_secs(TIMEOUT_SECS)))
             .build()?;
 
-        Ok(Client {
-            internal: client,
-        })
+        Ok(Client { internal: client })
     }
 
     pub fn query_pr(&self, repo: &str, pr_id: u32) -> Result<Pr> {

src/sanitize.rs

@@ -1,5 +1,5 @@
-use regex::bytes::Regex;
 use crate::ci::CiPlatform;
+use regex::bytes::Regex;
 
 pub fn split_lines(data: &[u8]) -> Vec<&[u8]> {
     lazy_static! {