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

Comparing version 11.0.0 to 12.0.0

dist/index.d.ts

@@ -17,2 +17,10 @@ export type { QueueConsumer, AsyncPublisher, SyncPublisher, TransactionObservabilityManager, Logger, LogFn, SchemaMap, ExtraParams, } from './lib/types/MessageQueueTypes';
 export { parseMessage } from './lib/utils/parseUtils';
+export { toDatePreprocessor } from './lib/utils/toDateProcessor';
 export { reloadConfig, isProduction } from './lib/utils/envUtils';
+export { DomainEventEmitter } from './lib/events/DomainEventEmitter';
+export { EventRegistry } from './lib/events/EventRegistry';
+export { FakeListener } from './lib/events/fakes/FakeListener';
+export * from './lib/events/eventTypes';
+export * from './lib/events/baseEventSchemas';
+export * from './lib/messages/baseMessageSchemas';
+export * from './lib/messages/MetadataFiller';

dist/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.isProduction = exports.reloadConfig = exports.parseMessage = exports.waitAndRetry = exports.objectToBuffer = exports.MessageSchemaContainer = exports.HandlerSpy = exports.MessageHandlerConfigBuilder = exports.MessageHandlerConfig = exports.HandlerContainer = exports.DoNotProcessMessageError = exports.RetryMessageLaterError = exports.objectMatches = exports.isShallowSubset = exports.MessageInvalidFormatError = exports.MessageValidationError = exports.isMessageError = exports.AbstractQueueService = void 0;
+exports.FakeListener = exports.EventRegistry = exports.DomainEventEmitter = exports.isProduction = exports.reloadConfig = exports.toDatePreprocessor = exports.parseMessage = exports.waitAndRetry = exports.objectToBuffer = exports.MessageSchemaContainer = exports.HandlerSpy = exports.MessageHandlerConfigBuilder = exports.MessageHandlerConfig = exports.HandlerContainer = exports.DoNotProcessMessageError = exports.RetryMessageLaterError = exports.objectMatches = exports.isShallowSubset = exports.MessageInvalidFormatError = exports.MessageValidationError = exports.isMessageError = exports.AbstractQueueService = void 0;
 const tslib_1 = require("tslib");
@@ -33,5 +33,17 @@ var AbstractQueueService_1 = require("./lib/queues/AbstractQueueService");
 Object.defineProperty(exports, "parseMessage", { enumerable: true, get: function () { return parseUtils_1.parseMessage; } });
+var toDateProcessor_1 = require("./lib/utils/toDateProcessor");
+Object.defineProperty(exports, "toDatePreprocessor", { enumerable: true, get: function () { return toDateProcessor_1.toDatePreprocessor; } });
 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; } });
+var DomainEventEmitter_1 = require("./lib/events/DomainEventEmitter");
+Object.defineProperty(exports, "DomainEventEmitter", { enumerable: true, get: function () { return DomainEventEmitter_1.DomainEventEmitter; } });
+var EventRegistry_1 = require("./lib/events/EventRegistry");
+Object.defineProperty(exports, "EventRegistry", { enumerable: true, get: function () { return EventRegistry_1.EventRegistry; } });
+var FakeListener_1 = require("./lib/events/fakes/FakeListener");
+Object.defineProperty(exports, "FakeListener", { enumerable: true, get: function () { return FakeListener_1.FakeListener; } });
+tslib_1.__exportStar(require("./lib/events/eventTypes"), exports);
+tslib_1.__exportStar(require("./lib/events/baseEventSchemas"), exports);
+tslib_1.__exportStar(require("./lib/messages/baseMessageSchemas"), exports);
+tslib_1.__exportStar(require("./lib/messages/MetadataFiller"), exports);
 //# sourceMappingURL=index.js.map

dist/lib/types/MessageQueueTypes.d.ts

@@ -0,1 +1,2 @@
+import type { TransactionObservabilityManager } from '@lokalise/node-core';
 import type { ZodSchema } from 'zod';
@@ -13,6 +14,3 @@ export interface QueueConsumer {
 }
-export type TransactionObservabilityManager = {
-    start: (transactionSpanId: string) => unknown;
-    stop: (transactionSpanId: string) => unknown;
-};
+export { TransactionObservabilityManager };
 export type LogFn = {
@@ -19,0 +17,0 @@ <T extends object>(obj: T, msg?: string, ...args: any[]): void;

package.json

 {
   "name": "@message-queue-toolkit/core",
-  "version": "11.0.0",
+  "version": "12.0.0",
   "private": false,
@@ -28,11 +28,12 @@ "license": "MIT",
   "dependencies": {
-    "@lokalise/node-core": "^9.14.0",
+    "@lokalise/node-core": "^9.17.0",
     "fast-equals": "^5.0.1",
-    "toad-cache": "^3.7.0"
+    "toad-cache": "^3.7.0",
+    "zod": "^3.23.6"
   },
   "devDependencies": {
-    "@types/node": "^20.11.25",
+    "@types/node": "^20.12.8",
     "@typescript-eslint/eslint-plugin": "^7.7.1",
     "@typescript-eslint/parser": "^7.7.1",
-    "@vitest/coverage-v8": "^1.5.0",
+    "@vitest/coverage-v8": "^1.6.0",
     "del-cli": "^5.1.0",
@@ -44,3 +45,3 @@ "eslint": "^8.57.0",
     "typescript": "^5.4.5",
-    "vitest": "^1.5.0"
+    "vitest": "^1.6.0"
   },
@@ -47,0 +48,0 @@ "homepage": "https://github.com/kibertoad/message-queue-toolkit",

No alert changes

Improved metrics

Total package byte prevSize

81425

increased by37.7%

Number of package files

70

increased by52.17%

Lines of code

1210

increased by44.56%

Worsened metrics

Dependency count

4

increased by33.33%

Dependency changes

• + Addedzod@^3.23.6

• Updated@lokalise/node-core@^9.17.0