resolves #99 pass version to the worker

.taprc

@@ -1,3 +1,4 @@
 jobs: 1
 check-coverage: false
-timeout: 60000
+# in seconds
+timeout: 60

index.js

@@ -1,5 +1,6 @@
 'use strict'
 
+const { version } = require('./package.json')
 const { EventEmitter } = require('events')
 const { Worker } = require('worker_threads')
 const { join } = require('path')
@@ -29,6 +30,7 @@ class FakeWeakRef {
 
 const FinalizationRegistry = global.FinalizationRegistry || class FakeFinalizationRegistry {
   register () {}
+
   unregister () {}
 }
 
@@ -55,7 +57,12 @@ function createWorker (stream, opts) {
         : pathToFileURL(filename).href,
       dataBuf: stream[kImpl].dataBuf,
       stateBuf: stream[kImpl].stateBuf,
-      workerData
+      workerData: {
+        $context: {
+          threadStreamVersion: version
+        },
+        ...workerData
+      }
     }
   })
 

test/context.test.js

@@ -0,0 +1,21 @@
+'use strict'
+
+const { test } = require('tap')
+const { join } = require('path')
+const ThreadStream = require('..')
+const { version } = require('../package.json')
+require('why-is-node-running')
+
+test('get context', (t) => {
+  const stream = new ThreadStream({
+    filename: join(__dirname, 'get-context.js'),
+    workerData: {},
+    sync: true
+  })
+  t.on('end', () => stream.end())
+  stream.on('context', (ctx) => {
+    t.same(ctx.threadStreamVersion, version)
+    t.end()
+  })
+  stream.write('hello')
+})

test/event.test.js

@@ -3,13 +3,15 @@
 const { test } = require('tap')
 const { join } = require('path')
 const ThreadStream = require('..')
+require('why-is-node-running')
 
-test('event propagate', function (t) {
+test('event propagate', (t) => {
   const stream = new ThreadStream({
     filename: join(__dirname, 'emit-event.js'),
     workerData: {},
     sync: true
   })
+  t.on('end', () => stream.end())
   stream.on('socketError', function (a, b, c, n, error) {
     t.same(a, 'list')
     t.same(b, 'of')
@@ -19,5 +21,4 @@ test('event propagate', function (t) {
     t.end()
   })
   stream.write('hello')
-  stream.end()
 })

test/get-context.js

@@ -0,0 +1,22 @@
+'use strict'
+
+const { Writable } = require('stream')
+const parentPort = require('worker_threads').parentPort
+
+async function run (opts) {
+  return new Writable({
+    autoDestroy: true,
+    write (chunk, enc, cb) {
+      if (parentPort) {
+        parentPort.postMessage({
+          code: 'EVENT',
+          name: 'context',
+          args: opts.$context
+        })
+      }
+      cb()
+    }
+  })
+}
+
+module.exports = run