Add support for snoop debugging in Python

Author: winniederidder

src/BackendEvent.ts

@@ -8,7 +8,8 @@ export enum BackendEventType {
     Output = "output",
     Sleep = "sleep",
     Error = "error",
-    Interrupt = "interrupt"
+    Interrupt = "interrupt",
+    Debug = "debug"
 }
 /**
  * All possible types for ease of iteration
@@ -17,7 +18,7 @@ export const BACKEND_EVENT_TYPES = [
     BackendEventType.Start, BackendEventType.End,
     BackendEventType.Input, BackendEventType.Output,
     BackendEventType.Sleep, BackendEventType.Error,
-    BackendEventType.Interrupt
+    BackendEventType.Interrupt, BackendEventType.Debug
 ];
 /**
  * Interface for events used for communication between threads

src/OutputManager.ts

@@ -48,6 +48,7 @@ export class OutputManager {
     constructor() {
         BackendManager.subscribe(BackendEventType.Start, () => this.reset());
         BackendManager.subscribe(BackendEventType.Output, e => this.showOutput(e));
+        BackendManager.subscribe(BackendEventType.Debug, e => this.showOutput(e));
         BackendManager.subscribe(BackendEventType.Error, e => this.showError(e));
         this.options = { parentElementId: "" };
     }

src/util/Util.ts

@@ -78,7 +78,7 @@ export interface ButtonOptions {
      */
     buttonText: string;
     /**
-     * Optional classes to apply to the button
+     * Optional Tailwind classes to apply to the button
      */
     extraClasses?: string;
 }

src/workers/python/PythonWorker.worker.ts

@@ -55,12 +55,20 @@ class PythonWorker extends Backend<PyodideExtras> {
         );
     }
 
-    async runCode(extras: PyodideExtras, code: string): Promise<any> {
+    override runModes(): string[] {
+        return [...super.runModes(), "snoop"];
+    }
+
+    async runCode(extras: PyodideExtras, code: string, mode = "exec"): Promise<any> {
         this.extras = extras;
         if (extras.interruptBuffer) {
             this.pyodide.setInterruptBuffer(extras.interruptBuffer);
         }
-        await this.papyros.run_async(code);
+        await this.papyros.run_async.callKwargs({
+            source_code: code,
+            mode: mode,
+            snoop_config: { color: false }
+        });
     }
 
     override async autocomplete(context: WorkerAutocompleteContext):

src/workers/python/build_package.py

@@ -46,4 +46,4 @@ def check_tar(tarname):
 
 
 if __name__ == "__main__":
-    create_package("python_package", "python-runner friendly_traceback jedi", extra_deps="papyros")
+    create_package("python_package", "python-runner friendly_traceback jedi snoop", extra_deps="papyros")

src/workers/python/papyros/papyros.py

@@ -47,7 +47,8 @@ def cb(typ, dat, contentType=None, **kwargs):
                         # Do not display values entered by user for input
                         continue
                     else:
-                        cb("output", part["text"], contentType=part.get("contentType"))
+                        ev_type = "debug" if typ in ["snoop"] else "output"
+                        cb(ev_type, part["text"], contentType=part.get("contentType"))
             elif event_type == "input":
                 return cb("input", data["prompt"])
             elif event_type == "sleep":
@@ -94,17 +95,17 @@ async def install_imports(self, source_code, ignore_missing=True):
             if not ignore_missing:
                 raise
 
-    def pre_run(self, source_code, mode="exec", top_level_await=False):
+    def pre_run(self, source_code, mode="exec", top_level_await=True):
         self.override_globals()
         return super().pre_run(source_code, mode=mode, top_level_await=top_level_await)
 
-    async def run_async(self, source_code, mode="exec", top_level_await=True):
+    async def run_async(self, source_code, mode="exec", top_level_await=True, snoop_config=None):
         with self._execute_context():
             try:
                 await self.install_imports(source_code, ignore_missing=False)
                 code_obj = self.pre_run(source_code, mode=mode, top_level_await=top_level_await)
                 if code_obj:
-                    result = self.execute(code_obj, mode)
+                    result = self.execute(code_obj, mode=mode, snoop_config=to_py(snoop_config))
                     while isinstance(result, Awaitable):
                         result = await result
                     return result

src/workers/python/python_package.tar.gz.load_by_url

@@ -86,6 +86,7 @@ module.exports = function (webpackEnv, argv) {
 		devServer: {
 			static: path.join(__dirname, PUBLIC_DIR),
 			port: DEVELOPMENT_PORT,
+			hot: false // Many things in the workers cannot be replaced in a hot fashion
 		},
 	}
 };