Added logger

Author: sdangol

packages/batch/src/BasePartialBatchProcessor.ts

@@ -1,8 +1,10 @@
+import { getStringFromEnv } from '@aws-lambda-powertools/commons/utils/env';
 import type {
   DynamoDBRecord,
   KinesisStreamRecord,
   SQSRecord,
 } from 'aws-lambda';
+import type { GenericLogger } from '../../commons/lib/esm/types/GenericLogger.js';
 import { BasePartialProcessor } from './BasePartialProcessor.js';
 import {
   DATA_CLASS_MAPPING,
@@ -43,6 +45,13 @@ abstract class BasePartialBatchProcessor extends BasePartialProcessor {
    */
   public eventType: keyof typeof EventType;
 
+  /**
+   * A logger instance to be used for logging debug, warning, and error messages.
+   *
+   * When no logger is provided, we'll only log warnings and errors using the global `console` object.
+   */
+  protected readonly logger: Pick<GenericLogger, 'debug' | 'warn' | 'error'>;
+
   /**
    * The configuration options for the parser integration
    */
@@ -66,6 +75,15 @@ abstract class BasePartialBatchProcessor extends BasePartialProcessor {
       [EventType.DynamoDBStreams]: () => this.collectDynamoDBFailures(),
     };
     this.parserConfig = parserConfig;
+    const alcLogLevel = getStringFromEnv({
+      key: 'AWS_LAMBDA_LOG_LEVEL',
+      defaultValue: '',
+    });
+    this.logger = parserConfig?.logger ?? {
+      debug: alcLogLevel === 'DEBUG' ? console.debug : () => undefined,
+      error: console.error,
+      warn: console.warn,
+    };
   }
 
   /**

packages/batch/src/BatchProcessor.ts

@@ -225,9 +225,11 @@ class BatchProcessor extends BasePartialBatchProcessor {
       return result.data as EventSourceDataClassTypes;
     }
     const issues = result.error.cause as ReadonlyArray<StandardSchemaV1.Issue>;
-    throw new Error(
-      `Failed to parse record: ${issues.map((issue) => `${issue?.path?.join('.')}: ${issue.message}`).join('; ')}`
-    );
+    const errorMessage = issues
+      .map((issue) => `${issue?.path?.join('.')}: ${issue.message}`)
+      .join('; ');
+    this.logger.error(errorMessage);
+    throw new Error(errorMessage);
   }
 
   /**
@@ -256,7 +258,7 @@ class BatchProcessor extends BasePartialBatchProcessor {
     if (innerSchema != null) {
       // Only proceed with schema extension if it's a Zod schema
       if (innerSchema['~standard'].vendor !== SchemaVendor.Zod) {
-        console.warn(
+        this.logger.error(
           'The schema provided is not supported. Only Zod schemas are supported for extension.'
         );
         throw new Error('Unsupported schema type');
@@ -275,6 +277,9 @@ class BatchProcessor extends BasePartialBatchProcessor {
       });
       return this.#parseWithErrorHandling(record, schemaWithoutTransformers);
     }
+    this.logger.error(
+      'The schema provided is not supported. Only Zod schemas are supported for extension.'
+    );
     throw new Error('Either schema or innerSchema is required for parsing');
   }
 }

packages/batch/src/types.ts

@@ -94,8 +94,8 @@ type PartialItemFailureResponse = { batchItemFailures: PartialItemFailures[] };
 /**
  * Type representing the parser configuration options passed to the BasePartialBatchProcessor class.
  *
- * @property schema - The schema to be used for parsing
- * @property innerSchema - The schema for the inner payload
+ * @property schema - The full event schema to be used for parsing
+ * @property innerSchema - The inner payload schema
  * @property transformer - The transformer to be used for parsing the payload
  * @property logger - The logger to be used for logging debug and warning messages.
  */
@@ -113,6 +113,7 @@ type BasePartialBatchProcessorParserConfig = {
   innerSchema?: StandardSchemaV1;
   /**
    * The transformer to be used for parsing the payload.
+   * No transformers will be used if this is not provided.
    * Supported transformers are:
    * 1. 'json': Uses JSONStringified helper
    * 2. 'base64': Uses Base64Encoded helper