lint

Author: i.galkin@timelesslounge.tech

eslint.config.mjs

@@ -1,9 +1,12 @@
 // @ts-check
 
-import eslint from '@eslint/js';
-import tseslint from 'typescript-eslint';
+import eslint from '@eslint/js'
+import tseslint from 'typescript-eslint'
 
 export default tseslint.config(
   eslint.configs.recommended,
   ...tseslint.configs.recommended,
-);
+  {
+    ignores: ['node_modules/**', 'dist/**'],
+  },
+)

package.json

@@ -3,6 +3,7 @@
   "version": "",
   "description": "Queue over Nats",
   "main": "dist/index.js",
+  "types": "dist/index.d.ts",
   "repository": "https://github.com/arusakov/node-nats-queue.git",
   "author": "Aleksandr Rusakov <aleksandr.s.rusakov@gmail.com>",
   "license": "MIT",
@@ -20,9 +21,6 @@
   },
   "devDependencies": {
     "@eslint/js": "9.11.0",
-    "@nats-io/jetstream": "3.0.2",
-    "@nats-io/nats-core": "3.0.2",
-    "@nats-io/transport-node": "3.0.2",
     "@types/eslint__js": "8.42.3",
     "@types/node": "22.0.0",
     "c8": "10.1.2",
@@ -35,6 +33,9 @@
     "node": ">=20.0.0"
   },
   "dependencies": {
-    "@nats-io/kv": "3.0.2"
+    "@nats-io/kv": "3.0.2",
+    "@nats-io/jetstream": "3.0.2",
+    "@nats-io/nats-core": "3.0.2",
+    "@nats-io/transport-node": "3.0.2"
   }
 }

src/index.ts

@@ -0,0 +1,4 @@
+export * from './flowQueue'
+export * from './queue'
+export * from './job'
+export * from './worker'

src/queue.ts

@@ -10,7 +10,7 @@ import { headers, nanos, NatsConnection } from '@nats-io/nats-core'
 const DEFAULT_DEDUPLICATE_WINDOW = 2000
 const MIN_DUPLICATE_WINDOW = 100
 
-type QueueOpts = {
+export type QueueOpts = {
   connection: NatsConnection
   name: string
   priorities: number

src/worker.ts

@@ -202,7 +202,6 @@ export class Worker {
     await this.client.publish(subject, JSON.stringify(event), {
       headers: messageHeaders,
     })
-    console.log(`Event published: ${JSON.stringify(event)}`)
   }
 
   private async publishJobFailedEvent(job: Job) {
@@ -218,7 +217,6 @@ export class Worker {
     await this.client.publish(subject, JSON.stringify(event), {
       headers: messageHeaders,
     })
-    console.log(`Event published: ${JSON.stringify(event)}`)
   }
 
   private async publishChildJobCompletedEvent(event: JobChildCompletedEvent) {
@@ -228,7 +226,6 @@ export class Worker {
     await this.client.publish(subject, JSON.stringify(event), {
       headers: messageHeaders,
     })
-    console.log(`Event published: ${JSON.stringify(event)}`)
   }
 
   private async publishChildJobFailedEvent(event: JobChildFailedEvent) {
@@ -238,9 +235,6 @@ export class Worker {
     await this.client.publish(subject, JSON.stringify(event), {
       headers: messageHeaders,
     })
-    console.log(
-      `Child job completed event published to subject=${subject} for job id=${event.data.childId} and parent id=${event.data.parentId}`,
-    )
   }
 
   private async setupConsumers(): Promise<Consumer[]> {
@@ -404,13 +398,11 @@ export class Worker {
   protected async processJobCompletedEvent(
     jobCompletedEvent: JobCompletedEvent,
   ) {
-    console.log('try get completed KV')
     const childParentsValue = await this.childParentsStore!.get(
       jobCompletedEvent.data.jobId,
     )
     if (!childParentsValue) return
 
-    console.log('try get completed data')
     const childParents: ChildToParentsKVValue = childParentsValue.json()
     const parentIds = childParents.parentIds
 

test/queue/constructor.test.ts

@@ -1,27 +1,18 @@
-import { describe, it, before, after, beforeEach, afterEach } from 'node:test'
-import {
-  jetstream,
-  JetStreamClient,
-  JetStreamManager,
-} from '@nats-io/jetstream'
+import { describe, it, before, after } from 'node:test'
+import { jetstream, JetStreamClient } from '@nats-io/jetstream'
 import { connect } from '@nats-io/transport-node'
 import { NatsConnection } from '@nats-io/nats-core'
-import { Kvm } from '@nats-io/kv'
 import assert from 'node:assert'
 import { Queue } from '../../src/queue'
 
 describe('Queue.constructor()', () => {
   let nc: NatsConnection
   let js: JetStreamClient
-  let jsm: JetStreamManager
-  let kvm: Kvm
   const queueName = 'queue'
 
   before(async () => {
     nc = await connect({ servers: '127.0.0.1:4222' })
     js = jetstream(nc)
-    jsm = await js.jetstreamManager()
-    kvm = await new Kvm(nc)
   })
 
   after(async () => {

test/queue/setup.test.ts

@@ -1,27 +1,24 @@
-import { describe, it, before, after, beforeEach, afterEach } from 'node:test'
+import { describe, it, before, after, afterEach } from 'node:test'
 import {
   jetstream,
   JetStreamClient,
   JetStreamManager,
 } from '@nats-io/jetstream'
 import { connect } from '@nats-io/transport-node'
 import { NatsConnection } from '@nats-io/nats-core'
-import { Kvm } from '@nats-io/kv'
 import assert from 'node:assert'
 import { Queue } from '../../src/queue'
 
 describe('Queue.setup()', () => {
   let nc: NatsConnection
   let js: JetStreamClient
   let jsm: JetStreamManager
-  let kvm: Kvm
   const queueName = 'queue'
 
   before(async () => {
     nc = await connect({ servers: '127.0.0.1:4222' })
     js = jetstream(nc)
     jsm = await js.jetstreamManager()
-    kvm = await new Kvm(nc)
     await jsm.streams.delete(queueName).catch(() => {})
   })
 

test/worker/process/common/test.ts

@@ -47,7 +47,7 @@ describe('Worker.process(): common', () => {
 
     // Create a mock function for the processor
     processorMock = mock.fn<(job: JsMsg, timeout: number) => Promise<void>>(
-      async (job, timeout) => {},
+      async () => {},
     )
 
     queue = new Queue({

test/worker/process/priority/test.ts

@@ -43,9 +43,7 @@ describe('Worker.process(): priority', () => {
   beforeEach(async () => {
     // Create a mock function for the processor
     processorMock = mock.fn<(job: JsMsg, timeout: number) => Promise<void>>(
-      async (job, timeout) => {
-        console.log(`Processing job: ${job.subject} with timeout: ${timeout}`)
-      },
+      async () => {},
     )
 
     queue = new Queue({

test/worker/process/rateLimit/test.ts

@@ -43,7 +43,7 @@ describe('Worker.process(): rateLimit', () => {
   beforeEach(async () => {
     // Create a mock function for the processor
     processorMock = mock.fn<(job: JsMsg, timeout: number) => Promise<void>>(
-      async (job, timeout) => {},
+      async () => {},
     )
 
     queue = new Queue({