diff --git a/src/google.rs b/src/google.rs index 715b7b5..a3d268e 100644 --- a/src/google.rs +++ b/src/google.rs @@ -1,8 +1,8 @@ -use std::time; use anyhow::{Context, Result}; +use log::info; use serde::{Deserialize, Serialize}; +use std::time; use url::Url; -use log::info; #[derive(Serialize, Deserialize, Debug)] pub struct GoogleChatMessage { @@ -44,17 +44,24 @@ impl GoogleChatMessage { .send() .await?; - if response.status().eq(&reqwest::StatusCode::TOO_MANY_REQUESTS) { + if response + .status() + .eq(&reqwest::StatusCode::TOO_MANY_REQUESTS) + { /* Sleep for 1.5 seconds to avoid rate limiting, at 60 requests per minute. See https://developers.google.com/workspace/chat/limits */ - info!("Received {} response. Sleeping for 1.5 seconds before retrying", response.status()); + info!( + "Received {} response. Sleeping for 1.5 seconds before retrying", + response.status() + ); tokio::time::sleep(time::Duration::from_millis(1500)).await; Box::pin(self.send(webhook_url, thread_key)).await?; } - let response_text = response.text() + let response_text = response + .text() .await .context(format!("Failed to get response from: {}", &webhook_url))?; diff --git a/src/main.rs b/src/main.rs index 6086d1b..f00804f 100644 --- a/src/main.rs +++ b/src/main.rs @@ -193,7 +193,10 @@ async fn main() -> Result<(), Error> { .await?; for pull_request in pull_requests_to_review { - info!("Sending message for PR {} #{}", pull_request.head.repo.name, pull_request.number); + info!( + "Sending message for PR {} #{}", + pull_request.head.repo.name, pull_request.number + ); GoogleChatMessage::from(make_message(pull_request, show_pr_age)) .send(&webhook_url, &thread_key) .await?;