fix(testing-sdk): fix errors when running as esm (#390)

*Issue #, if available:*

#387

*Description of changes:*

The testing SDK does not work in ESM due to a dependency on `__dirname`
which is CJS-only.

Solution:
- Adding ESM shims to the rollup config with `@rollup/plugin-esm-shim`.
This adds `__dirname`, `__filename`, and `require` as global variables
in our bundle (only `__dirname` is used currently).
- Fix the path to the worker file when running as ESM

Additional changes:
- Remove file system checking and use compile-time variables to
determine worker path
- Add step and wait example running as ESM (in local mode using vitest,
not yet running against the cloud)


By submitting this pull request, I confirm that you can use, modify,
copy, and redistribute this contribution, under the terms of your
choice.

Author: anthonyting

package-lock.json

@@ -34,6 +34,7 @@
     "@eslint/compat": "^1.3.0",
     "@eslint/js": "^9.29.0",
     "@microsoft/api-documenter": "^7.28.1",
+    "@rollup/plugin-esm-shim": "^0.1.8",
     "@rollup/plugin-json": "^6.1.0",
     "@rollup/plugin-typescript": "^12.1.4",
     "@tsconfig/node20": "^20.1.5",

package.json

@@ -16,9 +16,9 @@
       "types": "./dist/examples/*"
     },
     "./catalog": {
+      "types": "./dist/utils/examples-catalog.d.ts",
       "require": "./dist/examples-catalog.js",
-      "import": "./dist/examples-catalog.js",
-      "types": "./dist/utils/examples-catalog.d.ts"
+      "import": "./dist/examples-catalog.js"
     }
   },
   "scripts": {
@@ -37,13 +37,11 @@
     "copy-source": "mkdir -p build/source && cp -r src/examples/*.ts build/source/",
     "copy-catalog": "cp examples-catalog.json build/aws-durable-execution-sdk-js-examples/",
     "generate-sam-template": "tsx scripts/generate-sam-template.ts",
-    "test": "npm run unit-test",
+    "test": "jest && vitest run",
     "test:integration": "NODE_ENV=integration jest --config jest.config.integration.js",
     "pretest-with-sdk-coverage": "node scripts/copy-sdk-source.js",
     "test-with-sdk-coverage": "jest --config jest.config.sdk-coverage.js --collectCoverage",
     "coverage-to-csv": "node scripts/coverage-to-csv.js",
-    "unit-test": "jest --collectCoverage",
-    "unit-test-watch": "jest --watch",
     "prettier": "prettier --write './src/**/*.*' && prettier --write './test/**/*.*'"
   },
   "dependencies": {
@@ -74,7 +72,8 @@
     "ts-node": "^10.9.2",
     "tsx": "^4.20.6",
     "typescript": "^5.8.2",
-    "typescript-eslint": "^8.29.0"
+    "typescript-eslint": "^8.29.0",
+    "vitest": "^4.0.15"
   },
   "private": true
 }

packages/aws-durable-execution-sdk-js-examples/package.json

@@ -0,0 +1,32 @@
+import {
+  OperationType,
+  OperationStatus,
+  LocalDurableTestRunner,
+} from "@aws/durable-execution-sdk-js-testing";
+import { handler } from "./step-basic";
+import { beforeAll, afterAll, describe, expect, it } from "vitest";
+
+beforeAll(() => LocalDurableTestRunner.setupTestEnvironment());
+afterAll(() => LocalDurableTestRunner.teardownTestEnvironment());
+
+describe("step-basic", () => {
+  it("should execute step and return correct result with detailed verification", async () => {
+    const runner = new LocalDurableTestRunner({
+      handlerFunction: handler,
+    });
+
+    const execution = await runner.run();
+
+    // Get step operation
+    const stepOperation = runner.getOperationByIndex(0);
+
+    expect(execution.getOperations()).toHaveLength(1);
+    expect(execution.getResult()).toStrictEqual("step completed");
+
+    // Verify operation details
+    expect(stepOperation.getType()).toBe(OperationType.STEP);
+    expect(stepOperation.getStatus()).toBe(OperationStatus.SUCCEEDED);
+    expect(stepOperation.getStepDetails()).toBeDefined();
+    expect(stepOperation.getStepDetails()?.result).toEqual("step completed");
+  });
+});

