Fix test (#304)

* Adding isAcquireLockTimeoutError

* Fixing type check

* Missing export

* Lint fix

* Using symbol to differenciate error

Author: CarlosGamero

packages/core/lib/index.ts

@@ -91,6 +91,6 @@ export {
   type AcquireLockOptions,
   type DeduplicationRequester,
   DeduplicationRequesterEnum,
-  AcquireLockTimeoutError,
   noopReleasableLock,
 } from './message-deduplication/messageDeduplicationTypes.ts'
+export * from './message-deduplication/AcquireLockTimeoutError.ts'

packages/core/lib/message-deduplication/AcquireLockTimeoutError.ts

@@ -0,0 +1,15 @@
+import { isError } from '@lokalise/node-core'
+
+const AcquireLockTimeoutErrorSymbol = Symbol.for('ACQUIRE_LOCK_TIMEOUT_ERROR')
+export class AcquireLockTimeoutError extends Error {
+  constructor(message?: string) {
+    super(message)
+    Object.defineProperty(this, AcquireLockTimeoutErrorSymbol, {
+      value: true,
+    })
+  }
+}
+
+export const isAcquireLockTimeoutError = (error: unknown): error is AcquireLockTimeoutError =>
+  // biome-ignore lint/suspicious/noExplicitAny: Expected
+  isError(error) && (error as any)[AcquireLockTimeoutErrorSymbol] === true

packages/core/lib/message-deduplication/messageDeduplicationTypes.ts

@@ -1,12 +1,11 @@
 import type { Either } from '@lokalise/node-core'
 import type { MessageDeduplicationOptions } from '@message-queue-toolkit/schemas'
+import type { AcquireLockTimeoutError } from './AcquireLockTimeoutError.js'
 
 export interface ReleasableLock {
   release(): Promise<void>
 }
 
-export class AcquireLockTimeoutError extends Error {}
-
 export type AcquireLockOptions = Required<
   Pick<
     MessageDeduplicationOptions,

packages/core/lib/queues/AbstractQueueService.ts

@@ -17,7 +17,10 @@ import {
 } from '@message-queue-toolkit/schemas'
 import type { MessageInvalidFormatError, MessageValidationError } from '../errors/Errors.ts'
 import {
-  AcquireLockTimeoutError,
+  type AcquireLockTimeoutError,
+  isAcquireLockTimeoutError,
+} from '../message-deduplication/AcquireLockTimeoutError.js'
+import {
   DEFAULT_MESSAGE_DEDUPLICATION_OPTIONS,
   type DeduplicationRequester,
   DeduplicationRequesterEnum,
@@ -644,7 +647,7 @@ export abstract class AbstractQueueService<
       deduplicationOptions,
     )
 
-    if (acquireLockResult.error && !(acquireLockResult.error instanceof AcquireLockTimeoutError)) {
+    if (acquireLockResult.error && !isAcquireLockTimeoutError(acquireLockResult.error)) {
       this.handleError(acquireLockResult.error)
       return { result: noopReleasableLock }
     }

packages/core/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@message-queue-toolkit/core",
-    "version": "23.0.0",
+    "version": "23.1.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",

packages/redis-message-deduplication-store/package.json

@@ -32,14 +32,14 @@
         "redis-semaphore": "^5.6.2"
     },
     "peerDependencies": {
-        "@message-queue-toolkit/core": ">=21.0.0",
+        "@message-queue-toolkit/core": ">=23.1.0",
         "ioredis": "^5.3.2"
     },
     "devDependencies": {
         "@biomejs/biome": "1.9.4",
         "@lokalise/biome-config": "^2.0.0",
         "@lokalise/tsconfig": "^1.3.0",
-        "@message-queue-toolkit/core": "^21.2.0",
+        "@message-queue-toolkit/core": "*",
         "@types/node": "^24.0.3",
         "@vitest/coverage-v8": "^3.2.4",
         "rimraf": "^6.0.1",