fix(clippy): update to use latest version of rust

- also points back to quinn v7 on crates.io

Cargo.toml

@@ -36,8 +36,7 @@ tracing = "~0.1.26"
   optional = true
 
   [dependencies.quinn]
-  #version = "~0.7.0"
-  git = "https://github.com/djc/quinn"
+  version = "~0.7.0"
   features = [ "tls-rustls" ]
   default-features = false
 

src/connection_pool.rs

@@ -63,7 +63,7 @@ impl ConnectionPool {
 
         keys_to_remove
             .iter()
-            .filter_map(|key| store.map.remove(&key))
+            .filter_map(|key| store.map.remove(key))
             .collect::<Vec<_>>()
     }
 

src/endpoint.rs

@@ -140,7 +140,7 @@ impl Endpoint {
                 info!("Verifying provided public IP address");
                 endpoint.connect_to(contact).await?;
                 let connection = endpoint
-                    .get_connection(&contact)
+                    .get_connection(contact)
                     .await
                     .ok_or(Error::MissingConnection)?;
                 let (mut send, mut recv) = connection.open_bi().await?;

src/lib.rs

@@ -34,7 +34,6 @@
     unused_parens,
     while_true,
     clippy::unicode_not_nfc,
-    clippy::wrong_pub_self_convention,
     warnings
 )]
 #![warn(

src/tests/common.rs

@@ -425,7 +425,7 @@ async fn multiple_connections_with_many_concurrent_messages() -> Result<()> {
                 let mut hash_results = BTreeSet::new();
                 send_endpoint.connect_to(&server_addr).await?;
                 for (index, message) in messages.iter().enumerate().take(num_messages_each) {
-                    let _ = hash_results.insert(hash(&message));
+                    let _ = hash_results.insert(hash(message));
                     info!("sender #{} sending message #{}", id, index);
                     send_endpoint
                         .send_message(message.clone(), &server_addr)
@@ -534,7 +534,7 @@ async fn multiple_connections_with_many_larger_concurrent_messages() -> Result<(
 
                 send_endpoint.connect_to(&server_addr).await?;
                 for (index, message) in messages.iter().enumerate().take(num_messages_each) {
-                    let _ = hash_results.insert(hash(&message));
+                    let _ = hash_results.insert(hash(message));
 
                     info!("sender #{} sending message #{}", id, index);
                     send_endpoint

src/tests/quinn.rs

@@ -144,7 +144,7 @@ impl Peer {
     async fn send_message(&mut self, addr: &SocketAddr, msg: Bytes) -> Result<()> {
         let new_conn = self
             .endpoint
-            .connect_with(self.client_cfg.clone(), &addr, DOMAIN)?
+            .connect_with(self.client_cfg.clone(), addr, DOMAIN)?
             .await?;
         let mut stream = new_conn.connection.open_uni().await?;
         let _ = stream.write_all(&msg).await?;