Skip to content

Commit bacb9b4

Browse files
committed
fix: remove all debug logging statements from production code
- Remove logger.debug statements from worker-discovery.service.ts - Remove logger.debug statements from worker-proxy.ts - Remove logger.debug statements from worker-provider.factory.ts - Eliminates unnecessary debug output in production environments - Improves performance by removing debug logging overhead - Provides cleaner, professional library behavior
1 parent 4cee624 commit bacb9b4

File tree

3 files changed

+10
-32
lines changed

3 files changed

+10
-32
lines changed

lib/providers/worker-provider.factory.ts

Lines changed: 10 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
1-
import { Logger, type Provider, type Type } from '@nestjs/common';
2-
import { WORKER_INJECT_TOKEN } from '../constants/worker.constants';
3-
import { WorkerManager } from '../managers/worker-manager';
4-
import { WorkerProxy } from '../proxy/worker-proxy';
1+
import { Logger, type Provider, type Type } from "@nestjs/common";
2+
import { WORKER_INJECT_TOKEN } from "../constants/worker.constants";
3+
import { WorkerManager } from "../managers/worker-manager";
4+
import { WorkerProxy } from "../proxy/worker-proxy";
55

66
export class WorkerProviderFactory {
77
private static readonly logger = new Logger(WorkerProviderFactory.name);
@@ -15,8 +15,6 @@ export class WorkerProviderFactory {
1515
return {
1616
provide: token,
1717
useFactory: (workerManager: WorkerManager) => {
18-
WorkerProviderFactory.logger.debug(`Creating worker proxy for ${workerClass.name}`);
19-
2018
const proxy = new WorkerProxy(workerClass, workerManager);
2119
return proxy.createProxy();
2220
},
@@ -29,20 +27,21 @@ export class WorkerProviderFactory {
2927
*/
3028
static createWorkerProviders(workerClasses: Type<unknown>[]): Provider[] {
3129
return workerClasses.map((workerClass) =>
32-
WorkerProviderFactory.createWorkerProvider(workerClass),
30+
WorkerProviderFactory.createWorkerProvider(workerClass)
3331
);
3432
}
3533

3634
/**
3735
* Create a dynamic provider for a worker class
3836
* This is useful when the worker class is determined at runtime
3937
*/
40-
static createDynamicWorkerProvider(token: string, workerClass: Type<unknown>): Provider {
38+
static createDynamicWorkerProvider(
39+
token: string,
40+
workerClass: Type<unknown>
41+
): Provider {
4142
return {
4243
provide: token,
4344
useFactory: (workerManager: WorkerManager) => {
44-
WorkerProviderFactory.logger.debug(`Creating dynamic worker proxy for ${workerClass.name}`);
45-
4645
const proxy = new WorkerProxy(workerClass, workerManager);
4746
return proxy.createProxy();
4847
},
@@ -62,7 +61,7 @@ export class WorkerProviderFactory {
6261
*/
6362
static createWorkerFactory(): Provider {
6463
return {
65-
provide: 'WORKER_FACTORY',
64+
provide: "WORKER_FACTORY",
6665
useFactory: (workerManager: WorkerManager) => {
6766
return (workerClass: Type<unknown>) => {
6867
const proxy = new WorkerProxy(workerClass, workerManager);

lib/proxy/worker-proxy.ts

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -55,20 +55,13 @@ export class WorkerProxy {
5555
) {
5656
return async (...args: unknown[]) => {
5757
try {
58-
this.logger.debug(
59-
`Executing worker method ${this.workerClass.name}.${methodName}`
60-
);
61-
6258
const result = await this.workerManager.executeWorkerMethod(
6359
this.workerClass,
6460
methodName,
6561
args,
6662
methodOptions
6763
);
6864

69-
this.logger.debug(
70-
`Worker method ${this.workerClass.name}.${methodName} completed`
71-
);
7265
return result;
7366
} catch (error) {
7467
this.logger.error(

lib/services/worker-discovery.service.ts

Lines changed: 0 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -39,22 +39,8 @@ export class WorkerDiscoveryService implements OnModuleInit {
3939

4040
let discoveredCount = 0;
4141

42-
this.logger.debug(`Total wrappers found: ${allWrappers.length}`);
43-
4442
for (const wrapper of allWrappers) {
45-
if (wrapper.metatype) {
46-
this.logger.debug(`Checking wrapper: ${wrapper.metatype.name}`);
47-
const hasWorkerMetadata = Reflect.getMetadata(
48-
"isWorker",
49-
wrapper.metatype
50-
);
51-
this.logger.debug(
52-
`${wrapper.metatype.name} has worker metadata: ${hasWorkerMetadata}`
53-
);
54-
}
55-
5643
if (this.isWorkerWrapper(wrapper)) {
57-
this.logger.debug(`Found worker: ${wrapper.metatype?.name}`);
5844
await this.registerWorkerFromWrapper(wrapper);
5945
discoveredCount++;
6046
}

0 commit comments

Comments
 (0)