@message-queue-toolkit/core - npm Package Compare versions

Comparing version 9.0.5 to 9.1.0

dist/lib/queues/AbstractQueueService.d.ts

@@ -79,3 +79,3 @@ import type { ErrorReporter, ErrorResolver, Either } from '@lokalise/node-core';
     protected handleMessageProcessed(message: MessagePayloadSchemas | null, processingResult: MessageProcessingResult, messageId?: string): void;
-    protected processPrehandlersInternal(prehandlers: Prehandler<MessagePayloadSchemas, ExecutionContext, PrehandlerOutput>[] | undefined, message: MessagePayloadSchemas): Promise<PrehandlerOutput>;
+    protected processPrehandlersInternal(prehandlers: Prehandler<MessagePayloadSchemas, ExecutionContext, PrehandlerOutput>[], message: MessagePayloadSchemas): Promise<PrehandlerOutput>;
     protected abstract resolveNextFunction(prehandlers: Prehandler<MessagePayloadSchemas, ExecutionContext, PrehandlerOutput>[], message: MessagePayloadSchemas, index: number, prehandlerOutput: PrehandlerOutput, resolve: (value: PrehandlerOutput | PromiseLike<PrehandlerOutput>) => void, reject: (err: Error) => void): (prehandlerResult: PrehandlerResult) => void;
@@ -82,0 +82,0 @@ protected resolveNextPreHandlerFunctionInternal(prehandlers: Prehandler<MessagePayloadSchemas, ExecutionContext, PrehandlerOutput>[], executionContext: ExecutionContext, message: MessagePayloadSchemas, index: number, prehandlerOutput: PrehandlerOutput, resolve: (value: PrehandlerOutput | PromiseLike<PrehandlerOutput>) => void, reject: (err: Error) => void): (prehandlerResult: PrehandlerResult) => void;

dist/lib/queues/AbstractQueueService.js

@@ -81,3 +81,3 @@ "use strict";
     processPrehandlersInternal(prehandlers, message) {
-        if (!prehandlers || prehandlers.length === 0) {
+        if (prehandlers.length === 0) {
             return Promise.resolve({});
@@ -84,0 +84,0 @@ }

dist/lib/queues/HandlerContainer.d.ts

@@ -33,3 +33,3 @@ import type { Either } from '@lokalise/node-core';
     readonly preHandlerBarrier?: BarrierCallbackMultiConsumers<MessagePayloadSchema, ExecutionContext, PrehandlerOutput, BarrierOutput>;
-    readonly prehandlers?: Prehandler<MessagePayloadSchema, ExecutionContext, PrehandlerOutput>[];
+    readonly prehandlers: Prehandler<MessagePayloadSchema, ExecutionContext, PrehandlerOutput>[];
     constructor(schema: ZodSchema<MessagePayloadSchema>, handler: Handler<MessagePayloadSchema, ExecutionContext, PrehandlerOutput, BarrierOutput>, options?: HandlerConfigOptions<MessagePayloadSchema, ExecutionContext, PrehandlerOutput, BarrierOutput>);
@@ -36,0 +36,0 @@ }

dist/lib/queues/HandlerContainer.js

@@ -17,3 +17,3 @@ "use strict";
         this.preHandlerBarrier = options?.preHandlerBarrier;
-        this.prehandlers = options?.prehandlers;
+        this.prehandlers = options?.prehandlers ?? [];
     }
@@ -20,0 +20,0 @@ }

package.json

 {
   "name": "@message-queue-toolkit/core",
-  "version": "9.0.5",
+  "version": "9.1.0",
   "private": false,
@@ -44,3 +44,3 @@ "license": "MIT",
     "typescript": "^5.4.2",
-    "vitest": "^1.3.1"
+    "vitest": "^1.4.0"
   },
@@ -47,0 +47,0 @@ "homepage": "https://github.com/kibertoad/message-queue-toolkit",

No alert changes

Worsened metrics

Total package byte prevSize

57541

decreased by-0.05%

No dependency changes