fix(browser-repl)!: keep operation in progress COMPASS-8576 MONGOSH-1966

packages/browser-repl/README.md

@@ -31,14 +31,20 @@ const runtime = new IframeRuntime(serviceProvider);
 Shell is a React component with the following properties:
 
 - `runtime: Runtime`: The runtime used to evaluate code.
-- `onOutputChanged?: (output: readonly ShellOutputEntry[]) => void`: A function called each time the output changes with an array of `ShellOutputEntryes`.
-- `onHistoryChanged?: (history: readonly string[]) => void`: A function called each time the history changes with an array of history entries ordered from the most recent to the oldest entry.
+- `onOutputChanged?: (output: ShellOutputEntry[]) => void`: A function called each time the output changes with an array of `ShellOutputEntries`.
+- `onHistoryChanged?: (history: string[]) => void`: A function called each time the history changes with an array of history entries ordered from the most recent to the oldest entry.
+- `onEditorChanged?: (editor: EditorRef | null) => void`: A function called each time the editor ref changes. Can be used to call editor methods.
+- `onOperationStarted?: () => void`: A function called when an operation has begun.
+- `onOperationEnd?: () => void`: A function called when an operation has completed (both error and success).
 - `redactInfo?: boolean`: If set, the shell will omit or redact entries containing sensitive info from history. Defaults to `false`.
 - `maxOutputLength?: number`: The maxiumum number of lines to keep in the output. Defaults to `1000`.
 - `maxHistoryLength?: number`: The maxiumum number of lines to keep in the history. Defaults to `1000`.
-- `initialOutput?: readonly ShellOutputEntry[]`: An array of entries to be displayed in the output area. Can be used to restore the output between sessions, or to setup a greeting message. **Note**: new entries will not be appended to the array.
-- `initialHistory?: readonly string[]`: An array of history entries to prepopulate the history.
+- `initialEvaluate?: string|string[]`: A set of input strings to evaluate right after shell is mounted.
+- `inputText?: string`: Initial text for the input field.
+- `output?: ShellOutputEntry[]`: An array of entries to be displayed in the output area. Can be used to restore the output between sessions, or to setup a greeting message. **Note**: new entries will not be appended to the array.
+- `history?: readonly string[]`: An array of history entries to prepopulate the history.
   Can be used to restore the history between sessions. Entries must be ordered from the most recent to the oldest. Note: new entries will not be appended to the array.
+- `isOperationInProgress?: boolean`: Can be used to restore the value between sessions.
 
 ### `ShellOutputEntry`
 

packages/browser-repl/package.json

@@ -35,7 +35,8 @@
     "depcheck": "depcheck",
     "compile": "tsc -p tsconfig.json",
     "prettier": "prettier",
-    "reformat": "npm run prettier -- --write . && npm run eslint --fix"
+    "reformat": "npm run prettier -- --write . && npm run eslint --fix",
+    "sync-to-compass": "node scripts/sync-to-compass.js"
   },
   "config": {
     "unsafe-perm": true

packages/browser-repl/scripts/sync-to-compass.js

@@ -0,0 +1,73 @@
+/* eslint-disable no-console */
+'use strict';
+const fs = require('fs');
+const path = require('path');
+const child_process = require('child_process');
+const { debounce } = require('lodash');
+
+if (!process.env.COMPASS_HOME) {
+  throw new Error('Missing required environment variable $COMPASS_HOME.');
+}
+
+const packageDir = path.resolve(__dirname, '..');
+const srcDir = path.resolve(__dirname, '..', 'src');
+const libDir = path.resolve(__dirname, '..', 'lib');
+
+const destDir = path.dirname(
+  child_process.execFileSync(
+    'node',
+    ['-e', "console.log(require.resolve('@mongosh/browser-repl'))"],
+    { cwd: process.env.COMPASS_HOME, encoding: 'utf-8' }
+  )
+);
+
+console.log({ packageDir, srcDir, libDir, destDir });
+
+const compileAndCopy = debounce(
+  function () {
+    try {
+      child_process.execFileSync('npm', ['run', 'compile'], {
+        cwd: packageDir,
+      });
+    } catch (err) {
+      if (err.code) {
+        // Spawning child process failed
+        console.error(err.code);
+      } else {
+        // Child was spawned but exited with non-zero exit code
+        // Error contains any stdout and stderr from the child
+        const { stdout, stderr } = err;
+
+        console.log(stdout.toString());
+        console.error(stderr.toString());
+      }
+    }
+    fs.cpSync(libDir, destDir, { recursive: true });
+    console.log('done.');
+  },
+  1_000,
+  {
+    leading: true,
+    trailing: true,
+  }
+);
+
+const srcWatcher = fs.watch(
+  srcDir,
+  { recursive: true },
+  function (eventType, filename) {
+    console.log(eventType, filename);
+    compileAndCopy();
+  }
+);
+
+function cleanup() {
+  srcWatcher.close();
+}
+
+for (const evt of ['SIGINT', 'SIGTERM']) {
+  process.on(evt, cleanup);
+}
+
+// do an initial copy on startup
+compileAndCopy();

packages/browser-repl/src/components/shell-input.tsx

@@ -110,10 +110,12 @@ export class ShellInput extends Component<ShellInputProps, ShellInputState> {
 
   private onEnter = async (): Promise<void> => {
     if (this.props.onInput) {
-      await this.props.onInput(this.state.currentValue);
+      const value = this.state.currentValue;
+      // clear the value before evaluating the input because it could take a
+      // long time
+      this.setState({ currentValue: '' });
+      await this.props.onInput(value);
     }
-
-    this.setState({ currentValue: '' });
   };
 
   render(): JSX.Element {