Merge branch 'main' into improv/metrics-no-override-function-name

Author: dreamorosi

.devcontainer/Dockerfile

@@ -1,5 +1,5 @@
 # See here for image contents: https://github.com/microsoft/vscode-dev-containers/blob/v0.212.0/containers/javascript-node/.devcontainer/base.Dockerfile
-FROM mcr.microsoft.com/vscode/devcontainers/javascript-node@sha256:896bfba10582c9239d1c36bab53b80af06253019f62b846fa440ee643ca63eb1
+FROM mcr.microsoft.com/vscode/devcontainers/javascript-node@sha256:78fda8c284dd3247d7385d55974e278314233f1acc130ba89757703137dbda45
 
 # Install fnm to manage Node.js versions
 RUN curl -fsSL https://fnm.vercel.app/install -o /tmp/install \

.github/scripts/get_pr_info.js

@@ -88,7 +88,7 @@ jobs:
           mask-aws-account-id: true
       - id: go-setup
         name: Setup Go
-        uses: actions/setup-go@f111f3307d8850f501ac008e886eec1fd1932a34 # v5.3.0
+        uses: actions/setup-go@0aaccfd150d50ccaeb58ebd88d36e91967a5f35b # v5.4.0
         with:
           go-version: '>=1.23.0'
       - id: go-env

.github/workflows/bootstrap_region.yml

@@ -50,7 +50,7 @@ jobs:
           mask-aws-account-id: true
       - id: go-setup
         name: Setup Go
-        uses: actions/setup-go@f111f3307d8850f501ac008e886eec1fd1932a34 # v5.3.0
+        uses: actions/setup-go@0aaccfd150d50ccaeb58ebd88d36e91967a5f35b # v5.4.0
         with:
           go-version: '>=1.23.0'
       - id: go-env

.github/workflows/layer_balance.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@6bb031afdd8eb862ea3fc1848194185e076637e5 # v3.28.11
+        uses: github/codeql-action/upload-sarif@5f8171a638ada777af81d42b55959a643bb29017 # v3.28.12
         with:
           sarif_file: results.sarif

.github/workflows/ossf_scorecard.yml

@@ -97,7 +97,7 @@ jobs:
         with:
           ref: ${{ github.sha }}
       - name: Download CDK layer artifacts
-        uses: actions/download-artifact@cc203385981b70ca67e1cc392babf9cc229d5806 # v4.1.9
+        uses: actions/download-artifact@95815c38cf2ff2164869cbab79da8d1f422bc89e # v4.2.1
         with:
           path: cdk-layer-stack
           pattern: cdk-layer-stack-* # merge all Layer artifacts created per region earlier (reusable_deploy_layer_stack.yml; step "Save Layer ARN artifact")

.github/workflows/publish_layer.yml

@@ -81,7 +81,7 @@ jobs:
       - name: Setup dependencies
         uses: aws-powertools/actions/.github/actions/cached-node-modules@29979bc5339bf54f76a11ac36ff67701986bb0f0
       - name: Download artifact
-        uses: actions/download-artifact@cc203385981b70ca67e1cc392babf9cc229d5806 # v4.1.9
+        uses: actions/download-artifact@95815c38cf2ff2164869cbab79da8d1f422bc89e # v4.2.1
         with:
           name: ${{ inputs.artifact-name }}
       - name: Unzip artifact

.github/workflows/reusable_deploy_layer_stack.yml

@@ -17,20 +17,21 @@ jobs:
     env:
       NODE_ENV: dev
       PR_NUMBER: ${{ inputs.prNumber }}
+      GH_TOKEN: ${{ github.token }}
     permissions:
       id-token: write # needed to interact with GitHub's OIDC Token endpoint.
       contents: read
     strategy:
-      max-parallel: 30
+      max-parallel: 25
       matrix:
         package:
           [
-            layers,
+            packages/idempotency,
             packages/logger,
             packages/metrics,
-            packages/tracer,
             packages/parameters,
-            packages/idempotency,
+            packages/tracer,
+            layers,
           ]
         version: [18, 20, 22]
         arch: [x86_64, arm64]
@@ -42,11 +43,14 @@ jobs:
       - name: Extract PR details
         id: extract_PR_details
         if: ${{ inputs.prNumber != '' }}
