housekeeping(server): clippy warns fix
Some checks failed
Some checks failed
This commit is contained in:
@@ -15,37 +15,35 @@ mod outbound;
|
||||
#[async_trait]
|
||||
impl Receiver<vault_gate::Inbound> for AuthTransportAdapter<'_> {
|
||||
async fn recv(&mut self) -> Option<vault_gate::Inbound> {
|
||||
loop {
|
||||
let request = match self.bi_mut().recv().await? {
|
||||
Ok(request) => request,
|
||||
Err(error) => {
|
||||
warn!(
|
||||
?error,
|
||||
"Failed to receive user agent request during vault gate"
|
||||
);
|
||||
return None;
|
||||
}
|
||||
};
|
||||
|
||||
if let Err(err) = self.tracker_mut().request(request.id) {
|
||||
let _ = self.bi_mut().send(Err(err)).await;
|
||||
let request = match self.bi_mut().recv().await? {
|
||||
Ok(request) => request,
|
||||
Err(error) => {
|
||||
warn!(
|
||||
?error,
|
||||
"Failed to receive user agent request during vault gate"
|
||||
);
|
||||
return None;
|
||||
}
|
||||
};
|
||||
|
||||
let Some(payload) = request.payload else {
|
||||
let _ = self
|
||||
.bi_mut()
|
||||
.send(Err(Status::invalid_argument("Missing request payload")))
|
||||
.await;
|
||||
return None;
|
||||
};
|
||||
if let Err(err) = self.tracker_mut().request(request.id) {
|
||||
let _ = self.bi_mut().send(Err(err)).await;
|
||||
return None;
|
||||
}
|
||||
|
||||
match payload.try_convert() {
|
||||
Ok(inbound) => return Some(inbound),
|
||||
Err(status) => {
|
||||
let _ = self.bi_mut().send(Err(status)).await;
|
||||
return None;
|
||||
}
|
||||
let Some(payload) = request.payload else {
|
||||
let _ = self
|
||||
.bi_mut()
|
||||
.send(Err(Status::invalid_argument("Missing request payload")))
|
||||
.await;
|
||||
return None;
|
||||
};
|
||||
|
||||
match payload.try_convert() {
|
||||
Ok(inbound) => Some(inbound),
|
||||
Err(status) => {
|
||||
let _ = self.bi_mut().send(Err(status)).await;
|
||||
None
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -81,7 +81,7 @@ async fn verify_integrity(
|
||||
.get()
|
||||
.await
|
||||
.map_err(|_| Error::Internal("DB unavailable".into()))?;
|
||||
match integrity::verify_entity(&mut conn, &vault, credentials, credentials.id).await {
|
||||
match integrity::verify_entity(&mut conn, vault, credentials, credentials.id).await {
|
||||
Ok(AttestationStatus::Attested) => Ok(()),
|
||||
Ok(AttestationStatus::Unavailable) => {
|
||||
Err(Error::Internal("Vault sealed during promotion".into()))
|
||||
|
||||
@@ -132,7 +132,7 @@ impl VaultGate {
|
||||
let secret = ephemeral_secret.diffie_hellman(&client_pubkey);
|
||||
|
||||
self.state = State::ReadyForExchange {
|
||||
server_key: public_key.clone(),
|
||||
server_key: public_key,
|
||||
secret,
|
||||
};
|
||||
|
||||
@@ -179,7 +179,7 @@ impl VaultGate {
|
||||
}
|
||||
Err(err) => {
|
||||
error!(?err, "Failed to send unseal request to vault");
|
||||
Err(Error::internal("Vault actor error").into())
|
||||
Err(Error::internal("Vault actor error"))
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user