@vendure/job-queue-plugin - npm Package Compare versions

Comparing version 1.5.2 to 1.6.0

package.json

 {
   "name": "@vendure/job-queue-plugin",
-  "version": "1.5.2",
+  "version": "1.6.0",
   "license": "MIT",
@@ -27,4 +27,4 @@ "main": "package/index.js",
     "@types/redis": "^2.8.28",
-    "@vendure/common": "^1.5.2",
-    "@vendure/core": "^1.5.2",
+    "@vendure/common": "^1.6.0",
+    "@vendure/core": "^1.6.0",
     "bullmq": "^1.40.1",
@@ -35,3 +35,3 @@ "redis": "^3.0.2",
   },
-  "gitHead": "8b72fb60f2c190d42c727eb522941259d8e1a92f"
+  "gitHead": "bce3119a29d62a759590459d679a7a4d5eaa48b3"
 }

package/bullmq/plugin.d.ts

@@ -1,3 +0,1 @@
-import { HealthCheckRegistryService } from '@vendure/core';
-import { RedisHealthIndicator } from './redis-health-indicator';
 import { BullMQPluginOptions } from './types';
@@ -95,4 +93,2 @@ /**
 export declare class BullMQJobQueuePlugin {
-    private registry;
-    private redis;
     static options: BullMQPluginOptions;
@@ -104,3 +100,2 @@ /**
     static init(options: BullMQPluginOptions): typeof BullMQJobQueuePlugin;
-    constructor(registry: HealthCheckRegistryService, redis: RedisHealthIndicator);
 }

package/bullmq/plugin.js

@@ -8,5 +8,2 @@ "use strict";
 };
-var __metadata = (this && this.__metadata) || function (k, v) {
-    if (typeof Reflect === "object" && typeof Reflect.metadata === "function") return Reflect.metadata(k, v);
-};
 var BullMQJobQueuePlugin_1;
@@ -18,2 +15,3 @@ Object.defineProperty(exports, "__esModule", { value: true });
 const constants_1 = require("./constants");
+const redis_health_check_strategy_1 = require("./redis-health-check-strategy");
 const redis_health_indicator_1 = require("./redis-health-indicator");
@@ -112,7 +110,2 @@ const redis_job_buffer_storage_strategy_1 = require("./redis-job-buffer-storage-strategy");
 let BullMQJobQueuePlugin = BullMQJobQueuePlugin_1 = class BullMQJobQueuePlugin {
-    constructor(registry, redis) {
-        this.registry = registry;
-        this.redis = redis;
-        registry.registerIndicatorFunction(() => this.redis.isHealthy('redis (job queue)'));
-    }
     /**
@@ -133,2 +126,3 @@ * @description
             config.jobQueueOptions.jobBufferStorageStrategy = new redis_job_buffer_storage_strategy_1.RedisJobBufferStorageStrategy();
+            config.systemOptions.healthChecks.push(new redis_health_check_strategy_1.RedisHealthCheckStrategy());
             return config;
@@ -140,6 +134,5 @@ },
         ],
-    }),
-    __metadata("design:paramtypes", [core_1.HealthCheckRegistryService, redis_health_indicator_1.RedisHealthIndicator])
+    })
 ], BullMQJobQueuePlugin);
 exports.BullMQJobQueuePlugin = BullMQJobQueuePlugin;
 //# sourceMappingURL=plugin.js.map

package/bullmq/redis-health-indicator.js

@@ -65,3 +65,3 @@ "use strict";
         const result = this.getStatus(key, pingResult === 'PONG');
-        if (pingResult) {
+        if (pingResult === 'PONG') {
             return result;
@@ -68,0 +68,0 @@ }

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

68311

increased by0.87%

Number of package files

45

increased by7.14%

Lines of code

1079

increased by0.75%

No dependency changes