@queuedash/api - npm Package Compare versions

Comparing version 0.4.6 to 0.5.0

dist/src/routers/_app.d.ts

@@ -37,8 +37,19 @@ export type { Context } from "../trpc";
             data: object;
-            opts: import("bull").JobOptions;
+            opts: {
+                priority?: number | undefined;
+                delay?: number | undefined;
+                attempts?: number | undefined;
+                backoff?: number | undefined;
+                lifo?: boolean | undefined;
+                timeout?: number | undefined;
+                removeOnComplete?: number | boolean | undefined;
+                removeOnFail?: number | boolean | undefined;
+                stackTraceLimit?: number | undefined;
+                preventParsingData?: boolean | undefined;
+            };
             createdAt: Date;
             processedAt: Date | null;
             finishedAt: Date | null;
-            failedReason: string | undefined;
-            stacktrace: string[];
+            failedReason?: string | undefined;
+            stacktrace?: string[] | undefined;
             retriedAt: Date | null;
@@ -69,10 +80,63 @@ }>;
             data: object;
-            opts: import("bull").JobOptions;
+            opts: {
+                priority?: number | undefined;
+                delay?: number | undefined;
+                attempts?: number | undefined;
+                backoff?: number | undefined;
+                lifo?: boolean | undefined;
+                timeout?: number | undefined;
+                removeOnComplete?: number | boolean | undefined;
+                removeOnFail?: number | boolean | undefined;
+                stackTraceLimit?: number | undefined;
+                preventParsingData?: boolean | undefined;
+            };
             createdAt: Date;
             processedAt: Date | null;
             finishedAt: Date | null;
-            failedReason: string | undefined;
-            stacktrace: string[];
+            failedReason?: string | undefined;
+            stacktrace?: string[] | undefined;
             retriedAt: Date | null;
         }>;
+        rerun: import("@trpc/server").BuildProcedure<"mutation", {
+            _config: import("@trpc/server").RootConfig<{
+                ctx: import("../trpc").Context;
+                meta: object;
+                errorShape: import("@trpc/server").DefaultErrorShape;
+                transformer: import("@trpc/server").DefaultDataTransformer;
+            }>;
+            _meta: object;
+            _ctx_out: import("../trpc").Context;
+            _input_in: {
+                queueName: string;
+                jobId: string;
+            };
+            _input_out: {
+                queueName: string;
+                jobId: string;
+            };
+            _output_in: typeof import("@trpc/server").unsetMarker;
+            _output_out: typeof import("@trpc/server").unsetMarker;
+        }, {
+            id: string;
+            name: string;
+            data: object;
+            opts: {
+                priority?: number | undefined;
+                delay?: number | undefined;
+                attempts?: number | undefined;
+                backoff?: number | undefined;
+                lifo?: boolean | undefined;
+                timeout?: number | undefined;
+                removeOnComplete?: number | boolean | undefined;
+                removeOnFail?: number | boolean | undefined;
+                stackTraceLimit?: number | undefined;
+                preventParsingData?: boolean | undefined;
+            };
+            createdAt: Date;
+            processedAt: Date | null;
+            finishedAt: Date | null;
+            failedReason?: string | undefined;
+            stacktrace?: string[] | undefined;
+            retriedAt: Date | null;
+        }>;
         promote: import("@trpc/server").BuildProcedure<"mutation", {
@@ -101,8 +165,19 @@ _config: import("@trpc/server").RootConfig<{
             data: object;
-            opts: import("bull").JobOptions;
+            opts: {
+                priority?: number | undefined;
+                delay?: number | undefined;
+                attempts?: number | undefined;
+                backoff?: number | undefined;
+                lifo?: boolean | undefined;
+                timeout?: number | undefined;
+                removeOnComplete?: number | boolean | undefined;
+                removeOnFail?: number | boolean | undefined;
+                stackTraceLimit?: number | undefined;
+                preventParsingData?: boolean | undefined;
+            };
             createdAt: Date;
             processedAt: Date | null;
             finishedAt: Date | null;
-            failedReason: string | undefined;
-            stacktrace: string[];
+            failedReason?: string | undefined;
+            stacktrace?: string[] | undefined;
             retriedAt: Date | null;
@@ -133,8 +208,19 @@ }>;
             data: object;
-            opts: import("bull").JobOptions;
+            opts: {
+                priority?: number | undefined;
+                delay?: number | undefined;
+                attempts?: number | undefined;
+                backoff?: number | undefined;
+                lifo?: boolean | undefined;
+                timeout?: number | undefined;
+                removeOnComplete?: number | boolean | undefined;
+                removeOnFail?: number | boolean | undefined;
+                stackTraceLimit?: number | undefined;
+                preventParsingData?: boolean | undefined;
+            };
             createdAt: Date;
             processedAt: Date | null;
             finishedAt: Date | null;
-            failedReason: string | undefined;
-            stacktrace: string[];
+            failedReason?: string | undefined;
+            stacktrace?: string[] | undefined;
             retriedAt: Date | null;
@@ -173,8 +259,19 @@ }>;
                 data: object;
