Merge branch 'docs/parser-integration-batch' of github.com:aws-powertools/powertools-lambda-typescript into docs/parser-integration-batch

Author: sdangol

.github/workflows/ossf_scorecard.yml

@@ -43,6 +43,6 @@ jobs:
 
       # Upload the results to GitHub's code scanning dashboard.
       - name: "Upload to code-scanning"
-        uses: github/codeql-action/upload-sarif@2d92b76c45b91eb80fc44c74ce3fce0ee94e8f9d # v3.29.5
+        uses: github/codeql-action/upload-sarif@f1f6e5f6af878fb37288ce1c627459e94dbf7d01 # v3.29.5
         with:
           sarif_file: results.sarif

examples/snippets/package.json

@@ -46,7 +46,7 @@
     "zod": "^4.1.5"
   },
   "dependencies": {
-    "arktype": "^2.1.21",
+    "arktype": "^2.1.22",
     "valibot": "^1.1.0"
   }
 }

package-lock.json

@@ -10,9 +10,9 @@
     "packages/tracer",
     "packages/parameters",
     "packages/idempotency",
+    "packages/parser",
     "packages/batch",
     "packages/testing",
-    "packages/parser",
     "examples/snippets",
     "layers",
     "examples/app",
@@ -50,7 +50,7 @@
   },
   "homepage": "https://github.com/aws-powertools/powertools-lambda-typescript#readme",
   "devDependencies": {
-    "@biomejs/biome": "^2.2.2",
+    "@biomejs/biome": "^2.2.3",
     "@types/aws-lambda": "^8.10.152",
     "@types/node": "^24.3.1",
     "@vitest/coverage-v8": "^3.2.4",

package.json

@@ -73,6 +73,7 @@
     "nodejs"
   ],
   "devDependencies": {
-    "@aws-lambda-powertools/testing-utils": "file:../testing"
+    "@aws-lambda-powertools/testing-utils": "file:../testing",
+    "@aws-lambda-powertools/parser": "2.25.2"
   }
 }

packages/batch/package.json

@@ -1,3 +1,4 @@
+import type { StandardSchemaV1 } from '@standard-schema/spec';
 import type {
   DynamoDBRecord,
   KinesisStreamRecord,
@@ -11,6 +12,7 @@ import {
 } from './constants.js';
 import { FullBatchFailureError } from './errors.js';
 import type {
+  BasePartialBatchProcessorConfig,
   EventSourceDataClassTypes,
   PartialItemFailureResponse,
   PartialItemFailures,
@@ -42,12 +44,20 @@ abstract class BasePartialBatchProcessor extends BasePartialProcessor {
    */
   public eventType: keyof typeof EventType;
 
+  /**
+   * The schema of the body of the event record for parsing
+   */
+  protected schema?: StandardSchemaV1;
+
   /**
    * Initializes base batch processing class
    *
    * @param eventType The type of event to process (SQS, Kinesis, DynamoDB)
    */
-  public constructor(eventType: keyof typeof EventType) {
+  public constructor(
+    eventType: keyof typeof EventType,
+    config?: BasePartialBatchProcessorConfig
+  ) {
     super();
     this.eventType = eventType;
     this.batchResponse = DEFAULT_RESPONSE;
@@ -56,6 +66,9 @@ abstract class BasePartialBatchProcessor extends BasePartialProcessor {
       [EventType.KinesisDataStreams]: () => this.collectKinesisFailures(),
       [EventType.DynamoDBStreams]: () => this.collectDynamoDBFailures(),
     };
+    if (config) {
+      this.schema = config.schema;
+    }
   }
 
   /**

packages/batch/src/BasePartialBatchProcessor.ts

@@ -74,8 +74,8 @@ abstract class BasePartialProcessor {
    * This method should be called when a record fails processing so that
    * the processor can keep track of the error and the record that failed.
    *
-   * @param record Record that failed processing
-   * @param error Error that was thrown
+   * @param record - Record that failed processing
+   * @param error - Error that was thrown
    */
   public failureHandler(
     record: EventSourceDataClassTypes,
@@ -131,7 +131,7 @@ abstract class BasePartialProcessor {
    * This is to ensure that the processor keeps track of the results and the records
    * that succeeded and failed processing.
    *
-   * @param record Record to be processed
+   * @param record - Record to be processed
    */
   public abstract processRecord(
     record: BaseRecord
@@ -149,7 +149,7 @@ abstract class BasePartialProcessor {
    * This is to ensure that the processor keeps track of the results and the records
    * that succeeded and failed processing.
    *
-   * @param record Record to be processed
+   * @param record - Record to be processed
    */
   public abstract processRecordSync(
     record: BaseRecord
@@ -198,9 +198,9 @@ abstract class BasePartialProcessor {
    * to allow for reusing the processor instance across multiple invocations
    * by instantiating the processor outside of the Lambda function handler.
    *
-   * @param records Array of records to be processed
-   * @param handler CallableFunction to process each record from the batch
-   * @param options Options to be used during processing (optional)
+   * @param records - Array of records to be processed
+   * @param handler - CallableFunction to process each record from the batch
+   * @param options - Options to be used during processing (optional)
    */
   public register(
     records: BaseRecord[],
@@ -223,8 +223,8 @@ abstract class BasePartialProcessor {
    * This method should be called when a record succeeds processing so that
    * the processor can keep track of the result and the record that succeeded.
    *
-   * @param record Record that succeeded processing
-   * @param result Result from record handler
+   * @param record - Record that succeeded processing
+   * @param result - Result from record handler
    */
   public successHandler(
     record: EventSourceDataClassTypes,