From 84bab9175e9381cc52030b7d6fb6ceefbc9c794a Mon Sep 17 00:00:00 2001
From: "Spencer C. Imbleau" <spencer@imbleau.com>
Date: Thu, 28 Mar 2024 00:18:55 -0400
Subject: [PATCH] refactor: fmt

---
 examples/error_handling.rs | 32 ++++++++------------------------
 examples/simple.rs         | 27 +++++++--------------------
 src/data_types.rs          |  5 +----
 src/lib.rs                 |  3 +--
 src/systems.rs             | 14 ++++----------
 5 files changed, 21 insertions(+), 60 deletions(-)

diff --git a/examples/error_handling.rs b/examples/error_handling.rs
index 561bef6..9eda6ea 100644
--- a/examples/error_handling.rs
+++ b/examples/error_handling.rs
@@ -3,8 +3,8 @@ use bevy::{
     prelude::*,
 };
 use bevy_key_rotation::{
-    AuthProvider, KeyRotationPlugin, KeyRotationSettings, Keystore,
-    KeystoreState, StartKeyRotationExt, TokenRotationError,
+    AuthProvider, KeyRotationPlugin, KeyRotationSettings, Keystore, KeystoreState,
+    StartKeyRotationExt, TokenRotationError,
 };
 use std::sync::Arc;
 
@@ -29,10 +29,7 @@ impl AuthProvider for MyAuthProvider {
                 + bevy_key_rotation::Duration::from_secs(60),
         })
     }
