Branch remote runner plugin fixed

package.json

@@ -40,5 +40,8 @@
   "bugs": {
     "url": "https://github.com/source-academy/plugins/issues"
   },
-  "homepage": "https://github.com/source-academy/plugins#readme"
+  "homepage": "https://github.com/source-academy/plugins#readme",
+  "resolutions": {
+    "@sourceacademy/conductor": "^0.5.0"
+  }
 }

src/common/test/tsconfig.json

@@ -1,7 +1,7 @@
 {
   "extends": "../../tsconfig.json",
   "exclude": ["./dist"],
-  "include": ["./src"],
+  "include": ["./src", "../../runner/test/src/__tests__/runner.test.ts"],
   "compilerOptions": {
     "declaration": true,
     "outDir": "./dist",

src/runner/remoteExecution/index.ts

@@ -1,24 +1,2 @@
-import { CHANNEL_ID, RUNNER_ID, type PySlangMessage } from "@sourceacademy/common-test";
-import type { IPlugin, IChannel, IConduit } from "@sourceacademy/conductor/conduit";
-import { EV3Engine } from "py-slang/src/engines/ev3/EV3Engine";
-
-export class remoteRunnerPlugin implements IPlugin {
-  readonly id: string = RUNNER_ID;
-  static readonly channelAttach = [CHANNEL_ID];
-  private readonly __channel: IChannel<PySlangMessage>;
-  private readonly engine: EV3Engine;
-
-  // eslint-disable-next-line @typescript-eslint/no-explicit-any
-  constructor(_conduit: IConduit, [channel]: IChannel<any>[]) {
-    this.__channel = channel;
-    this.engine = new EV3Engine();
-
-    this.__channel.subscribe(async message => {
-      if (message.type === "run") {
-        const result = await this.engine.execute(message.code);
-        console.log("Engine response:", result);
-        this.__channel.send({ type: "result", output: JSON.stringify(result) });
-      }
-    });
-  }
-}
+export { RemoteExecutionPlugin } from "./src";
+export type { ConnectionStatus, ConnectionStatusMessage } from "./src";

src/runner/remoteExecution/package.json

@@ -22,20 +22,20 @@
     "build": "rollup -c",
     "prepack": "yarn build"
   },
-  "dependencies": {
-    "py-slang": "github:proto-aiken-13/py-slang#branch-ev3-engine"
-  },
   "peerDependencies": {
     "@sourceacademy/conductor": ">=0.3.0"
   },
   "devDependencies": {
+    "@rollup/plugin-commonjs": "^29.0.3",
     "@rollup/plugin-node-resolve": "^16.0.3",
     "@rollup/plugin-terser": "^1.0.0",
     "@rollup/plugin-typescript": "^12.3.0",
     "@sourceacademy/common-test": "workspace:*",
     "@sourceacademy/conductor": ">=0.3.0",
     "@vitest/coverage-istanbul": "^4.1.9",
-    "rollup": "^4.60.2",
+    "esbuild": "^0.28.1",
+    "rollup": "^4.62.2",
+    "rollup-plugin-esbuild": "^6.2.1",
     "tslib": "^2.8.1",
     "typescript": "^6.0.3",
     "vitest": "^4.1.9"

src/runner/remoteExecution/rollup.config.mjs

@@ -2,21 +2,13 @@ import nodeResolve from "@rollup/plugin-node-resolve";
 import terser from "@rollup/plugin-terser";
 import typescript from "@rollup/plugin-typescript";
 
-/**
- * @type {import('rollup').RollupOptions}
- */
-export default {
-  input: "src/index.ts",
-  external: id => id.includes("py-slang"),
-  output: [
-    {
-      file: "dist/index.cjs",
-      format: "cjs",
-    },
-    {
-      file: "dist/index.mjs",
-      format: "esm",
-    },
-  ],
-  plugins: [nodeResolve(), typescript(), terser()],
-};
+export default [
+  {
+    input: "src/index.ts",
+    output: [
+      { file: "dist/index.cjs", format: "cjs" },
+      { file: "dist/index.mjs", format: "esm" },
+    ],
+    plugins: [nodeResolve(), typescript(), terser()],
+  },
+];

src/runner/remoteExecution/src/index.ts

@@ -1 +1,25 @@
-export { remoteRunnerPlugin } from "../index";
+import {
+  CHANNEL_ID,
+  RUNNER_ID,
+  MESSAGE_TYPE_CONNECTION_STATUS,
+  type ConnectionStatusMessage,
+  type ConnectionStatus,
+} from "@sourceacademy/common-remote-execution";
+import type { IPlugin, IChannel, IConduit } from "@sourceacademy/conductor/conduit";
+
+export class RemoteExecutionPlugin implements IPlugin {
+  readonly id: string = RUNNER_ID;
+  static readonly channelAttach = [CHANNEL_ID];
+  private readonly __channel: IChannel<ConnectionStatusMessage>;
+
+  constructor(_conduit: IConduit, [channel]: IChannel<any>[]) {
+    if (!channel) {
+      throw new Error("Remote execution channel is required but was not provided.");
+    }
+    this.__channel = channel;
+  }
+
+  sendConnectionStatus(status: ConnectionStatus): void {
+    this.__channel.send({ type: MESSAGE_TYPE_CONNECTION_STATUS, status });
+  }
+}