chore: bump fusio to 0.3.8

Author: crwen

.github/workflows/ci_wasm.yml

@@ -9,7 +9,6 @@ env:
   CARGO_TERM_COLOR: always
   CARGO_REGISTRIES_MY_REGISTRY_INDEX: https://github.com/rust-lang/crates.io-index
 
-
 jobs:
   check:
     name: Rust project wasm check
@@ -40,7 +39,7 @@ jobs:
         uses: actions-rs/cargo@v1
         with:
           command: build
-          args: --target wasm32-unknown-unknown --no-default-features --features aws,bytes,opfs
+          args: --target wasm32-unknown-unknown --no-default-features --features bytes,wasm
 
       - name: Install Chrome Environment
         run: |
@@ -59,4 +58,4 @@ jobs:
       - name: Run wasm-pack test
         run: |
           export PATH=$PATH:/tmp/chrome/chrome-linux64/:/tmp/chrome/chromedriver-linux64/
-          wasm-pack test --chrome --headless --test wasm --no-default-features --features aws,bytes,opfs
+          wasm-pack test --chrome --headless --test wasm --no-default-features --features bytes,wasm

Cargo.toml

@@ -39,10 +39,11 @@ tokio = [
     "fusio/tokio",
     "parquet/default",
     "tokio/fs",
+    "tokio/rt-multi-thread"
 ]
-tokio-http = ["fusio/tokio-http"]
+tokio-http = ["fusio/tokio-http", "fusio-log/tokio-http"]
 wasm = ["aws", "bytes", "opfs", "wasm-http"]
-wasm-http = ["fusio/wasm-http"]
+wasm-http = ["fusio/wasm-http", "fusio-log/web-http"]
 
 [[example]]
 name = "declare"
@@ -83,12 +84,12 @@ crc32fast = "1"
 crossbeam-skiplist = "0.1"
 datafusion = { version = "45", optional = true }
 flume = { version = "0.11", features = ["async"] }