-                opts: import("bull").JobOptions;
+                opts: {
+                    priority?: number | undefined;
+                    delay?: number | undefined;
+                    attempts?: number | undefined;
+                    backoff?: number | undefined;
+                    lifo?: boolean | undefined;
+                    timeout?: number | undefined;
+                    removeOnComplete?: number | boolean | undefined;
+                    removeOnFail?: number | boolean | undefined;
+                    stackTraceLimit?: number | undefined;
+                    preventParsingData?: boolean | undefined;
+                };
                 createdAt: Date;
                 processedAt: Date | null;
                 finishedAt: Date | null;
-                failedReason: string | undefined;
-                stacktrace: string[];
+                failedReason?: string | undefined;
+                stacktrace?: string[] | undefined;
                 retriedAt: Date | null;
@@ -283,5 +380,7 @@ }[];
                 queueName: string;
+                data: {};
             };
             _input_out: {
                 queueName: string;
+                data: {};
             };
@@ -288,0 +387,0 @@ _output_in: typeof import("@trpc/server").unsetMarker;

dist/src/routers/job.d.ts

@@ -1,2 +0,1 @@
-import Queue from "bull";
 export declare const jobRouter: import("@trpc/server").CreateRouterInner<import("@trpc/server").RootConfig<{
@@ -31,8 +30,19 @@ ctx: import("../trpc").Context;
         data: object;
-        opts: Queue.JobOptions;
+        opts: {
+            priority?: number | undefined;
+            delay?: number | undefined;
+            attempts?: number | undefined;
+            backoff?: number | undefined;
+            lifo?: boolean | undefined;
+            timeout?: number | undefined;
+            removeOnComplete?: number | boolean | undefined;
+            removeOnFail?: number | boolean | undefined;
+            stackTraceLimit?: number | undefined;
+            preventParsingData?: boolean | undefined;
+        };
         createdAt: Date;
         processedAt: Date | null;
         finishedAt: Date | null;
-        failedReason: string | undefined;
-        stacktrace: string[];
+        failedReason?: string | undefined;
+        stacktrace?: string[] | undefined;
         retriedAt: Date | null;
@@ -63,10 +73,63 @@ }>;
         data: object;
-        opts: Queue.JobOptions;
+        opts: {
+            priority?: number | undefined;
+            delay?: number | undefined;
+            attempts?: number | undefined;
+            backoff?: number | undefined;
+            lifo?: boolean | undefined;
+            timeout?: number | undefined;
+            removeOnComplete?: number | boolean | undefined;
+            removeOnFail?: number | boolean | undefined;
+            stackTraceLimit?: number | undefined;
+            preventParsingData?: boolean | undefined;
+        };
         createdAt: Date;
         processedAt: Date | null;
         finishedAt: Date | null;
