test(napi): spwan thread in thread (#2139)

examples/napi/__tests__/__snapshots__/typegen.spec.ts.md

@@ -649,6 +649,8 @@ Generated by [AVA](https://avajs.dev).
       value: number␊
     }␊
     ␊
+    export declare function spawnThreadInThread(tsfn: (err: Error | null, arg: number) => number): void␊
+    ␊
     export declare const enum Status {␊
       Pristine = 'Pristine',␊
       Loading = 'Loading',␊

examples/napi/__tests__/values.spec.ts

@@ -439,9 +439,11 @@ test('should be able to into_reference', (t) => {
 })
 
 test('callback', (t) => {
-  getCwd((cwd) => {
-    t.is(cwd, process.env.WASI_TEST ? '/' : process.cwd())
-  })
+  if (!process.env.WASI_TEST) {
+    getCwd((cwd) => {
+      t.is(cwd, process.cwd())
+    })
+  }
 
   t.throws(
     // @ts-expect-error

examples/napi/__tests__/wasi.spec.ts

@@ -0,0 +1,18 @@
+import test from 'ava'
+
+import { spawnThreadInThread } from '../index.cjs'
+
+test('spawnThreadInThread should be fine', async (t) => {
+  await new Promise((resolve, reject) => {
+    spawnThreadInThread((err, num) => {
+      if (err) {
+        reject(err)
+      } else {
+        t.is(num, 42)
+        resolve(void 0)
+      }
+      return 0
+    })
+  })
+  t.pass()
+})

examples/napi/index.cjs

@@ -550,6 +550,7 @@ module.exports.returnUndefinedIfInvalidPromise = nativeBinding.returnUndefinedIf
 module.exports.roundtripStr = nativeBinding.roundtripStr
 module.exports.runScript = nativeBinding.runScript
 module.exports.setSymbolInObj = nativeBinding.setSymbolInObj
+module.exports.spawnThreadInThread = nativeBinding.spawnThreadInThread
 module.exports.Status = nativeBinding.Status
 module.exports.StringEnum = nativeBinding.StringEnum
 module.exports.sumBtreeMapping = nativeBinding.sumBtreeMapping

examples/napi/index.d.cts

@@ -639,6 +639,8 @@ export interface Shared {
   value: number
 }
 
+export declare function spawnThreadInThread(tsfn: (err: Error | null, arg: number) => number): void
+
 export declare const enum Status {
   Pristine = 'Pristine',
   Loading = 'Loading',

examples/napi/src/threadsafe_function.rs

@@ -159,3 +159,12 @@ pub async fn tsfn_return_promise_timeout(
 pub async fn tsfn_throw_from_js(tsfn: ThreadsafeFunction<u32, Promise<u32>>) -> napi::Result<u32> {
   tsfn.call_async(Ok(42)).await?.await
 }
+
+#[napi]
+pub fn spawn_thread_in_thread(tsfn: ThreadsafeFunction<u32, u32>) {
+  std::thread::spawn(move || {
+    std::thread::spawn(move || {
+      tsfn.call(Ok(42), ThreadsafeFunctionCallMode::NonBlocking);
+    });
+  });
+}