-    async fn refresh(
-        &self,
-        _keystore: Keystore,
-    ) -> Result<Keystore, TokenRotationError> {
+    async fn refresh(&self, _keystore: Keystore) -> Result<Keystore, TokenRotationError> {
         #[derive(thiserror::Error, Default, Debug)]
         #[error("This fails on purpose!")]
         struct MyError;
@@ -40,11 +37,7 @@ impl AuthProvider for MyAuthProvider {
     }
 }
 
-fn status_check(
-    time: Res<Time>,
-    mut update_every: Local<Option<Timer>>,
-    keystore: Res<Keystore>,
-) {
+fn status_check(time: Res<Time>, mut update_every: Local<Option<Timer>>, keystore: Res<Keystore>) {
     // Print status every few seconds...
     const PRINT_EVERY_SECONDS: f32 = 1.0;
     let update_every = update_every.get_or_insert(Timer::from_seconds(
@@ -56,9 +49,7 @@ fn status_check(
         return;
     }
 
-    if keystore.access_token_valid_for()
-        < bevy_key_rotation::Duration::from_secs(5)
-    {
+    if keystore.access_token_valid_for() < bevy_key_rotation::Duration::from_secs(5) {
         log::warn!("The keystore is about to be non-conformant!");
         // You could attempt to re-authenticate from scratch:
         // commands.start_key_rotation(username, password);
@@ -81,18 +72,13 @@ pub fn main() {
         .add_plugins(KeyRotationPlugin {
             rotation_settings: KeyRotationSettings {
                 rotation_timeout: bevy_key_rotation::Duration::MAX, // no timeout
-                rotation_check_interval: bevy_key_rotation::Duration::from_secs(
-                    5,
-                ),
+                rotation_check_interval: bevy_key_rotation::Duration::from_secs(5),
                 rotate_before: bevy_key_rotation::Duration::from_secs(15),
             },
             auth_provider: Arc::new(MyAuthProvider),
         })
         .add_systems(Startup, |mut commands: Commands| {
-            commands.start_key_rotation(
-                "username".to_string(),
-                "password".to_string(),
-            );
+            commands.start_key_rotation("username".to_string(), "password".to_string());
         })
         .add_systems(
             Update,
@@ -104,9 +90,7 @@ pub fn main() {
                 to: KeystoreState::NonConformant,
             },
             || {
-                error!(
-                    "Keystore is now non-conformant! Keys cannot be rotated."
-                );
+                error!("Keystore is now non-conformant! Keys cannot be rotated.");
             },
         )
         .run();
diff --git a/examples/simple.rs b/examples/simple.rs
index bba2a31..c994ddb 100644
--- a/examples/simple.rs
+++ b/examples/simple.rs
@@ -3,8 +3,8 @@ use bevy::{
     prelude::*,
 };
 use bevy_key_rotation::{
-    AuthProvider, KeyRotationPlugin, KeyRotationSettings, Keystore,
-    StartKeyRotationExt, TokenRotationError,
+    AuthProvider, KeyRotationPlugin, KeyRotationSettings, Keystore, StartKeyRotationExt,
+    TokenRotationError,
 };
 use std::sync::Arc;
 
@@ -29,27 +29,19 @@ impl AuthProvider for MyAuthProvider {
                 + bevy_key_rotation::Duration::from_secs(20),
         })
     }
-    async fn refresh(
-        &self,
-        keystore: Keystore,
-    ) -> Result<Keystore, TokenRotationError> {
+    async fn refresh(&self, keystore: Keystore) -> Result<Keystore, TokenRotationError> {
         Ok(Keystore {
             username: keystore.username,
             password: keystore.password,
             access_token: random_token(),
             refresh_token: keystore.refresh_token,
-            access_expires: keystore.access_expires
-                + bevy_key_rotation::Duration::from_secs(5),
+            access_expires: keystore.access_expires + bevy_key_rotation::Duration::from_secs(5),
             refresh_expires: keystore.refresh_expires,
         })
     }
 }
 
-fn status_check(
-    time: Res<Time>,
-    mut update_every: Local<Option<Timer>>,
-    keystore: Res<Keystore>,
-) {
+fn status_check(time: Res<Time>, mut update_every: Local<Option<Timer>>, keystore: Res<Keystore>) {
     // Print status every few seconds...
     const PRINT_EVERY_SECONDS: f32 = 1.0;
     let update_every = update_every.get_or_insert(Timer::from_seconds(
@@ -77,18 +69,13 @@ pub fn main() {
         .add_plugins(KeyRotationPlugin {
             rotation_settings: KeyRotationSettings {
                 rotation_timeout: bevy_key_rotation::Duration::MAX, // no timeout
-                rotation_check_interval: bevy_key_rotation::Duration::from_secs(
-                    1,
-                ),
+                rotation_check_interval: bevy_key_rotation::Duration::from_secs(1),
                 rotate_before: bevy_key_rotation::Duration::from_secs(5),
             },
             auth_provider: Arc::new(MyAuthProvider),
         })
         .add_systems(Startup, |mut commands: Commands| {
-            commands.start_key_rotation(
-                "username".to_string(),
-                "password".to_string(),
-            );
+            commands.start_key_rotation("username".to_string(), "password".to_string());
         })
         .add_systems(Update, status_check)
         .run();
diff --git a/src/data_types.rs b/src/data_types.rs
index 74cf608..04df5e7 100644
--- a/src/data_types.rs
+++ b/src/data_types.rs
@@ -11,10 +11,7 @@ pub trait AuthProvider {
         username: String,
         password: String,
     ) -> Result<Keystore, TokenRotationError>;
-    async fn refresh(
-        &self,
-        keystore: Keystore,
-    ) -> Result<Keystore, TokenRotationError>;
+    async fn refresh(&self, keystore: Keystore) -> Result<Keystore, TokenRotationError>;
 }
 
 /// A resource around the auth provider used (mostly internally) to perform
diff --git a/src/lib.rs b/src/lib.rs
index 23543d3..7f6b669 100644
--- a/src/lib.rs
+++ b/src/lib.rs
@@ -10,8 +10,7 @@ pub use web_time::{Duration, Instant};
 
 pub use commands::{StartKeyRotationExt, StopKeyRotationExt};
 pub use data_types::{
-    AuthProvider, KeyRotationEvent, KeyRotationSettings, Keygen, Keystore,
-    KeystoreState,
+    AuthProvider, KeyRotationEvent, KeyRotationSettings, Keygen, Keystore, KeystoreState,
 };
 pub use error::TokenRotationError;
 pub use plugin::KeyRotationPlugin;
diff --git a/src/systems.rs b/src/systems.rs
index c233207..19eff73 100644
--- a/src/systems.rs
+++ b/src/systems.rs
@@ -4,17 +4,13 @@ use crate::{
     Duration, KeystoreState,
 };
 use bevy::prelude::*;
-use bevy_async_task::{
-    AsyncTask, AsyncTaskRunner, AsyncTaskStatus, TimeoutError,
-};
+use bevy_async_task::{AsyncTask, AsyncTaskRunner, AsyncTaskStatus, TimeoutError};
 
 pub(crate) fn rotate_tokens(
     keygen: Res<Keygen>,
     settings: Res<KeyRotationSettings>,
     mut keystore: ResMut<Keystore>,
-    mut tr_rotate: AsyncTaskRunner<
-        Result<Result<Keystore, TokenRotationError>, TimeoutError>,
-    >,
+    mut tr_rotate: AsyncTaskRunner<Result<Result<Keystore, TokenRotationError>, TimeoutError>>,
     mut event_writer: EventWriter<KeyRotationEvent>,
     mut rotation_timer: Local<Option<Timer>>,
     time: Res<Time>,
@@ -51,10 +47,8 @@ pub(crate) fn rotate_tokens(
     rotation_timer.reset();
 
     // Check if rotation is necessary
-    let rtoken_expiring =
-        keystore.refresh_token_valid_for() < settings.rotate_before;
-    let atoken_expiring =
-        keystore.access_token_valid_for() < settings.rotate_before;
+    let rtoken_expiring = keystore.refresh_token_valid_for() < settings.rotate_before;
+    let atoken_expiring = keystore.access_token_valid_for() < settings.rotate_before;
 
     if rtoken_expiring {
         info!("rotating refresh token...");