-        failedReason: string | undefined;
-        stacktrace: string[];
+        failedReason?: string | undefined;
+        stacktrace?: string[] | undefined;
         retriedAt: Date | null;
     }>;
+    rerun: import("@trpc/server").BuildProcedure<"mutation", {
+        _config: import("@trpc/server").RootConfig<{
+            ctx: import("../trpc").Context;
+            meta: object;
+            errorShape: import("@trpc/server").DefaultErrorShape;
+            transformer: import("@trpc/server").DefaultDataTransformer;
+        }>;
+        _meta: object;
+        _ctx_out: import("../trpc").Context;
+        _input_in: {
+            queueName: string;
+            jobId: string;
+        };
+        _input_out: {
+            queueName: string;
+            jobId: string;
+        };
+        _output_in: typeof import("@trpc/server").unsetMarker;
+        _output_out: typeof import("@trpc/server").unsetMarker;
+    }, {
+        id: string;
+        name: string;
+        data: object;
+        opts: {
+            priority?: number | undefined;
+            delay?: number | undefined;
+            attempts?: number | undefined;
+            backoff?: number | undefined;
+            lifo?: boolean | undefined;
+            timeout?: number | undefined;
+            removeOnComplete?: number | boolean | undefined;
+            removeOnFail?: number | boolean | undefined;
+            stackTraceLimit?: number | undefined;
+            preventParsingData?: boolean | undefined;
+        };
+        createdAt: Date;
+        processedAt: Date | null;
+        finishedAt: Date | null;
+        failedReason?: string | undefined;
+        stacktrace?: string[] | undefined;
+        retriedAt: Date | null;
+    }>;
     promote: import("@trpc/server").BuildProcedure<"mutation", {
@@ -95,8 +158,19 @@ _config: import("@trpc/server").RootConfig<{
         data: object;
-        opts: Queue.JobOptions;
+        opts: {
+            priority?: number | undefined;
+            delay?: number | undefined;
+            attempts?: number | undefined;
+            backoff?: number | undefined;
+            lifo?: boolean | undefined;
+            timeout?: number | undefined;
+            removeOnComplete?: number | boolean | undefined;
+            removeOnFail?: number | boolean | undefined;
+            stackTraceLimit?: number | undefined;
+            preventParsingData?: boolean | undefined;
+        };
         createdAt: Date;
         processedAt: Date | null;
         finishedAt: Date | null;
-        failedReason: string | undefined;
-        stacktrace: string[];
+        failedReason?: string | undefined;
+        stacktrace?: string[] | undefined;
         retriedAt: Date | null;
@@ -127,8 +201,19 @@ }>;
         data: object;
-        opts: Queue.JobOptions;
+        opts: {
+            priority?: number | undefined;
+            delay?: number | undefined;
+            attempts?: number | undefined;
+            backoff?: number | undefined;
+            lifo?: boolean | undefined;
+            timeout?: number | undefined;
+            removeOnComplete?: number | boolean | undefined;
+            removeOnFail?: number | boolean | undefined;
+            stackTraceLimit?: number | undefined;
+            preventParsingData?: boolean | undefined;
+        };
         createdAt: Date;
         processedAt: Date | null;
         finishedAt: Date | null;
-        failedReason: string | undefined;
-        stacktrace: string[];
+        failedReason?: string | undefined;
+        stacktrace?: string[] | undefined;
         retriedAt: Date | null;
@@ -167,8 +252,19 @@ }>;
             data: object;
-            opts: Queue.JobOptions;
+            opts: {
+                priority?: number | undefined;
+                delay?: number | undefined;
+                attempts?: number | undefined;
+                backoff?: number | undefined;
+                lifo?: boolean | undefined;
+                timeout?: number | undefined;
+                removeOnComplete?: number | boolean | undefined;
+                removeOnFail?: number | boolean | undefined;
+                stackTraceLimit?: number | undefined;
+                preventParsingData?: boolean | undefined;
+            };
             createdAt: Date;
             processedAt: Date | null;
             finishedAt: Date | null;
