Add wasi build in CI

Author: BadMachine

.github/workflows/CI.yml

@@ -94,6 +94,9 @@ jobs:
           - host: windows-latest
             target: aarch64-pc-windows-msvc
             build: yarn build --target aarch64-pc-windows-msvc
+          - host: ubuntu-latest
+            target: wasm32-wasip1-threads
+            build: yarn build --target wasm32-wasip1-threads
     name: stable - ${{ matrix.settings.target }} - node@22
     runs-on: ${{ matrix.settings.host }}
     steps:
@@ -343,6 +346,34 @@ jobs:
 
             fi
             yarn test
+  test-wasi:
+    name: Test WASI target
+    needs:
+      - build
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v5
+      - name: Setup node
+        uses: actions/setup-node@v4
+        with:
+          node-version: 22
+          cache: yarn
+      - name: Install dependencies
+        run: |
+          yarn config set supportedArchitectures.cpu "wasm32"
+          yarn install
+      - name: Download artifacts
+        uses: actions/download-artifact@v5
+        with:
+          name: bindings-wasm32-wasip1-threads
+          path: .
+      - name: List packages
+        run: ls -R .
+        shell: bash
+      - name: Test bindings
+        run: yarn test
+        env:
+          NAPI_RS_FORCE_WASI: 1
   publish:
     name: Publish
     runs-on: ubuntu-latest
@@ -354,6 +385,7 @@ jobs:
       - build-freebsd
       - test-macOS-windows-binding
       - test-linux-binding
+      - test-wasi
     steps:
       - uses: actions/checkout@v5
       - name: Setup node

src/client/browser/client.rs

@@ -1,15 +1,15 @@
+use crate::client::browser::HttpQueryResponseV1;
 use crate::client::http_client::get_http_client;
 use crate::client::options::{FlightOptions, QueryPayload, WriteOptions};
-use crate::serializer::browser::{Serializer};
+use crate::query::browser::query_processor::into_stream;
+use crate::serializer::browser::Serializer;
+use napi::bindgen_prelude::*;
 use napi::bindgen_prelude::{Buffer, Either, ReadableStream};
-use napi::Env;
 use napi::tokio_stream::wrappers::ReceiverStream;
+use napi::Env;
 use reqwest::Client;
 use serde::{Deserialize, Serialize};
 use serde_json::{Map, Value};
-use crate::client::browser::HttpQueryResponseV1;
-use crate::query::browser::query_processor::into_stream;
-use napi::bindgen_prelude::*;
 
 #[napi_derive::napi]
 pub struct InfluxDBClient {
@@ -20,7 +20,7 @@ pub struct InfluxDBClient {
 }
 
 // replace it with #[napi_derive::napi] in the future
-                                                        // impl InfluxClientTrait for InfluxDBClient {
+// impl InfluxClientTrait for InfluxDBClient {
 #[napi_derive::napi]
 impl InfluxDBClient {
   #[napi(constructor)]
@@ -43,12 +43,7 @@ impl InfluxDBClient {
     &mut self,
     query_payload: QueryPayload,
     env: &Env,
-  ) -> napi::Result<
-    Either<
-      ReadableStream<'_, Map<String, Value>>,
-      ReadableStream<'_, Buffer>,
-    >,
-  > {
+  ) -> napi::Result<Either<ReadableStream<'_, Map<String, Value>>, ReadableStream<'_, Buffer>>> {
     let stream = self.query_inner(query_payload, env)?;
     Ok(Either::A(stream))
   }
@@ -60,35 +55,36 @@ impl InfluxDBClient {
   ) -> Result<ReadableStream<'_, serde_json::Map<String, serde_json::Value>>> {
     use napi::bindgen_prelude::block_on;
 
-    let stream: ReceiverStream<Result<serde_json::Map<String, serde_json::Value>>> = block_on(async {
-      let url = format!("{}/query", self.addr);
+    let stream: ReceiverStream<Result<serde_json::Map<String, serde_json::Value>>> =
+      block_on(async {
+        let url = format!("{}/query", self.addr);
 
-      let response = self
-        .http_client
-        .get(&url)
-        .query(&[
-          ("db", query_payload.database.clone()),
-          ("q", query_payload.query.clone()),
-        ])
-        .send()
-        .await
-        .map_err(|e| Error::from_reason(format!("HTTP request failed: {}", e)))?;
+        let response = self
+          .http_client
+          .get(&url)
+          .query(&[
+            ("db", query_payload.database.clone()),
+            ("q", query_payload.query.clone()),
+          ])
+          .send()
+          .await
+          .map_err(|e| Error::from_reason(format!("HTTP request failed: {}", e)))?;
 
-      let status = response.status();
-      if !status.is_success() {
-        return Err(Error::from_reason(format!(
-          "InfluxDB returned non-success status: {}",
-          status
-        )));
-      }
+        let status = response.status();
+        if !status.is_success() {
+          return Err(Error::from_reason(format!(
+            "InfluxDB returned non-success status: {}",
+            status
+          )));
+        }
 
-      let data: HttpQueryResponseV1 = response
-        .json()
-        .await
-        .map_err(|e| Error::from_reason(format!("Failed to parse JSON: {}", e)))?;
+        let data: HttpQueryResponseV1 = response
+          .json()
+          .await
+          .map_err(|e| Error::from_reason(format!("Failed to parse JSON: {}", e)))?;
 
-      Ok(into_stream(data))
-    })?;
+        Ok(into_stream(data))
+      })?;
 
     ReadableStream::new(env, stream)
   }

src/client/browser/mod.rs

@@ -4,18 +4,18 @@ pub(crate) mod client;
 
 #[derive(Deserialize, Serialize)]
 pub struct Series {
-    name: String,
-    pub(crate)columns: Vec<String>,
-    pub(crate)values: Vec<Vec<serde_json::Value>>,
+  name: String,
+  pub(crate) columns: Vec<String>,
+  pub(crate) values: Vec<Vec<serde_json::Value>>,
 }
 
 #[derive(Deserialize, Serialize)]
 pub struct QueryDataV1 {
-    statement_id: u32,
-    pub(crate) series: Vec<Series>,
+  statement_id: u32,
+  pub(crate) series: Vec<Series>,
 }
 
 #[derive(Deserialize, Serialize)]
 pub(crate) struct HttpQueryResponseV1 {
-    pub(crate)results: Vec<QueryDataV1>,
-}
+  pub(crate) results: Vec<QueryDataV1>,
+}

src/client/mod.rs

@@ -12,4 +12,4 @@ pub mod browser;
 pub mod napi_rs;
 
 pub mod http_client;
-pub mod options;
+pub mod options;