feat: allow to change job queue or setup options for it

README.md

@@ -26,8 +26,15 @@ const redis = new IORedis({
 
 const defineJob = initJobify(redis);
 
-const job1 = defineJob("some")
+const job1 = defineJob("some", {
+    queue: {
+        defaultJobOptions: {
+            delay: 100,
+        },
+    },
+})
     .input<{ date: string }>()
+    // WORKER OPTIONS
     .options({
         limiter: {
             max: 10,

package.json

@@ -12,7 +12,7 @@
 	},
 	"description": "Right way to work with jobs",
 	"keywords": ["jobs", "queue", "bullmq", "bull", "pg-boss"],
-	"version": "0.0.2",
+	"version": "0.1.0",
 	"type": "module",
 	"devDependencies": {
 		"@biomejs/biome": "^1.8.3",

src/define-job.ts

@@ -3,12 +3,18 @@ import {
 	type JobsOptions,
 	type Processor,
 	Queue,
+	type QueueOptions,
 	type RepeatOptions,
 	Worker,
 	type WorkerOptions,
 } from "bullmq";
+import type { NoConnection } from "./utils";
 
-type OptionsData = Omit<WorkerOptions, "connection">;
+type OptionsData = NoConnection<WorkerOptions>;
+
+export interface DefinedJobsOptions {
+	queue?: Queue | NoConnection<QueueOptions>;
+}
 
 export class Job<GlobalInput = never> {
 	private connection: ConnectionOptions;
@@ -18,13 +24,21 @@ export class Job<GlobalInput = never> {
 	worker!: Worker<GlobalInput>;
 	private optionsData?: OptionsData;
 
-	constructor(connection: ConnectionOptions, jobName: string) {
+	constructor(
+		connection: ConnectionOptions,
+		jobName: string,
+		options?: DefinedJobsOptions,
+	) {
 		this.connection = connection;
 		this.name = jobName;
 
-		this.queue = new Queue(jobName, {
-			connection,
-		});
+		this.queue =
+			options?.queue instanceof Queue
+				? options.queue
+				: new Queue(jobName, {
+						connection,
+						...options?.queue,
+					});
 	}
 
 	input<Input>(input?: Input): Job<Input> {

src/index.ts

@@ -1,8 +1,9 @@
-import { type ConnectionOptions, Queue } from "bullmq";
+import type { ConnectionOptions } from "bullmq";
 import { Job } from "define-job";
+import type { Shift } from "./utils";
 
 export function initJobify(connection: ConnectionOptions) {
-	return (name: string) => {
-		return new Job(connection, name);
+	return (...args: Shift<ConstructorParameters<typeof Job>>) => {
+		return new Job(connection, ...args);
 	};
 }

src/utils.ts

@@ -0,0 +1,8 @@
+export type Shift<T extends any[]> = ((...t: T) => void) extends (
+	h: any,
+	...r: infer R
+) => void
+	? R
+	: never;
+
+export type NoConnection<T> = Omit<T, "connection">;

tests/index.test.ts

@@ -0,0 +1,20 @@
+// TODO:
+import { describe, expect, it } from "bun:test";
+import { initJobify } from "index";
+import IORedis from "ioredis";
+
+const connection = new IORedis({});
+
+describe("test", () => {
+	it("some", () => {
+		const defineJob = initJobify(connection);
+
+		const job = defineJob("ok", {
+			queue: {
+				defaultJobOptions: {
+					delay: 100,
+				},
+			},
+		});
+	});
+});

tsconfig.json

@@ -1,27 +1,27 @@
 {
-    "compilerOptions": {
-        // Enable latest features
-        "lib": ["ESNext", "DOM"],
-        "target": "ESNext",
-        "module": "ESNext",
-        "moduleDetection": "force",
-        "jsx": "react-jsx",
-        "allowJs": true,
+	"compilerOptions": {
+		// Enable latest features
+		"lib": ["ESNext", "DOM"],
+		"target": "ESNext",
+		"module": "ESNext",
+		"moduleDetection": "force",
+		"jsx": "react-jsx",
+		"allowJs": true,
 
-        // Bundler mode
-        "moduleResolution": "bundler",
-        "verbatimModuleSyntax": true,
-        "declaration": true,
+		// Bundler mode
+		"moduleResolution": "Node",
+		"verbatimModuleSyntax": true,
+		"declaration": true,
 
-        // Best practices
-        "strict": true,
-        "skipLibCheck": true,
-        "noFallthroughCasesInSwitch": true,
+		// Best practices
+		"strict": true,
+		"skipLibCheck": true,
+		"noFallthroughCasesInSwitch": true,
 
-        // Some stricter flags (disabled by default)
-        "noUnusedLocals": false,
-        "noUnusedParameters": false,
-        "noPropertyAccessFromIndexSignature": false,
-        "baseUrl": "./src"
-    }
+		// Some stricter flags (disabled by default)
+		"noUnusedLocals": false,
+		"noUnusedParameters": false,
+		"noPropertyAccessFromIndexSignature": false,
+		"baseUrl": "./src"
+	}
 }