-fusio = { version = "0.3.7", package = "fusio", features = ["dyn", "fs"] }
-fusio-dispatch = { version = "0.3.7", package = "fusio-dispatch" }
-fusio-log = { version = "0.3.7", package = "fusio-log", default-features = false, features = [
+fusio = { version = "0.3.8", package = "fusio", features = ["dyn", "fs"] }
+fusio-dispatch = { version = "0.3.8", package = "fusio-dispatch" }
+fusio-log = { version = "0.3.8", package = "fusio-log", default-features = false, features = [
     "bytes",
 ] }
-fusio-parquet = { version = "0.3.7", package = "fusio-parquet" }
+fusio-parquet = { version = "0.3.8", package = "fusio-parquet" }
 futures-core = "0.3"
 futures-util = "0.3"
 lockable = "0.1.1"

src/compaction/mod.rs

@@ -630,7 +630,7 @@ pub(crate) mod tests {
         Ok(())
     }
 
-    #[tokio::test]
+    #[tokio::test(flavor = "multi_thread")]
     async fn minor_compaction() {
         let temp_dir = tempfile::tempdir().unwrap();
         let temp_dir_l0 = tempfile::tempdir().unwrap();
@@ -744,7 +744,7 @@ pub(crate) mod tests {
         assert_eq!(scope.max, 6.to_string());
     }
 
-    #[tokio::test]
+    #[tokio::test(flavor = "multi_thread")]
     async fn dyn_minor_compaction() {
         let temp_dir = tempfile::tempdir().unwrap();
         let manager = StoreManager::new(FsOptions::Local, vec![]).unwrap();
@@ -813,7 +813,7 @@ pub(crate) mod tests {
         );
     }
 
-    #[tokio::test]
+    #[tokio::test(flavor = "multi_thread")]
     async fn major_compaction() {
         let temp_dir = TempDir::new().unwrap();
         let temp_dir_l0 = TempDir::new().unwrap();
@@ -1170,7 +1170,7 @@ pub(crate) mod tests {
     }
 
     // https://github.com/tonbo-io/tonbo/pull/139
-    #[tokio::test]
+    #[tokio::test(flavor = "multi_thread")]
     pub(crate) async fn major_panic() {
         let temp_dir = TempDir::new().unwrap();
 
@@ -1291,7 +1291,7 @@ pub(crate) mod tests {
     }
 
     // issue: https://github.com/tonbo-io/tonbo/issues/152
-    #[tokio::test]
+    #[tokio::test(flavor = "multi_thread")]
     async fn test_flush_major_level_sort() {
         let temp_dir = TempDir::new().unwrap();
 
@@ -1405,7 +1405,7 @@ pub(crate) mod tests {
     }
 
     #[ignore = "s3"]
-    #[tokio::test]
+    #[tokio::test(flavor = "multi_thread")]
     async fn test_recover_before_flush_from_s3() {
         if option_env!("AWS_ACCESS_KEY_ID").is_none()
             || option_env!("AWS_SECRET_ACCESS_KEY").is_none()

src/lib.rs

@@ -1494,7 +1494,7 @@ pub(crate) mod tests {
         assert_eq!(option1.get().vbool, Some(true));
     }
 
-    #[tokio::test]
+    #[tokio::test(flavor = "multi_thread")]
     async fn test_flush() {
         let temp_dir = TempDir::new().unwrap();
 
@@ -1531,7 +1531,7 @@ pub(crate) mod tests {
     }
 
     #[ignore = "s3"]
-    #[tokio::test]
+    #[tokio::test(flavor = "multi_thread")]
     async fn test_recover_from_s3() {
         let temp_dir = TempDir::new().unwrap();
 
@@ -1616,7 +1616,7 @@ pub(crate) mod tests {
         }
     }
 
-    #[tokio::test]
+    #[tokio::test(flavor = "multi_thread")]
     async fn schema_recover() {
         let temp_dir = TempDir::new().unwrap();
         let fs = Arc::new(TokioFs) as Arc<dyn DynFs>;
@@ -1682,7 +1682,7 @@ pub(crate) mod tests {
         }
     }
 
-    #[tokio::test]
+    #[tokio::test(flavor = "multi_thread")]
     async fn dyn_schema_recover() {
         let temp_dir = TempDir::new().unwrap();
         let manager = StoreManager::new(FsOptions::Local, vec![]).unwrap();
@@ -1762,7 +1762,7 @@ pub(crate) mod tests {
         }
     }
 
-    #[tokio::test]
+    #[tokio::test(flavor = "multi_thread")]
     async fn test_get_removed() {
         let temp_dir = TempDir::new().unwrap();
 
@@ -1801,7 +1801,7 @@ pub(crate) mod tests {
         }
     }
 
-    #[tokio::test]
+    #[tokio::test(flavor = "multi_thread")]
     async fn test_read_write_dyn() {
         let temp_dir = TempDir::new().unwrap();
 
@@ -1959,7 +1959,7 @@ pub(crate) mod tests {
         }
     }
 
-    #[tokio::test]
+    #[tokio::test(flavor = "multi_thread")]
     async fn test_dyn_multiple_db() {
         let temp_dir1 = TempDir::with_prefix("db1").unwrap();
 

src/snapshot.rs

@@ -125,7 +125,7 @@ mod tests {
         DbOption,
     };
 
-    #[tokio::test]
+    #[tokio::test(flavor = "multi_thread")]
     async fn snapshot_scan() {
         let temp_dir = TempDir::new().unwrap();
         let manager = Arc::new(StoreManager::new(FsOptions::Local, vec![]).unwrap());

src/stream/level.rs

@@ -233,7 +233,7 @@ mod tests {
         inmem::immutable::tests::TestSchema, record::Schema, stream::level::LevelStream, DbOption,
     };
 
-    #[tokio::test]
+    #[tokio::test(flavor = "multi_thread")]
     async fn projection_scan() {
         let temp_dir = TempDir::new().unwrap();
         let manager = StoreManager::new(FsOptions::Local, vec![]).unwrap();

src/transaction.rs

@@ -321,7 +321,7 @@ mod tests {
         DbOption, Projection, DB,
     };
 
-    #[tokio::test]
+    #[tokio::test(flavor = "multi_thread")]
     async fn transaction_read_write() {
         let temp_dir = TempDir::new().unwrap();
 
@@ -361,7 +361,7 @@ mod tests {
         }
     }
 
-    #[tokio::test]
+    #[tokio::test(flavor = "multi_thread")]
     async fn transaction_get() {
         let temp_dir = TempDir::new().unwrap();
         let manager = Arc::new(StoreManager::new(FsOptions::Local, vec![]).unwrap());
@@ -454,7 +454,7 @@ mod tests {
         }
     }
 
-    #[tokio::test]
+    #[tokio::test(flavor = "multi_thread")]
     async fn write_conflicts() {
         let temp_dir = TempDir::new().unwrap();
         let option = DbOption::new(
@@ -490,7 +490,7 @@ mod tests {
         unreachable!();
     }
 
-    #[tokio::test]
+    #[tokio::test(flavor = "multi_thread")]
     async fn transaction_projection() {
         let temp_dir = TempDir::new().unwrap();
         let option = DbOption::new(
@@ -541,7 +541,7 @@ mod tests {
         assert_eq!(entry.get().vbool, None);
     }
 
-    #[tokio::test]
+    #[tokio::test(flavor = "multi_thread")]
     async fn transaction_scan() {
         let temp_dir = TempDir::new().unwrap();
         let manager = Arc::new(StoreManager::new(FsOptions::Local, vec![]).unwrap());
@@ -638,7 +638,7 @@ mod tests {
         assert_eq!(entry_15.key().value, "king");
     }
 
-    #[tokio::test]
+    #[tokio::test(flavor = "multi_thread")]
     async fn test_transaction_scan_bound() {
         let temp_dir = TempDir::new().unwrap();
         let manager = Arc::new(StoreManager::new(FsOptions::Local, vec![]).unwrap());
@@ -816,7 +816,7 @@ mod tests {
         }
     }
 
-    #[tokio::test]
+    #[tokio::test(flavor = "multi_thread")]
     async fn test_transaction_scan_limit() {
         let temp_dir = TempDir::new().unwrap();
         let manager = Arc::new(StoreManager::new(FsOptions::Local, vec![]).unwrap());
@@ -881,7 +881,7 @@ mod tests {
         }
     }
 
-    #[tokio::test]
+    #[tokio::test(flavor = "multi_thread")]
     async fn test_dyn_record() {
         let temp_dir = TempDir::new().unwrap();
         let schema = test_dyn_item_schema();

src/version/set.rs

@@ -431,7 +431,7 @@ pub(crate) mod tests {
         })
     }
 
-    #[tokio::test]
+    #[tokio::test(flavor = "multi_thread")]
     async fn timestamp_persistence() {
         let temp_dir = TempDir::new().unwrap();
         let manager = Arc::new(StoreManager::new(FsOptions::Local, vec![]).unwrap());
@@ -598,13 +598,13 @@ pub(crate) mod tests {
         );
     }
 
-    #[tokio::test]
+    #[tokio::test(flavor = "multi_thread")]
     async fn test_version_log_snap_shot() {
         version_log_snap_shot(FsOptions::Local).await;
     }
 
     #[ignore = "s3"]
-    #[tokio::test]
+    #[tokio::test(flavor = "multi_thread")]
     async fn test_s3_version_log_snap_shot() {
         use fusio::remotes::aws::AwsCredential;
 
@@ -634,7 +634,7 @@ pub(crate) mod tests {
         version_log_snap_shot(fs_option).await;
     }
 
-    #[tokio::test]
+    #[tokio::test(flavor = "multi_thread")]
     async fn version_level_sort() {
         let temp_dir = TempDir::new().unwrap();
         let manager = Arc::new(StoreManager::new(FsOptions::Local, vec![]).unwrap());

src/wal/mod.rs

@@ -222,13 +222,13 @@ mod tests {
         }
     }
 
-    #[tokio::test]
+    #[tokio::test(flavor = "multi_thread")]
     async fn test_local_write_and_recover() {
         write_and_recover(FsOptions::Local).await
     }
 
     #[ignore = "s3"]
-    #[tokio::test]
+    #[tokio::test(flavor = "multi_thread")]
     async fn test_s3_write_and_recover() {
         use fusio::remotes::aws::AwsCredential;