chore: wip

Author: chrisbbreuer

packages/bun-queue/src/dead-letter-queue.ts

@@ -107,16 +107,16 @@ export class DeadLetterQueue<T = any> {
           // Convert array to object
           const jobObj: Record<string, string> = {}
           for (let i = 0; i < jobData.length; i += 2) {
-            jobObj[jobData[i]] = jobData[i + 1]
+            jobObj[jobData[i] as string] = jobData[i + 1] as string
           }
 
           // Create job instance
           const job = new Job<T>(this.queue, jobId as string)
-          job.data = JSON.parse(jobObj.data || '{}')
+          job.data = JSON.parse(jobObj.data || '{}') as T
           job.name = jobObj.originalQueue
           job.timestamp = Number.parseInt(jobObj.timestamp || '0', 10)
           job.attemptsMade = Number.parseInt(jobObj.attemptsMade || '0', 10)
-          job.stacktrace = JSON.parse(jobObj.stacktrace || '[]')
+          job.stacktrace = JSON.parse(jobObj.stacktrace || '[]') as string[]
           job.failedReason = jobObj.failedReason
 
           jobs.push(job)
@@ -149,11 +149,11 @@ export class DeadLetterQueue<T = any> {
       // Convert array to object
       const jobObj: Record<string, string> = {}
       for (let i = 0; i < jobData.length; i += 2) {
-        jobObj[jobData[i]] = jobData[i + 1]
+        jobObj[jobData[i] as string] = jobData[i + 1] as string
       }
 
       // Parse job data
-      const data = JSON.parse(jobObj.data || '{}')
+      const data = JSON.parse(jobObj.data || '{}') as T
       const queueName = jobObj.originalQueue
 
       // Add job back to original queue

packages/bun-queue/src/job-base.ts

@@ -191,7 +191,7 @@ export abstract class JobBase implements JobContract, Queueable, Dispatchable, I
       const jobData = {
         class: this.constructor.name,
         method: 'handle',
-        args: [],
+        args: [] as any[],
         job: this,
       }
 

packages/bun-queue/src/job.ts

@@ -48,7 +48,7 @@ export class Job<T = any> {
     // Convert array to object
     const jobObj: Record<string, string> = {}
     for (let i = 0; i < jobData.length; i += 2) {
-      jobObj[jobData[i]] = jobData[i + 1]
+      jobObj[jobData[i] as string] = jobData[i + 1] as string
     }
 
     const parsed = parseJob(jobObj)

packages/bun-queue/src/observable.ts

@@ -195,15 +195,15 @@ export class QueueObservable {
    * Get an observable by id
    */
   async getObservable(observableId: string): Promise<Observable | null> {
-    const data = await this.redisClient.send('HGETALL', [this.getObservableKey(observableId)])
+    const data = await this.redisClient.send('HGETALL', [this.getObservableKey(observableId)]) as Record<string, string> | null
 
     if (!data || Object.keys(data).length === 0) {
       return null
     }
 
     return {
       id: observableId,
-      queues: JSON.parse(data.queues || '[]'),
+      queues: JSON.parse(data.queues || '[]') as string[],
       interval: Number.parseInt(data.interval || '5000'),
       running: data.running === 'true',
     }

packages/bun-queue/src/queue.ts

@@ -1110,7 +1110,7 @@ export class Queue<T = any> {
       const jobData = {
         class: job.constructor.name,
         method: 'handle',
-        args: [],
+        args: [] as any[],
         job,
         batchId,
         batchIndex: index,

packages/bun-queue/src/work-coordinator.ts

@@ -192,7 +192,7 @@ export class WorkCoordinator {
       }
 
       // Update the heartbeat time
-      const instanceInfo = JSON.parse(instanceInfoJson)
+      const instanceInfo = JSON.parse(instanceInfoJson) as Record<string, any>
       instanceInfo.lastHeartbeat = Date.now()
 
       // Save updated info
@@ -239,10 +239,10 @@ export class WorkCoordinator {
           continue // Instance data missing
         }
 
-        const info = JSON.parse(infoJson)
+        const info = JSON.parse(infoJson) as Record<string, any>
 
         // Check if instance is still active (heartbeat not too old)
-        const lastHeartbeat = info.lastHeartbeat || 0
+        const lastHeartbeat = (info.lastHeartbeat as number) || 0
         if (Date.now() - lastHeartbeat > this.pollInterval * 3) {
           // Instance considered dead, remove it
           await this.redisClient.send('SREM', [instancesKey, instanceId])
@@ -252,8 +252,8 @@ export class WorkCoordinator {
 
         instanceInfo[instanceId] = info
         activeInstances.push(instanceId)
-        totalWorkers += info.workersAssigned || 0
-        totalMaxWorkers += info.maxWorkers || this.maxWorkersPerInstance
+        totalWorkers += (info.workersAssigned as number) || 0
+        totalMaxWorkers += (info.maxWorkers as number) || this.maxWorkersPerInstance
       }
 
       if (activeInstances.length === 0) {

packages/bun-queue/src/workers/queue-worker.ts

@@ -308,7 +308,7 @@ export class QueueWorker {
     if (this.isJobClass(jobData) && jobData.job.backoff) {
       const backoff = jobData.job.backoff
       if (Array.isArray(backoff)) {
-        return backoff[Math.min(queueJob.attemptsMade, backoff.length - 1)] * 1000
+        return (backoff[Math.min(queueJob.attemptsMade, backoff.length - 1)] as number) * 1000
       }
       return backoff * 1000
     }