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

Comparing version 3.0.0 to 3.1.0

dist/index.d.ts

 export type { QueueConsumer, AsyncPublisher, SyncPublisher, TransactionObservabilityManager, Logger, SchemaMap, } from './lib/types/MessageQueueTypes';
 export { AbstractQueueService } from './lib/queues/AbstractQueueService';
-export type { NewQueueOptions, ExistingQueueOptions, NewQueueOptionsMultiSchema, ExistingQueueOptionsMultiSchema, MonoSchemaQueueOptions, MultiSchemaConsumerOptions, QueueDependencies, QueueConsumerDependencies, Deserializer, CommonQueueLocator, } from './lib/queues/AbstractQueueService';
+export type { NewQueueOptions, ExistingQueueOptions, NewQueueOptionsMultiSchema, ExistingQueueOptionsMultiSchema, MonoSchemaQueueOptions, MultiSchemaConsumerOptions, QueueDependencies, QueueConsumerDependencies, Deserializer, CommonQueueLocator, DeletionConfig, } from './lib/queues/AbstractQueueService';
 export { isMessageError, MessageValidationError, MessageInvalidFormatError, } from './lib/errors/Errors';
@@ -12,1 +12,2 @@ export { HandlerContainer, MessageHandlerConfig, MessageHandlerConfigBuilder, } from './lib/queues/HandlerContainer';
 export { parseMessage } from './lib/utils/parseUtils';
+export { reloadConfig, isProduction } from './lib/utils/envUtils';

dist/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.parseMessage = exports.waitAndRetry = exports.objectToBuffer = exports.MessageSchemaContainer = exports.MessageHandlerConfigBuilder = exports.MessageHandlerConfig = exports.HandlerContainer = exports.MessageInvalidFormatError = exports.MessageValidationError = exports.isMessageError = exports.AbstractQueueService = void 0;
+exports.isProduction = exports.reloadConfig = exports.parseMessage = exports.waitAndRetry = exports.objectToBuffer = exports.MessageSchemaContainer = exports.MessageHandlerConfigBuilder = exports.MessageHandlerConfig = exports.HandlerContainer = exports.MessageInvalidFormatError = exports.MessageValidationError = exports.isMessageError = exports.AbstractQueueService = void 0;
 var AbstractQueueService_1 = require("./lib/queues/AbstractQueueService");
@@ -22,2 +22,5 @@ Object.defineProperty(exports, "AbstractQueueService", { enumerable: true, get: function () { return AbstractQueueService_1.AbstractQueueService; } });
 Object.defineProperty(exports, "parseMessage", { enumerable: true, get: function () { return parseUtils_1.parseMessage; } });
+var envUtils_1 = require("./lib/utils/envUtils");
+Object.defineProperty(exports, "reloadConfig", { enumerable: true, get: function () { return envUtils_1.reloadConfig; } });
+Object.defineProperty(exports, "isProduction", { enumerable: true, get: function () { return envUtils_1.isProduction; } });
 //# sourceMappingURL=index.js.map

dist/lib/queues/AbstractQueueService.d.ts

@@ -17,5 +17,10 @@ import type { ErrorReporter, ErrorResolver, Either } from '@lokalise/node-core';
 export type ExistingQueueOptionsMultiSchema<MessagePayloadSchemas extends object, QueueLocatorType extends object, ExecutionContext> = ExistingQueueOptions<QueueLocatorType> & MultiSchemaConsumerOptions<MessagePayloadSchemas, ExecutionContext>;
+export type DeletionConfig = {
+    deleteIfExists?: boolean;
+    forceDeleteInProduction?: boolean;
+};
 export type NewQueueOptions<CreationConfigType extends object> = {
     messageTypeField: string;
     locatorConfig?: never;
+    deletionConfig?: DeletionConfig;
     creationConfig: CreationConfigType;
@@ -26,2 +31,3 @@ };
     locatorConfig: QueueLocatorType;
+    deletionConfig?: DeletionConfig;
     creationConfig?: never;
@@ -44,3 +50,4 @@ };
     protected readonly locatorConfig?: QueueLocatorType;
-    constructor({ errorReporter, logger }: DependenciesType, { messageTypeField, creationConfig, locatorConfig }: OptionsType);
+    protected readonly deletionConfig?: DeletionConfig;
+    constructor({ errorReporter, logger }: DependenciesType, options: OptionsType);
     protected abstract resolveSchema(message: MessagePayloadSchemas): Either<Error, ZodSchema<MessagePayloadSchemas>>;
@@ -47,0 +54,0 @@ protected abstract resolveMessage(message: MessageEnvelopeType): Either<MessageInvalidFormatError | MessageValidationError, unknown>;

dist/lib/queues/AbstractQueueService.js

@@ -12,8 +12,10 @@ "use strict";
     locatorConfig;
-    constructor({ errorReporter, logger }, { messageTypeField, creationConfig, locatorConfig }) {
+    deletionConfig;
+    constructor({ errorReporter, logger }, options) {
         this.errorReporter = errorReporter;
         this.logger = logger;
-        this.messageTypeField = messageTypeField;
-        this.creationConfig = creationConfig;
-        this.locatorConfig = locatorConfig;
+        this.messageTypeField = options.messageTypeField;
+        this.creationConfig = options.creationConfig;
+        this.locatorConfig = options.locatorConfig;
+        this.deletionConfig = options.deletionConfig;
     }
@@ -20,0 +22,0 @@ handleError(err) {

package.json

 {
   "name": "@message-queue-toolkit/core",
-  "version": "3.0.0",
+  "version": "3.1.0",
   "private": false,
@@ -5,0 +5,0 @@ "license": "MIT",

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

27385

increased by6.49%

Number of package files

31

increased by10.71%

Lines of code

394

increased by7.65%

No dependency changes