feat: add support for wasm targets

Signed-off-by: Ho Kim <[email protected]>

Author: HoKim98

crates/catalog/glue/src/catalog.rs

@@ -198,7 +198,8 @@ impl GlueCatalog {
     }
 }
 
-#[async_trait]
+#[cfg_attr(not(target_arch = "wasm32"), async_trait)]
+#[cfg_attr(target_arch = "wasm32", async_trait(?Send))]
 impl Catalog for GlueCatalog {
     /// List namespaces from glue catalog.
     ///

crates/catalog/hms/src/catalog.rs

@@ -210,7 +210,8 @@ impl HmsCatalog {
     }
 }
 
-#[async_trait]
+#[cfg_attr(not(target_arch = "wasm32"), async_trait)]
+#[cfg_attr(target_arch = "wasm32", async_trait(?Send))]
 impl Catalog for HmsCatalog {
     /// HMS doesn't support nested namespaces.
     ///

crates/catalog/loader/src/lib.rs

@@ -41,7 +41,8 @@ pub fn supported_types() -> Vec<&'static str> {
     CATALOG_REGISTRY.iter().map(|(k, _)| *k).collect()
 }
 
-#[async_trait]
+#[cfg_attr(not(target_arch = "wasm32"), async_trait)]
+#[cfg_attr(target_arch = "wasm32", async_trait(?Send))]
 pub trait BoxedCatalogBuilder {
     async fn load(
         self: Box<Self>,
@@ -50,7 +51,8 @@ pub trait BoxedCatalogBuilder {
     ) -> Result<Arc<dyn Catalog>>;
 }
 
-#[async_trait]
+#[cfg_attr(not(target_arch = "wasm32"), async_trait)]
+#[cfg_attr(target_arch = "wasm32", async_trait(?Send))]
 impl<T: CatalogBuilder + 'static> BoxedCatalogBuilder for T {
     async fn load(
         self: Box<Self>,

crates/catalog/rest/src/catalog.rs

@@ -435,7 +435,8 @@ impl RestCatalog {
 
 /// All requests and expected responses are derived from the REST catalog API spec:
 /// https://github.com/apache/iceberg/blob/main/open-api/rest-catalog-open-api.yaml
-#[async_trait]
+#[cfg_attr(not(target_arch = "wasm32"), async_trait)]
+#[cfg_attr(target_arch = "wasm32", async_trait(?Send))]
 impl Catalog for RestCatalog {
     async fn list_namespaces(
         &self,

crates/catalog/s3tables/src/catalog.rs

@@ -191,7 +191,8 @@ impl S3TablesCatalog {
     }
 }
 
-#[async_trait]
+#[cfg_attr(not(target_arch = "wasm32"), async_trait)]
+#[cfg_attr(target_arch = "wasm32", async_trait(?Send))]
 impl Catalog for S3TablesCatalog {
     /// List namespaces from s3tables catalog.
     ///

crates/catalog/sql/src/catalog.rs

@@ -218,7 +218,8 @@ impl SqlCatalog {
     }
 }
 
-#[async_trait]
+#[cfg_attr(not(target_arch = "wasm32"), async_trait)]
+#[cfg_attr(target_arch = "wasm32", async_trait(?Send))]
 impl Catalog for SqlCatalog {
     async fn list_namespaces(
         &self,

crates/iceberg/Cargo.toml

@@ -40,7 +40,7 @@ storage-oss = ["opendal/services-oss"]
 storage-s3 = ["opendal/services-s3", "reqsign"]
 
 smol = ["dep:smol"]
-tokio = ["tokio/rt-multi-thread"]
+tokio = []
 
 [dependencies]
 anyhow = { workspace = true }
@@ -74,8 +74,8 @@ opendal = { workspace = true }
 ordered-float = { workspace = true }
 parquet = { workspace = true, features = ["async"] }
 rand = { workspace = true }
-reqwest = { workspace = true }
 reqsign = { version = "0.16.3", optional = true, default-features = false }
+reqwest = { workspace = true }
 roaring = { workspace = true }
 rust_decimal = { workspace = true }
 serde = { workspace = true }
@@ -87,7 +87,6 @@ serde_with = { workspace = true }
 smol = { workspace = true, optional = true }
 strum = { workspace = true, features = ["derive"] }
 thrift = { workspace = true }
-tokio = { workspace = true, optional = false, features = ["sync"] }
 typed-builder = { workspace = true }
 url = { workspace = true }
 uuid = { workspace = true }
@@ -104,6 +103,15 @@ regex = { workspace = true }
 tempfile = { workspace = true }
 tera = { workspace = true }
 
+[target.'cfg(not(target_arch = "wasm32"))'.dependencies]
+tokio = { workspace = true, optional = false, features = [
+  "rt-multi-thread",
+  "sync",
+] }
+
+[target.'cfg(target_arch = "wasm32")'.dependencies]
+tokio = { workspace = true, optional = false, features = ["rt", "sync"] }
+
 [package.metadata.cargo-machete]
 # These dependencies are added to ensure minimal dependency version
 ignored = ["tap"]

crates/iceberg/src/arrow/delete_file_loader.rs

@@ -28,7 +28,8 @@ use crate::{Error, ErrorKind, Result};
 
 /// Delete File Loader
 #[allow(unused)]
-#[async_trait::async_trait]
+#[cfg_attr(not(target_arch = "wasm32"), async_trait::async_trait)]
+#[cfg_attr(target_arch = "wasm32", async_trait::async_trait(?Send))]
 pub trait DeleteFileLoader {
     /// Read the delete file referred to in the task
     ///
@@ -96,7 +97,8 @@ impl BasicDeleteFileLoader {
     }
 }
 
-#[async_trait::async_trait]
+#[cfg_attr(not(target_arch = "wasm32"), async_trait::async_trait)]
+#[cfg_attr(target_arch = "wasm32", async_trait::async_trait(?Send))]
 impl DeleteFileLoader for BasicDeleteFileLoader {
     async fn read_delete_file(
         &self,

crates/iceberg/src/arrow/reader.rs

@@ -32,8 +32,8 @@ use arrow_schema::{
 use arrow_string::like::starts_with;
 use bytes::Bytes;
 use fnv::FnvHashSet;
-use futures::future::BoxFuture;
-use futures::{FutureExt, StreamExt, TryFutureExt, TryStreamExt, try_join};
+use futures::{StreamExt, TryFutureExt, TryStreamExt, try_join};
+use opendal::raw::BoxedFuture;
 use parquet::arrow::arrow_reader::{
     ArrowPredicateFn, ArrowReaderOptions, RowFilter, RowSelection, RowSelector,
 };
@@ -1373,7 +1373,7 @@ impl<R: FileRead> ArrowFileReader<R> {
 }
 
 impl<R: FileRead> AsyncFileReader for ArrowFileReader<R> {
-    fn get_bytes(&mut self, range: Range<u64>) -> BoxFuture<'_, parquet::errors::Result<Bytes>> {
+    fn get_bytes(&mut self, range: Range<u64>) -> BoxedFuture<'_, parquet::errors::Result<Bytes>> {
         Box::pin(
             self.r
                 .read(range.start..range.end)
@@ -1386,8 +1386,8 @@ impl<R: FileRead> AsyncFileReader for ArrowFileReader<R> {
     fn get_metadata(
         &mut self,
         _options: Option<&'_ ArrowReaderOptions>,
-    ) -> BoxFuture<'_, parquet::errors::Result<Arc<ParquetMetaData>>> {
-        async move {
+    ) -> BoxedFuture<'_, parquet::errors::Result<Arc<ParquetMetaData>>> {
+        Box::pin(async move {
             let reader = ParquetMetaDataReader::new()
                 .with_prefetch_hint(self.metadata_size_hint)
                 .with_column_indexes(self.preload_column_index)
@@ -1397,8 +1397,7 @@ impl<R: FileRead> AsyncFileReader for ArrowFileReader<R> {
             let meta = reader.load_and_finish(self, size).await?;
 
             Ok(Arc::new(meta))
-        }
-        .boxed()
+        })
     }
 }
 

crates/iceberg/src/catalog/memory/catalog.rs

@@ -140,7 +140,8 @@ impl MemoryCatalog {
     }
 }
 
-#[async_trait]
+#[cfg_attr(not(target_arch = "wasm32"), async_trait)]
+#[cfg_attr(target_arch = "wasm32", async_trait(?Send))]
 impl Catalog for MemoryCatalog {
     /// List namespaces inside the catalog.
     async fn list_namespaces(