implement interrupts

Cargo.lock

···
 
 [[package]]
 name = "alphanumeric-sort"
-version = "1.5.4"
+version = "1.5.5"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "ab31f79a61d3c25cae1d6734a386662e5cf1b6ba5a9720c135b609273c058c15"
+checksum = "774ffdfeac16e9b4d75e41225dc2545d9c2082a0634b5d7f6f70e168546eecb1"
 
 [[package]]
 name = "android_system_properties"
···
 dependencies = [
  "alloc-no-stdlib",
  "alloc-stdlib",
-]
-
-[[package]]
-name = "bstr"
-version = "1.12.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "63044e1ae8e69f3b5a92c736ca6269b8d12fa7efe39bf34ddb06d102cf0e2cab"
-dependencies = [
- "memchr",
- "regex-automata",
- "serde",
 ]
 
 [[package]]
···
  "jacquard-repo",
  "js-sys",
  "miette",
+ "nu-cmd-base",
  "nu-cmd-extra",
  "nu-cmd-lang",
  "nu-command",
  "nu-engine",
  "nu-parser",
+ "nu-path",
  "nu-protocol",
  "rapidhash",
  "reqwest",
···
 
 [[package]]
 name = "nu-cmd-base"
-version = "0.109.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "2460ee389a43b935aa18ef5ed9fa8275bdf617e8c05eba7c2b82f92effd2132b"
+version = "0.109.2"
+source = "git+https://github.com/90-008/nushell#db3f8b1979bc9bfc6b4b54046804db9c1709eaa0"
 dependencies = [
  "indexmap 2.12.1",
  "miette",
···
 
 [[package]]
 name = "nu-cmd-extra"
-version = "0.109.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "96f1ac416cd5182ca427a1007c9d0193feaa746aeb54b5320251faad41481cfe"
+version = "0.109.2"
+source = "git+https://github.com/90-008/nushell#db3f8b1979bc9bfc6b4b54046804db9c1709eaa0"
 dependencies = [
  "fancy-regex",
  "heck 0.5.0",
···
 
 [[package]]
 name = "nu-cmd-lang"
-version = "0.109.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "5b266674d87b816264f6aff8cca351e6ebb156f34faab45d7d728c2aba005495"
+version = "0.109.2"
+source = "git+https://github.com/90-008/nushell#db3f8b1979bc9bfc6b4b54046804db9c1709eaa0"
 dependencies = [
  "itertools 0.14.0",
  "nu-cmd-base",
···
 
 [[package]]
 name = "nu-color-config"
-version = "0.109.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "440a59265caf5468af6ff186e656bc6e6d349c08662ee959b116375597864206"
+version = "0.109.2"
+source = "git+https://github.com/90-008/nushell#db3f8b1979bc9bfc6b4b54046804db9c1709eaa0"
 dependencies = [
  "nu-ansi-term",
  "nu-engine",
···
 
 [[package]]
 name = "nu-command"
-version = "0.109.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "5380a9cf6ef0f482280b71d6e78fa8d4bc1b2b43aa8f0b1fa786f96087c2d500"
+version = "0.109.2"
+source = "git+https://github.com/90-008/nushell#db3f8b1979bc9bfc6b4b54046804db9c1709eaa0"
 dependencies = [
  "alphanumeric-sort",
  "base64",
···
  "pathdiff",
  "percent-encoding",
  "print-positions",
- "procfs 0.17.0",
+ "procfs",
  "quick-xml 0.38.4",
  "rayon",
  "rmp",
···
 
 [[package]]
 name = "nu-derive-value"
-version = "0.109.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "1465d2d3ada6004cb6689f269a08c70ba81056231e2b5392d1e0ccf5825f81cb"
+version = "0.109.2"
+source = "git+https://github.com/90-008/nushell#db3f8b1979bc9bfc6b4b54046804db9c1709eaa0"
 dependencies = [
  "heck 0.5.0",
  "proc-macro-error2",
···
 
 [[package]]
 name = "nu-engine"
-version = "0.109.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "b3b777faf7c5180fe5d7f67d83c44fd14138d91f2938a36494ed6ac66b7160f3"
+version = "0.109.2"
+source = "git+https://github.com/90-008/nushell#db3f8b1979bc9bfc6b4b54046804db9c1709eaa0"
 dependencies = [
  "fancy-regex",
  "log",
···
 
 [[package]]
 name = "nu-experimental"
-version = "0.109.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "73dd212a1afdad646a38c00579a0988264880aeb97fee820b349a28cdcc04df2"
+version = "0.109.2"
+source = "git+https://github.com/90-008/nushell#db3f8b1979bc9bfc6b4b54046804db9c1709eaa0"
 dependencies = [
  "itertools 0.14.0",
  "thiserror 2.0.17",
···
 
 [[package]]
 name = "nu-glob"
-version = "0.109.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "15aa2c17078926f14e393b4b708e69f228cb6fd4c81136839bde82772bdde1b5"
+version = "0.109.2"
+source = "git+https://github.com/90-008/nushell#db3f8b1979bc9bfc6b4b54046804db9c1709eaa0"
 
 [[package]]
 name = "nu-json"
-version = "0.109.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "7ca63927a3c1c4fb889e80dc5cfbe754daed822a7b503cc74e600627c2aa8435"
+version = "0.109.2"
+source = "git+https://github.com/90-008/nushell#db3f8b1979bc9bfc6b4b54046804db9c1709eaa0"
 dependencies = [
  "linked-hash-map",
  "nu-utils",
···
 
 [[package]]
 name = "nu-parser"
-version = "0.109.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "237172636312c3566272511a00c1dc355202406c376e1546a45a33c65e81babe"
+version = "0.109.2"
+source = "git+https://github.com/90-008/nushell#db3f8b1979bc9bfc6b4b54046804db9c1709eaa0"
 dependencies = [
  "bytesize",
  "chrono",
···
 
 [[package]]
 name = "nu-path"
-version = "0.109.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "dde9d8ba26f62c07176c0237a36f38ce964ab3a0dcfb6aab1feea7515d1c6594"
+version = "0.109.2"
+source = "git+https://github.com/90-008/nushell#db3f8b1979bc9bfc6b4b54046804db9c1709eaa0"
 dependencies = [
  "dirs",
  "omnipath",
···
 
 [[package]]
 name = "nu-pretty-hex"
-version = "0.109.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "02561546604ac4c443bad65d9485ab3965154cad0873340e2e9ebe72d4a18aef"
+version = "0.109.2"
+source = "git+https://github.com/90-008/nushell#db3f8b1979bc9bfc6b4b54046804db9c1709eaa0"
 dependencies = [
  "nu-ansi-term",
 ]
 
 [[package]]
 name = "nu-protocol"
-version = "0.109.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "038943300ca9de0924fef1c795a7dd16ffc67105629477cf163e8ee6bad95ea6"
+version = "0.109.2"
+source = "git+https://github.com/90-008/nushell#db3f8b1979bc9bfc6b4b54046804db9c1709eaa0"
 dependencies = [
  "bytes",
  "chrono",
···
 
 [[package]]
 name = "nu-system"
-version = "0.109.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "46be734cc9b19e09a9665769e14360e13e6978490056ba5c8bfad7dd0537ea83"
+version = "0.109.2"
+source = "git+https://github.com/90-008/nushell#db3f8b1979bc9bfc6b4b54046804db9c1709eaa0"
 dependencies = [
  "chrono",
  "itertools 0.14.0",
···
  "mach2",
  "nix",
  "ntapi",
- "procfs 0.17.0",
+ "procfs",
  "sysinfo",
  "web-time",
  "windows 0.62.2",
···
 
 [[package]]
 name = "nu-table"
-version = "0.109.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "aa96502adbb69c838d8469715327ba2dacf2c4f5254a4cdee7536e2c6849de1d"
+version = "0.109.2"
+source = "git+https://github.com/90-008/nushell#db3f8b1979bc9bfc6b4b54046804db9c1709eaa0"
 dependencies = [
  "fancy-regex",
  "nu-ansi-term",
···
 
 [[package]]
 name = "nu-term-grid"
-version = "0.109.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "2b6545b361413e88bea37c4b9c7aa97a7fd7a11d84a5d330a72242367fd1d2df"
+version = "0.109.2"
+source = "git+https://github.com/90-008/nushell#db3f8b1979bc9bfc6b4b54046804db9c1709eaa0"
 dependencies = [
  "nu-utils",
  "unicode-width 0.2.2",
···
 
 [[package]]
 name = "nu-utils"
-version = "0.109.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "3f8eb43c29cc5bce85f87defdadc2cca964fa434d808af37036a7cb78f3c68e9"
+version = "0.109.2"
+source = "git+https://github.com/90-008/nushell#db3f8b1979bc9bfc6b4b54046804db9c1709eaa0"
 dependencies = [
  "byteyarn",
  "crossterm_winapi",
···
 ]
 
 [[package]]
-name = "number_prefix"
-version = "0.4.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "830b246a0e5f20af87141b25c173cd1b609bd7779a4617d6ec582abaf90870f3"
-
-[[package]]
 name = "nuon"
-version = "0.109.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "f8c4f2e4460a6cf00e50cddf0840f954874d645be3af5196c5858c70c069d8c0"
+version = "0.109.2"
+source = "git+https://github.com/90-008/nushell#db3f8b1979bc9bfc6b4b54046804db9c1709eaa0"
 dependencies = [
  "nu-engine",
  "nu-parser",
···
  "chrono",
  "flate2",
  "hex",
- "procfs-core 0.17.0",
+ "procfs-core",
  "rustix 0.38.44",
 ]
 
 [[package]]
-name = "procfs"
-version = "0.18.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "25485360a54d6861439d60facef26de713b1e126bf015ec8f98239467a2b82f7"
-dependencies = [
- "bitflags",
- "chrono",
- "flate2",
- "procfs-core 0.18.0",
- "rustix 1.1.2",
-]
-
-[[package]]
 name = "procfs-core"
 version = "0.17.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "239df02d8349b06fc07398a3a1697b06418223b1c7725085e801e7c0fc6a12ec"
-dependencies = [
- "bitflags",
- "chrono",
- "hex",
-]
-
-[[package]]
-name = "procfs-core"
-version = "0.18.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "e6401bf7b6af22f78b563665d15a22e9aef27775b79b149a66ca022468a4e405"
 dependencies = [
  "bitflags",
  "chrono",
···
 
 [[package]]
 name = "reqwest"
-version = "0.12.25"
+version = "0.12.26"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "b6eff9328d40131d43bd911d42d79eb6a47312002a4daefc9e37f17e74a7701a"
+checksum = "3b4c14b2d9afca6a60277086b0cc6a6ae0b568f6f7916c943a8cdc79f8be240f"
 dependencies = [
  "base64",
  "bytes",
···
 
 [[package]]
 name = "rustls"
-version = "0.23.28"
+version = "0.23.35"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "7160e3e10bf4535308537f3c4e1641468cd0e485175d6163087c0393c7d46643"
+checksum = "533f54bc6a7d4f647e46ad909549eda97bf5afc1585190ef692b4286b198bd8f"
 dependencies = [
  "once_cell",
  "ring",
···
 
 [[package]]
 name = "uucore"
-version = "0.4.0"
+version = "0.5.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "2003164a38a7f39da1de103a70fa66b745f572f0045ec261481539516c0a8a0e"
+checksum = "b5eddd390f3fdef74f104a948559e6de29203f60f8f563c8c9f528cd4c88ee78"
 dependencies = [
- "bstr",
  "clap",
  "fluent",
  "fluent-bundle",
  "fluent-syntax",
  "libc",
  "nix",
- "number_prefix",
  "os_display",
  "phf 0.13.1",
- "procfs 0.18.0",
  "thiserror 2.0.17",
  "unic-langid",
  "uucore_procs",
···
 
 [[package]]
 name = "uucore_procs"
-version = "0.4.0"
+version = "0.5.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "c76f0308f7810d915246a39748e7f5d64e43e6bb9d6c8107224f9d741aefc375"
+checksum = "47148309a1f7a989d165dabbbc7f2bf156d7ff6affe7d69c1c5bfb822e663ae6"
 dependencies = [
  "proc-macro2",
  "quote",

Cargo.toml

···
 getrandom = { version = "0.3", features = ["wasm_js"] }
 web-sys = { version = "0.3", features = ["console", "Window"] }
 vfs = { version = "0.12" }
-nu-cmd-lang = { version = "0.109.1", default-features = false }
-nu-command = { version = "0.109.1", default-features = false }
-nu-engine = { version = "0.109.1", default-features = false }
-nu-parser = { version = "0.109.1", default-features = false }
-nu-protocol = { version = "0.109.1", default-features = false }
-nu-cmd-extra = { version = "0.109.1", default-features = false }
+nu-command = { git = "https://github.com/90-008/nushell", default-features = false }
+nu-engine = { git = "https://github.com/90-008/nushell", default-features = false }
+nu-parser = { git = "https://github.com/90-008/nushell", default-features = false }
+nu-protocol = { git = "https://github.com/90-008/nushell", default-features = false }
+nu-path = { git = "https://github.com/90-008/nushell", default-features = false }
+nu-cmd-base = { git = "https://github.com/90-008/nushell", default-features = false }
+nu-cmd-lang = { git = "https://github.com/90-008/nushell", default-features = false }
+nu-cmd-extra = { git = "https://github.com/90-008/nushell", default-features = false }
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1"
 miette = { version = "7.6", features = ["fancy"] }
···
 lto = true
 codegen-units = 1
 strip = true
+debug-assertions = false

src/cmd/cd.rs

···
 use crate::globals::{get_pwd, get_vfs, set_pwd, to_shell_err};
 use nu_engine::CallExt;
 use nu_protocol::{
-    Category, PipelineData, ShellError, Signature, SyntaxShape,
+    Category, IntoValue, PipelineData, ShellError, Signature, SyntaxShape,
     engine::{Command, EngineState, Stack},
 };
 use std::sync::Arc;
···
     fn run(
         &self,
         engine_state: &EngineState,
-        _stack: &mut Stack,
+        stack: &mut Stack,
         call: &nu_protocol::engine::Call,
         _input: PipelineData,
     ) -> Result<PipelineData, ShellError> {
-        let path_arg: Option<String> = call.opt(engine_state, _stack, 0)?;
+        let path_arg: Option<String> = call.opt(engine_state, stack, 0)?;
         let path = path_arg.unwrap_or_else(|| "/".to_string());
 
         let base: Arc<vfs::VfsPath> = if path.starts_with('/') {
···
         let metadata = target.metadata().map_err(to_shell_err(call.head))?;
         match metadata.file_type {
             VfsFileType::Directory => {
+                stack.add_env_var(
+                    "PWD".to_string(),
+                    target.as_str().into_value(call.arguments_span()),
+                );
                 set_pwd(Arc::new(target));
                 Ok(PipelineData::Empty)
             }

src/cmd/fetch.rs

···
                     match result {
                         Ok(_) => {}
                         Err(e) => {
-                            print_to_console(
+                            let _ = print_to_console(
                                 &format!("\x1b[31m✖\x1b[0m ({task_desc}) error: {e}"),
                                 false,
                             );

src/globals.rs

···
 use futures::stream::AbortHandle;
 use nu_protocol::{
-    ShellError, Span,
+    ShellError, Signal, Span,
     engine::{EngineState, StateDelta},
 };
 use std::{
···
     }
 }
 
-pub fn print_to_console(msg: &str, is_cmd: bool) {
+pub fn print_to_console(msg: &str, is_cmd: bool) -> Result<(), ShellError> {
+    // if is_interrupted() {
+    //     return Err(ShellError::Interrupted {
+    //         span: Span::unknown(),
+    //     });
+    // }
     if let Some(mutex) = CONSOLE_CALLBACK.get() {
         if let Ok(guard) = mutex.lock() {
             if let Some(cb) = guard.as_ref() {
···
             }
         }
     }
+    Ok(())
 }
 
 pub fn current_time() -> Option<SystemTime> {
     UNIX_EPOCH.checked_add(Duration::from_millis(js_sys::Date::now() as u64))
 }
+
+use js_sys::Int32Array;
+use std::cell::RefCell;
+
+// We use thread_local storage because the Wasm worker is single-threaded.
+// This holds the reference to the SharedArrayBuffer view passed from JS.
+thread_local! {
+    pub static INTERRUPT_BUFFER: RefCell<Option<Int32Array>> = RefCell::new(None);
+}
+
+/// Called from JS to pass the SharedArrayBuffer view
+#[wasm_bindgen]
+pub fn set_interrupt_buffer(buffer: Int32Array) {
+    INTERRUPT_BUFFER.with(|b| {
+        *b.borrow_mut() = Some(buffer);
+    });
+}
+
+/// Call this function periodically in your long-running loops!
+/// Returns `true` if an interrupt was requested.
+pub fn check_interrupt() -> bool {
+    INTERRUPT_BUFFER.with(|b| {
+        if let Some(buffer) = b.borrow().as_ref() {
+            // Check index 0. If it's 1, an interrupt occurred.
+            // We use Atomics to ensure we see the value written by the main thread.
+            match js_sys::Atomics::load(buffer, 0) {
+                Ok(1) => true,
+                _ => false,
+            }
+        } else {
+            false
+        }
+    })
+}
+
+pub fn set_interrupt(value: bool) {
+    INTERRUPT_BUFFER.with(|b| {
+        if let Some(buffer) = b.borrow().as_ref() {
+            let _ = js_sys::Atomics::store(buffer, 0, value as i32);
+        }
+    });
+}
+
+pub struct InterruptBool;
+
+impl Signal for InterruptBool {
+    #[inline]
+    fn get(&self) -> bool {
+        check_interrupt()
+    }
+    #[inline]
+    fn set(&self, value: bool) {
+        set_interrupt(value);
+    }
+}

src/lib.rs

···
 use jacquard::chrono;
 use miette::Report;
+use nu_cmd_base::hook::eval_hook;
 use nu_cmd_extra::add_extra_command_context;
 use nu_cmd_lang::create_default_context;
 use nu_engine::{command_prelude::*, eval_block};
 use nu_parser::{FlatShape, TokenContents, flatten_block, lex, parse};
 use nu_protocol::{
-    Config, ListStream, PipelineData, Span,
+    Config, ListStream, PipelineData, Signals, Span,
     engine::{Call, EngineState, Stack, StateWorkingSet},
 };
 use serde::Serialize;
 use std::{
     io::Cursor,
+    path::PathBuf,
     sync::{Arc, Mutex, OnceLock},
     time::UNIX_EPOCH,
 };
···
     },
     default_context::add_shell_command_context,
     error::format_error,
-    globals::{apply_pending_deltas, current_time, get_pwd, print_to_console},
+    globals::{
+        InterruptBool, apply_pending_deltas, current_time, get_pwd, print_to_console, set_interrupt,
+    },
 };
 use error::CommandError;
 use globals::get_vfs;
 
+#[wasm_bindgen]
+extern "C" {
+    #[wasm_bindgen(js_namespace = console)]
+    fn error(msg: String);
+
+    type Error;
+
+    #[wasm_bindgen(constructor)]
+    fn new() -> Error;
+
+    #[wasm_bindgen(structural, method, getter)]
+    fn stack(error: &Error) -> String;
+}
+
+fn panic_hook(info: &std::panic::PanicHookInfo) {
+    let mut msg = info.to_string();
+
+    msg.push_str("\n\nStack:\n\n");
+    let e = Error::new();
+    let stack = e.stack();
+    msg.push_str(&stack);
+    msg.push_str("\n\n");
+
+    let _ = print_to_console(&msg, false);
+}
+
 static ENGINE_STATE: OnceLock<Mutex<EngineState>> = OnceLock::new();
 static STACK: OnceLock<Mutex<Stack>> = OnceLock::new();
 
···
     let mut config = Config::default();
     config.use_ansi_coloring = true.into();
     config.show_banner = nu_protocol::BannerKind::Full;
+    config.hooks.display_output = Some("table".into_value(Span::unknown()));
     engine_state.config = Arc::new(config);
+
+    engine_state.set_signals(Signals::new(Arc::new(InterruptBool)));
 
     ENGINE_STATE
         .set(Mutex::new(engine_state))
···
 
 #[wasm_bindgen]
 pub fn init_engine() -> String {
-    console_error_panic_hook::set_once();
+    std::panic::set_hook(Box::new(panic_hook));
     init_engine_internal().map_or_else(|err| format!("error: {err}"), |_| String::new())
 }
 
···
         error: Report::new(e),
         start_offset: 0,
     })?;
-    // set PWD
-    engine_state.add_env_var(
-        "PWD".to_string(),
-        get_pwd_string().into_value(Span::unknown()),
-    );
+    let pwd = get_pwd_string().into_value(Span::unknown());
+    engine_state.add_env_var("PWD".to_string(), pwd.clone());
 
     let mut working_set = StateWorkingSet::new(engine_state);
     let start_offset = working_set.next_span_start();
···
         x => x,
     };
 
-    // TODO: idk what this does i copied it from PipelineData::print_table
-    // dunno if it matters, we can just use nu_command::Table and it works fine i think
-    let table_command = engine_state
-        .table_decl_id
-        .map(|decl_id| engine_state.get_decl(decl_id))
-        .filter(|command| command.block_id().is_some())
-        .unwrap_or(&nu_command::Table);
-    let call = Call::new(pipeline_data.span().unwrap_or_else(Span::unknown));
-
-    let res = table_command
-        .run(engine_state, stack, &call, pipeline_data)
-        .map_err(cmd_err)?;
+    let conf = stack.get_config(engine_state);
+    let hook = conf.hooks.display_output.as_ref();
+    let res = eval_hook(
+        engine_state,
+        stack,
+        Some(pipeline_data),
+        vec![],
+        hook.unwrap(),
+        "display_output",
+    )
+    .map_err(cmd_err)?;
 
     match res {
         PipelineData::Empty => {}
         PipelineData::Value(v, _) => {
             print_to_console(&v.to_expanded_string("\n", &engine_state.config), true)
+                .map_err(cmd_err)?;
         }
         PipelineData::ByteStream(s, _) => {
             for line in s.lines().into_iter().flatten() {
                 let out = line.map_err(cmd_err)?; // TODO: do we turn this into a Value ??? or is returning err fine
-                print_to_console(&out, true);
+                print_to_console(&out, true).map_err(cmd_err)?;
             }
         }
         PipelineData::ListStream(s, _) => {
             for item in s.into_iter() {
-                let out = item.to_expanded_string("\n", &engine_state.config);
-                print_to_console(&out, true);
+                let out = item
+                    .unwrap_error()
+                    .map_err(cmd_err)?
+                    .to_expanded_string("\n", &engine_state.config);
+                print_to_console(&out, true).map_err(cmd_err)?;
             }
         }
     }
···
         STACK.get().unwrap().lock().expect("stack initialized"),
     );
 
+    set_interrupt(false);
     match run_command_internal(&mut engine_guard, &mut stack_guard, input) {
         Ok(_) => None,
         Err(cmd_err) => Some(format_error(
···
     }
     pwd.as_str().to_string()
 }
+
+pub fn get_pwd_buf() -> PathBuf {
+    // web_sys::console::log_1(&"before pwd".into());
+    let pwd = get_pwd();
+    // web_sys::console::log_1(&"after pwd".into());
+    if pwd.is_root() {
+        return PathBuf::new().join("/");
+    }
+    pwd.as_str().into()
+}

www/src/main.ts

···
 type SearchState = "history" | "completion" | "none";
 
 async function bootstrap() {
+  const sab = new SharedArrayBuffer(4);
+  const interruptBuffer = new Int32Array(sab);
+
   // Instantiate the worker using the imported class
   const worker = new DysnomiaWorker();
 
···
         break;
 
       case "\u0003": // Ctrl+C
+        Atomics.store(interruptBuffer, 0, 1);
         currentLine = "";
         cursorPos = 0;
         completionCandidates = [];
···
 
   await readyPromise;
 
+  await callWorker("set-interrupt-buffer", interruptBuffer);
   await callWorker("run", "open welcome.txt");
 
   term.write(getPrompt());

www/src/worker.ts

···
   get_pwd_string,
   register_console_callback,
   register_task_count_callback,
+  set_interrupt_buffer,
 } from "../../pkg";
 
 // Initialize WASM
···
   try {
     let result;
     switch (type) {
+      case "set-interrupt-buffer":
+        set_interrupt_buffer(payload);
+        break;
       case "run":
         result = run_command(payload);
         break;

www/vite.config.ts

···
     fs: {
       allow: [".."],
     },
+    cors: true,
+    headers: {
+      "Cross-Origin-Embedder-Policy": "require-corp",
+      "Cross-Origin-Opener-Policy": "same-origin",
+    },
   },
 });