Skip to content
2 changes: 1 addition & 1 deletion examples/sns-sqs/lib/01-publish-message.spec.ts
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
import { afterEach, beforeEach, describe, expect, it } from 'vitest'
import { userConsumer } from './common/Dependencies.ts'
import { publisherManager } from './common/TestPublisherManager.ts'
import { UserConsumer } from './common/UserConsumer.js'
import { UserConsumer } from './common/UserConsumer.ts'

describe('Publish message', () => {
beforeEach(async () => {
Expand Down
2 changes: 1 addition & 1 deletion examples/sns-sqs/lib/02-configurable-init.spec.ts
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ import {
transactionObservabilityManager,
} from './common/Dependencies.ts'
import { publisherManager } from './common/TestPublisherManager.ts'
import { UserConsumer } from './common/UserConsumer.js'
import { UserConsumer } from './common/UserConsumer.ts'

// This test suite illustrates the importance of only initting the consumers you need
// to prevent test execution time from increasing with every new consumer added
Expand Down
6 changes: 4 additions & 2 deletions examples/sns-sqs/lib/common/Dependencies.ts
Original file line number Diff line number Diff line change
@@ -1,11 +1,13 @@
import { SNSClient, type SNSClientConfig } from '@aws-sdk/client-sns'
import { SNSClient } from '@aws-sdk/client-sns'
import { SQSClient } from '@aws-sdk/client-sqs'
import { STSClient } from '@aws-sdk/client-sts'
import { SnsConsumerErrorResolver } from '@message-queue-toolkit/sns'
import pino from 'pino'
import { UserConsumer } from './UserConsumer.ts'

export const TEST_AWS_CONFIG: SNSClientConfig = {
// Shared across SNS, SQS and STS clients, so it is intentionally not typed as
// any single client's config - those types are no longer mutually assignable.
export const TEST_AWS_CONFIG = {
endpoint: 'http://s3.localhost.localstack.cloud:4566',
region: 'eu-west-1',
credentials: {
Expand Down
6 changes: 3 additions & 3 deletions examples/sns-sqs/lib/common/TestMessages.ts
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
import type { CommonEventDefinition } from '@message-queue-toolkit/schemas'
import {
type SnsAwareEventDefinition,
enrichMessageSchemaWithBaseStrict,
type SnsAwareEventDefinition,
} from '@message-queue-toolkit/schemas'
import type { CommonEventDefinition } from '@message-queue-toolkit/schemas'
import { z } from 'zod/v3'
import { z } from 'zod'

type AllConsumerMessageSchemas<MessageDefinitionTypes extends CommonEventDefinition[]> = z.infer<
MessageDefinitionTypes[number]['consumerSchema']
Expand Down
3 changes: 1 addition & 2 deletions examples/sns-sqs/lib/common/TestPublisherManager.ts
Original file line number Diff line number Diff line change
@@ -1,8 +1,7 @@
import { CommonMetadataFiller, EventRegistry } from '@message-queue-toolkit/core'
import type { AllPublisherMessageSchemas } from '@message-queue-toolkit/schemas'
import { SnsPublisherManager } from '@message-queue-toolkit/sns'
import type { CommonSnsPublisher } from '@message-queue-toolkit/sns'
import { CommonSnsPublisherFactory } from '@message-queue-toolkit/sns'
import { CommonSnsPublisherFactory, SnsPublisherManager } from '@message-queue-toolkit/sns'
import { errorReporter, logger, snsClient, stsClient } from './Dependencies.ts'
import { UserEvents, type UserEventsType } from './TestMessages.ts'

Expand Down
2 changes: 1 addition & 1 deletion examples/sns-sqs/lib/common/UserConsumer.ts
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
import { MessageHandlerConfigBuilder } from '@message-queue-toolkit/core'
import type { ConsumerMessageSchema } from '@message-queue-toolkit/schemas'
import { AbstractSnsSqsConsumer, type SNSSQSConsumerDependencies } from '@message-queue-toolkit/sns'
import { UserEvents } from './TestMessages.ts'
import { userCreatedHandler } from './handlers/UserCreatedHandler.ts'
import { userUpdatedHandler } from './handlers/UserUpdatedHandler.ts'
import { UserEvents } from './TestMessages.ts'

type SupportedMessages = ConsumerMessageSchema<
typeof UserEvents.created | typeof UserEvents.updated
Expand Down
2 changes: 1 addition & 1 deletion examples/sns-sqs/lib/common/handlers/UserCreatedHandler.ts
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import type { Either } from '@lokalise/node-core'
import type { z } from 'zod/v3'
import type { z } from 'zod'
import type { USER_SCHEMA, UserEvents } from '../TestMessages.ts'

let _latestData: z.infer<typeof USER_SCHEMA>
Expand Down
2 changes: 1 addition & 1 deletion examples/sns-sqs/lib/common/handlers/UserUpdatedHandler.ts
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import type { Either } from '@lokalise/node-core'
import type { z } from 'zod/v3'
import type { z } from 'zod'
import type { USER_SCHEMA, UserEvents } from '../TestMessages.ts'

let _latestData: z.infer<typeof USER_SCHEMA>
Expand Down
32 changes: 16 additions & 16 deletions examples/sns-sqs/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -16,24 +16,24 @@
"url": "https://github.com/kibertoad/message-queue-toolkit.git"
},
"dependencies": {
"@aws-sdk/client-sns": "^3.812.0",
"@aws-sdk/client-sts": "^3.812.0",
"@aws-sdk/client-sqs": "^3.812.0",
"@message-queue-toolkit/core": "^21.2.0",
"@message-queue-toolkit/schemas": "^6.2.0",
"@message-queue-toolkit/sns": "22.2.0",
"@message-queue-toolkit/sqs": "21.1.0",
"pino": "^9.7.0",
"zod": "^3.25.7"
"@aws-sdk/client-sns": "^3.1106.0",
"@aws-sdk/client-sts": "^3.1106.0",
"@aws-sdk/client-sqs": "^3.1106.0",
"@message-queue-toolkit/core": "^26.1.1",
"@message-queue-toolkit/schemas": "^7.2.0",
"@message-queue-toolkit/sns": "26.2.1",
"@message-queue-toolkit/sqs": "26.1.1",
"pino": "^10.3.1",
"zod": "^4.4.3"
},
"devDependencies": {
"@biomejs/biome": "^2.3.2",
"@lokalise/biome-config": "^3.1.0",
"@types/node": "^22.15.19",
"@lokalise/tsconfig": "^1.3.0",
"@vitest/coverage-v8": "^4.0.15",
"typescript": "^5.8.3",
"vitest": "^4.0.15"
"@biomejs/biome": "^2.5.6",
"@lokalise/biome-config": "^3.1.1",
"@types/node": "^26.1.2",
"@lokalise/tsconfig": "^5.0.0",
"@vitest/coverage-v8": "^4.1.10",
"typescript": "^7.0.2",
"vitest": "^4.1.10"
},
"private": true
}
2 changes: 1 addition & 1 deletion examples/sns-sqs/tsconfig.json
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,6 @@
"extends": "@lokalise/tsconfig/tsc",
"include": ["lib/**/*", "test/**/*", "vitest.config.ts"],
"compilerOptions": {
"types": ["vitest/globals"]
"types": ["node", "vitest/globals"]
}
}
4 changes: 2 additions & 2 deletions package.json
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@
},
"dependencies": {},
"devDependencies": {
"turbo": "^2.10.7"
"turbo": "^2.10.8"
},
"packageManager": "pnpm@11.1.2"
"packageManager": "pnpm@11.18.0"
Comment thread
coderabbitai[bot] marked this conversation as resolved.
}
16 changes: 8 additions & 8 deletions packages/amqp/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
"name": "@message-queue-toolkit/amqp",
"version": "24.1.1",
"engines": {
"node": ">=18"
"node": ">=22.0.0"
},
"private": false,
"license": "MIT",
Expand Down Expand Up @@ -31,7 +31,7 @@
"prepublishOnly": "pnpm run lint && pnpm run build"
},
"dependencies": {
"@lokalise/node-core": "^14.7.4"
"@lokalise/node-core": "^14.8.1"
},
"peerDependencies": {
"@message-queue-toolkit/core": ">=25.0.0",
Expand All @@ -40,20 +40,20 @@
"zod": ">=3.25.76 <5.0.0"
},
"devDependencies": {
"@biomejs/biome": "^2.5.3",
"@lokalise/biome-config": "^3.1.0",
"@lokalise/tsconfig": "^3.0.0",
"@biomejs/biome": "^2.5.6",
"@lokalise/biome-config": "^3.1.1",
"@lokalise/tsconfig": "^5.0.0",
"@message-queue-toolkit/core": "workspace:*",
"@types/amqplib": "0.10.8",
"@types/node": "^25.5.0",
"@types/node": "^26.1.2",
"@vitest/coverage-v8": "^4.1.10",
"amqplib": "^2.0.1",
"awilix": "^13.0.5",
"awilix-manager": "^7.0.0",
"rimraf": "^6.1.3",
"typescript": "^5.9.3",
"typescript": "^7.0.2",
"vitest": "^4.1.10",
"zod": "^4.1.13"
"zod": "^4.4.3"
},
"homepage": "https://github.com/kibertoad/message-queue-toolkit",
"repository": {
Expand Down
3 changes: 3 additions & 0 deletions packages/amqp/tsconfig.build.json
Original file line number Diff line number Diff line change
@@ -1,5 +1,8 @@
{
"extends": ["./tsconfig.json", "@lokalise/tsconfig/build-public-lib"],
"compilerOptions": {
"rootDir": "lib"
},
"include": ["lib/**/*"],
"exclude": ["lib/**/*.spec.ts", "lib/**/*.test.ts"]
}
2 changes: 1 addition & 1 deletion packages/amqp/tsconfig.json
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,6 @@
"extends": "@lokalise/tsconfig/tsc",
"include": ["lib/**/*", "test/**/*", "vitest.config.ts"],
"compilerOptions": {
"types": ["vitest/globals"]
"types": ["node", "vitest/globals"]
}
}
16 changes: 8 additions & 8 deletions packages/core/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@
"prepublishOnly": "pnpm run lint && pnpm run build"
},
"dependencies": {
"@lokalise/node-core": "^14.2.0",
"@lokalise/node-core": "^14.8.1",
"@lokalise/universal-ts-utils": "^4.11.0",
"@message-queue-toolkit/schemas": "^7.2.0",
"dot-prop": "^10.2.0",
Expand All @@ -38,18 +38,18 @@
"zod": ">=3.25.76 <5.0.0"
},
"devDependencies": {
"@biomejs/biome": "^2.5.3",
"@lokalise/biome-config": "^3.1.0",
"@lokalise/tsconfig": "^3.0.0",
"@types/node": "^25.0.2",
"@biomejs/biome": "^2.5.6",
"@lokalise/biome-config": "^3.1.1",
"@lokalise/tsconfig": "^5.0.0",
"@types/node": "^26.1.2",
"@types/tmp": "^0.2.6",
"@vitest/coverage-v8": "^4.1.10",
"awilix": "^13.0.5",
"awilix-manager": "^7.0.0",
"rimraf": "^6.0.1",
"typescript": "^5.9.2",
"rimraf": "^6.1.3",
"typescript": "^7.0.2",
"vitest": "^4.1.10",
"zod": "^4.1.13"
"zod": "^4.4.3"
},
"homepage": "https://github.com/kibertoad/message-queue-toolkit",
"repository": {
Expand Down
3 changes: 3 additions & 0 deletions packages/core/tsconfig.build.json
Original file line number Diff line number Diff line change
@@ -1,5 +1,8 @@
{
"extends": ["./tsconfig.json", "@lokalise/tsconfig/build-public-lib"],
"compilerOptions": {
"rootDir": "lib"
},
"include": ["lib/**/*"],
"exclude": ["lib/**/*.spec.ts", "lib/**/*.test.ts"]
}
2 changes: 1 addition & 1 deletion packages/core/tsconfig.json
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,6 @@
"extends": "@lokalise/tsconfig/tsc",
"include": ["lib/**/*", "test/**/*", "vitest.config.ts"],
"compilerOptions": {
"types": ["vitest/globals"]
"types": ["node", "vitest/globals"]
}
}
16 changes: 8 additions & 8 deletions packages/gcp-pubsub/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -28,31 +28,31 @@
},
"dependencies": {
"@grpc/grpc-js": "^1.14.4",
"@lokalise/node-core": "^14.6.1"
"@lokalise/node-core": "^14.8.1"
},
"peerDependencies": {
"@google-cloud/pubsub": "^5.3.1",
"@message-queue-toolkit/core": ">=26.0.0",
"zod": ">=3.25.76 <5.0.0"
},
"devDependencies": {
"@biomejs/biome": "^2.5.3",
"@biomejs/biome": "^2.5.6",
"@google-cloud/pubsub": "^5.3.1",
"@lokalise/biome-config": "^3.1.0",
"@lokalise/tsconfig": "^3.0.0",
"@lokalise/biome-config": "^3.1.1",
"@lokalise/tsconfig": "^5.0.0",
"@message-queue-toolkit/core": "workspace:*",
"@message-queue-toolkit/gcs-payload-store": "*",
"@message-queue-toolkit/redis-message-deduplication-store": "*",
"@message-queue-toolkit/schemas": "*",
"@types/node": "^25.0.2",
"@types/node": "^26.1.2",
"@vitest/coverage-v8": "^4.1.10",
"awilix": "^13.0.5",
"awilix-manager": "^7.0.0",
"ioredis": "^5.11.1",
"rimraf": "^6.0.1",
"typescript": "^5.9.3",
"rimraf": "^6.1.3",
"typescript": "^7.0.2",
"vitest": "^4.1.10",
"zod": "^4.1.13"
"zod": "^4.4.3"
},
"homepage": "https://github.com/kibertoad/message-queue-toolkit",
"repository": {
Expand Down
3 changes: 3 additions & 0 deletions packages/gcp-pubsub/tsconfig.build.json
Original file line number Diff line number Diff line change
@@ -1,5 +1,8 @@
{
"extends": ["./tsconfig.json", "@lokalise/tsconfig/build-public-lib"],
"compilerOptions": {
"rootDir": "lib"
},
"include": ["lib/**/*"],
"exclude": ["lib/**/*.spec.ts", "lib/**/*.test.ts"]
}
2 changes: 1 addition & 1 deletion packages/gcp-pubsub/tsconfig.json
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,6 @@
"extends": "@lokalise/tsconfig/tsc",
"include": ["lib/**/*", "test/**/*", "vitest.config.ts"],
"compilerOptions": {
"types": ["vitest/globals"]
"types": ["node", "vitest/globals"]
}
}
12 changes: 6 additions & 6 deletions packages/gcs-payload-store/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -34,13 +34,13 @@
"devDependencies": {
"@google-cloud/storage": "^7.21.0",
"@message-queue-toolkit/core": "workspace:*",
"@biomejs/biome": "^2.5.3",
"@lokalise/biome-config": "^3.1.0",
"@lokalise/tsconfig": "^3.0.0",
"@types/node": "^25.0.2",
"@biomejs/biome": "^2.5.6",
"@lokalise/biome-config": "^3.1.1",
"@lokalise/tsconfig": "^5.0.0",
"@types/node": "^26.1.2",
"@vitest/coverage-v8": "^4.1.10",
"rimraf": "^6.0.1",
"typescript": "^5.9.2",
"rimraf": "^6.1.3",
"typescript": "^7.0.2",
"vitest": "^4.1.10"
},
"homepage": "https://github.com/kibertoad/message-queue-toolkit",
Expand Down
3 changes: 3 additions & 0 deletions packages/gcs-payload-store/tsconfig.build.json
Original file line number Diff line number Diff line change
@@ -1,5 +1,8 @@
{
"extends": ["./tsconfig.json", "@lokalise/tsconfig/build-public-lib"],
"compilerOptions": {
"rootDir": "lib"
},
"include": ["lib/**/*"],
"exclude": ["lib/**/*.spec.ts", "lib/**/*.test.ts"]
}
2 changes: 1 addition & 1 deletion packages/gcs-payload-store/tsconfig.json
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,6 @@
"extends": "@lokalise/tsconfig/tsc",
"include": ["lib/**/*", "test/**/*", "vitest.config.ts"],
"compilerOptions": {
"types": ["vitest/globals"]
"types": ["node", "vitest/globals"]
}
}
Loading
Loading