-            failedReason: string | undefined;
-            stacktrace: string[];
+            failedReason?: string | undefined;
+            stacktrace?: string[] | undefined;
             retriedAt: Date | null;
@@ -175,0 +271,0 @@ }[];

dist/src/routers/queue.d.ts

@@ -100,5 +100,7 @@ export declare const queueRouter: import("@trpc/server").CreateRouterInner<import("@trpc/server").RootConfig<{
             queueName: string;
+            data: {};
         };
         _input_out: {
             queueName: string;
+            data: {};
         };
@@ -105,0 +107,0 @@ _output_in: typeof import("@trpc/server").unsetMarker;

dist/src/trpc.d.ts

@@ -1,9 +0,19 @@
-import type Queue from "bull";
+import type Bull from "bull";
+import type BullMQ from "bullmq";
+import type BeeQueue from "bee-queue";
+type Queue = {
+    displayName: string;
+    jobName?: (data: Record<string, unknown>) => string;
+} & ({
+    queue: Bull.Queue;
+    type: "bull";
+} | {
+    queue: BullMQ.Queue;
+    type: "bullmq";
+} | {
+    queue: BeeQueue;
+    type: "bee";
+});
 export type Context = {
-    queues: {
-        name: string;
-        displayName: string;
-        jobName?: (data: Record<string, unknown>) => string;
-    }[];
-    opts: Queue.QueueOptions;
+    queues: Queue[];
 };
@@ -30,2 +40,3 @@ export declare const router: <TProcRouterRecord extends import("@trpc/server").ProcedureRouterRecord>(procedures: TProcRouterRecord) => import("@trpc/server").CreateRouterInner<import("@trpc/server").RootConfig<{
 }>;
+export {};
 //# sourceMappingURL=trpc.d.ts.map

dist/src/utils/global.utils.d.ts

@@ -1,18 +0,33 @@
-import type Queue from "bull";
+import type Bull from "bull";
+import type BullMQ from "bullmq";
 import type { Context } from "../trpc";
-export declare const formatJob: ({ job, queueInCtx, }: {
-    job: Queue.Job;
-    queueInCtx: Context["queues"][0];
-}) => {
+import type BeeQueue from "bee-queue";
+type QueueDashOptions = {
+    priority?: number;
+    delay?: number;
+    attempts?: number;
+    backoff?: number;
+    lifo?: boolean;
+    timeout?: number;
+    removeOnComplete?: boolean | number;
+    removeOnFail?: boolean | number;
+    stackTraceLimit?: number;
+    preventParsingData?: boolean;
+};
+type QueueDashJob = {
     id: string;
     name: string;
     data: object;
-    opts: Queue.JobOptions;
+    opts: QueueDashOptions;
     createdAt: Date;
     processedAt: Date | null;
     finishedAt: Date | null;
-    failedReason: string | undefined;
-    stacktrace: string[];
+    failedReason?: string;
+    stacktrace?: string[];
     retriedAt: Date | null;
 };
+export declare const formatJob: ({ job, queueInCtx, }: {
+    job: Bull.Job | BullMQ.Job | BeeQueue.Job<Record<string, unknown>>;
+    queueInCtx: Context["queues"][0];
+}) => QueueDashJob;
 export declare const findQueueInCtxOrFail: ({ queueName, queues, }: {
@@ -22,6 +37,15 @@ queueName: string;
 }) => {
-    name: string;
     displayName: string;
     jobName?: ((data: Record<string, unknown>) => string) | undefined;
-};
+} & ({
+    queue: Bull.Queue<any>;
+    type: "bull";
+} | {
+    queue: BullMQ.Queue<any, any, string>;
+    type: "bullmq";
+} | {
+    queue: BeeQueue<any>;
+    type: "bee";
+});
+export {};
 //# sourceMappingURL=global.utils.d.ts.map

