update node version (v18, v20, v22)

packages/ws-worker/src/channels/worker-queue.ts

@@ -3,10 +3,10 @@ import { Socket as PhxSocket } from 'phoenix';
 import { WebSocket } from 'ws';
 import { API_VERSION } from '@openfn/lexicon/lightning';
 import generateWorkerToken from '../util/worker-token';
+import version from '../util/load-version';
 
 import type { Logger } from '@openfn/logger';
 import type { Channel } from '../types';
-import loadVersions from '../util/load-versions';
 
 const connectToWorkerQueue = (
   endpoint: string,
@@ -22,7 +22,7 @@ const connectToWorkerQueue = (
     const params = {
       token,
       api_version: API_VERSION,
-      worker_version: loadVersions().engine,
+      worker_version: version,
     };
 
     // @ts-ignore ts doesn't like the constructor here at all

packages/ws-worker/src/events/run-start.ts

@@ -7,7 +7,7 @@ import { sendEvent, Context, onJobLog } from '../api/execute';
 import calculateVersionString from '../util/versions';
 
 import { timeInMicroseconds } from '../util';
-import loadVersions from '../util/load-versions';
+import version from '../util/load-version';
 
 export default async function onRunStart(
   context: Context,
@@ -31,7 +31,7 @@ export default async function onRunStart(
   };
 
   const versions = {
-    worker: loadVersions().engine,
+    worker: version,
     ...event.versions,
   };
 

packages/ws-worker/src/util/load-version.ts

@@ -0,0 +1,12 @@
+import fs from 'fs';
+import path from 'node:path';
+import { fileURLToPath } from 'node:url';
+
+const pkg = JSON.parse(
+  fs.readFileSync(
+    path.join(fileURLToPath(import.meta.url), '../../../package.json'),
+    'utf-8'
+  )
+);
+
+export default pkg.version;

packages/ws-worker/test/channels/worker-queue.test.ts

@@ -5,7 +5,7 @@ import { API_VERSION } from '@openfn/lexicon/lightning';
 
 import connectToWorkerQueue from '../../src/channels/worker-queue';
 import { MockSocket } from '../../src/mock/sockets';
-import loadVersions from '../../src/util/load-versions';
+import loadVersions from '../../src/util/load-version';
 
 const logger = createMockLogger();
 

packages/ws-worker/test/events/run-start.test.ts

@@ -7,7 +7,7 @@ import { createRunState } from '../../src/util';
 import { RUN_LOG, RUN_START } from '../../src/events';
 
 import { timestamp } from '@openfn/logger';
-import loadVersions from '../../src/util/load-versions';
+import version from '../../src/util/load-version';
 
 test('should include a timestamp', async (t) => {
   const plan = {
@@ -69,7 +69,7 @@ test('run:start event should include versions', async (t) => {
     [RUN_START]: (evt) => {
       t.deepEqual(evt.versions, {
         ...versions,
-        worker: loadVersions().engine,
+        worker: version,
       });
       return true;
     },
@@ -91,12 +91,18 @@ test('run:start should log the version number', async (t) => {
   const input = 'abc';
   const jobId = 'job-1';
 
+  // explicitly load package.json her
+  // because load-version does it a bit differently
+  const { default: pkg } = await import('../../package.json', {
+    with: { type: 'json' },
+  });
+
   const versions = {
     node: process.version.substring(1),
     engine: '1.0.0',
     compiler: '1.0.0',
     runtime: '1.0.0',
-    worker: loadVersions().engine,
+    worker: pkg.version,
     '@openfn/language-common': ['1.0.0'],
   };
 
@@ -130,4 +136,5 @@ test('run:start should log the version number', async (t) => {
   // This just a light test of the string to make sure it's here
   // It uses src/util/versions, which is tested elsewhere
   t.regex(message, /(node\.js).+(worker).+(@openfn\/language-common)/is);
+  t.regex(message, new RegExp(`worker(\\s+)${pkg.version}`, 'is'));
 });