chore: wip

Author: chrisbbreuer

.vscode/dictionary.txt

@@ -1,6 +1,8 @@
 antfu
+backoffs
 biomejs
 booleanish
+bullmq
 bumpp
 bunfig
 bunx

bun.lock

@@ -74,5 +74,11 @@
   },
   "lint-staged": {
     "*.{js,ts}": "bunx --bun eslint . --fix"
+  },
+  "dependencies": {
+    "@types/semver": "^7.7.0",
+    "ioredis": "^5.6.1",
+    "semver": "^7.7.1",
+    "uuid": "^11.1.0"
   }
 }

package.json

@@ -23,7 +23,7 @@ class LinkedList<T> {
       this.head = newNode
     }
     else {
-      this.tail.next = newNode
+      this.tail!.next = newNode
     }
 
     this.tail = newNode
@@ -37,7 +37,7 @@ class LinkedList<T> {
     }
     else {
       const head = this.head
-      this.head = this.head.next
+      this.head = this.head!.next
       this.length -= 1
 
       return head
@@ -91,7 +91,7 @@ export class AsyncFifoQueue<T> {
       .catch((err) => {
         // Ignore errors
         if (this.ignoreErrors) {
-          this.queue.push(undefined)
+          this.queue.push(undefined as unknown as T)
         }
         this.pending.delete(promise)
         this.rejectPromise(err)

src/classes/async-fifo-queue.ts

@@ -1,5 +1,6 @@
 import type { SandboxedOptions } from '../interfaces'
 import * as path from 'node:path'
+import process from 'node:process'
 import { Child } from './child'
 
 const CHILD_KILL_TIMEOUT = 30_000
@@ -31,11 +32,11 @@ export class ChildPool {
     let child = this.getFree(processFile).pop()
 
     if (child) {
-      this.retained[child.pid] = child
+      this.retained[child.pid as number] = child
       return child
     }
 
-    child = new Child(this.opts.mainFile, processFile, {
+    child = new Child(this.opts.mainFile!, processFile, {
       useWorkerThreads: this.opts.useWorkerThreads,
       workerForkOptions: this.opts.workerForkOptions,
       workerThreadsOptions: this.opts.workerThreadsOptions,
@@ -52,7 +53,7 @@ export class ChildPool {
         throw new Error('Child exited before it could be retained')
       }
 
-      this.retained[child.pid] = child
+      this.retained[child.pid as number] = child
 
       return child
     }
@@ -64,12 +65,12 @@ export class ChildPool {
   }
 
   release(child: Child): void {
-    delete this.retained[child.pid]
+    delete this.retained[child.pid as number]
     this.getFree(child.processFile).push(child)
   }
 
   remove(child: Child): void {
-    delete this.retained[child.pid]
+    delete this.retained[child.pid as number]
 
     const free = this.getFree(child.processFile)
 

src/classes/child-pool.ts

@@ -1,5 +1,6 @@
 import type { Receiver, SandboxedJob } from '../interfaces'
 import type { JobJsonSandbox, JobProgress } from '../types'
+import process from 'node:process'
 import { ParentCommand } from '../enums'
 import { errorToJSON } from '../utils'
 

src/classes/child-processor.ts

@@ -50,18 +50,18 @@ export class Child extends EventEmitter {
     super()
   }
 
-  get pid() {
+  get pid(): number | undefined {
     if (this.childProcess) {
       return this.childProcess.pid
     }
-    else if (this.worker) {
+
+    if (this.worker) {
       // Worker threads pids can become negative when they are terminated
       // so we need to use the absolute value to index the retained object
       return Math.abs(this.worker.threadId)
     }
-    else {
-      throw new Error('No child process or worker thread')
-    }
+
+    throw new Error('No child process or worker thread')
   }
 
   get exitCode() {

src/classes/child.ts

@@ -7,6 +7,8 @@ import type {
   Span,
   Tracer,
 } from './interfaces'
+import { Buffer } from 'node:buffer'
+import process from 'node:process'
 import { Cluster } from 'ioredis'
 import { CONNECTION_CLOSED_ERROR_MSG } from 'ioredis/built/utils'
 import * as semver from 'semver'
@@ -182,8 +184,7 @@ export function getParentKey(opts: {
   }
 }
 
-export const clientCommandMessageReg
-  = /ERR unknown command ['`]\s*client\s*['`]/
+export const clientCommandMessageReg = /ERR unknown command ['`]\s*client\s*['`]/
 
 export const DELAY_TIME_5 = 5000
 
@@ -284,7 +285,7 @@ export function toString(value: any): string {
   }
   if (
     typeof value == 'symbol'
-    || Object.prototype.toString.call(value) == '[object Symbol]'
+    || Object.prototype.toString.call(value) === '[object Symbol]'
   ) {
     return value.toString()
   }
@@ -373,7 +374,7 @@ export async function trace<T>(
         messageContext = span.setSpanOnContext(currentContext)
       }
 
-      if (callback.length == 2) {
+      if (callback.length === 2) {
         dstPropagationMetadata = contextManager.getMetadata(messageContext)
       }