diff --git a/packages/amqp/package.json b/packages/amqp/package.json index 6376efe7..2d8f6019 100644 --- a/packages/amqp/package.json +++ b/packages/amqp/package.json @@ -28,7 +28,7 @@ "prepublishOnly": "npm run lint && npm run build" }, "dependencies": { - "@lokalise/node-core": "^14.2.0" + "@lokalise/node-core": "^14.4.2" }, "peerDependencies": { "@message-queue-toolkit/core": ">=22.0.0", diff --git a/packages/core/lib/events/DomainEventEmitter.spec.ts b/packages/core/lib/events/DomainEventEmitter.spec.ts index e7efdb7c..91c79b44 100644 --- a/packages/core/lib/events/DomainEventEmitter.spec.ts +++ b/packages/core/lib/events/DomainEventEmitter.spec.ts @@ -412,7 +412,7 @@ describe('AutopilotEventEmitter', () => { }) expect(logSpy).toHaveBeenCalledWith({ error: expect.anything(), - message: 'ErroredFakeListener error', + msg: 'ErroredFakeListener error', ...expectedContext, }) diff --git a/packages/core/lib/message-deduplication/messageDeduplicationTypes.ts b/packages/core/lib/message-deduplication/messageDeduplicationTypes.ts index 0516214a..049aab6b 100644 --- a/packages/core/lib/message-deduplication/messageDeduplicationTypes.ts +++ b/packages/core/lib/message-deduplication/messageDeduplicationTypes.ts @@ -1,6 +1,6 @@ import type { Either } from '@lokalise/node-core' import type { MessageDeduplicationOptions } from '@message-queue-toolkit/schemas' -import type { AcquireLockTimeoutError } from './AcquireLockTimeoutError.js' +import type { AcquireLockTimeoutError } from './AcquireLockTimeoutError.ts' export interface ReleasableLock { release(): Promise diff --git a/packages/core/lib/queues/AbstractQueueService.ts b/packages/core/lib/queues/AbstractQueueService.ts index 773ca647..8f42c213 100644 --- a/packages/core/lib/queues/AbstractQueueService.ts +++ b/packages/core/lib/queues/AbstractQueueService.ts @@ -17,7 +17,7 @@ import type { MessageInvalidFormatError, MessageValidationError } from '../error import { type AcquireLockTimeoutError, isAcquireLockTimeoutError, -} from '../message-deduplication/AcquireLockTimeoutError.js' +} from '../message-deduplication/AcquireLockTimeoutError.ts' import { DEFAULT_MESSAGE_DEDUPLICATION_OPTIONS, type DeduplicationRequester, diff --git a/packages/core/package.json b/packages/core/package.json index cbecb600..d249c26b 100644 --- a/packages/core/package.json +++ b/packages/core/package.json @@ -26,11 +26,11 @@ "prepublishOnly": "npm run lint && npm run build" }, "dependencies": { - "@lokalise/node-core": "^14.2.0", + "@lokalise/node-core": "^14.4.2", "@message-queue-toolkit/schemas": "^7.0.0", - "fast-equals": "^5.2.2", + "fast-equals": "^5.3.2", "json-stream-stringify": "^3.1.6", - "tmp": "^0.2.3", + "tmp": "^0.2.5", "toad-cache": "^3.7.0" }, "peerDependencies": { diff --git a/packages/kafka/lib/AbstractKafkaConsumer.ts b/packages/kafka/lib/AbstractKafkaConsumer.ts index f26d3574..0ce936b5 100644 --- a/packages/kafka/lib/AbstractKafkaConsumer.ts +++ b/packages/kafka/lib/AbstractKafkaConsumer.ts @@ -38,7 +38,7 @@ import { ILLEGAL_GENERATION, REBALANCE_IN_PROGRESS, UNKNOWN_MEMBER_ID } from './ import { type KafkaMessageBatchOptions, KafkaMessageBatchStream, -} from './utils/KafkaMessageBatchStream.js' +} from './utils/KafkaMessageBatchStream.ts' import { safeJsonDeserializer } from './utils/safeJsonDeserializer.ts' export type KafkaConsumerDependencies = KafkaDependencies & diff --git a/packages/kafka/lib/handler-routing/KafkaHandlerConfig.ts b/packages/kafka/lib/handler-routing/KafkaHandlerConfig.ts index 47eab52f..d333cefb 100644 --- a/packages/kafka/lib/handler-routing/KafkaHandlerConfig.ts +++ b/packages/kafka/lib/handler-routing/KafkaHandlerConfig.ts @@ -1,5 +1,5 @@ import type { ZodSchema } from 'zod/v4' -import type { DeserializedMessage, RequestContext } from '../types.js' +import type { DeserializedMessage, RequestContext } from '../types.ts' export type KafkaHandler< MessageValue extends object, diff --git a/packages/kafka/package.json b/packages/kafka/package.json index 3fb9ef11..f621be1d 100644 --- a/packages/kafka/package.json +++ b/packages/kafka/package.json @@ -51,7 +51,7 @@ "prepublishOnly": "npm run lint && npm run build" }, "dependencies": { - "@lokalise/node-core": "^14.2.0", + "@lokalise/node-core": "^14.4.2", "@lokalise/universal-ts-utils": "^4.5.1", "@platformatic/kafka": "^1.15.0" }, diff --git a/packages/metrics/lib/prometheus/metrics/message-time/PrometheusMessageQueueTimeMetric.spec.ts b/packages/metrics/lib/prometheus/metrics/message-time/PrometheusMessageQueueTimeMetric.spec.ts index cd7a78c5..ac28c38f 100644 --- a/packages/metrics/lib/prometheus/metrics/message-time/PrometheusMessageQueueTimeMetric.spec.ts +++ b/packages/metrics/lib/prometheus/metrics/message-time/PrometheusMessageQueueTimeMetric.spec.ts @@ -2,7 +2,7 @@ import type { ProcessedMessageMetadata } from '@message-queue-toolkit/core' import type { Histogram } from 'prom-client' import * as promClient from 'prom-client' import { describe, expect, it, vi } from 'vitest' -import { PrometheusMessageQueueTimeMetric } from './PrometheusMessageQueueTimeMetric.js' +import { PrometheusMessageQueueTimeMetric } from './PrometheusMessageQueueTimeMetric.ts' type TestMessage = { id: string diff --git a/packages/metrics/package.json b/packages/metrics/package.json index ae0ab082..7d4f2c2f 100644 --- a/packages/metrics/package.json +++ b/packages/metrics/package.json @@ -26,7 +26,7 @@ "prepublishOnly": "npm run lint && npm run build" }, "dependencies": { - "@lokalise/node-core": "^14.2.0", + "@lokalise/node-core": "^14.4.2", "@lokalise/universal-ts-utils": "^4.5.1" }, "peerDependencies": { diff --git a/packages/redis-message-deduplication-store/package.json b/packages/redis-message-deduplication-store/package.json index c5252373..97629fc9 100644 --- a/packages/redis-message-deduplication-store/package.json +++ b/packages/redis-message-deduplication-store/package.json @@ -28,7 +28,7 @@ "prepublishOnly": "npm run lint && npm run build" }, "dependencies": { - "@lokalise/node-core": "^14.2.0", + "@lokalise/node-core": "^14.4.2", "redis-semaphore": "^5.6.2" }, "peerDependencies": { diff --git a/packages/schemas/lib/events/eventTypes.ts b/packages/schemas/lib/events/eventTypes.ts index 6b3014f4..53856663 100644 --- a/packages/schemas/lib/events/eventTypes.ts +++ b/packages/schemas/lib/events/eventTypes.ts @@ -1,6 +1,6 @@ import { z } from 'zod/v4' -import { MetadataObjectSchema } from '../messages/baseMessageSchemas.js' +import { MetadataObjectSchema } from '../messages/baseMessageSchemas.ts' import { CONSUMER_BASE_EVENT_SCHEMA, PUBLISHER_BASE_EVENT_SCHEMA } from './baseEventSchemas.ts' export type EventTypeNames = diff --git a/packages/sns/lib/utils/snsInitter.ts b/packages/sns/lib/utils/snsInitter.ts index f6dbb35f..5c1c9b40 100644 --- a/packages/sns/lib/utils/snsInitter.ts +++ b/packages/sns/lib/utils/snsInitter.ts @@ -16,7 +16,7 @@ import { isCreateTopicCommand, type TopicResolutionOptions } from '../types/Topi import type { SNSSubscriptionOptions } from './snsSubscriber.ts' import { subscribeToTopic } from './snsSubscriber.ts' import { assertTopic, deleteSubscription, deleteTopic, getTopicAttributes } from './snsUtils.ts' -import { buildTopicArn } from './stsUtils.js' +import { buildTopicArn } from './stsUtils.ts' // biome-ignore lint/complexity/noExcessiveCognitiveComplexity: fixme export async function initSnsSqs( diff --git a/packages/sns/lib/utils/snsSubscriber.ts b/packages/sns/lib/utils/snsSubscriber.ts index 0eb06f53..6f1963c5 100644 --- a/packages/sns/lib/utils/snsSubscriber.ts +++ b/packages/sns/lib/utils/snsSubscriber.ts @@ -13,7 +13,7 @@ import { type TopicResolutionOptions, } from '../types/TopicTypes.ts' import { assertTopic, findSubscriptionByTopicAndQueue } from './snsUtils.ts' -import { buildTopicArn } from './stsUtils.js' +import { buildTopicArn } from './stsUtils.ts' export type SNSSubscriptionOptions = Omit< SubscribeCommandInput, diff --git a/packages/sns/package.json b/packages/sns/package.json index 96933e46..f5be6291 100644 --- a/packages/sns/package.json +++ b/packages/sns/package.json @@ -28,7 +28,7 @@ "prepublishOnly": "npm run lint && npm run build" }, "dependencies": { - "@lokalise/node-core": "^14.2.0", + "@lokalise/node-core": "^14.4.2", "sqs-consumer": "^14.0.0" }, "peerDependencies": { diff --git a/packages/sqs/lib/utils/sqsAttributeUtils.ts b/packages/sqs/lib/utils/sqsAttributeUtils.ts index 92c56868..7066888e 100644 --- a/packages/sqs/lib/utils/sqsAttributeUtils.ts +++ b/packages/sqs/lib/utils/sqsAttributeUtils.ts @@ -3,7 +3,7 @@ import { SQS_RESOURCE_ANY, SQS_RESOURCE_CURRENT_QUEUE, type SQSPolicyConfig, -} from '../sqs/AbstractSqsService.js' +} from '../sqs/AbstractSqsService.ts' const POLICY_VERSION = '2012-10-17' diff --git a/packages/sqs/package.json b/packages/sqs/package.json index 19c5133c..3b08a033 100644 --- a/packages/sqs/package.json +++ b/packages/sqs/package.json @@ -28,7 +28,7 @@ "prepublishOnly": "npm run lint && npm run build" }, "dependencies": { - "@lokalise/node-core": "^14.2.0", + "@lokalise/node-core": "^14.4.2", "sqs-consumer": "^14.0.0" }, "peerDependencies": { diff --git a/packages/sqs/test/consumers/SqsPermissionConsumer.spec.ts b/packages/sqs/test/consumers/SqsPermissionConsumer.spec.ts index 073e5c52..f0a02068 100644 --- a/packages/sqs/test/consumers/SqsPermissionConsumer.spec.ts +++ b/packages/sqs/test/consumers/SqsPermissionConsumer.spec.ts @@ -17,7 +17,7 @@ import { FakeConsumerErrorResolver } from '../../lib/fakes/FakeConsumerErrorReso import { SQS_RESOURCE_CURRENT_QUEUE, type SQSPolicyConfig, -} from '../../lib/sqs/AbstractSqsService.js' +} from '../../lib/sqs/AbstractSqsService.ts' import { assertQueue, deleteQueue, getQueueAttributes } from '../../lib/utils/sqsUtils.ts' import { FakeLogger } from '../fakes/FakeLogger.ts' import { SqsPermissionPublisher } from '../publishers/SqsPermissionPublisher.ts' diff --git a/packages/sqs/test/publishers/SqsPermissionPublisher.spec.ts b/packages/sqs/test/publishers/SqsPermissionPublisher.spec.ts index f3808d5c..aeb32659 100644 --- a/packages/sqs/test/publishers/SqsPermissionPublisher.spec.ts +++ b/packages/sqs/test/publishers/SqsPermissionPublisher.spec.ts @@ -8,7 +8,7 @@ import { FakeConsumerErrorResolver } from '../../lib/fakes/FakeConsumerErrorReso import { SQS_RESOURCE_CURRENT_QUEUE, type SQSPolicyConfig, -} from '../../lib/sqs/AbstractSqsService.js' +} from '../../lib/sqs/AbstractSqsService.ts' import type { SQSMessage } from '../../lib/types/MessageTypes.ts' import { deserializeSQSMessage } from '../../lib/utils/sqsMessageDeserializer.ts' import { assertQueue, deleteQueue, getQueueAttributes } from '../../lib/utils/sqsUtils.ts'