Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion packages/amqp/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -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",
Expand Down
2 changes: 1 addition & 1 deletion packages/core/lib/events/DomainEventEmitter.spec.ts
Original file line number Diff line number Diff line change
Expand Up @@ -412,7 +412,7 @@ describe('AutopilotEventEmitter', () => {
})
expect(logSpy).toHaveBeenCalledWith({
error: expect.anything(),
message: 'ErroredFakeListener error',
msg: 'ErroredFakeListener error',
...expectedContext,
})

Expand Down
Original file line number Diff line number Diff line change
@@ -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<void>
Expand Down
2 changes: 1 addition & 1 deletion packages/core/lib/queues/AbstractQueueService.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand Down
6 changes: 3 additions & 3 deletions packages/core/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -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": {
Expand Down
2 changes: 1 addition & 1 deletion packages/kafka/lib/AbstractKafkaConsumer.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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 &
Expand Down
2 changes: 1 addition & 1 deletion packages/kafka/lib/handler-routing/KafkaHandlerConfig.ts
Original file line number Diff line number Diff line change
@@ -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,
Expand Down
2 changes: 1 addition & 1 deletion packages/kafka/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -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"
},
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
2 changes: 1 addition & 1 deletion packages/metrics/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -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": {
Expand Down
2 changes: 1 addition & 1 deletion packages/redis-message-deduplication-store/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -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": {
Expand Down
2 changes: 1 addition & 1 deletion packages/schemas/lib/events/eventTypes.ts
Original file line number Diff line number Diff line change
@@ -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<EventDefinition extends CommonEventDefinition> =
Expand Down
2 changes: 1 addition & 1 deletion packages/sns/lib/utils/snsInitter.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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(
Expand Down
2 changes: 1 addition & 1 deletion packages/sns/lib/utils/snsSubscriber.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand Down
2 changes: 1 addition & 1 deletion packages/sns/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -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": {
Expand Down
2 changes: 1 addition & 1 deletion packages/sqs/lib/utils/sqsAttributeUtils.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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'

Expand Down
2 changes: 1 addition & 1 deletion packages/sqs/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -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": {
Expand Down
2 changes: 1 addition & 1 deletion packages/sqs/test/consumers/SqsPermissionConsumer.spec.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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'
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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'
Expand Down
Loading