summaryrefslogtreecommitdiffstats
path: root/crates/core/tedge/src/cli/connect/c8y_direct_connection.rs
diff options
context:
space:
mode:
Diffstat (limited to 'crates/core/tedge/src/cli/connect/c8y_direct_connection.rs')
-rw-r--r--crates/core/tedge/src/cli/connect/c8y_direct_connection.rs37
1 files changed, 14 insertions, 23 deletions
diff --git a/crates/core/tedge/src/cli/connect/c8y_direct_connection.rs b/crates/core/tedge/src/cli/connect/c8y_direct_connection.rs
index 049429b2..d080eda2 100644
--- a/crates/core/tedge/src/cli/connect/c8y_direct_connection.rs
+++ b/crates/core/tedge/src/cli/connect/c8y_direct_connection.rs
@@ -24,7 +24,7 @@ pub fn create_device_with_direct_connection(
const DEVICE_CREATE_ERROR_TOPIC: &str = "s/e";
let address = bridge_config.address.clone();
- let host: Vec<&str> = address.split(":").collect();
+ let host: Vec<&str> = address.split(':').collect();
let mut mqtt_options = MqttOptions::new(bridge_config.remote_clientid.clone(), host[0], 8883);
mqtt_options.set_keep_alive(std::time::Duration::from_secs(5));
@@ -53,7 +53,7 @@ pub fn create_device_with_direct_connection(
publish_device_create_message(
&mut client,
&bridge_config.remote_clientid.clone(),
- &device_type,
+ device_type,
)?;
}
Ok(Event::Incoming(Packet::Publish(response))) => {
@@ -69,7 +69,7 @@ pub fn create_device_with_direct_connection(
publish_device_create_message(
&mut client,
&bridge_config.remote_clientid.clone(),
- &device_type,
+ device_type,
)?;
device_create_try += 1;
} else {
@@ -117,10 +117,12 @@ fn load_root_certs(
let file = file_entry?;
let f = File::open(file.path())?;
let mut rd = BufReader::new(f);
- let _ = root_store
- .add_pem_file(&mut rd)
- .map(|_| ())
- .map_err(|()| Error::new(ErrorKind::InvalidData, format!("could not load PEM file")));
+ let _ = root_store.add_pem_file(&mut rd).map(|_| ()).map_err(|()| {
+ Error::new(
+ ErrorKind::InvalidData,
+ "could not load PEM file".to_string(),
+ )
+ });
}
Ok(())
}
@@ -140,10 +142,8 @@ fn parse_pkcs8_key(
let f = File::open(&key_file)?;
let mut key_reader = BufReader::new(f);
match pkcs8_private_keys(&mut key_reader) {
- Ok(key) if key.len() > 0 => return Ok(key[0].clone()),
- _ => {
- return Err(ConnectError::UnknownPrivateKeyFormat);
- }
+ Ok(key) if !key.is_empty() => Ok(key[0].clone()),
+ _ => Err(ConnectError::UnknownPrivateKeyFormat),
}
}
@@ -153,10 +153,8 @@ fn parse_rsa_key(
let f = File::open(&key_file)?;
let mut key_reader = BufReader::new(f);
match rsa_private_keys(&mut key_reader) {
- Ok(key) if key.len() > 0 => return Ok(key[0].clone()),
- _ => {
- return Err(ConnectError::UnknownPrivateKeyFormat);
- }
+ Ok(key) if !key.is_empty() => Ok(key[0].clone()),
+ _ => Err(ConnectError::UnknownPrivateKeyFormat),
}
}
@@ -165,14 +163,7 @@ fn read_cert_chain(
) -> Result<Vec<rustls_0_19::Certificate>, ConnectError> {
let f = File::open(cert_file)?;
let mut cert_reader = BufReader::new(f);
- let result = certs(&mut cert_reader);
- let cert_chain: Vec<rustls_0_19::Certificate> = match result {
- Ok(cert) => cert,
- Err(_) => {
- return Err(ConnectError::RumqttcCertificate);
- }
- };
- Ok(cert_chain)
+ certs(&mut cert_reader).map_err(|_| ConnectError::RumqttcCertificate)
}
#[cfg(test)]