feat: replace threadedclass with comlink

package.json

@@ -90,13 +90,13 @@
   ],
   "dependencies": {
     "@julusian/freetype2": "^1.1.2",
+    "comlink": "npm:@superflytv/comlink@^4.4.2",
     "debug": "^4.3.4",
     "eventemitter3": "^4.0.7",
     "exit-hook": "^2.2.1",
     "nanotimer": "^0.3.15",
     "p-lazy": "^3.1.0",
     "p-queue": "^6.6.2",
-    "threadedclass": "^1.2.1",
     "tslib": "^2.6.2",
     "wavefile": "^8.4.6"
   },

src/__tests__/atem.spec.ts

@@ -1,5 +1,5 @@
 /* eslint-disable @typescript-eslint/unbound-method */
-import { Atem, DEFAULT_MAX_PACKET_SIZE, DEFAULT_PORT } from '../atem'
+import { Atem, DEFAULT_MAX_PACKET_SIZE } from '../atem'
 import { CutCommand } from '../commands'
 import { promisify } from 'util'
 import { EventEmitter } from 'events'
@@ -29,12 +29,9 @@ describe('Atem', () => {
 
 			expect(AtemSocket).toHaveBeenCalledTimes(1)
 			expect(AtemSocket).toHaveBeenCalledWith({
-				address: '',
-				childProcessTimeout: 600,
 				debugBuffers: false,
 				disableMultithreaded: true,
 				log: (conn as any)._log,
-				port: DEFAULT_PORT,
 				maxPacketSize: DEFAULT_MAX_PACKET_SIZE,
 			})
 		} finally {
@@ -50,12 +47,9 @@ describe('Atem', () => {
 
 			expect(AtemSocket).toHaveBeenCalledTimes(1)
 			expect(AtemSocket).toHaveBeenCalledWith({
-				address: 'test1',
-				childProcessTimeout: 600,
 				debugBuffers: true,
 				disableMultithreaded: false,
 				log: (conn as any)._log,
-				port: 23,
 				maxPacketSize: 500,
 			})
 		} finally {

src/__tests__/connection.spec.ts

@@ -2,7 +2,6 @@
 import { readFileSync } from 'fs'
 import { resolve } from 'path'
 import { AtemSocketChild } from '../lib/atemSocketChild'
-import { ThreadedClass } from 'threadedclass'
 import { BasicAtem } from '../atem'
 import { AtemState, InvalidIdError } from '../state'
 import { IDeserializedCommand } from '../commands'
@@ -58,8 +57,8 @@ function createConnection(): BasicAtem {
 	})
 }
 
-function getChild(conn: BasicAtem): ThreadedClass<AtemSocketChildMock> {
-	return (conn as any).socket._socketProcess
+function getChild(conn: BasicAtem): AtemSocketChildMock {
+	return (conn as any).socket._socketProcess.wrappedChild
 }
 
 function runTest(name: string, filename: string): void {
@@ -70,7 +69,7 @@ function runTest(name: string, filename: string): void {
 	describe(name, () => {
 		test(`Connection`, async () => {
 			const conn = createConnection()
-			await conn.connect('')
+			await conn.connect('127.0.0.1')
 
 			const child = getChild(conn)
 			expect(child).toBeTruthy()

src/atem.ts

@@ -60,6 +60,7 @@ export interface AtemOptions {
 	port?: number
 	debugBuffers?: boolean
 	disableMultithreaded?: boolean
+	/** @deprecated No longer user */
 	childProcessTimeout?: number
 	/**
 	 * Maximum size of packets to transmit
@@ -107,10 +108,7 @@ export class BasicAtem extends EventEmitter<AtemEvents> {
 		this._status = AtemConnectionStatus.CLOSED
 		this.socket = new AtemSocket({
 			debugBuffers: options?.debugBuffers ?? false,
-			address: options?.address || '',
-			port: options?.port || DEFAULT_PORT,
 			disableMultithreaded: options?.disableMultithreaded ?? false,
-			childProcessTimeout: options?.childProcessTimeout || 600,
 			maxPacketSize: options?.maxPacketSize ?? DEFAULT_MAX_PACKET_SIZE,
 		})
 		this.dataTransferManager = new DT.DataTransferManager(this.sendCommands.bind(this))