fix ipv6 parsing for zdb (#31)

also print the full error stack

Author: muhamadazmy

src/fungi/meta.rs

@@ -41,7 +41,7 @@ static SCHEMA: &str = include_str!("../../schema/schema.sql");
 
 #[derive(thiserror::Error, Debug)]
 pub enum Error {
-    #[error("failed to execute query: {0}")]
+    #[error("failed to execute query: {0:#}")]
     SqlError(#[from] sqlx::Error),
 
     #[error("invalid hash length")]
@@ -50,10 +50,10 @@ pub enum Error {
     #[error("invalid key length")]
     InvalidKey,
 
-    #[error("io error: {0}")]
+    #[error("io error: {0:#}")]
     IO(#[from] std::io::Error),
 
-    #[error("{0}")]
+    #[error("{0:#}")]
     Anyhow(#[from] anyhow::Error),
 }
 

src/pack.rs

@@ -217,7 +217,7 @@ where
 
     async fn run(&mut self, (ino, path): Self::Input) -> Self::Output {
         if let Err(err) = self.upload(ino, &path).await {
-            log::error!("failed to upload file ({:?}): {}", path, err);
+            log::error!("failed to upload file ({:?}): {:#}", path, err);
         }
     }
 }

src/store/mod.rs

@@ -46,7 +46,7 @@ pub enum Error {
     #[error("store is not available")]
     Unavailable,
 
-    #[error("compression error: {0}")]
+    #[error("compression error: {0:#}")]
     Compression(#[from] snap::Error),
 
     #[error("encryption error")]
@@ -56,7 +56,7 @@ pub enum Error {
     #[error("multiple error: {0:?}")]
     Multiple(Box<Vec<Self>>),
 
-    #[error("io error: {0}")]
+    #[error("io error: {0:#}")]
     IO(#[from] std::io::Error),
 
     #[error("url parse error: {0}")]
@@ -65,7 +65,7 @@ pub enum Error {
     UnknownStore(String),
     #[error("invalid schema '{0}' expected '{1}'")]
     InvalidScheme(String, String),
-    #[error("other: {0}")]
+    #[error("{0:#}")]
     Other(#[from] anyhow::Error),
 }
 

src/store/zdb.rs

@@ -45,7 +45,13 @@ fn get_connection_info<U: AsRef<str>>(u: U) -> Result<(ConnectionInfo, Option<St
 
     let (address, namespace) = match u.host() {
         Some(host) => {
-            let addr = ConnectionAddr::Tcp(host.to_string(), u.port().unwrap_or(9900));
+            let addr = match host {
+                url::Host::Domain(domain) => domain.to_owned(),
+                url::Host::Ipv4(ipv4) => ipv4.to_string(),
+                url::Host::Ipv6(ipv6) => ipv6.to_string(),
+            };
+
+            let addr = ConnectionAddr::Tcp(addr, u.port().unwrap_or(9900));
             let ns: Option<String> = u
                 .path_segments()
                 .and_then(|s| s.last().map(|s| s.to_owned()));
@@ -79,7 +85,9 @@ async fn make_inner(url: String) -> Result<Box<dyn Store>> {
         password: info.redis.password.take(),
     };
 
+    log::debug!("connection {:#?}", info);
     log::debug!("switching namespace to: {:?}", namespace.namespace);
+
     let mgr =
         RedisConnectionManager::new(info).context("failed to create redis connection manager")?;