Fix macro lints

Author: ohsayan

src/aio.rs

@@ -115,34 +115,34 @@ cfg_async!(
         }
     }
     impl_async_methods!(Connection);
+);
 
-    cfg_async_ssl_any!(
-        use tokio_openssl::SslStream;
-        use openssl::ssl::{SslContext, SslMethod, Ssl};
-        use core::pin::Pin;
-        use crate::error::SslError;
+cfg_async_ssl_any!(
+    use tokio_openssl::SslStream;
+    use openssl::ssl::{SslContext, SslMethod, Ssl};
+    use core::pin::Pin;
+    use crate::error::SslError;
 
-        /// An asynchronous database connection over Skyhash/TLS
-        pub struct TlsConnection {
-            stream: SslStream<TcpStream>,
-            buffer: BytesMut
-        }
+    /// An asynchronous database connection over Skyhash/TLS
+    pub struct TlsConnection {
+        stream: SslStream<TcpStream>,
+        buffer: BytesMut
+    }
 
-        impl TlsConnection {
-            /// Pass the `host` and `port` and the path to the CA certificate to use for TLS
-            pub async fn new(host: &str, port: u16, sslcert: &str) -> Result<Self, SslError> {
-                let mut ctx = SslContext::builder(SslMethod::tls_client())?;
-                ctx.set_ca_file(sslcert)?;
-                let ssl = Ssl::new(&ctx.build())?;
-                let stream = TcpStream::connect((host, port)).await?;
-                let mut stream = SslStream::new(ssl, stream)?;
-                Pin::new(&mut stream).connect().await?;
-                Ok(Self {
-                    stream,
-                    buffer: BytesMut::with_capacity(BUF_CAP),
-                })
-            }
+    impl TlsConnection {
+        /// Pass the `host` and `port` and the path to the CA certificate to use for TLS
+        pub async fn new(host: &str, port: u16, sslcert: &str) -> Result<Self, SslError> {
+            let mut ctx = SslContext::builder(SslMethod::tls_client())?;
+            ctx.set_ca_file(sslcert)?;
+            let ssl = Ssl::new(&ctx.build())?;
+            let stream = TcpStream::connect((host, port)).await?;
+            let mut stream = SslStream::new(ssl, stream)?;
+            Pin::new(&mut stream).connect().await?;
+            Ok(Self {
+                stream,
+                buffer: BytesMut::with_capacity(BUF_CAP),
+            })
         }
-        impl_async_methods!(TlsConnection);
-    );
+    }
+    impl_async_methods!(TlsConnection);
 );

src/sync.rs

@@ -121,32 +121,33 @@ cfg_sync!(
 
     impl_sync_methods!(Connection);
 
-    cfg_sync_ssl_any!(
-        use openssl::ssl::{Ssl, SslContext, SslMethod, SslStream};
-        use crate::error::SslError;
-        #[derive(Debug)]
-        /// A database connection over Skyhash/TLS
-        pub struct TlsConnection {
-            stream: SslStream<TcpStream>,
-            buffer: Vec<u8>,
-        }
+);
 
-        impl TlsConnection {
-            /// Pass the `host` and `port` and the path to the CA certificate to use for TLS
-            pub fn new(host: &str, port: u16, ssl_certificate: &str) -> Result<Self, SslError> {
-                let mut ctx = SslContext::builder(SslMethod::tls_client())?;
-                ctx.set_ca_file(ssl_certificate)?;
-                let ssl = Ssl::new(&ctx.build())?;
-                let stream = TcpStream::connect((host, port))?;
-                let mut stream = SslStream::new(ssl, stream).map_err(|e| SslError::SslError(e.into()))?;
-                stream.connect()?;
-                Ok(Self {
-                    stream,
-                    buffer: Vec::with_capacity(BUF_CAP),
-                })
-            }
+cfg_sync_ssl_any!(
+    use openssl::ssl::{Ssl, SslContext, SslMethod, SslStream};
+    use crate::error::SslError;
+    #[derive(Debug)]
+    /// A database connection over Skyhash/TLS
+    pub struct TlsConnection {
+        stream: SslStream<TcpStream>,
+        buffer: Vec<u8>,
+    }
+
+    impl TlsConnection {
+        /// Pass the `host` and `port` and the path to the CA certificate to use for TLS
+        pub fn new(host: &str, port: u16, ssl_certificate: &str) -> Result<Self, SslError> {
+            let mut ctx = SslContext::builder(SslMethod::tls_client())?;
+            ctx.set_ca_file(ssl_certificate)?;
+            let ssl = Ssl::new(&ctx.build())?;
+            let stream = TcpStream::connect((host, port))?;
+            let mut stream = SslStream::new(ssl, stream).map_err(|e| SslError::SslError(e.into()))?;
+            stream.connect()?;
+            Ok(Self {
+                stream,
+                buffer: Vec::with_capacity(BUF_CAP),
+            })
         }
+    }
 
-        impl_sync_methods!(TlsConnection);
-    );
+    impl_sync_methods!(TlsConnection);
 );

src/util.rs

@@ -15,6 +15,8 @@
  *
 */
 
+#![allow(unused_macros)] // This is done just to avoid unnecessary complications
+
 macro_rules! cfg_sync_ssl_any {
     ($($body:item)*) => {
         $(
@@ -35,7 +37,6 @@ macro_rules! cfg_ssl_any {
     };
 }
 
-
 macro_rules! cfg_async_ssl_any {
     ($($body:item)*) => {
         $(