aboutsummaryrefslogtreecommitdiff
path: root/azalea-client/src/plugins/chat_signing.rs
diff options
context:
space:
mode:
authormat <git@matdoes.dev>2025-05-30 19:36:59 -0800
committermat <git@matdoes.dev>2025-05-30 19:36:59 -0800
commitae4b1e85e669bc882d158509ef1eda46c6b2a72e (patch)
treeadf81cc01b0ce1575e95b99ad109fd92db1738f6 /azalea-client/src/plugins/chat_signing.rs
parenta64c6505049082175224802c5be51ac8f0cf4677 (diff)
downloadazalea-drasl-ae4b1e85e669bc882d158509ef1eda46c6b2a72e.tar.xz
fix clippy issues and improve formatting everywhere
Diffstat (limited to 'azalea-client/src/plugins/chat_signing.rs')
-rw-r--r--azalea-client/src/plugins/chat_signing.rs34
1 files changed, 16 insertions, 18 deletions
diff --git a/azalea-client/src/plugins/chat_signing.rs b/azalea-client/src/plugins/chat_signing.rs
index 9863cb3f..8961430e 100644
--- a/azalea-client/src/plugins/chat_signing.rs
+++ b/azalea-client/src/plugins/chat_signing.rs
@@ -102,10 +102,10 @@ pub fn request_certs_if_needed(
>,
) {
for (entity, account, only_refresh_certs_after, chat_signing_session) in query.iter_mut() {
- if let Some(only_refresh_certs_after) = only_refresh_certs_after {
- if only_refresh_certs_after.refresh_at > Instant::now() {
- continue;
- }
+ if let Some(only_refresh_certs_after) = only_refresh_certs_after
+ && only_refresh_certs_after.refresh_at > Instant::now()
+ {
+ continue;
}
let certs = account.certs.lock();
@@ -124,20 +124,18 @@ pub fn request_certs_if_needed(
};
drop(certs);
- if should_refresh {
- if let Some(access_token) = &account.access_token {
- let task_pool = IoTaskPool::get();
-
- let access_token = access_token.lock().clone();
- debug!("Started task to fetch certs");
- let task = task_pool.spawn(async_compat::Compat::new(async move {
- azalea_auth::certs::fetch_certificates(&access_token).await
- }));
- commands
- .entity(entity)
- .insert(RequestCertsTask(task))
- .remove::<OnlyRefreshCertsAfter>();
- }
+ if should_refresh && let Some(access_token) = &account.access_token {
+ let task_pool = IoTaskPool::get();
+
+ let access_token = access_token.lock().clone();
+ debug!("Started task to fetch certs");
+ let task = task_pool.spawn(async_compat::Compat::new(async move {
+ azalea_auth::certs::fetch_certificates(&access_token).await
+ }));
+ commands
+ .entity(entity)
+ .insert(RequestCertsTask(task))
+ .remove::<OnlyRefreshCertsAfter>();
}
}
}