From b669efb5ff372ddcfbef045f24d4c1fc1302869b Mon Sep 17 00:00:00 2001 From: Bacon2994 <108093786+Bacon2994@users.noreply.github.com> Date: Fri, 8 May 2026 10:11:44 +0800 Subject: [PATCH] =?UTF-8?q?style(redis):=20=E4=BF=AE=E6=AD=A3=20Rust=20?= =?UTF-8?q?=E6=A0=BC=E5=BC=8F=E6=A3=80=E6=9F=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- crates/dbx-core/src/db/redis_driver.rs | 11 +++++------ src-web/src/routes/redis.rs | 12 +++--------- 2 files changed, 8 insertions(+), 15 deletions(-) diff --git a/crates/dbx-core/src/db/redis_driver.rs b/crates/dbx-core/src/db/redis_driver.rs index aad94e96e..d2b30912c 100644 --- a/crates/dbx-core/src/db/redis_driver.rs +++ b/crates/dbx-core/src/db/redis_driver.rs @@ -139,7 +139,8 @@ pub async fn get_value(con: &mut redis::aio::MultiplexedConnection, key: &[u8]) (redis_raw_to_json(v), value_is_binary) } "list" => { - let v: RedisRawValue = redis::cmd("LRANGE").arg(key).arg(0).arg(-1).query_async(con).await.map_err(|e| e.to_string())?; + let v: RedisRawValue = + redis::cmd("LRANGE").arg(key).arg(0).arg(-1).query_async(con).await.map_err(|e| e.to_string())?; (redis_array_to_json(v), false) } "set" => { @@ -368,9 +369,7 @@ pub fn redis_key_bytes_to_raw(bytes: &[u8]) -> String { } pub fn redis_key_raw_to_bytes(value: &str) -> Result, String> { - base64::engine::general_purpose::STANDARD - .decode(value) - .map_err(|e| format!("Invalid Redis key encoding: {e}")) + base64::engine::general_purpose::STANDARD.decode(value).map_err(|e| format!("Invalid Redis key encoding: {e}")) } pub async fn set_string( @@ -426,8 +425,8 @@ pub async fn set_remove(con: &mut redis::aio::MultiplexedConnection, key: &[u8], #[cfg(test)] mod tests { use super::{ - parse_database_count, parse_scan_keys, parse_stream_entries, redis_key_bytes_to_display, redis_key_bytes_to_raw, - redis_key_raw_to_bytes, redis_raw_to_json, RedisRawValue, + parse_database_count, parse_scan_keys, parse_stream_entries, redis_key_bytes_to_display, + redis_key_bytes_to_raw, redis_key_raw_to_bytes, redis_raw_to_json, RedisRawValue, }; fn bulk(value: &str) -> RedisRawValue { diff --git a/src-web/src/routes/redis.rs b/src-web/src/routes/redis.rs index d731b0181..42d520a2c 100644 --- a/src-web/src/routes/redis.rs +++ b/src-web/src/routes/redis.rs @@ -146,8 +146,8 @@ pub async fn hash_set( &req.field, value, ) - .await - .map_err(AppError)?; + .await + .map_err(AppError)?; Ok(Json(())) } @@ -197,13 +197,7 @@ pub async fn set_remove( State(state): State>, Json(req): Json, ) -> Result, AppError> { - dbx_core::redis_ops::redis_set_remove_in_db_core( - &state.app, - &req.connection_id, - req.db, - &req.key_raw, - &req.member, - ) + dbx_core::redis_ops::redis_set_remove_in_db_core(&state.app, &req.connection_id, req.db, &req.key_raw, &req.member) .await .map_err(AppError)?; Ok(Json(()))