-        uses: actions/github-script@60a0d83039c74a4aee543508d2ffcb1c3799cdea # v7.0.1
-        with:
-          script: |
-            const script = require('.github/scripts/get_pr_info.js');
-            await script({github, context, core});
+        run: |
+          # Get the PR number from the input
+          pr_number=${{ inputs.prNumber }}
+          # Get the headSHA of the PR
+          head_sha=$(gh pr view $pr_number --json headRefOid -q '.headRefOid')
+          # Set the headSHA as an output variable
+          echo "headSHA=$head_sha" >> $GITHUB_OUTPUT
+          echo "headSHA=$head_sha"
       # Only if a PR Number was passed and the headSHA of the PR extracted,
       # we checkout the PR at that point in time
       - name: Checkout PR code
@@ -75,4 +79,4 @@ jobs:
           ARCH: ${{ matrix.arch }}
           JSII_SILENCE_WARNING_DEPRECATED_NODE_VERSION: true
           RUNNER_DEBUG: ${{ env.RUNNER_DEBUG }}
-        run: npm run test:e2e -w ${{ matrix.package }}
+        run: npm run test:e2e -w ${{ matrix.package }}

.github/workflows/run-e2e-tests.yml

@@ -767,16 +767,19 @@ sequenceDiagram
 4. **What happens if the log buffer reaches its maximum size?**
    Older logs are removed from the buffer to make room for new logs. This means that if the buffer is full, you may lose some logs if they are not flushed before the buffer reaches its maximum size. When this happens, we emit a warning when flushing the buffer to indicate that some logs have been dropped.
 
-5. **What timestamp is used when I flush the logs?**
+5. **How is the log size of a log line calculated?**
+   The log size is calculated based on the size of the stringified log line in bytes. This includes the size of the log message, the size of any additional keys, and the size of the timestamp.
+
+6. **What timestamp is used when I flush the logs?**
    The timestamp preserves the original time when the log record was created. If you create a log record at 11:00:10 and flush it at 11:00:25, the log line will retain its original timestamp of 11:00:10.
 
-6. **What happens if I try to add a log line that is bigger than max buffer size?**
+7. **What happens if I try to add a log line that is bigger than max buffer size?**
    The log will be emitted directly to standard output and not buffered. When this happens, we emit a warning to indicate that the log line was too big to be buffered.
 
-7. **What happens if Lambda times out without flushing the buffer?**
+8. **What happens if Lambda times out without flushing the buffer?**
    Logs that are still in the buffer will be lost. If you are using the log buffer to log asynchronously, you should ensure that the buffer is flushed before the Lambda function times out. You can do this by calling the `logger.flushBuffer()` method at the end of your Lambda function.
 
-8. **Do child loggers inherit the buffer?**
+9. **Do child loggers inherit the buffer?**
    No, child loggers do not inherit the buffer from their parent logger but only the buffer configuration. This means that if you create a child logger, it will have its own buffer and will not share the buffer with the parent logger.
 
 ### Reordering log keys position

docs/core/logger.md

@@ -44,7 +44,7 @@ Both are also able to parse either an object or JSON string as an input.
     Be cautious when using multiple decorators that expect event to have a specific structure, the order of evaluation for decorators is from bottom to top.
 
 === "Middy middleware"
-    ```typescript hl_lines="34"
+    ```typescript hl_lines="22"
     --8<-- "examples/snippets/parser/middy.ts"
     ```
 
@@ -157,7 +157,7 @@ If you want to extend a schema and transform a JSON stringified payload to an ob
 If you want to parse a DynamoDB stream event with unmarshalling, you can use the helper function `DynamoDBMarshalled`:
 
 === "DynamoDBStreamSchema with DynamoDBMarshalled"
-    ```typescript hl_lines="17"
+    ```typescript hl_lines="18"
     --8<-- "examples/snippets/parser/extendDynamoDBStreamSchema.ts"
     ```
 
@@ -180,12 +180,12 @@ Envelopes can be used via envelope parameter available in middy and decorator.
 Here's an example of parsing a custom schema in an event coming from EventBridge, where all you want is what's inside the detail key.
 
 === "Middy middleware"
-    ```typescript hl_lines="5 36"
+    ```typescript hl_lines="23"
     --8<-- "examples/snippets/parser/envelopeMiddy.ts"
     ```
 
 === "Decorator"
-    ```typescript hl_lines="5 26 30"
+    ```typescript hl_lines="26"
     --8<-- "examples/snippets/parser/envelopeDecorator.ts"
     ```
 
