@message-queue-toolkit/core 21.2.0

Author: kibertoad

packages/core/lib/payload-store/offloadedPayloadMessageSchemas.ts

@@ -1,4 +1,4 @@
-import { z } from 'zod'
+import { z } from 'zod/v3'
 
 /**
  * When the payload is too large to be sent in a single message, it is offloaded to a storage service and a pointer to the offloaded payload is sent instead.

packages/core/lib/queues/AbstractPublisherManager.ts

@@ -1,4 +1,4 @@
-import type { TypeOf, z } from 'zod'
+import type { TypeOf, z } from 'zod/v3'
 
 import type { EventRegistry } from '../events/EventRegistry.ts'
 import type { PublisherBaseEventType } from '../events/baseEventSchemas.ts'

packages/core/lib/queues/AbstractQueueService.ts

@@ -9,7 +9,7 @@ import {
 } from '@lokalise/node-core'
 import { resolveGlobalErrorLogObject } from '@lokalise/node-core'
 import type { CommonEventDefinition } from '@message-queue-toolkit/schemas'
-import type { ZodSchema, ZodType } from 'zod'
+import type { ZodSchema, ZodType } from 'zod/v3'
 
 import {
   MESSAGE_DEDUPLICATION_OPTIONS_SCHEMA,

packages/core/lib/queues/HandlerContainer.ts

@@ -1,7 +1,7 @@
 import type { Either } from '@lokalise/node-core'
 import type { CommonEventDefinition } from '@message-queue-toolkit/schemas'
 import { isCommonEventDefinition } from '@message-queue-toolkit/schemas'
-import type { ZodSchema } from 'zod'
+import type { ZodSchema } from 'zod/v3'
 
 import type { DoNotProcessMessageError } from '../errors/DoNotProcessError.ts'
 import type { RetryMessageLaterError } from '../errors/RetryMessageLaterError.ts'

packages/core/lib/queues/MessageSchemaContainer.ts

@@ -1,6 +1,6 @@
 import type { Either } from '@lokalise/node-core'
 import type { CommonEventDefinition } from '@message-queue-toolkit/schemas'
-import type { ZodSchema } from 'zod'
+import type { ZodSchema } from 'zod/v3'
 
 export type MessageSchemaContainerOptions<MessagePayloadSchemas extends object> = {
   messageDefinitions: readonly CommonEventDefinition[]

packages/core/lib/types/MessageQueueTypes.ts

@@ -1,5 +1,5 @@
 import type { CommonLogger, TransactionObservabilityManager } from '@lokalise/node-core'
-import type { ZodSchema } from 'zod'
+import type { ZodSchema } from 'zod/v3'
 
 import type { PublicHandlerSpy } from '../queues/HandlerSpy.ts'
 

packages/core/lib/types/queueOptionsTypes.ts

@@ -1,5 +1,5 @@
 import type { CommonLogger, ErrorReporter, ErrorResolver } from '@lokalise/node-core'
-import type { ZodSchema } from 'zod'
+import type { ZodSchema } from 'zod/v3'
 
 import type { PayloadStoreConfig } from '../payload-store/payloadStoreTypes.ts'
 import type { MessageHandlerConfig } from '../queues/HandlerContainer.ts'

packages/core/lib/utils/parseUtils.ts

@@ -1,5 +1,5 @@
 import type { Either, ErrorResolver } from '@lokalise/node-core'
-import type { ZodSchema } from 'zod'
+import type { ZodSchema } from 'zod/v3'
 
 import type { MessageInvalidFormatError, MessageValidationError } from '../errors/Errors.ts'
 

packages/core/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@message-queue-toolkit/core",
-    "version": "21.1.1",
+    "version": "21.2.0",
     "private": false,
     "license": "MIT",
     "description": "Useful utilities, interfaces and base classes for message queue handling. Supports AMQP and SQS with a common abstraction on top currently",
@@ -26,26 +26,26 @@
         "prepublishOnly": "npm run lint && npm run build"
     },
     "dependencies": {
-        "@lokalise/node-core": "^14.0.0",
-        "@message-queue-toolkit/schemas": "^6.0.0",
-        "fast-equals": "^5.0.1",
+        "@lokalise/node-core": "^14.0.1",
+        "@message-queue-toolkit/schemas": "^6.2.0",
+        "fast-equals": "^5.2.2",
         "json-stream-stringify": "^3.1.6",
         "tmp": "^0.2.3",
         "toad-cache": "^3.7.0",
-        "zod": "^3.23.8"
+        "zod": "^3.25.3"
     },
     "devDependencies": {
         "@biomejs/biome": "1.9.4",
         "@lokalise/biome-config": "^2.0.0",
         "@lokalise/tsconfig": "^1.3.0",
-        "@types/node": "^22.7.5",
+        "@types/node": "^22.15.19",
         "@types/tmp": "^0.2.6",
-        "@vitest/coverage-v8": "^3.0.7",
+        "@vitest/coverage-v8": "^3.1.4",
         "awilix": "^12.0.1",
-        "awilix-manager": "^6.0.0",
+        "awilix-manager": "^6.1.0",
         "rimraf": "^6.0.1",
-        "typescript": "^5.7.2",
-        "vitest": "^3.0.7"
+        "typescript": "^5.8.3",
+        "vitest": "^3.1.4"
     },
     "homepage": "https://github.com/kibertoad/message-queue-toolkit",
     "repository": {

packages/core/test/testContext.ts

@@ -3,7 +3,7 @@ import { type Resolver, asClass } from 'awilix'
 import { Lifetime, asFunction, createContainer } from 'awilix'
 import { AwilixManager } from 'awilix-manager'
 import { pino } from 'pino'
-import { z } from 'zod'
+import { z } from 'zod/v3'
 
 import type { TransactionObservabilityManager } from '@lokalise/node-core'
 import { enrichMessageSchemaWithBase } from '@message-queue-toolkit/schemas'