Fixed camelCasing.

Author: gasperzgonec

src/workers/create-worker.ts

@@ -13,7 +13,7 @@ async function createWorker<ConnectorState>(
         event: workerData.event,
         options: workerData.options,
       }));
-      const unverified_logger = createUserLogger(new Logger({
+      const unverifiedLogger = createUserLogger(new Logger({
         event: workerData.event,
         options: workerData.options,
       }));
@@ -24,7 +24,7 @@ async function createWorker<ConnectorState>(
       } as WorkerOptions);
 
       worker.on(WorkerEvent.WorkerError, (error) => {
-        unverified_logger.error('Worker error', error);
+        unverifiedLogger.error('Worker error', error);
         reject(error);
       });
       worker.on(WorkerEvent.WorkerOnline, () => {

src/workers/spawn.ts

@@ -95,7 +95,7 @@ export async function spawn<ConnectorState>({
   options,
 }: SpawnFactoryInterface<ConnectorState>): Promise<void> {
   const logger = getInternalLogger(new Logger({ event, options }));
-  const unverified_logger = createUserLogger(new Logger({ event, options }));
+  const unverifiedLogger = createUserLogger(new Logger({ event, options }));
   const script = getWorkerPath({
     event,
     connectorWorkerPath: workerPath,
@@ -135,7 +135,7 @@ export async function spawn<ConnectorState>({
         });
       });
     } catch (error) {
-      unverified_logger.error('Worker error while processing task', error);
+      unverifiedLogger.error('Worker error while processing task', error);
       return Promise.reject(error);
     }
   } else {
@@ -172,14 +172,14 @@ export class Spawn {
   private hardTimeoutTimer: ReturnType<typeof setTimeout> | undefined;
   private memoryMonitoringInterval: ReturnType<typeof setInterval> | undefined;
   private logger: Logger;
-  private unverified_logger: Logger;
+  private unverifiedLogger: Logger;
   private resolve: (value: void | PromiseLike<void>) => void;
 
   constructor({ event, worker, options, resolve }: SpawnInterface) {
     this.alreadyEmitted = false;
     this.event = event;
     this.logger = getInternalLogger(new Logger({ event, options }));
-    this.unverified_logger = createUserLogger(new Logger({ event, options }));
+    this.unverifiedLogger = createUserLogger(new Logger({ event, options }));
     this.lambdaTimeout = options?.timeout
       ? Math.min(options.timeout, this.defaultLambdaTimeout)
       : this.defaultLambdaTimeout;
@@ -239,7 +239,7 @@ export class Spawn {
       if (message?.subject === WorkerMessageSubject.WorkerMessageLog) {
         const args = message.payload?.args;
         const level = message.payload?.level as LogLevel;
-        this.unverified_logger.logFn(args, level);
+        this.unverifiedLogger.logFn(args, level);
       }
 
       // If worker sends a message that it has emitted an event, then set alreadyEmitted to true.