Moved private_logger contents into logger.

Author: gasperzgonec

src/logger/logger.ts

@@ -166,3 +166,30 @@ export function serializeAxiosError(error: AxiosError): AxiosErrorResponse {
 
   return serializedAxiosError;
 }
+
+// Private symbol and token
+export function getInternalLogger(logger: Logger): Logger {
+  return (logger as any)[INTERNAL_CHANNEL](verificationToken);
+}
+
+// Factory function to create a user-safe logger that can never access verified channel
+export function createUserLogger(logger: Logger): Logger {
+  // Create a new logger instance that is guaranteed to be unverified
+  // This ensures user code can never access the verified channel
+  const userLogger = Object.create(Logger.prototype);
+
+  // Copy all the necessary properties but ensure isVerifiedChannel is false
+  Object.assign(userLogger, logger);
+  userLogger.isVerifiedChannel = false;
+
+  // Remove the internal channel method to prevent access
+  delete userLogger[INTERNAL_CHANNEL];
+
+  // Override the internal channel method to throw an error if accessed
+  userLogger[INTERNAL_CHANNEL] = () => {
+    throw new Error('Unauthorized access to internal channel');
+  };
+
+  return userLogger;
+}
+

src/logger/private_logger.test.ts

@@ -1,5 +1,5 @@
 import { Logger } from './logger';
-import { getInternalLogger, createUserLogger, INTERNAL_CHANNEL, verificationToken } from './private_logger';
+import { getInternalLogger, createUserLogger, INTERNAL_CHANNEL, verificationToken } from './logger';
 import { createEvent } from '../tests/test-helpers';
 import { EventType } from '../types/extraction';
 import { WorkerAdapterOptions } from '../types/workers';

src/logger/private_logger.ts

@@ -2,7 +2,7 @@ import { isMainThread, Worker } from 'node:worker_threads';
 
 import { Logger } from '../logger/logger';
 import { WorkerData, WorkerEvent } from '../types/workers';
-import { createUserLogger, getInternalLogger } from '../logger/private_logger';
+import { createUserLogger, getInternalLogger } from '../logger/logger';
 
 async function createWorker<ConnectorState>(
   workerData: WorkerData<ConnectorState>

src/workers/create-worker.ts

@@ -7,7 +7,7 @@ import {
   WorkerMessageSubject,
 } from '../types/workers';
 import { WorkerAdapter } from './worker-adapter';
-import { createUserLogger } from '../logger/private_logger';
+import { createUserLogger } from '../logger/logger';
 
 export function processTask<ConnectorState>({
   task,

src/workers/process-task.ts

@@ -24,7 +24,7 @@ import {
 } from '../common/constants';
 import { LogLevel } from '../logger/logger.interfaces';
 import { createWorker } from './create-worker';
-import { createUserLogger, getInternalLogger } from '../logger/private_logger';
+import { createUserLogger, getInternalLogger } from '../logger/logger';
 
 function getWorkerPath({
   event,