mobiletto-base - npm Package Compare versions

Comparing version 2.0.7 to 2.0.8

lib/cjs/mobiletto.js

		@@ -242,3 +242,3 @@ "use strict";
		const port = client.redisConfig.port \|\| parseInt(`${redis_1.REDIS_PORT}`);
		META_LOAD_QUEUE = new bullmq_1.Queue(META_LOAD_QUEUE_NAME, {
		const queueOptions = {
		connection: {
		@@ -249,8 +249,9 @@ host: client.redisConfig.host \|\| redis_1.REDIS_HOST,
		prefix: client.redisConfig.prefix + "_" + META_LOAD_QUEUE_NAME,
		});
		};
		META_LOAD_QUEUE = new bullmq_1.Queue(META_LOAD_QUEUE_NAME, queueOptions);
		const numWorkers = enc.metaWorkers \|\| crypt_js_1.DEFAULT_META_WORKERS;
		for (let i = 0; i < numWorkers; i++) {
		META_WORKERS.push(new bullmq_1.Worker(META_LOAD_QUEUE_NAME, _singleMeta));
		META_WORKERS.push(new bullmq_1.Worker(META_LOAD_QUEUE_NAME, _singleMeta, queueOptions));
		}
		const queueEvents = new bullmq_1.QueueEvents(META_LOAD_QUEUE_NAME);
		const queueEvents = new bullmq_1.QueueEvents(META_LOAD_QUEUE_NAME, queueOptions);
		queueEvents.on("completed", ({ jobId, returnvalue }) => {
		@@ -257,0 +258,0 @@ mobiletto_common_1.logger.info(`${META_LOAD_JOB_NAME} completed job ${jobId} with result: ${returnvalue}`);

lib/esm/mobiletto.js

		@@ -213,3 +213,3 @@ var __awaiter = (this && this.__awaiter) \|\| function (thisArg, _arguments, P, generator) {
		const port = client.redisConfig.port \|\| parseInt(`${REDIS_PORT}`);
		META_LOAD_QUEUE = new Queue(META_LOAD_QUEUE_NAME, {
		const queueOptions = {
		connection: {
		@@ -220,8 +220,9 @@ host: client.redisConfig.host \|\| REDIS_HOST,
		prefix: client.redisConfig.prefix + "_" + META_LOAD_QUEUE_NAME,
		});
		};
		META_LOAD_QUEUE = new Queue(META_LOAD_QUEUE_NAME, queueOptions);
		const numWorkers = enc.metaWorkers \|\| DEFAULT_META_WORKERS;
		for (let i = 0; i < numWorkers; i++) {
		META_WORKERS.push(new Worker(META_LOAD_QUEUE_NAME, _singleMeta));
		META_WORKERS.push(new Worker(META_LOAD_QUEUE_NAME, _singleMeta, queueOptions));
		}
		const queueEvents = new QueueEvents(META_LOAD_QUEUE_NAME);
		const queueEvents = new QueueEvents(META_LOAD_QUEUE_NAME, queueOptions);
		queueEvents.on("completed", ({ jobId, returnvalue }) => {
		@@ -228,0 +229,0 @@ logger.info(`${META_LOAD_JOB_NAME} completed job ${jobId} with result: ${returnvalue}`);

package.json

		{
		"name": "mobiletto-base",
		"version": "2.0.7",
		"version": "2.0.8",
		"type": "module",
		@@ -5,0 +5,0 @@ "description": "A storage layer that presents a uniform interface to Amazon S3, Backblaze B2, local and other storage systems.",

New alerts