@gramio/broadcast - npm Package Compare versions

Comparing version 0.0.1 to 0.0.2

dist/index.cjs

@@ -10,5 +10,19 @@ 'use strict';
   job;
-  constructor(redis, options) {
+  constructor(redis, options, workerOptions) {
     const defineJob = jobify.initJobify(redis);
-    this.job = defineJob("@gramio/broadcast").options({
+    this.job = defineJob("@gramio/broadcast", {
+      ...options,
+      queue: {
+        ...options?.queue,
+        defaultJobOptions: {
+          ...options?.queue?.defaultJobOptions,
+          attempts: 5,
+          backoff: {
+            type: "fixed",
+            delay: 1e3,
+            ...typeof options?.queue?.defaultJobOptions?.backoff === "object" ? options?.queue?.defaultJobOptions?.backoff : {}
+          }
+        }
+      }
+    }).options({
       limiter: {
@@ -18,3 +32,3 @@ max: 25,
       },
-      ...options
+      ...workerOptions
     }).input().action(async ({ data }) => {
@@ -21,0 +35,0 @@ try {

dist/index.d.cts

 import * as jobify_bullmq from 'jobify/bullmq';
-import { Job, initJobify, OptionsData } from 'jobify';
+import { Job, initJobify, DefinedJobsOptions, OptionsData } from 'jobify';
 
@@ -16,3 +16,3 @@ type Action = Function;
     }>;
-    constructor(redis: Parameters<typeof initJobify>[0], options?: OptionsData);
+    constructor(redis: Parameters<typeof initJobify>[0], options?: DefinedJobsOptions, workerOptions?: OptionsData);
     type<const T extends string, F extends Function>(type: T, action: F): Broadcast<Types & {
@@ -19,0 +19,0 @@ [K in T]: {

dist/index.d.ts

 import * as jobify_bullmq from 'jobify/bullmq';
-import { Job, initJobify, OptionsData } from 'jobify';
+import { Job, initJobify, DefinedJobsOptions, OptionsData } from 'jobify';
 
@@ -16,3 +16,3 @@ type Action = Function;
     }>;
-    constructor(redis: Parameters<typeof initJobify>[0], options?: OptionsData);
+    constructor(redis: Parameters<typeof initJobify>[0], options?: DefinedJobsOptions, workerOptions?: OptionsData);
     type<const T extends string, F extends Function>(type: T, action: F): Broadcast<Types & {
@@ -19,0 +19,0 @@ [K in T]: {

dist/index.js

@@ -8,5 +8,19 @@ import { TelegramError } from 'gramio';
   job;
-  constructor(redis, options) {
+  constructor(redis, options, workerOptions) {
     const defineJob = initJobify(redis);
-    this.job = defineJob("@gramio/broadcast").options({
+    this.job = defineJob("@gramio/broadcast", {
+      ...options,
+      queue: {
+        ...options?.queue,
+        defaultJobOptions: {
+          ...options?.queue?.defaultJobOptions,
+          attempts: 5,
+          backoff: {
+            type: "fixed",
+            delay: 1e3,
+            ...typeof options?.queue?.defaultJobOptions?.backoff === "object" ? options?.queue?.defaultJobOptions?.backoff : {}
+          }
+        }
+      }
+    }).options({
       limiter: {
@@ -16,3 +30,3 @@ max: 25,
       },
-      ...options
+      ...workerOptions
     }).input().action(async ({ data }) => {
@@ -19,0 +33,0 @@ try {

package.json

 {
 	"name": "@gramio/broadcast",
-	"version": "0.0.1",
+	"version": "0.0.2",
 	"description": "Broadcast for GramIO",
@@ -47,3 +47,3 @@ "main": "dist/index.cjs",
 		"ioredis": "^5.4.1",
-		"jobify": "^0.1.5",
+		"jobify": "^0.1.6",
 		"pkgroll": "^2.5.1",
@@ -50,0 +50,0 @@ "typescript": "^5.7.2"

No alert changes

Improved metrics

Total package byte prevSize

8895

11.99%

Lines of code

149

23.14%

No dependency changes