jobify - npm Package Compare versions

Comparing version 0.0.2 to 0.1.0

dist/index.d.ts

 import * as bullmq from 'bullmq';
-import { Queue, Worker, ConnectionOptions, Processor, JobsOptions, RepeatOptions, WorkerOptions } from 'bullmq';
+import { Queue, QueueOptions, Worker, ConnectionOptions, Processor, JobsOptions, RepeatOptions, WorkerOptions } from 'bullmq';
 
-type OptionsData = Omit<WorkerOptions, "connection">;
-declare class Job<GlobalInput = never> {
+type NoConnection<T> = Omit<T, "connection">;
+
+type OptionsData = NoConnection<WorkerOptions>;
+interface DefinedJobsOptions {
+    queue?: Queue | NoConnection<QueueOptions>;
+}
+declare class Job<GlobalInput = undefined> {
     private connection;
@@ -11,3 +16,3 @@ private name;
     private optionsData?;
-    constructor(connection: ConnectionOptions, jobName: string);
+    constructor(connection: ConnectionOptions, jobName: string, options?: DefinedJobsOptions);
     input<Input>(input?: Input): Job<Input>;
@@ -25,4 +30,4 @@ options(options: OptionsData): this;
 
-declare function initJobify(connection: ConnectionOptions): (name: string) => Job<never>;
+declare function initJobify(connection: ConnectionOptions): (jobName: string, options?: DefinedJobsOptions | undefined) => Job<undefined>;
 
 export { initJobify };

dist/index.js

@@ -10,7 +10,8 @@ import { Queue, Worker } from 'bullmq';
   optionsData;
-  constructor(connection, jobName) {
+  constructor(connection, jobName, options) {
     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
     });
@@ -48,4 +49,4 @@ }
 function initJobify(connection) {
-  return (name) => {
-    return new Job(connection, name);
+  return (...args) => {
+    return new Job(connection, ...args);
   };
@@ -52,0 +53,0 @@ }

package.json

@@ -15,3 +15,3 @@ {
 	"keywords": ["jobs", "queue", "bullmq", "bull", "pg-boss"],
-	"version": "0.0.2",
+	"version": "0.1.0",
 	"type": "module",
@@ -18,0 +18,0 @@ "devDependencies": {

README.md

@@ -29,4 +29,11 @@ # jobify
 
-const job1 = defineJob("some")
+const job1 = defineJob("some", {
+    queue: {
+        defaultJobOptions: {
+            delay: 100,
+        },
+    },
+})
     .input<{ date: string }>()
+    // WORKER OPTIONS
     .options({
@@ -33,0 +40,0 @@ limiter: {

No alert changes

Improved metrics

Total package byte prevSize

6169

increased by9.15%

Lines of code

128

increased by4.92%

Number of lines in readme file

84

increased by9.09%

No dependency changes