fix: linter

Author: jot2re

core/service/src/backup/custodian.rs

@@ -221,7 +221,7 @@ impl<S: BackupSigner, D: BackupDecryptor> Custodian<S, D> {
             signature: sigt_i_j,
             ciphertext: st_i_j,
             custodian_role: self.role,
-            operator_role: operator_role,
+            operator_role,
         })
     }
 

core/service/src/bin/kms-custodian.rs

@@ -226,7 +226,7 @@ fn get_rng(randomness: Option<&String>) -> AesRng {
 mod tests {
     use crate::{get_rng, SEED_PHRASE_DESC};
     use assert_cmd::Command;
-    use kms_grpc::RequestId;
+    use kms_grpc::{rpc_types::InternalCustodianRecoveryOutput, RequestId};
     use kms_lib::{
         backup::{
             custodian::InternalCustodianSetupMessage,

core/service/src/client/mod.rs

@@ -6106,9 +6106,7 @@ pub(crate) mod tests {
             resp_tasks.spawn(async move {
                 let req = Empty {};
                 // send query
-                cur_client
-                    .custodian_backup_restore(tonic::Request::new(req))
-                    .await
+                cur_client.backup_restore(tonic::Request::new(req)).await
             });
         }
         while let Some(res) = resp_tasks.join_next().await {
@@ -6259,7 +6257,7 @@ pub(crate) mod tests {
                 let req = Empty {};
                 // send query
                 cur_client
-                    .custodian_backup_restore(tonic::Request::new(req))
+                    .backup_restore(tonic::Request::new(req))
                     .await
             });
         }

core/service/src/engine/threshold/endpoint.rs

@@ -590,10 +590,7 @@ impl_endpoint! {
             &self,
             request: Request<kms_grpc::kms::v1::BackupRecoveryRequest>,
         ) -> Result<Response<kms_grpc::kms::v1::Empty>, Status> {
-            self.backup_operator.custodian_backup_recovery(request.try_into().map_err(|e| {
-                tracing::error!("Failed to convert request: {}", e);
-                Status::invalid_argument("Invalid request")
-            })?).await
+            self.backup_operator.custodian_backup_recovery(request).await
         }
 
         #[tracing::instrument(skip(self, request))]