bull - npm Package Compare versions

Comparing version 4.14.0 to 4.15.0

CHANGELOG.md

@@ -0,1 +1,8 @@
+# [4.15.0](https://github.com/OptimalBits/bull/compare/v4.14.0...v4.15.0) (2024-06-30)
+
+
+### Features
+
+* **queue:** emit internal duplicated event ([#2754](https://github.com/OptimalBits/bull/issues/2754)) ([021ab7f](https://github.com/OptimalBits/bull/commit/021ab7fd8d6c89b01767572b0e53422f34f7bc04))
+
 # [4.14.0](https://github.com/OptimalBits/bull/compare/v4.13.1...v4.14.0) (2024-06-25)
@@ -2,0 +9,0 @@

lib/queue.js

@@ -443,2 +443,5 @@ 'use strict';
       case duplicatedKey:
+        if (this.token === token) {
+          utils.emitSafe(this, 'duplicated', message);
+        }
         utils.emitSafe(this, 'global:duplicated', message);
@@ -514,3 +517,3 @@ break;
 Queue.prototype._registerEvent = function(eventName) {
-  const internalEvents = ['waiting', 'delayed'];
+  const internalEvents = ['waiting', 'delayed', 'duplicated'];
 
@@ -517,0 +520,0 @@ if (

lib/scripts/addJob-6.js

@@ -72,3 +72,3 @@ 'use strict';
   if rcall("EXISTS", jobIdKey) == 1 then
-    rcall("PUBLISH", ARGV[1] .. "duplicated", jobId)
+    rcall("PUBLISH", ARGV[1] .. "duplicated@" .. ARGV[11], jobId)
     return jobId .. "" -- convert to string
@@ -75,0 +75,0 @@ end

package.json

 {
   "name": "bull",
-  "version": "4.14.0",
+  "version": "4.15.0",
   "description": "Job manager",
@@ -5,0 +5,0 @@ "engines": {

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

299512

increased by0.15%

Lines of code

6132

increased by0.05%

No dependency changes