@@ -230,26 +230,24 @@ The `ParsedResult` object will have `success`, `data`,  or `error` and `original
 If the parsing is successful, the `data` field will contain the parsed event, otherwise you can access the `error` field and the `originalEvent` to handle the error and recover the original event.
 
 === "Middy middleware"
-    ```typescript hl_lines="32 35 38 39 44"
+    ```typescript hl_lines="23 28 32-33"
     --8<-- "examples/snippets/parser/safeParseMiddy.ts"
     ```
 
     1. Use `safeParse` option to parse the event without throwing an error
-    2. Check if the result is successful or not and handle the error accordingly
-    3. Use `data` to access the parsed event
-    4. Use `error` to handle the error message
-    5. Use `originalEvent` to get the original event and recover
+    2. Use `data` to access the parsed event when successful
+    3. Use `error` to handle the error message
+    4. Use `originalEvent` to get the original event and recover
 
 === "Decorator"
-    ```typescript hl_lines="29 35 37 40 41"
+    ```typescript hl_lines="33 41 45-46"
     --8<-- "examples/snippets/parser/safeParseDecorator.ts"
     ```
 
     1. Use `safeParse` option to parse the event without throwing an error
-    2. Check if the result is successful or not and handle the error accordingly
-    3. Use `data` to access the parsed event
-    4. Use `error` to handle the error message
-    5. Use `originalEvent` to get the original event and recover
+    2. Use `data` to access the parsed event when successful
+    3. Use `error` to handle the error message
+    4. Use `originalEvent` to get the original event and recover
 
 ## Manual parsing
 
@@ -316,7 +314,7 @@ If you are you use middy middleware, you don't need to do this.
 
 === "handlerDecorator.test.ts"
 
-    ```typescript hl_lines="26"
+    ```typescript hl_lines="27"
     --8<-- "examples/snippets/parser/unitTestDecorator.ts"
     ```
 
@@ -338,7 +336,7 @@ This also works when using `safeParse` option.
 
 === "handlerSafeParse.test.ts"
 
