diff --git a/src/server/decorators/on-queue-event.decorator.ts b/src/server/decorators/on-queue-event.decorator.ts index d16ea27..3d4b7c6 100644 --- a/src/server/decorators/on-queue-event.decorator.ts +++ b/src/server/decorators/on-queue-event.decorator.ts @@ -8,7 +8,6 @@ * @layer server/decorators */ -import 'reflect-metadata' import type { QueueEventListenerMetadata } from '../interfaces/processor-metadata.interface' import { QUEUE_EVENT_LISTENERS_METADATA_KEY } from './metadata-keys.constants' diff --git a/src/server/decorators/on-worker-event.decorator.ts b/src/server/decorators/on-worker-event.decorator.ts index d9087bd..2ca0cf2 100644 --- a/src/server/decorators/on-worker-event.decorator.ts +++ b/src/server/decorators/on-worker-event.decorator.ts @@ -7,7 +7,6 @@ * @layer server/decorators */ -import 'reflect-metadata' import type { QueueEventListenerMetadata } from '../interfaces/processor-metadata.interface' import { WORKER_EVENT_LISTENERS_METADATA_KEY } from './metadata-keys.constants' @@ -20,14 +19,7 @@ import { WORKER_EVENT_LISTENERS_METADATA_KEY } from './metadata-keys.constants' * @see https://docs.bullmq.io/guide/workers/worker-events */ export type WorkerEventName = - | 'completed' - | 'failed' - | 'progress' - | 'active' - | 'stalled' - | 'closing' - | 'closed' - | 'error' + 'completed' | 'failed' | 'progress' | 'active' | 'stalled' | 'closing' | 'closed' | 'error' /** * Marks a method as a worker-local event listener for the given event. The diff --git a/src/server/decorators/process.decorator.ts b/src/server/decorators/process.decorator.ts index 1854b5d..e7cb19b 100644 --- a/src/server/decorators/process.decorator.ts +++ b/src/server/decorators/process.decorator.ts @@ -6,7 +6,6 @@ * @layer server/decorators */ -import 'reflect-metadata' import type { ProcessHandlerMetadata } from '../interfaces/processor-metadata.interface' import { PROCESS_HANDLERS_METADATA_KEY } from './metadata-keys.constants' @@ -38,9 +37,7 @@ export function Process(jobName?: string): MethodDecorator { const existing = (Reflect.getOwnMetadata(PROCESS_HANDLERS_METADATA_KEY, target.constructor) ?? []) as ProcessHandlerMetadata[] const entry: ProcessHandlerMetadata = - jobName !== undefined - ? { jobName, methodKey: propertyKey } - : { methodKey: propertyKey } + jobName !== undefined ? { jobName, methodKey: propertyKey } : { methodKey: propertyKey } Reflect.defineMetadata(PROCESS_HANDLERS_METADATA_KEY, [...existing, entry], target.constructor) } } diff --git a/src/server/decorators/processor.decorator.ts b/src/server/decorators/processor.decorator.ts index 1d4c637..bd0c51f 100644 --- a/src/server/decorators/processor.decorator.ts +++ b/src/server/decorators/processor.decorator.ts @@ -5,7 +5,6 @@ * @layer server/decorators */ -import 'reflect-metadata' import { DEFAULT_WORKER_CONCURRENCY } from '../constants/default-options' import type { ProcessorMetadata } from '../interfaces/processor-metadata.interface' import type { WorkerOptions } from '../interfaces/worker-options.interface'