Switched from prefixes to flags.

Author: gasperzgonec

src/logger/logger.test.ts

@@ -83,7 +83,8 @@ describe(Logger.name, () => {
 
       expect(mockConsoleInfo).toHaveBeenCalledWith(
         JSON.stringify({
-          message: '[USER] ' + message,
+          message: message,
+          verified: false,
           ...mockEvent.payload.event_context,
           dev_oid: mockEvent.payload.event_context.dev_oid,
         })
@@ -101,7 +102,8 @@ describe(Logger.name, () => {
       });
       expect(mockConsoleInfo).toHaveBeenCalledWith(
         JSON.stringify({
-          message: '[USER] ' + expectedMessage,
+          message: expectedMessage,
+          verified: false,
           ...mockEvent.payload.event_context,
           dev_oid: mockEvent.payload.event_context.dev_oid,
         })
@@ -120,7 +122,8 @@ describe(Logger.name, () => {
       });
       expect(mockConsoleInfo).toHaveBeenCalledWith(
         JSON.stringify({
-          message: `[USER] ${text} ${expectedDataMessage}`,
+          message: `${text} ${expectedDataMessage}`,
+          verified: false,
           ...mockEvent.payload.event_context,
           dev_oid: mockEvent.payload.event_context.dev_oid,
         })
@@ -140,7 +143,8 @@ describe(Logger.name, () => {
       });
       expect(mockConsoleInfo).toHaveBeenCalledWith(
         JSON.stringify({
-          message: `[USER] ${text1} ${expectedDataMessage} ${text2}`,
+          message: `${text1} ${expectedDataMessage} ${text2}`,
+          verified: false,
           ...mockEvent.payload.event_context,
           dev_oid: mockEvent.payload.event_context.dev_oid,
         })
@@ -162,7 +166,7 @@ describe(Logger.name, () => {
 
       logger.info(message, data);
 
-      expect(mockConsoleInfo).toHaveBeenCalledWith('[USER]', message, data);
+      expect(mockConsoleInfo).toHaveBeenCalledWith(message, data);
     });
   });
 
@@ -210,7 +214,7 @@ describe(Logger.name, () => {
       const callArgs = mockConsoleInfo.mock.calls[0][0];
       const logObject = JSON.parse(callArgs);
 
-      expect(logObject.message).toBe('[USER] ');
+      expect(logObject.message).toBe('');
       expect(logObject.dev_oid).toBe(mockEvent.payload.event_context.dev_oid);
       expect(logObject.request_id).toBe(
         mockEvent.payload.event_context.request_id
@@ -225,7 +229,7 @@ describe(Logger.name, () => {
       const logObject = JSON.parse(callArgs);
 
       // inspect shows 'null' and 'undefined' as strings
-      expect(logObject.message).toBe('[USER] test null undefined');
+      expect(logObject.message).toBe('test null undefined');
       expect(logObject.dev_oid).toBe(mockEvent.payload.event_context.dev_oid);
     });
 
@@ -250,7 +254,7 @@ describe(Logger.name, () => {
         compact: false,
         depth: Infinity,
       });
-      expect(logObject.message).toBe('[USER] ' + expectedMessage);
+      expect(logObject.message).toBe(expectedMessage);
       expect(logObject.dev_oid).toBe(mockEvent.payload.event_context.dev_oid);
       expect(typeof logObject.callback_url).toBe('string');
     });

src/logger/logger.ts

@@ -73,35 +73,25 @@ export class Logger extends Console {
   }
 
   logFn(args: unknown[], level: LogLevel): void {
-    // Always add prefix based on verification status
-    // false = unverified ([USER] prefix), true = verified ([SDK] prefix)
-    const prefix = this.isVerifiedChannel ? '[SDK]' : '[USER]';
-
-    // Don't prepend prefix if the string already contains the same one
-    let processedArgs: unknown[] = args;
-    if (!(typeof args[0] === 'string' && args[0].startsWith(prefix)) || typeof args[0] !== 'string') {
-      processedArgs.unshift(prefix);
-    }
-
-
     if (isMainThread) {
       if (this.options?.isLocalDevelopment) {
-        console[level](...processedArgs);
+        console[level](...args);
       } else {
         let message: string;
-        if (processedArgs.length === 1 && typeof processedArgs[0] === 'string') {
+        if (args.length === 1 && typeof args[0] === 'string') {
           // Single string argument - use directly
-          message = processedArgs[0];
-        } else if (processedArgs.length === 1) {
+          message = args[0];
+        } else if (args.length === 1) {
           // Single non-string argument - convert to string properly
-          message = this.valueToString(processedArgs[0]);
+          message = this.valueToString(args[0]);
         } else {
           // Multiple arguments - create a readable format
-          message = processedArgs.map((arg) => this.valueToString(arg)).join(' ');
+          message = args.map((arg) => this.valueToString(arg)).join(' ');
         }
 
         const logObject = {
           message,
+          verified: this.isVerifiedChannel,
           ...this.tags,
         };
 
@@ -111,7 +101,7 @@ export class Logger extends Console {
       parentPort?.postMessage({
         subject: WorkerMessageSubject.WorkerMessageLog,
         payload: {
-          args: processedArgs.map((arg) => this.valueToString(arg)),
+          args: args.map((arg) => this.valueToString(arg)),
           level,
         },
       });

src/logger/private_logger.test.ts

@@ -54,7 +54,7 @@ describe('Private Logger Security', () => {
       sdkLogger.info('SDK message');
 
       expect(mockConsoleInfo).toHaveBeenCalledWith(
-        expect.stringContaining('"message":"[SDK] SDK message"')
+        expect.stringContaining('"message":"SDK message"')
       );
     });
 
@@ -68,7 +68,7 @@ describe('Private Logger Security', () => {
       userLogger.info('User message');
 
       expect(mockConsoleInfo).toHaveBeenCalledWith(
-        expect.stringContaining('"message":"[USER] User message"')
+        expect.stringContaining('"message":"User message"')
       );
     });
 
@@ -109,10 +109,10 @@ describe('Private Logger Security', () => {
 
       expect(mockConsoleInfo).toHaveBeenCalledTimes(2);
       expect(mockConsoleInfo).toHaveBeenNthCalledWith(1,
-        expect.stringContaining('"message":"[SDK] SDK internal message"')
+        expect.stringContaining('"message":"SDK internal message"')
       );
       expect(mockConsoleInfo).toHaveBeenNthCalledWith(2,
-        expect.stringContaining('"message":"[USER] User application message"')
+        expect.stringContaining('"message":"User application message"')
       );
     });
 
@@ -134,8 +134,8 @@ describe('Private Logger Security', () => {
       expect(userCall).toContain('"dev_oid":"test-dev-oid"');
 
       // But different prefixes
-      expect(sdkCall).toContain('"[SDK] Warning from SDK"');
-      expect(userCall).toContain('"[USER] Warning from user"');
+      expect(sdkCall).toContain('"Warning from SDK"');
+      expect(userCall).toContain('"Warning from user"');
     });
   });