package.json

 {
   "name": "@queuedash/api",
-  "version": "0.4.6",
+  "version": "0.5.0",
   "main": "./dist/main.js",
@@ -14,9 +14,6 @@ "module": "./dist/main.mjs",
   "dependencies": {
-    "@trpc/server": "^10.5.0",
+    "@trpc/server": "^10.12.0",
     "redis-info": "^3.1.0",
     "zod": "^3.20.2"
   },
-  "peerDependencies": {
-    "bull": "^4.10.2"
-  },
   "devDependencies": {
@@ -30,3 +27,5 @@ "@rollup/plugin-typescript": "^10.0.1",
     "@typescript-eslint/parser": "^5.46.1",
+    "bee-queue": "^1.5.0",
     "bull": "^4.10.2",
+    "bullmq": "^3.6.2",
     "eslint": "^8.29.0",
@@ -33,0 +32,0 @@ "eslint-config-prettier": "^8.5.0",

New alerts

Uses eval

Supply chain risk

Package uses dynamic code execution (e.g., eval()), which is a dangerous practice. This can prevent the code from running in certain environments and increases the risk that the code may contain exploits or malicious behavior.

Found 1 instance in 1 package

Long strings

Supply chain risk

Contains long string literals, which may be a sign of obfuscated or packed code.

Found 1 instance in 1 package

Fixed alerts

Uses eval

Supply chain risk

Package uses dynamic code execution (e.g., eval()), which is a dangerous practice. This can prevent the code from running in certain environments and increases the risk that the code may contain exploits or malicious behavior.

Found 1 instance in 1 package

Long strings

Supply chain risk

Contains long string literals, which may be a sign of obfuscated or packed code.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

595247

5.2%

Dependency count

3

-25%

Lines of code

9315

4.04%

Number of low supply chain risk alerts

45

-2.17%

Worsened metrics

Dev dependency count

18

12.5%

Dependency changes

• - Removed

  @ioredis/commands@1.10.0
  (transitive)

• - Removed

  @msgpackr-extract/msgpackr-extract-darwin-arm64@3.0.4
  (transitive)

• - Removed

  @msgpackr-extract/msgpackr-extract-darwin-x64@3.0.4
  (transitive)

• - Removed

  @msgpackr-extract/msgpackr-extract-linux-arm@3.0.4
  (transitive)

• - Removed

  @msgpackr-extract/msgpackr-extract-linux-arm64@3.0.4
  (transitive)

• - Removed

  @msgpackr-extract/msgpackr-extract-linux-x64@3.0.4
  (transitive)

• - Removed

  @msgpackr-extract/msgpackr-extract-win32-x64@3.0.4
  (transitive)

• - Removed

  bull@4.16.5
  (transitive)

• - Removed

  cluster-key-slot@1.1.1
  (transitive)

• - Removed

  cron-parser@4.9.0
  (transitive)

• - Removed

  debug@4.4.3
  (transitive)

• - Removed

  denque@2.1.0
  (transitive)

• - Removed

  detect-libc@2.1.2
  (transitive)

• - Removed

  get-port@5.1.1
  (transitive)

• - Removed

  ioredis@5.11.0
  (transitive)

• - Removed

  luxon@3.7.2
  (transitive)

• - Removed

  ms@2.1.3
  (transitive)

• - Removed

  msgpackr@1.11.12
  (transitive)

• - Removed

  msgpackr-extract@3.0.4
  (transitive)

• - Removed

  node-gyp-build-optional-packages@5.2.2
  (transitive)

• - Removed

  redis-errors@1.2.0
  (transitive)

• - Removed

  redis-parser@3.0.0
  (transitive)

• - Removed

  semver@7.8.1
  (transitive)

• - Removed

  standard-as-callback@2.1.0
  (transitive)

• - Removed

  uuid@8.3.2
  (transitive)

• Updated

  @trpc/server@^10.12.0