refactor: make backend storage interface async

This change refactors the backend storage interface to be asynchronous,
making it easier to support a wider range of storage backends in the future.

Author: wa5i

src/cli/command/auth.rs

@@ -93,9 +93,9 @@ mod test {
 
     use crate::test_utils::TestHttpServer;
 
-    #[test]
-    fn test_cli_auth_help() {
-        let mut test_http_server = TestHttpServer::new("test_cli_auth_help", true);
+    #[maybe_async::test(feature = "sync_handler", async(all(not(feature = "sync_handler")), tokio::test))]
+    async fn test_cli_auth_help() {
+        let mut test_http_server = TestHttpServer::new("test_cli_auth_help", true).await;
         test_http_server.token = test_http_server.root_token.clone();
 
         // auth help token/
@@ -122,9 +122,9 @@ mod test {
         assert!(ret.unwrap().contains("Usage: rvault login -method=cert"));
     }
 
-    #[test]
-    fn test_cli_auth_list() {
-        let mut test_http_server = TestHttpServer::new("test_cli_auth_list", true);
+    #[maybe_async::test(feature = "sync_handler", async(all(not(feature = "sync_handler")), tokio::test))]
+    async fn test_cli_auth_list() {
+        let mut test_http_server = TestHttpServer::new("test_cli_auth_list", true).await;
         test_http_server.token = test_http_server.root_token.clone();
 
         // test auth list
@@ -137,9 +137,9 @@ mod test {
         assert_eq!(list["token/"]["type"], Value::String("token".into()));
     }
 
-    #[test]
-    fn test_cli_auth_enable_disable() {
-        let mut test_http_server = TestHttpServer::new("test_cli_auth_enable_disable", true);
+    #[maybe_async::test(feature = "sync_handler", async(all(not(feature = "sync_handler")), tokio::test))]
+    async fn test_cli_auth_enable_disable() {
+        let mut test_http_server = TestHttpServer::new("test_cli_auth_enable_disable", true).await;
         test_http_server.token = test_http_server.root_token.clone();
 
         // test auth enable
@@ -196,9 +196,9 @@ mod test {
         assert!(ret.is_err());
     }
 
-    #[test]
-    fn test_cli_auth_move() {
-        let mut test_http_server = TestHttpServer::new("test_cli_auth_move", true);
+    #[maybe_async::test(feature = "sync_handler", async(all(not(feature = "sync_handler")), tokio::test))]
+    async fn test_cli_auth_move() {
+        let mut test_http_server = TestHttpServer::new("test_cli_auth_move", true).await;
         test_http_server.token = test_http_server.root_token.clone();
 
         // test auth enable

src/cli/command/login.rs

@@ -165,9 +165,9 @@ mod test {
 
     use crate::test_utils::TestHttpServer;
 
-    #[test]
-    fn test_cli_login() {
-        let mut test_http_server = TestHttpServer::new("test_cli_login", true);
+    #[maybe_async::test(feature = "sync_handler", async(all(not(feature = "sync_handler")), tokio::test))]
+    async fn test_cli_login() {
+        let mut test_http_server = TestHttpServer::new("test_cli_login", true).await;
 
         // set token
         test_http_server.token = test_http_server.root_token.clone();

src/cli/command/mod.rs

@@ -238,9 +238,9 @@ pub trait CommandExecutor {
 mod test {
     use crate::{errors::RvError, rv_error_string, test_utils::TestHttpServer};
 
-    #[test]
-    fn test_cli_logical() {
-        let mut test_http_server = TestHttpServer::new("test_cli_read", true);
+    #[maybe_async::test(feature = "sync_handler", async(all(not(feature = "sync_handler")), tokio::test))]
+    async fn test_cli_logical() {
+        let mut test_http_server = TestHttpServer::new("test_cli_read", true).await;
         test_http_server.token = test_http_server.root_token.clone();
 
         // There is no data by default, and reading should fail.

src/cli/command/operator_seal.rs

@@ -67,9 +67,9 @@ mod test {
 
     use crate::test_utils::TestHttpServer;
 
-    #[test]
-    fn test_cli_operator_seal() {
-        let test_http_server = TestHttpServer::new("test_cli_operator_seal", true);
+    #[maybe_async::test(feature = "sync_handler", async(all(not(feature = "sync_handler")), tokio::test))]
+    async fn test_cli_operator_seal() {
+        let test_http_server = TestHttpServer::new("test_cli_operator_seal", true).await;
 
         // rvault status
         let ret = test_http_server.cli(&["status"], &["--format=raw"]);

src/cli/command/policy.rs

@@ -65,9 +65,9 @@ impl Policy {
 mod test {
     use crate::{errors::RvError, rv_error_string, test_utils::TestHttpServer};
 
-    #[test]
-    fn test_cli_policy() {
-        let mut test_http_server = TestHttpServer::new("test_cli_policy", true);
+    #[maybe_async::test(feature = "sync_handler", async(all(not(feature = "sync_handler")), tokio::test))]
+    async fn test_cli_policy() {
+        let mut test_http_server = TestHttpServer::new("test_cli_policy", true).await;
         test_http_server.token = test_http_server.root_token.clone();
 
         // There is no data by default, and reading should fail.

src/cli/command/policy_delete.rs

@@ -61,9 +61,9 @@ impl CommandExecutor for Delete {
 mod test {
     use crate::test_utils::TestHttpServer;
 
-    #[test]
-    fn test_cli_policy_delete() {
-        let mut test_http_server = TestHttpServer::new("test_cli_policy_delete", true);
+    #[maybe_async::test(feature = "sync_handler", async(all(not(feature = "sync_handler")), tokio::test))]
+    async fn test_cli_policy_delete() {
+        let mut test_http_server = TestHttpServer::new("test_cli_policy_delete", true).await;
         test_http_server.token = test_http_server.root_token.clone();
 
         // delete default should be failed

src/cli/command/policy_list.rs

@@ -53,9 +53,9 @@ impl CommandExecutor for List {
 mod test {
     use crate::test_utils::TestHttpServer;
 
-    #[test]
-    fn test_cli_policy_list() {
-        let mut test_http_server = TestHttpServer::new("test_cli_policy_list", true);
+    #[maybe_async::test(feature = "sync_handler", async(all(not(feature = "sync_handler")), tokio::test))]
+    async fn test_cli_policy_list() {
+        let mut test_http_server = TestHttpServer::new("test_cli_policy_list", true).await;
         test_http_server.token = test_http_server.root_token.clone();
 
         // list policy

src/cli/command/policy_read.rs

@@ -72,9 +72,9 @@ mod test {
         errors::RvError, modules::policy::policy_store::DEFAULT_POLICY, rv_error_string, test_utils::TestHttpServer,
     };
 
-    #[test]
-    fn test_cli_policy_read() {
-        let mut test_http_server = TestHttpServer::new("test_cli_policy_read", true);
+    #[maybe_async::test(feature = "sync_handler", async(all(not(feature = "sync_handler")), tokio::test))]
+    async fn test_cli_policy_read() {
+        let mut test_http_server = TestHttpServer::new("test_cli_policy_read", true).await;
         test_http_server.token = test_http_server.root_token.clone();
 
         // read a not exist policy should be failed

src/cli/command/policy_write.rs

@@ -82,9 +82,9 @@ mod test {
 
     use crate::test_utils::TestHttpServer;
 
-    #[test]
-    fn test_cli_policy_write() {
-        let mut test_http_server = TestHttpServer::new("test_cli_policy_write", true);
+    #[maybe_async::test(feature = "sync_handler", async(all(not(feature = "sync_handler")), tokio::test))]
+    async fn test_cli_policy_write() {
+        let mut test_http_server = TestHttpServer::new("test_cli_policy_write", true).await;
         test_http_server.token = test_http_server.root_token.clone();
 
         let test_policy = r#"path "secret/" {

src/cli/command/secrets.rs

@@ -63,9 +63,9 @@ mod test {
 
     use crate::test_utils::TestHttpServer;
 
-    #[test]
-    fn test_cli_secrets_list() {
-        let mut test_http_server = TestHttpServer::new("test_cli_secrets_list", true);
+    #[maybe_async::test(feature = "sync_handler", async(all(not(feature = "sync_handler")), tokio::test))]
+    async fn test_cli_secrets_list() {
+        let mut test_http_server = TestHttpServer::new("test_cli_secrets_list", true).await;
         test_http_server.token = test_http_server.root_token.clone();
 
         let ret = test_http_server.cli(&["secrets", "list"], &["--format=json"]);
@@ -78,9 +78,9 @@ mod test {
         assert_eq!(list["sys/"]["type"], Value::String("system".into()));
     }
 
-    #[test]
-    fn test_cli_secret_enable_disable() {
-        let mut test_http_server = TestHttpServer::new("test_cli_secret_enable_disable", true);
+    #[maybe_async::test(feature = "sync_handler", async(all(not(feature = "sync_handler")), tokio::test))]
+    async fn test_cli_secret_enable_disable() {
+        let mut test_http_server = TestHttpServer::new("test_cli_secret_enable_disable", true).await;
         test_http_server.token = test_http_server.root_token.clone();
 
         // test secrets enable
@@ -124,9 +124,9 @@ mod test {
         assert!(list.get("kv1").is_none());
     }
 
-    #[test]
-    fn test_cli_secret_move() {
-        let mut test_http_server = TestHttpServer::new("test_cli_secret_move", true);
+    #[maybe_async::test(feature = "sync_handler", async(all(not(feature = "sync_handler")), tokio::test))]
+    async fn test_cli_secret_move() {
+        let mut test_http_server = TestHttpServer::new("test_cli_secret_move", true).await;
         test_http_server.token = test_http_server.root_token.clone();
 
         // test secrets enable