fix: add url encode for username and password

tair-opensource · Aug 22, 2024 · 79982cf · 79982cf
1 parent 81483b4
commit 79982cf
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 2 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -26,3 +26,4 @@ awaitgroup = "0.7.0"
 colored = "2.1.0"
 enum_delegate = "0.2.0"
 ctrlc = "3.4.4"
+urlencoding = "2.1.3"
diff --git a/src/client.rs b/src/client.rs
@@ -4,6 +4,7 @@ use redis::aio::MultiplexedConnection;
 use redis::cluster_async::ClusterConnection;
 use redis::{Cmd, RedisFuture, Value};
 use std::fmt::{Display, Formatter};
+use urlencoding::encode;
 
 #[derive(Clone)]
 pub struct ClientConfig {
@@ -17,10 +18,12 @@ pub struct ClientConfig {
 
 impl ClientConfig {
     pub async fn get_client(&self) -> Client {
+        let username = encode(&self.username);
+        let password = encode(&self.password);
         let conn_str = if self.tls {
-            format!("rediss://{}:{}@{}/#insecure", &self.username, &self.password, &self.address)
+            format!("rediss://{}:{}@{}/#insecure", username, password, &self.address)
         } else {
-            format!("redis://{}:{}@{}", &self.username, &self.password, &self.address)
+            format!("redis://{}:{}@{}", username, password, &self.address)
         };
 
         if self.cluster {