packages/aws-durable-execution-sdk-js-examples/src/esm-examples/step/basic/step-basic.test.ts

@@ -0,0 +1,19 @@
+import {
+  DurableContext,
+  withDurableExecution,
+} from "@aws/durable-execution-sdk-js";
+import { ExampleConfig } from "../../../types";
+
+export const config: ExampleConfig = {
+  name: "Basic Step",
+  description: "Basic usage of context.step() to checkpoint a simple operation",
+};
+
+export const handler = withDurableExecution(
+  async (event: any, context: DurableContext) => {
+    const result = await context.step(async () => {
+      return "step completed";
+    });
+    return result;
+  },
+);

packages/aws-durable-execution-sdk-js-examples/src/esm-examples/step/basic/step-basic.ts

@@ -0,0 +1,42 @@
+import {
+  OperationType,
+  OperationStatus,
+  LocalDurableTestRunner,
+} from "@aws/durable-execution-sdk-js-testing";
+import { handler } from "./wait";
+import { beforeAll, afterAll, describe, expect, it } from "vitest";
+
+beforeAll(() =>
+  LocalDurableTestRunner.setupTestEnvironment({
+    skipTime: true,
+  }),
+);
+afterAll(() => LocalDurableTestRunner.teardownTestEnvironment());
+
+describe("wait", () => {
+  it("should call wait for 2 seconds with comprehensive verification", async () => {
+    const runner = new LocalDurableTestRunner({
+      handlerFunction: handler,
+    });
+
+    const execution = await runner.run();
+
+    // Get operation using runner helper
+    const waitOperation = runner.getOperationByIndex(0);
+
+    // Verify final result
+    expect(execution.getResult()).toBe("Function Completed");
+
+    // Verify operations were tracked
+    const completedOperations = execution.getOperations();
+    expect(completedOperations.length).toEqual(1);
+
+    // Verify operation data can be accessed
+    expect(waitOperation.getType()).toBe(OperationType.WAIT);
+    expect(waitOperation.getStatus()).toBe(OperationStatus.SUCCEEDED);
+    expect(waitOperation.getWaitDetails()?.waitSeconds).toBe(2);
+    expect(
+      waitOperation.getWaitDetails()?.scheduledEndTimestamp,
+    ).toBeInstanceOf(Date);
+  });
+});

packages/aws-durable-execution-sdk-js-examples/src/esm-examples/wait/basic/wait.test.ts

@@ -0,0 +1,20 @@
+import {
+  DurableContext,
+  withDurableExecution,
+} from "@aws/durable-execution-sdk-js";
+import { ExampleConfig } from "../../../types";
+import { log } from "../../../utils/logger";
+
+export const config: ExampleConfig = {
+  name: "Wait State",
+  description: "Basic usage of context.wait() to pause execution",
+};
+
+export const handler = withDurableExecution(
+  async (event: any, context: DurableContext) => {
+    log("Hello world before wait!");
+    await context.wait({ seconds: 2 });
+    log("Hello world after wait!");
+    return "Function Completed";
+  },
+);

packages/aws-durable-execution-sdk-js-examples/src/esm-examples/wait/basic/wait.ts

@@ -0,0 +1,7 @@
+import { defineConfig } from "vitest/config";
+
+export default defineConfig({
+  test: {
+    include: ["src/esm-examples/**/*.test.ts"],
+  },
+});

packages/aws-durable-execution-sdk-js-examples/vitest.config.ts

@@ -45,6 +45,7 @@
   "devDependencies": {
     "@eslint/compat": "^1.3.0",
     "@eslint/js": "^9.29.0",
+    "@rollup/plugin-replace": "^6.0.3",
     "@types/aws-lambda": "^8.10.150",
     "@types/morgan": "^1.9.10",
     "@types/sinonjs__fake-timers": "^15.0.1",