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

Comparing version 1.1.0 to 1.2.0

dist/index.d.ts

 export type { QueueConsumer, AsyncPublisher, SyncPublisher, TransactionObservabilityManager, Logger, } from './lib/types/MessageQueueTypes';
 export { AbstractQueueService } from './lib/queues/AbstractQueueService';
-export type { QueueOptions, QueueDependencies, QueueConsumerDependencies, Deserializer, } from './lib/queues/AbstractQueueService';
+export type { QueueOptions, QueueDependencies, QueueConsumerDependencies, Deserializer, CommonQueueLocator, } from './lib/queues/AbstractQueueService';
 export { isMessageError, MessageValidationError, MessageInvalidFormatError, } from './lib/errors/Errors';
 export { objectToBuffer } from './lib/utils/queueUtils';
 export { waitAndRetry } from './lib/utils/waitUtils';

dist/lib/queues/AbstractQueueService.d.ts

@@ -14,9 +14,13 @@ import type { ErrorReporter, ErrorResolver, Either } from '@lokalise/node-core';
 export type Deserializer<MessagePayloadType extends object, QueueEngineMessageType extends object> = (message: QueueEngineMessageType, type: ZodType<MessagePayloadType>, errorProcessor: ErrorResolver) => Either<MessageInvalidFormatError | MessageValidationError, MessagePayloadType>;
-export type QueueOptions<MessagePayloadType extends object, QueueConfiguration extends object> = {
+export type QueueOptions<MessagePayloadType extends object, QueueConfiguration extends object, QueueLocatorType extends object> = {
     messageSchema: ZodSchema<MessagePayloadType>;
     messageTypeField: string;
     queueName: string;
-    queueConfiguration: QueueConfiguration;
+    queueLocator?: QueueLocatorType;
+    queueConfiguration?: QueueConfiguration;
 };
-export declare abstract class AbstractQueueService<MessagePayloadType extends object, DependenciesType extends QueueDependencies, QueueConfiguration extends object, OptionsType extends QueueOptions<MessagePayloadType, QueueConfiguration> = QueueOptions<MessagePayloadType, QueueConfiguration>> {
+export type CommonQueueLocator = {
+    queueName: string;
+};
+export declare abstract class AbstractQueueService<MessagePayloadType extends object, DependenciesType extends QueueDependencies, QueueConfiguration extends object, QueueLocatorType extends object = CommonQueueLocator, OptionsType extends QueueOptions<MessagePayloadType, QueueConfiguration, QueueLocatorType> = QueueOptions<MessagePayloadType, QueueConfiguration, QueueLocatorType>> {
     protected readonly queueName: string;
@@ -27,6 +31,7 @@ protected readonly errorReporter: ErrorReporter;
     protected readonly messageTypeField: string;
-    protected readonly queueConfiguration: QueueConfiguration;
-    constructor({ errorReporter, logger }: DependenciesType, { messageSchema, messageTypeField, queueName, queueConfiguration }: OptionsType);
+    protected readonly queueConfiguration?: QueueConfiguration;
+    protected readonly queueLocator?: QueueLocatorType;
+    constructor({ errorReporter, logger }: DependenciesType, { messageSchema, messageTypeField, queueName, queueConfiguration, queueLocator }: OptionsType);
     protected handleError(err: unknown): void;
     abstract close(): Promise<unknown>;
 }

dist/lib/queues/AbstractQueueService.js

@@ -13,3 +13,4 @@ "use strict";
     queueConfiguration;
-    constructor({ errorReporter, logger }, { messageSchema, messageTypeField, queueName, queueConfiguration }) {
+    queueLocator;
+    constructor({ errorReporter, logger }, { messageSchema, messageTypeField, queueName, queueConfiguration, queueLocator }) {
         this.errorReporter = errorReporter;
@@ -21,2 +22,3 @@ this.logger = logger;
         this.queueConfiguration = queueConfiguration;
+        this.queueLocator = queueLocator;
     }
@@ -23,0 +25,0 @@ handleError(err) {

package.json

 {
   "name": "@message-queue-toolkit/core",
-  "version": "1.1.0",
+  "version": "1.2.0",
   "private": false,
@@ -29,7 +29,7 @@ "license": "MIT",
   "devDependencies": {
-    "@types/node": "^20.3.1",
-    "@typescript-eslint/eslint-plugin": "^5.60.0",
-    "@typescript-eslint/parser": "^5.60.0",
+    "@types/node": "^20.4.1",
+    "@typescript-eslint/eslint-plugin": "^5.62.0",
+    "@typescript-eslint/parser": "^5.62.0",
     "del-cli": "^5.0.0",
-    "eslint": "^8.43.0",
+    "eslint": "^8.44.0",
     "eslint-config-prettier": "^8.8.0",
@@ -39,3 +39,3 @@ "eslint-plugin-import": "^2.27.5",
     "prettier": "^2.8.8",
-    "typescript": "^5.1.3"
+    "typescript": "^5.1.6"
   },
@@ -42,0 +42,0 @@ "homepage": "https://github.com/kibertoad/message-queue-toolkit",

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

14509

increased by3.2%

Lines of code

200

increased by3.63%

No dependency changes