-    ```typescript hl_lines="21-29 35 45"
+    ```typescript hl_lines="21-30 36 46"
     --8<-- "examples/snippets/parser/unitTestSafeParse.ts"
     ```
 

docs/utilities/parser.md

@@ -49,7 +49,7 @@
     "@middy/core": "^4.7.0",
     "@types/aws-lambda": "^8.10.147",
     "@types/node": "22.13.10",
-    "aws-cdk": "^2.1004.0",
+    "aws-cdk": "^2.1005.0",
     "constructs": "^10.4.2",
     "esbuild": "^0.25.1",
     "typescript": "^5.8.2"

examples/app/package.json

@@ -1,7 +1,7 @@
 import type { LambdaInterface } from '@aws-lambda-powertools/commons/types';
 import { Logger } from '@aws-lambda-powertools/logger';
 import { parser } from '@aws-lambda-powertools/parser';
-import { EventBridgeEnvelope } from '@aws-lambda-powertools/parser/envelopes';
+import { EventBridgeEnvelope } from '@aws-lambda-powertools/parser/envelopes/eventbridge';
 import type { Context } from 'aws-lambda';
 import { z } from 'zod';
 

examples/snippets/parser/envelopeDecorator.ts

@@ -1,8 +1,7 @@
 import { Logger } from '@aws-lambda-powertools/logger';
-import { EventBridgeEnvelope } from '@aws-lambda-powertools/parser/envelopes';
+import { EventBridgeEnvelope } from '@aws-lambda-powertools/parser/envelopes/eventbridge';
 import { parser } from '@aws-lambda-powertools/parser/middleware';
 import middy from '@middy/core';
-import type { Context } from 'aws-lambda';
 import { z } from 'zod';
 
 const logger = new Logger();
@@ -20,18 +19,11 @@ const orderSchema = z.object({
   optionalField: z.string().optional(),
 });
 
-type Order = z.infer<typeof orderSchema>;
-
-const lambdaHandler = async (
-  event: Order,
-  _context: Context
-): Promise<void> => {
-  for (const item of event.items) {
-    // item is parsed as OrderItem
-    logger.info('Processing item', { item });
-  }
-};
-
-export const handler = middy(lambdaHandler).use(
-  parser({ schema: orderSchema, envelope: EventBridgeEnvelope })
-);
+export const handler = middy()
+  .use(parser({ schema: orderSchema, envelope: EventBridgeEnvelope }))
+  .handler(async (event): Promise<void> => {
+    for (const item of event.items) {
+      // item is parsed as OrderItem
+      logger.info('Processing item', { item });
+    }
+  });

examples/snippets/parser/envelopeMiddy.ts

@@ -1,7 +1,7 @@
 import type { LambdaInterface } from '@aws-lambda-powertools/commons/types';
 import { Logger } from '@aws-lambda-powertools/logger';
 import { parser } from '@aws-lambda-powertools/parser';
-import { EventBridgeSchema } from '@aws-lambda-powertools/parser/schemas';
+import { EventBridgeSchema } from '@aws-lambda-powertools/parser/schemas/eventbridge';
 import type { Context } from 'aws-lambda';
 import { z } from 'zod';
 

examples/snippets/parser/extend.ts

@@ -1,5 +1,6 @@
 import { DynamoDBMarshalled } from '@aws-lambda-powertools/parser/helpers/dynamodb';
 import {
+  DynamoDBStreamChangeRecordBase,
   DynamoDBStreamRecord,
   DynamoDBStreamSchema,
 } from '@aws-lambda-powertools/parser/schemas/dynamodb';
@@ -13,7 +14,7 @@ const customSchema = z.object({
 const extendedSchema = DynamoDBStreamSchema.extend({
   Records: z.array(
     DynamoDBStreamRecord.extend({
-      dynamodb: z.object({
+      dynamodb: DynamoDBStreamChangeRecordBase.extend({
         NewImage: DynamoDBMarshalled(customSchema).optional(),
       }),
     })

examples/snippets/parser/extendDynamoDBStreamSchema.ts

@@ -1,7 +1,7 @@
 import type { LambdaInterface } from '@aws-lambda-powertools/commons/types';
 import { Logger } from '@aws-lambda-powertools/logger';
 import { parser } from '@aws-lambda-powertools/parser';
-import { EventBridgeEnvelope } from '@aws-lambda-powertools/parser/envelopes';
+import { EventBridgeEnvelope } from '@aws-lambda-powertools/parser/envelopes/eventbridge';
 import type {
   EventBridgeEvent,
   ParsedResult,

examples/snippets/parser/handlerSafeParseDecorator.ts

@@ -1,6 +1,6 @@
 import { Logger } from '@aws-lambda-powertools/logger';
-import { EventBridgeEnvelope } from '@aws-lambda-powertools/parser/envelopes';
-import { EventBridgeSchema } from '@aws-lambda-powertools/parser/schemas';
+import { EventBridgeEnvelope } from '@aws-lambda-powertools/parser/envelopes/eventbridge';
+import { EventBridgeSchema } from '@aws-lambda-powertools/parser/schemas/eventbridge';
 import type { EventBridgeEvent } from '@aws-lambda-powertools/parser/types';
 import type { Context } from 'aws-lambda';
 import { z } from 'zod';

examples/snippets/parser/manual.ts

@@ -1,6 +1,6 @@
 import { Logger } from '@aws-lambda-powertools/logger';
-import { EventBridgeEnvelope } from '@aws-lambda-powertools/parser/envelopes';
-import { EventBridgeSchema } from '@aws-lambda-powertools/parser/schemas';
+import { EventBridgeEnvelope } from '@aws-lambda-powertools/parser/envelopes/eventbridge';
+import { EventBridgeSchema } from '@aws-lambda-powertools/parser/schemas/eventbridge';
 import type { EventBridgeEvent } from '@aws-lambda-powertools/parser/types';
 import type { Context } from 'aws-lambda';
 import { z } from 'zod';

examples/snippets/parser/manualSafeParse.ts

@@ -1,7 +1,6 @@
 import { Logger } from '@aws-lambda-powertools/logger';
 import { parser } from '@aws-lambda-powertools/parser/middleware';
 import middy from '@middy/core';
-import type { Context } from 'aws-lambda';
 import { z } from 'zod';
 
 const logger = new Logger();
@@ -19,18 +18,11 @@ const orderSchema = z.object({
   optionalField: z.string().optional(),
 });
 
-type Order = z.infer<typeof orderSchema>;
-
-const lambdaHandler = async (
-  event: Order,
-  _context: Context
-): Promise<void> => {
-  for (const item of event.items) {
-    // item is parsed as OrderItem
-    logger.info('Processing item', { item });
-  }
-};
-
-export const handler = middy(lambdaHandler).use(
-  parser({ schema: orderSchema })
-);
+export const handler = middy()
+  .use(parser({ schema: orderSchema }))
+  .handler(async (event): Promise<void> => {
+    for (const item of event.items) {
+      // item is parsed as OrderItem
+      logger.info('Processing item', { item });
+    }
+  });