Report error and close on WebAssembly.RuntimeError

src/webR/chan/channel-postmessage.ts

@@ -266,7 +266,16 @@ export class PostMessageChannelWorker {
           this.#dispatch(msg);
         }
       } catch (e) {
-        // Don't break the REPL loop on any other Wasm issues
+        // Close on unrecoverable error
+        if (e instanceof WebAssembly.RuntimeError) {
+          this.writeSystem({ type: 'console.error', data: e.message });
+          this.writeSystem({
+            type: 'console.error',
+            data: "An unrecoverable WebAssembly error has occurred, the webR worker will be closed.",
+          });
+          this.writeSystem({ type: 'close' });
+        }
+        // Don't break the REPL loop on other Wasm `Exception` errors
         if (!(e instanceof (WebAssembly as any).Exception)) {
           throw e;
         }

src/webR/chan/channel-service.ts

@@ -297,7 +297,19 @@ export class ServiceWorkerChannelWorker implements ChannelWorker {
   }
 
   run(args: string[]) {
-    Module.callMain(args);
+    try{
+      Module.callMain(args);
+    } catch (e) {
+      if (e instanceof WebAssembly.RuntimeError) {
+        this.writeSystem({ type: 'console.error', data: e.message });
+        this.writeSystem({
+          type: 'console.error',
+          data: "An unrecoverable WebAssembly error has occurred, the webR worker will be closed.",
+        });
+        this.writeSystem({ type: 'close' });
+      }
+      throw e;
+    }
   }
 
   setInterrupt(interrupt: () => void) {

src/webR/chan/channel-shared.ts

@@ -175,7 +175,19 @@ export class SharedBufferChannelWorker implements ChannelWorker {
   }
 
   run(args: string[]) {
-    Module.callMain(args);
+    try{
+      Module.callMain(args);
+    } catch (e) {
+      if (e instanceof WebAssembly.RuntimeError) {
+        this.writeSystem({ type: 'console.error', data: e.message });
+        this.writeSystem({
+          type: 'console.error',
+          data: "An unrecoverable WebAssembly error has occurred, the webR worker will be closed.",
+        });
+        this.writeSystem({ type: 'close' });
+      }
+      throw e;
+    }
   }
 
   setInterrupt(interrupt: () => void) {

src/webR/webr-main.ts

@@ -310,6 +310,9 @@ export class WebR {
         case 'console.error':
           console.error(msg.data);
           break;
+        case 'close':
+          this.#chan.close();
+          break;
         default:
           throw new WebRError('Unknown system message type `' + msg.type + '`');
       }