fix: add locking around transpilation

bin/lang-js/package.json

@@ -55,6 +55,7 @@
   "dependencies": {
     "@si/ts-lib-deno": "workspace:*",
     "@typescript/vfs": "^1.4.0",
+    "async-mutex": "^0.5.0",
     "execa": "^5.1.1",
     "fast-json-patch": "^3.1.1",
     "joi": "^17.11.0",

bin/lang-js/src/function.ts

@@ -18,6 +18,7 @@ import { rawStorage } from "./sandbox/requestStorage.ts";
 import { Debugger } from "./debug.ts";
 import { transpile } from "jsr:@deno/emit";
 import { Debug } from "./debug.ts";
+import { Mutex } from "npm:async-mutex";
 import * as _worker from "./worker.js";
 
 const debug = Debug("langJs:function");
@@ -265,27 +266,31 @@ export async function runCode(
   });
 }
 
-async function bundleCode(code: string): Promise<string> {
-  debug({ "code before bundle": code });
-  const tempDir = await Deno.makeTempDir();
-  const tempFile = `${tempDir}/script.ts`;
+const transpileMutex = new Mutex();
 
-  await Deno.writeTextFile(tempFile, code);
-  const fileUrl = new URL(tempFile, import.meta.url);
+function bundleCode(code: string): Promise<string> {
+  return transpileMutex.runExclusive(async () => {
+    debug({ "code before bundle": code });
+    const tempDir = await Deno.makeTempDir();
+    const tempFile = `${tempDir}/script.ts`;
 
-  try {
-    const result = await transpile(fileUrl);
+    await Deno.writeTextFile(tempFile, code);
+    const fileUrl = new URL(tempFile, import.meta.url);
 
-    const bundled = result.get(fileUrl.href) as string;
-    if (!bundled) {
-      throw new Error("Transpilation resulted in empty output");
-    }
+    try {
+      const result = await transpile(fileUrl);
 
-    debug({ "code after bundle": code });
-    return bundled;
-  } catch (error) {
-    throw error;
-  } finally {
-    await Deno.remove(tempDir, { recursive: true });
-  }
+      const bundled = result.get(fileUrl.href) as string;
+      if (!bundled) {
+        throw new Error("Transpilation resulted in empty output");
+      }
+
+      debug({ "code after bundle": code });
+      return bundled;
+    } catch (error) {
+      throw error;
+    } finally {
+      await Deno.remove(tempDir, { recursive: true });
+    }
+  });
 }

bin/lang-js/src/function_kinds/management.ts

@@ -44,7 +44,7 @@ export interface ManagementCreate {
 }
 
 export interface ManagementOperations {
-  create?: ManagementCreate,
+  create?: ManagementCreate;
   update?: {
     [key: string]: {
       properties?: object;