Update to TS SDK 1.9 (#328)

Author: mjameswh

.scripts/copy-shared-files.mjs

@@ -1,4 +1,6 @@
 // Run with https://github.com/google/zx
+const { readFileSync } = require('fs');
+
 const STORED_SAMPLES = new Set(require('./list-of-samples.json').samples);
 
 const yaml = require('yaml');
@@ -180,8 +182,10 @@ testProjectsNode.value.items = [];
 lintProjectsNode.value.items = [];
 
 for (const sample of samples) {
-  const hasTestScript = !!require(`../${sample}/package.json`).scripts.test;
-  const hasLintScript = !!require(`../${sample}/package.json`).scripts.lint;
+  // Don't use require, because it won't work with ESM samples
+  const packageJson = JSON.parse(readFileSync(`../${sample}/package.json`));
+  const hasTestScript = !!packageJson.scripts.test;
+  const hasLintScript = !!packageJson.scripts.lint;
 
   if (hasTestScript) {
     testProjectsNode.value.items.push(sample);

activities-cancellation-heartbeating/README.md

@@ -13,7 +13,7 @@ Running [`src/client.ts`](./src/client.ts) does this:
   - The `fakeProgress` activity starts and heartbeats
 - Waits 40s
 - Uses the handle to `cancel()` the workflow
-  - The activity's `Context.current().sleep` receives the cancellation signal and throws a `CancelledFailure` for you to handle
+  - The activity's `sleep` receives the cancellation signal and throws a `CancelledFailure` for you to handle
   - Activity catches the `CancelledFailure` which you can check with `isCancellation(err)`
     - Prints `Fake progress activity cancelled` in the Worker terminal
   - Workflow prints `Workflow cancelled along with its activity` in the Worker terminal

activities-cancellation-heartbeating/package.json

@@ -20,10 +20,10 @@
     ]
   },
   "dependencies": {
-    "@temporalio/activity": "^1.8.4",
-    "@temporalio/client": "^1.8.4",
-    "@temporalio/worker": "^1.8.4",
-    "@temporalio/workflow": "^1.8.4"
+    "@temporalio/activity": "^1.9.0",
+    "@temporalio/client": "^1.9.0",
+    "@temporalio/worker": "^1.9.0",
+    "@temporalio/workflow": "^1.9.0"
   },
   "devDependencies": {
     "@tsconfig/node16": "^1.0.0",

activities-cancellation-heartbeating/src/activities.ts

@@ -1,11 +1,10 @@
 // @@@SNIPSTART typescript-activity-fake-progress
-import { CancelledFailure, Context } from '@temporalio/activity';
+import { activityInfo, log, sleep, CancelledFailure, heartbeat } from '@temporalio/activity';
 
 export async function fakeProgress(sleepIntervalMs = 1000): Promise<void> {
-  const { log, info, sleep, heartbeat } = Context.current();
   try {
     // allow for resuming from heartbeat
-    const startingPoint = info.heartbeatDetails || 1;
+    const startingPoint = activityInfo().heartbeatDetails || 1;
     log.info('Starting activity at progress', { startingPoint });
     for (let progress = startingPoint; progress <= 100; ++progress) {
       // simple utility to sleep in activity for given interval or throw if Activity is cancelled

activities-dependency-injection/package.json

@@ -20,10 +20,10 @@
     ]
   },
   "dependencies": {
-    "@temporalio/activity": "^1.8.4",
-    "@temporalio/client": "^1.8.4",
-    "@temporalio/worker": "^1.8.4",
-    "@temporalio/workflow": "^1.8.4"
+    "@temporalio/activity": "^1.9.0",
+    "@temporalio/client": "^1.9.0",
+    "@temporalio/worker": "^1.9.0",
+    "@temporalio/workflow": "^1.9.0"
   },
   "devDependencies": {
     "@tsconfig/node16": "^1.0.0",

activities-examples/package.json

@@ -24,16 +24,16 @@
     ]
   },
   "dependencies": {
-    "@temporalio/activity": "^1.8.4",
-    "@temporalio/client": "^1.8.4",
-    "@temporalio/worker": "^1.8.4",
-    "@temporalio/workflow": "^1.8.4",
+    "@temporalio/activity": "^1.9.0",
+    "@temporalio/client": "^1.9.0",
+    "@temporalio/worker": "^1.9.0",
+    "@temporalio/workflow": "^1.9.0",
     "axios": "^0.26.0",
     "node-fetch": "2.x"
   },
   "devDependencies": {
-    "@temporalio/nyc-test-coverage": "^1.8.4",
-    "@temporalio/testing": "^1.8.4",
+    "@temporalio/nyc-test-coverage": "^1.9.0",
+    "@temporalio/testing": "^1.9.0",
     "@tsconfig/node16": "^1.0.0",
     "@types/jest": "^27.5.1",
     "@types/mocha": "8.x",

activities-examples/src/activities/async-completion.ts

@@ -1,9 +1,9 @@
 // @@@SNIPSTART typescript-activity-complete-async
-import { CompleteAsyncError, Context } from '@temporalio/activity';
+import { CompleteAsyncError, activityInfo } from '@temporalio/activity';
 import { AsyncCompletionClient } from '@temporalio/client';
 
 export async function doSomethingAsync(): Promise<string> {
-  const taskToken = Context.current().info.taskToken;
+  const taskToken = activityInfo().taskToken;
   setTimeout(() => doSomeWork(taskToken), 1000);
   throw new CompleteAsyncError();
 }

activities-examples/src/activities/cancellable-fetch.ts

@@ -1,10 +1,10 @@
 // @@@SNIPSTART typescript-activity-cancellable-fetch
 import fetch from 'node-fetch';
-import { Context } from '@temporalio/activity';
+import { cancellationSignal, heartbeat } from '@temporalio/activity';
 import type { AbortSignal as FetchAbortSignal } from 'node-fetch/externals';
 
 export async function cancellableFetch(url: string): Promise<Uint8Array> {
-  const response = await fetch(url, { signal: Context.current().cancellationSignal as FetchAbortSignal });
+  const response = await fetch(url, { signal: cancellationSignal() as FetchAbortSignal });
   const contentLengthHeader = response.headers.get('Content-Length');
   if (contentLengthHeader === null) {
     throw new Error('expected Content-Length header to be set');
@@ -19,7 +19,7 @@ export async function cancellableFetch(url: string): Promise<Uint8Array> {
     }
     bytesRead += chunk.length;
     chunks.push(chunk);
-    Context.current().heartbeat(bytesRead / contentLength);
+    heartbeat(bytesRead / contentLength);
   }
   return Buffer.concat(chunks);
 }

activities-examples/src/mocha/workflows.test.ts

@@ -23,7 +23,7 @@ describe('example workflow', async function () {
   before(async function () {
     // Filter INFO log messages for clearer test output
     Runtime.install({ logger: new DefaultLogger('WARN') });
-    const env = await TestWorkflowEnvironment.createTimeSkipping();
+    const env = await TestWorkflowEnvironment.createLocal();
 
     const worker = await Worker.create(
       workflowCoverage.augmentWorkerOptions({

activities-examples/src/workflows.test.ts

@@ -15,7 +15,7 @@ beforeAll(async () => {
     logger: new DefaultLogger('WARN', (entry: LogEntry) => console.log(`[${entry.level}]`, entry.message)),
   });
 
-  testEnv = await TestWorkflowEnvironment.createTimeSkipping();
+  testEnv = await TestWorkflowEnvironment.createLocal();
 });
 
 afterAll(async () => {