redis-smq-common - npm Package Compare versions

Comparing version 1.0.0-rc.7 to 1.0.0-rc.8

CHANGELOG.md

 # CHANGELOG
 
-## 1.0.0-rc.6 (2022-05-30)
+## 1.0.0-rc.8 (2022-05-30)
 
+* Add WatchedKeysChangedError class (1e42e80)
+
+## 1.0.0-rc.7 (2022-05-30)
+
 * Fix various redis errors (9349261)
@@ -6,0 +10,0 @@

dist/src/redis-client/clients/ioredis-client-multi.js

@@ -5,2 +5,3 @@ "use strict";
 const redis_client_error_1 = require("../errors/redis-client.error");
+const watched_keys_changed_error_1 = require("../errors/watched-keys-changed.error");
 class IoredisClientMulti {
@@ -75,3 +76,3 @@ constructor(client) {
             else if (!reply)
-                cb(new redis_client_error_1.RedisClientError(`Redis transaction has been abandoned. Try again.`));
+                cb(new watched_keys_changed_error_1.WatchedKeysChangedError());
             else {
@@ -78,0 +79,0 @@ const lengths = [];

dist/src/redis-client/clients/node-redis-v3-client-multi.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.NodeRedisV3ClientMulti = void 0;
-const redis_client_error_1 = require("../errors/redis-client.error");
+const watched_keys_changed_error_1 = require("../errors/watched-keys-changed.error");
 class NodeRedisV3ClientMulti {
@@ -74,3 +74,3 @@ constructor(client) {
             else if (!reply)
-                cb(new redis_client_error_1.RedisClientError(`Redis transaction has been abandoned. Try again.`));
+                cb(new watched_keys_changed_error_1.WatchedKeysChangedError());
             else
@@ -77,0 +77,0 @@ cb(null, reply);

dist/src/redis-client/clients/node-redis-v4-client-multi.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.NodeRedisV4ClientMulti = void 0;
+const client_1 = require("@redis/client");
+const watched_keys_changed_error_1 = require("../errors/watched-keys-changed.error");
 class NodeRedisV4ClientMulti {
@@ -72,3 +74,8 @@ constructor(client) {
             .then((reply) => cb(null, reply))
-            .catch(cb);
+            .catch((err) => {
+            if (err instanceof client_1.WatchError)
+                cb(new watched_keys_changed_error_1.WatchedKeysChangedError());
+            else
+                cb(err);
+        });
     }
@@ -75,0 +82,0 @@ }

package.json

 {
   "name": "redis-smq-common",
-  "version": "1.0.0-rc.7",
+  "version": "1.0.0-rc.8",
   "description": "RedisSMQ shared components that may be used by integrated applications and extensions.",
@@ -5,0 +5,0 @@ "author": "Weyoss <[e-mail]>",

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

105480

increased by1.02%

Number of package files

83

increased by2.47%

Lines of code

2619

increased by0.85%

No dependency changes