@aws-lambda-powertools/parser - npm Package Compare versions

Comparing version 2.11.0 to 2.12.0

lib/cjs/envelopes/envelope.d.ts

@@ -19,3 +19,3 @@ import type { ZodSchema, z } from 'zod';
      */
-    safeParse<T extends ZodSchema>(input: unknown, schema: T): ParsedResult;
+    safeParse<T extends ZodSchema>(input: unknown, schema: T): ParsedResult<unknown, z.infer<T>>;
 };
@@ -22,0 +22,0 @@ /**

lib/cjs/envelopes/event-bridge.d.ts

@@ -14,4 +14,4 @@ import type { ZodSchema, z } from 'zod';
     parse<T extends ZodSchema>(data: unknown, schema: T): z.infer<T>;
-    safeParse<T extends ZodSchema>(data: unknown, schema: T): ParsedResult;
+    safeParse<T extends ZodSchema>(data: unknown, schema: T): ParsedResult<unknown, z.infer<T>>;
 };
 //# sourceMappingURL=event-bridge.d.ts.map

lib/cjs/envelopes/lambda.d.ts

@@ -14,4 +14,4 @@ import type { ZodSchema, z } from 'zod';
     parse<T extends ZodSchema>(data: unknown, schema: T): z.infer<T>;
-    safeParse<T extends ZodSchema>(data: unknown, schema: T): ParsedResult;
+    safeParse<T extends ZodSchema>(data: unknown, schema: T): ParsedResult<unknown, z.infer<T>>;
 };
 //# sourceMappingURL=lambda.d.ts.map

lib/cjs/envelopes/vpc-lattice.d.ts

@@ -14,4 +14,4 @@ import type { ZodSchema, z } from 'zod';
     parse<T extends ZodSchema>(data: unknown, schema: T): z.infer<T>;
-    safeParse<T extends ZodSchema>(data: unknown, schema: T): ParsedResult;
+    safeParse<T extends ZodSchema>(data: unknown, schema: T): ParsedResult<unknown, z.infer<T>>;
 };
 //# sourceMappingURL=vpc-lattice.d.ts.map

lib/cjs/envelopes/vpc-latticev2.d.ts

@@ -14,4 +14,4 @@ import type { ZodSchema, z } from 'zod';
     parse<T extends ZodSchema>(data: unknown, schema: T): z.infer<T>;
-    safeParse<T extends ZodSchema>(data: unknown, schema: T): ParsedResult;
+    safeParse<T extends ZodSchema>(data: unknown, schema: T): ParsedResult<unknown, z.infer<T>>;
 };
 //# sourceMappingURL=vpc-latticev2.d.ts.map

lib/cjs/schemas/dynamodb.d.ts

@@ -120,2 +120,115 @@ import { z } from 'zod';
 }>;
+declare const DynamoDBStreamToKinesisRecord: z.ZodObject<Omit<z.objectUtil.extendShape<{
+    eventID: z.ZodString;
+    eventName: z.ZodEnum<["INSERT", "MODIFY", "REMOVE"]>;
+    eventVersion: z.ZodString;
+    eventSource: z.ZodLiteral<"aws:dynamodb">;
+    awsRegion: z.ZodString;
+    eventSourceARN: z.ZodString;
+    dynamodb: z.ZodObject<{
+        ApproximateCreationDateTime: z.ZodOptional<z.ZodNumber>;
+        Keys: z.ZodRecord<z.ZodString, z.ZodRecord<z.ZodString, z.ZodAny>>;
+        NewImage: z.ZodOptional<z.ZodRecord<z.ZodString, z.ZodAny>>;
+        OldImage: z.ZodOptional<z.ZodRecord<z.ZodString, z.ZodAny>>;
+        SequenceNumber: z.ZodString;
+        SizeBytes: z.ZodNumber;
+        StreamViewType: z.ZodEnum<["NEW_IMAGE", "OLD_IMAGE", "NEW_AND_OLD_IMAGES", "KEYS_ONLY"]>;
+    }, "strip", z.ZodTypeAny, {
+        Keys: Record<string, Record<string, any>>;
+        SequenceNumber: string;
+        SizeBytes: number;
+        StreamViewType: "NEW_IMAGE" | "OLD_IMAGE" | "NEW_AND_OLD_IMAGES" | "KEYS_ONLY";
+        ApproximateCreationDateTime?: number | undefined;
+        NewImage?: Record<string, any> | undefined;
+        OldImage?: Record<string, any> | undefined;
+    }, {
+        Keys: Record<string, Record<string, any>>;
+        SequenceNumber: string;
+        SizeBytes: number;
+        StreamViewType: "NEW_IMAGE" | "OLD_IMAGE" | "NEW_AND_OLD_IMAGES" | "KEYS_ONLY";
+        ApproximateCreationDateTime?: number | undefined;
+        NewImage?: Record<string, any> | undefined;
+        OldImage?: Record<string, any> | undefined;
+    }>;
+    userIdentity: z.ZodOptional<z.ZodObject<{
+        type: z.ZodEnum<["Service"]>;
+        principalId: z.ZodLiteral<"dynamodb.amazonaws.com">;
+    }, "strip", z.ZodTypeAny, {
+        type: "Service";
+        principalId: "dynamodb.amazonaws.com";
+    }, {
+        type: "Service";
+        principalId: "dynamodb.amazonaws.com";
+    }>>;
+}, {
+    recordFormat: z.ZodLiteral<"application/json">;
+    tableName: z.ZodString;
+    userIdentity: z.ZodOptional<z.ZodNullable<z.ZodObject<{
+        type: z.ZodEnum<["Service"]>;
+        principalId: z.ZodLiteral<"dynamodb.amazonaws.com">;
+    }, "strip", z.ZodTypeAny, {
+        type: "Service";
+        principalId: "dynamodb.amazonaws.com";
+    }, {
+        type: "Service";
+        principalId: "dynamodb.amazonaws.com";
+    }>>>;
+    dynamodb: z.ZodObject<Omit<{
+        ApproximateCreationDateTime: z.ZodOptional<z.ZodNumber>;
+        Keys: z.ZodRecord<z.ZodString, z.ZodRecord<z.ZodString, z.ZodAny>>;
+        NewImage: z.ZodOptional<z.ZodRecord<z.ZodString, z.ZodAny>>;
+        OldImage: z.ZodOptional<z.ZodRecord<z.ZodString, z.ZodAny>>;
+        SequenceNumber: z.ZodString;
+        SizeBytes: z.ZodNumber;
+        StreamViewType: z.ZodEnum<["NEW_IMAGE", "OLD_IMAGE", "NEW_AND_OLD_IMAGES", "KEYS_ONLY"]>;
+    }, "SequenceNumber" | "StreamViewType">, "strip", z.ZodTypeAny, {
+        Keys: Record<string, Record<string, any>>;
+        SizeBytes: number;
+        ApproximateCreationDateTime?: number | undefined;
+        NewImage?: Record<string, any> | undefined;
+        OldImage?: Record<string, any> | undefined;
+    }, {
+        Keys: Record<string, Record<string, any>>;
+        SizeBytes: number;
+        ApproximateCreationDateTime?: number | undefined;
+        NewImage?: Record<string, any> | undefined;
+        OldImage?: Record<string, any> | undefined;
+    }>;
+}>, "eventVersion" | "eventSourceARN">, "strip", z.ZodTypeAny, {
+    eventID: string;
+    eventName: "INSERT" | "MODIFY" | "REMOVE";
+    eventSource: "aws:dynamodb";
+    awsRegion: string;
+    dynamodb: {
+        Keys: Record<string, Record<string, any>>;
+        SizeBytes: number;
+        ApproximateCreationDateTime?: number | undefined;
+        NewImage?: Record<string, any> | undefined;
+        OldImage?: Record<string, any> | undefined;
+    };
+    recordFormat: "application/json";
+    tableName: string;
+    userIdentity?: {
+        type: "Service";
+        principalId: "dynamodb.amazonaws.com";
+    } | null | undefined;
+}, {
+    eventID: string;
+    eventName: "INSERT" | "MODIFY" | "REMOVE";
+    eventSource: "aws:dynamodb";
+    awsRegion: string;
+    dynamodb: {
+        Keys: Record<string, Record<string, any>>;
+        SizeBytes: number;
+        ApproximateCreationDateTime?: number | undefined;
+        NewImage?: Record<string, any> | undefined;
+        OldImage?: Record<string, any> | undefined;
+    };
+    recordFormat: "application/json";
+    tableName: string;
+    userIdentity?: {
+        type: "Service";
+        principalId: "dynamodb.amazonaws.com";
+    } | null | undefined;
+}>;
 /**
@@ -325,3 +438,3 @@ * Zod schema for Amazon DynamoDB Stream event.
 }>;
-export { DynamoDBStreamSchema, DynamoDBStreamRecord, DynamoDBStreamChangeRecord, UserIdentity, };
+export { DynamoDBStreamToKinesisRecord, DynamoDBStreamSchema, DynamoDBStreamRecord, DynamoDBStreamChangeRecord, UserIdentity, };
 //# sourceMappingURL=dynamodb.d.ts.map

lib/cjs/schemas/dynamodb.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.UserIdentity = exports.DynamoDBStreamChangeRecord = exports.DynamoDBStreamRecord = exports.DynamoDBStreamSchema = void 0;
+exports.UserIdentity = exports.DynamoDBStreamChangeRecord = exports.DynamoDBStreamRecord = exports.DynamoDBStreamSchema = exports.DynamoDBStreamToKinesisRecord = void 0;
 const zod_1 = require("zod");
@@ -36,2 +36,15 @@ const DynamoDBStreamChangeRecord = zod_1.z.object({
 exports.DynamoDBStreamRecord = DynamoDBStreamRecord;
+const DynamoDBStreamToKinesisRecord = DynamoDBStreamRecord.extend({
+    recordFormat: zod_1.z.literal('application/json'),
+    tableName: zod_1.z.string(),
+    userIdentity: UserIdentity.nullish(),
+    dynamodb: DynamoDBStreamChangeRecord.omit({
+        SequenceNumber: true,
+        StreamViewType: true,
+    }),
+}).omit({
+    eventVersion: true,
+    eventSourceARN: true,
+});
+exports.DynamoDBStreamToKinesisRecord = DynamoDBStreamToKinesisRecord;
 /**
@@ -38,0 +51,0 @@ * Zod schema for Amazon DynamoDB Stream event.

lib/cjs/schemas/eventbridge.d.ts

@@ -42,5 +42,5 @@ import { z } from 'zod';
     time: string;
+    source: string;
     version: string;
     id: string;
-    source: string;
     account: string;
@@ -54,5 +54,5 @@ region: string;
     time: string;
+    source: string;
     version: string;
     id: string;
-    source: string;
     account: string;
@@ -59,0 +59,0 @@ region: string;

lib/cjs/schemas/index.d.ts

 export { AlbSchema, AlbMultiValueHeadersSchema } from './alb.js';
 export { APIGatewayProxyEventSchema, APIGatewayRequestAuthorizerEventSchema, APIGatewayTokenAuthorizerEventSchema, } from './apigw.js';
+export { AppSyncResolverSchema, AppSyncBatchResolverSchema, } from './appsync.js';
 export { APIGatewayProxyEventV2Schema, APIGatewayRequestAuthorizerEventV2Schema, APIGatewayRequestAuthorizerV2Schema, APIGatewayRequestContextV2Schema, } from './apigwv2.js';
 export { CloudFormationCustomResourceCreateSchema, CloudFormationCustomResourceDeleteSchema, CloudFormationCustomResourceUpdateSchema, } from './cloudformation-custom-resource.js';
 export { CloudWatchLogEventSchema, CloudWatchLogsDecodeSchema, CloudWatchLogsSchema, } from './cloudwatch.js';
-export { DynamoDBStreamSchema } from './dynamodb.js';
+export { DynamoDBStreamSchema, DynamoDBStreamToKinesisRecord, } from './dynamodb.js';
 export { EventBridgeSchema } from './eventbridge.js';
 export { KafkaMskEventSchema, KafkaSelfManagedEventSchema, KafkaRecordSchema, } from './kafka.js';
-export { KinesisDataStreamSchema, KinesisDataStreamRecord } from './kinesis.js';
+export { KinesisDataStreamSchema, KinesisDynamoDBStreamSchema, KinesisDataStreamRecord, } from './kinesis.js';
 export { KinesisFirehoseSchema, KinesisFirehoseSqsSchema, KinesisFirehoseRecordSchema, KinesisFirehoseSqsRecordSchema, } from './kinesis-firehose.js';
@@ -11,0 +12,0 @@ export { LambdaFunctionUrlSchema } from './lambda.js';

lib/cjs/schemas/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.VpcLatticeV2Schema = exports.VpcLatticeSchema = exports.SqsRecordSchema = exports.SqsSchema = exports.SnsNotificationSchema = exports.SnsSqsNotificationSchema = exports.SnsRecordSchema = exports.SnsSchema = exports.SesRecordSchema = exports.SesSchema = exports.S3Schema = exports.S3ObjectLambdaEventSchema = exports.S3EventNotificationEventBridgeSchema = exports.S3SqsEventNotificationSchema = exports.LambdaFunctionUrlSchema = exports.KinesisFirehoseSqsRecordSchema = exports.KinesisFirehoseRecordSchema = exports.KinesisFirehoseSqsSchema = exports.KinesisFirehoseSchema = exports.KinesisDataStreamRecord = exports.KinesisDataStreamSchema = exports.KafkaRecordSchema = exports.KafkaSelfManagedEventSchema = exports.KafkaMskEventSchema = exports.EventBridgeSchema = exports.DynamoDBStreamSchema = exports.CloudWatchLogsSchema = exports.CloudWatchLogsDecodeSchema = exports.CloudWatchLogEventSchema = exports.CloudFormationCustomResourceUpdateSchema = exports.CloudFormationCustomResourceDeleteSchema = exports.CloudFormationCustomResourceCreateSchema = exports.APIGatewayRequestContextV2Schema = exports.APIGatewayRequestAuthorizerV2Schema = exports.APIGatewayRequestAuthorizerEventV2Schema = exports.APIGatewayProxyEventV2Schema = exports.APIGatewayTokenAuthorizerEventSchema = exports.APIGatewayRequestAuthorizerEventSchema = exports.APIGatewayProxyEventSchema = exports.AlbMultiValueHeadersSchema = exports.AlbSchema = void 0;
+exports.VpcLatticeV2Schema = exports.VpcLatticeSchema = exports.SqsRecordSchema = exports.SqsSchema = exports.SnsNotificationSchema = exports.SnsSqsNotificationSchema = exports.SnsRecordSchema = exports.SnsSchema = exports.SesRecordSchema = exports.SesSchema = exports.S3Schema = exports.S3ObjectLambdaEventSchema = exports.S3EventNotificationEventBridgeSchema = exports.S3SqsEventNotificationSchema = exports.LambdaFunctionUrlSchema = exports.KinesisFirehoseSqsRecordSchema = exports.KinesisFirehoseRecordSchema = exports.KinesisFirehoseSqsSchema = exports.KinesisFirehoseSchema = exports.KinesisDataStreamRecord = exports.KinesisDynamoDBStreamSchema = exports.KinesisDataStreamSchema = exports.KafkaRecordSchema = exports.KafkaSelfManagedEventSchema = exports.KafkaMskEventSchema = exports.EventBridgeSchema = exports.DynamoDBStreamToKinesisRecord = exports.DynamoDBStreamSchema = exports.CloudWatchLogsSchema = exports.CloudWatchLogsDecodeSchema = exports.CloudWatchLogEventSchema = exports.CloudFormationCustomResourceUpdateSchema = exports.CloudFormationCustomResourceDeleteSchema = exports.CloudFormationCustomResourceCreateSchema = exports.APIGatewayRequestContextV2Schema = exports.APIGatewayRequestAuthorizerV2Schema = exports.APIGatewayRequestAuthorizerEventV2Schema = exports.APIGatewayProxyEventV2Schema = exports.AppSyncBatchResolverSchema = exports.AppSyncResolverSchema = exports.APIGatewayTokenAuthorizerEventSchema = exports.APIGatewayRequestAuthorizerEventSchema = exports.APIGatewayProxyEventSchema = exports.AlbMultiValueHeadersSchema = exports.AlbSchema = void 0;
 var alb_js_1 = require("./alb.js");
@@ -11,2 +11,5 @@ Object.defineProperty(exports, "AlbSchema", { enumerable: true, get: function () { return alb_js_1.AlbSchema; } });
 Object.defineProperty(exports, "APIGatewayTokenAuthorizerEventSchema", { enumerable: true, get: function () { return apigw_js_1.APIGatewayTokenAuthorizerEventSchema; } });
+var appsync_js_1 = require("./appsync.js");
+Object.defineProperty(exports, "AppSyncResolverSchema", { enumerable: true, get: function () { return appsync_js_1.AppSyncResolverSchema; } });
+Object.defineProperty(exports, "AppSyncBatchResolverSchema", { enumerable: true, get: function () { return appsync_js_1.AppSyncBatchResolverSchema; } });
 var apigwv2_js_1 = require("./apigwv2.js");
@@ -27,2 +30,3 @@ Object.defineProperty(exports, "APIGatewayProxyEventV2Schema", { enumerable: true, get: function () { return apigwv2_js_1.APIGatewayProxyEventV2Schema; } });
 Object.defineProperty(exports, "DynamoDBStreamSchema", { enumerable: true, get: function () { return dynamodb_js_1.DynamoDBStreamSchema; } });
+Object.defineProperty(exports, "DynamoDBStreamToKinesisRecord", { enumerable: true, get: function () { return dynamodb_js_1.DynamoDBStreamToKinesisRecord; } });
 var eventbridge_js_1 = require("./eventbridge.js");
@@ -36,2 +40,3 @@ Object.defineProperty(exports, "EventBridgeSchema", { enumerable: true, get: function () { return eventbridge_js_1.EventBridgeSchema; } });
 Object.defineProperty(exports, "KinesisDataStreamSchema", { enumerable: true, get: function () { return kinesis_js_1.KinesisDataStreamSchema; } });
+Object.defineProperty(exports, "KinesisDynamoDBStreamSchema", { enumerable: true, get: function () { return kinesis_js_1.KinesisDynamoDBStreamSchema; } });
 Object.defineProperty(exports, "KinesisDataStreamRecord", { enumerable: true, get: function () { return kinesis_js_1.KinesisDataStreamRecord; } });
@@ -38,0 +43,0 @@ var kinesis_firehose_js_1 = require("./kinesis-firehose.js");

lib/cjs/schemas/kinesis.d.ts

@@ -79,2 +79,284 @@ import { z } from 'zod';
 }>;
+declare const KinesisDynamoDBStreamSchema: z.ZodObject<{
+    Records: z.ZodArray<z.ZodObject<z.objectUtil.extendShape<{
+        eventSource: z.ZodLiteral<"aws:kinesis">;
+        eventVersion: z.ZodString;
+        eventID: z.ZodString;
+        eventName: z.ZodLiteral<"aws:kinesis:record">;
+        awsRegion: z.ZodString;
+        invokeIdentityArn: z.ZodString;
+        eventSourceARN: z.ZodString;
+        kinesis: z.ZodObject<{
+            kinesisSchemaVersion: z.ZodString;
+            partitionKey: z.ZodString;
+            sequenceNumber: z.ZodString;
+            approximateArrivalTimestamp: z.ZodNumber;
+            data: z.ZodEffects<z.ZodString, any, string>;
+        }, "strip", z.ZodTypeAny, {
+            kinesisSchemaVersion: string;
+            partitionKey: string;
+            sequenceNumber: string;
+            approximateArrivalTimestamp: number;
+            data?: any;
+        }, {
+            data: string;
+            kinesisSchemaVersion: string;
+            partitionKey: string;
+            sequenceNumber: string;
+            approximateArrivalTimestamp: number;
+        }>;
+    }, {
+        kinesis: z.ZodObject<z.objectUtil.extendShape<{
+            kinesisSchemaVersion: z.ZodString;
+            partitionKey: z.ZodString;
+            sequenceNumber: z.ZodString;
+            approximateArrivalTimestamp: z.ZodNumber;
+            data: z.ZodEffects<z.ZodString, any, string>;
+        }, {
+            data: z.ZodPipeline<z.ZodEffects<z.ZodString, any, string>, z.ZodObject<Omit<z.objectUtil.extendShape<{
+                eventID: z.ZodString;
+                eventName: z.ZodEnum<["INSERT", "MODIFY", "REMOVE"]>;
+                eventVersion: z.ZodString;
+                eventSource: z.ZodLiteral<"aws:dynamodb">;
+                awsRegion: z.ZodString;
+                eventSourceARN: z.ZodString;
+                dynamodb: z.ZodObject<{
+                    ApproximateCreationDateTime: z.ZodOptional<z.ZodNumber>;
+                    Keys: z.ZodRecord<z.ZodString, z.ZodRecord<z.ZodString, z.ZodAny>>;
+                    NewImage: z.ZodOptional<z.ZodRecord<z.ZodString, z.ZodAny>>;
+                    OldImage: z.ZodOptional<z.ZodRecord<z.ZodString, z.ZodAny>>;
+                    SequenceNumber: z.ZodString;
+                    SizeBytes: z.ZodNumber;
+                    StreamViewType: z.ZodEnum<["NEW_IMAGE", "OLD_IMAGE", "NEW_AND_OLD_IMAGES", "KEYS_ONLY"]>;
+                }, "strip", z.ZodTypeAny, {
+                    Keys: Record<string, Record<string, any>>;
+                    SequenceNumber: string;
+                    SizeBytes: number;
+                    StreamViewType: "NEW_IMAGE" | "OLD_IMAGE" | "NEW_AND_OLD_IMAGES" | "KEYS_ONLY";
+                    ApproximateCreationDateTime?: number | undefined;
+                    NewImage?: Record<string, any> | undefined;
+                    OldImage?: Record<string, any> | undefined;
+                }, {
+                    Keys: Record<string, Record<string, any>>;
+                    SequenceNumber: string;
+                    SizeBytes: number;
+                    StreamViewType: "NEW_IMAGE" | "OLD_IMAGE" | "NEW_AND_OLD_IMAGES" | "KEYS_ONLY";
+                    ApproximateCreationDateTime?: number | undefined;
+                    NewImage?: Record<string, any> | undefined;
+                    OldImage?: Record<string, any> | undefined;
+                }>;
+                userIdentity: z.ZodOptional<z.ZodObject<{
+                    type: z.ZodEnum<["Service"]>;
+                    principalId: z.ZodLiteral<"dynamodb.amazonaws.com">;
+                }, "strip", z.ZodTypeAny, {
+                    type: "Service";
+                    principalId: "dynamodb.amazonaws.com";
+                }, {
+                    type: "Service";
+                    principalId: "dynamodb.amazonaws.com";
+                }>>;
+            }, {
+                recordFormat: z.ZodLiteral<"application/json">;
+                tableName: z.ZodString;
+                userIdentity: z.ZodOptional<z.ZodNullable<z.ZodObject<{
+                    type: z.ZodEnum<["Service"]>;
+                    principalId: z.ZodLiteral<"dynamodb.amazonaws.com">;
+                }, "strip", z.ZodTypeAny, {
+                    type: "Service";
+                    principalId: "dynamodb.amazonaws.com";
+                }, {
+                    type: "Service";
+                    principalId: "dynamodb.amazonaws.com";
+                }>>>;
+                dynamodb: z.ZodObject<Omit<{
+                    ApproximateCreationDateTime: z.ZodOptional<z.ZodNumber>;
+                    Keys: z.ZodRecord<z.ZodString, z.ZodRecord<z.ZodString, z.ZodAny>>;
+                    NewImage: z.ZodOptional<z.ZodRecord<z.ZodString, z.ZodAny>>;
+                    OldImage: z.ZodOptional<z.ZodRecord<z.ZodString, z.ZodAny>>;
+                    SequenceNumber: z.ZodString;
+                    SizeBytes: z.ZodNumber;
+                    StreamViewType: z.ZodEnum<["NEW_IMAGE", "OLD_IMAGE", "NEW_AND_OLD_IMAGES", "KEYS_ONLY"]>;
+                }, "SequenceNumber" | "StreamViewType">, "strip", z.ZodTypeAny, {
+                    Keys: Record<string, Record<string, any>>;
+                    SizeBytes: number;
+                    ApproximateCreationDateTime?: number | undefined;
+                    NewImage?: Record<string, any> | undefined;
+                    OldImage?: Record<string, any> | undefined;
+                }, {
+                    Keys: Record<string, Record<string, any>>;
+                    SizeBytes: number;
+                    ApproximateCreationDateTime?: number | undefined;
+                    NewImage?: Record<string, any> | undefined;
+                    OldImage?: Record<string, any> | undefined;
+                }>;
+            }>, "eventVersion" | "eventSourceARN">, "strip", z.ZodTypeAny, {
+                eventID: string;
+                eventName: "INSERT" | "MODIFY" | "REMOVE";
+                eventSource: "aws:dynamodb";
+                awsRegion: string;
+                dynamodb: {
+                    Keys: Record<string, Record<string, any>>;
+                    SizeBytes: number;
+                    ApproximateCreationDateTime?: number | undefined;
+                    NewImage?: Record<string, any> | undefined;
+                    OldImage?: Record<string, any> | undefined;
+                };
+                recordFormat: "application/json";
+                tableName: string;
+                userIdentity?: {
+                    type: "Service";
+                    principalId: "dynamodb.amazonaws.com";
+                } | null | undefined;
+            }, {
+                eventID: string;
+                eventName: "INSERT" | "MODIFY" | "REMOVE";
+                eventSource: "aws:dynamodb";
+                awsRegion: string;
+                dynamodb: {
+                    Keys: Record<string, Record<string, any>>;
+                    SizeBytes: number;
+                    ApproximateCreationDateTime?: number | undefined;
+                    NewImage?: Record<string, any> | undefined;
+                    OldImage?: Record<string, any> | undefined;
+                };
+                recordFormat: "application/json";
+                tableName: string;
+                userIdentity?: {
+                    type: "Service";
+                    principalId: "dynamodb.amazonaws.com";
+                } | null | undefined;
+            }>>;
+        }>, "strip", z.ZodTypeAny, {
+            data: {
+                eventID: string;
+                eventName: "INSERT" | "MODIFY" | "REMOVE";
+                eventSource: "aws:dynamodb";
+                awsRegion: string;
+                dynamodb: {
+                    Keys: Record<string, Record<string, any>>;
+                    SizeBytes: number;
+                    ApproximateCreationDateTime?: number | undefined;
+                    NewImage?: Record<string, any> | undefined;
+                    OldImage?: Record<string, any> | undefined;
+                };
+                recordFormat: "application/json";
+                tableName: string;
+                userIdentity?: {
+                    type: "Service";
+                    principalId: "dynamodb.amazonaws.com";
+                } | null | undefined;
+            };
+            kinesisSchemaVersion: string;
+            partitionKey: string;
+            sequenceNumber: string;
+            approximateArrivalTimestamp: number;
+        }, {
+            data: string;
+            kinesisSchemaVersion: string;
+            partitionKey: string;
+            sequenceNumber: string;
+            approximateArrivalTimestamp: number;
+        }>;
+    }>, "strip", z.ZodTypeAny, {
+        eventID: string;
+        eventName: "aws:kinesis:record";
+        eventVersion: string;
+        eventSource: "aws:kinesis";
+        awsRegion: string;
+        eventSourceARN: string;
+        invokeIdentityArn: string;
+        kinesis: {
+            data: {
+                eventID: string;
+                eventName: "INSERT" | "MODIFY" | "REMOVE";
+                eventSource: "aws:dynamodb";
+                awsRegion: string;
+                dynamodb: {
+                    Keys: Record<string, Record<string, any>>;
+                    SizeBytes: number;
+                    ApproximateCreationDateTime?: number | undefined;
+                    NewImage?: Record<string, any> | undefined;
+                    OldImage?: Record<string, any> | undefined;
+                };
+                recordFormat: "application/json";
+                tableName: string;
+                userIdentity?: {
+                    type: "Service";
+                    principalId: "dynamodb.amazonaws.com";
+                } | null | undefined;
+            };
+            kinesisSchemaVersion: string;
+            partitionKey: string;
+            sequenceNumber: string;
+            approximateArrivalTimestamp: number;
+        };
+    }, {
+        eventID: string;
+        eventName: "aws:kinesis:record";
+        eventVersion: string;
+        eventSource: "aws:kinesis";
+        awsRegion: string;
+        eventSourceARN: string;
+        invokeIdentityArn: string;
+        kinesis: {
+            data: string;
+            kinesisSchemaVersion: string;
+            partitionKey: string;
+            sequenceNumber: string;
+            approximateArrivalTimestamp: number;
+        };
+    }>, "many">;
+}, "strip", z.ZodTypeAny, {
+    Records: {
+        eventID: string;
+        eventName: "aws:kinesis:record";
+        eventVersion: string;
+        eventSource: "aws:kinesis";
+        awsRegion: string;
+        eventSourceARN: string;
+        invokeIdentityArn: string;
+        kinesis: {
+            data: {
+                eventID: string;
+                eventName: "INSERT" | "MODIFY" | "REMOVE";
+                eventSource: "aws:dynamodb";
+                awsRegion: string;
+                dynamodb: {
+                    Keys: Record<string, Record<string, any>>;
+                    SizeBytes: number;
+                    ApproximateCreationDateTime?: number | undefined;
+                    NewImage?: Record<string, any> | undefined;
+                    OldImage?: Record<string, any> | undefined;
+                };
+                recordFormat: "application/json";
+                tableName: string;
+                userIdentity?: {
+                    type: "Service";
+                    principalId: "dynamodb.amazonaws.com";
+                } | null | undefined;
+            };
+            kinesisSchemaVersion: string;
+            partitionKey: string;
+            sequenceNumber: string;
+            approximateArrivalTimestamp: number;
+        };
+    }[];
+}, {
+    Records: {
+        eventID: string;
+        eventName: "aws:kinesis:record";
+        eventVersion: string;
+        eventSource: "aws:kinesis";
+        awsRegion: string;
+        eventSourceARN: string;
+        invokeIdentityArn: string;
+        kinesis: {
+            data: string;
+            kinesisSchemaVersion: string;
+            partitionKey: string;
+            sequenceNumber: string;
+            approximateArrivalTimestamp: number;
+        };
+    }[];
+}>;
 /**
@@ -220,3 +502,3 @@ * Zod schema for Kinesis Data Stream event
 }>;
-export { KinesisDataStreamSchema, KinesisDataStreamRecord, KinesisDataStreamRecordPayload, };
+export { KinesisDataStreamRecord, KinesisDataStreamRecordPayload, KinesisDataStreamSchema, KinesisDynamoDBStreamSchema, };
 //# sourceMappingURL=kinesis.d.ts.map

lib/cjs/schemas/kinesis.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.KinesisDataStreamRecordPayload = exports.KinesisDataStreamRecord = exports.KinesisDataStreamSchema = void 0;
+exports.KinesisDynamoDBStreamSchema = exports.KinesisDataStreamSchema = exports.KinesisDataStreamRecordPayload = exports.KinesisDataStreamRecord = void 0;
 const node_zlib_1 = require("node:zlib");
 const zod_1 = require("zod");
+const dynamodb_js_1 = require("./dynamodb.js");
 const KinesisDataStreamRecordPayload = zod_1.z.object({
@@ -12,7 +13,7 @@ kinesisSchemaVersion: zod_1.z.string(),
     data: zod_1.z.string().transform((data) => {
-        const decompresed = decompress(data);
+        const decompressed = decompress(data);
         const decoded = Buffer.from(data, 'base64').toString('utf-8');
         try {
             // If data was not compressed, try to parse it as JSON otherwise it must be string
-            return decompresed === data ? JSON.parse(decoded) : decompresed;
+            return decompressed === data ? JSON.parse(decoded) : decompressed;
         }
@@ -44,2 +45,15 @@ catch (e) {
 exports.KinesisDataStreamRecord = KinesisDataStreamRecord;
+const KinesisDynamoDBStreamSchema = zod_1.z.object({
+    Records: zod_1.z.array(KinesisDataStreamRecord.extend({
+        kinesis: KinesisDataStreamRecordPayload.extend({
+            data: zod_1.z
+                .string()
+                .transform((data) => {
+                return JSON.parse(Buffer.from(data, 'base64').toString('utf8'));
+            })
+                .pipe(dynamodb_js_1.DynamoDBStreamToKinesisRecord),
+        }),
+    })),
+});
+exports.KinesisDynamoDBStreamSchema = KinesisDynamoDBStreamSchema;
 /**
@@ -46,0 +60,0 @@ * Zod schema for Kinesis Data Stream event

lib/cjs/schemas/s3.d.ts

@@ -134,5 +134,5 @@ import { z } from 'zod';
     time: string;
+    source: string;
     version: string;
     id: string;
-    source: string;
     account: string;
@@ -167,5 +167,5 @@ region: string;
     time: string;
+    source: string;
     version: string;
     id: string;
-    source: string;
     account: string;
@@ -172,0 +172,0 @@ region: string;

lib/cjs/schemas/ses.d.ts

@@ -65,4 +65,4 @@ import { z } from 'zod';
             messageId: string;
+            source: string;
             timestamp: string;
-            source: string;
             destination: string[];
@@ -88,4 +88,4 @@ headersTruncated: boolean;
             messageId: string;
+            source: string;
             timestamp: string;
-            source: string;
             destination: string[];
@@ -217,4 +217,4 @@ headersTruncated: boolean;
             messageId: string;
+            source: string;
             timestamp: string;
-            source: string;
             destination: string[];
@@ -268,4 +268,4 @@ headersTruncated: boolean;
             messageId: string;
+            source: string;
             timestamp: string;
-            source: string;
             destination: string[];
@@ -323,4 +323,4 @@ headersTruncated: boolean;
             messageId: string;
+            source: string;
             timestamp: string;
-            source: string;
             destination: string[];
@@ -378,4 +378,4 @@ headersTruncated: boolean;
             messageId: string;
+            source: string;
             timestamp: string;
-            source: string;
             destination: string[];
@@ -596,4 +596,4 @@ headersTruncated: boolean;
                 messageId: string;
+                source: string;
                 timestamp: string;
-                source: string;
                 destination: string[];
@@ -619,4 +619,4 @@ headersTruncated: boolean;
                 messageId: string;
+                source: string;
                 timestamp: string;
-                source: string;
                 destination: string[];
@@ -748,4 +748,4 @@ headersTruncated: boolean;
                 messageId: string;
+                source: string;
                 timestamp: string;
-                source: string;
                 destination: string[];
@@ -799,4 +799,4 @@ headersTruncated: boolean;
                 messageId: string;
+                source: string;
                 timestamp: string;
-                source: string;
                 destination: string[];
@@ -854,4 +854,4 @@ headersTruncated: boolean;
                 messageId: string;
+                source: string;
                 timestamp: string;
-                source: string;
                 destination: string[];
@@ -909,4 +909,4 @@ headersTruncated: boolean;
                 messageId: string;
+                source: string;
                 timestamp: string;
-                source: string;
                 destination: string[];
@@ -966,4 +966,4 @@ headersTruncated: boolean;
                 messageId: string;
+                source: string;
                 timestamp: string;
-                source: string;
                 destination: string[];
@@ -1023,4 +1023,4 @@ headersTruncated: boolean;
                 messageId: string;
+                source: string;
                 timestamp: string;
-                source: string;
                 destination: string[];
@@ -1027,0 +1027,0 @@ headersTruncated: boolean;

lib/cjs/schemas/sns.d.ts

@@ -6,3 +6,3 @@ import { z } from 'zod';
 declare const SnsNotificationSchema: z.ZodObject<{
-    Subject: z.ZodOptional<z.ZodString>;
+    Subject: z.ZodOptional<z.ZodNullable<z.ZodString>>;
     TopicArn: z.ZodString;
@@ -36,3 +36,3 @@ UnsubscribeUrl: z.ZodString;
     Timestamp: string;
-    Subject?: string | undefined;
+    Subject?: string | null | undefined;
     UnsubscribeURL?: string | undefined;
@@ -54,3 +54,3 @@ SigningCertUrl?: string | undefined;
     Timestamp: string;
-    Subject?: string | undefined;
+    Subject?: string | null | undefined;
     UnsubscribeURL?: string | undefined;
@@ -96,3 +96,3 @@ SigningCertUrl?: string | undefined;
 declare const SnsSqsNotificationSchema: z.ZodObject<Omit<z.objectUtil.extendShape<{
-    Subject: z.ZodOptional<z.ZodString>;
+    Subject: z.ZodOptional<z.ZodNullable<z.ZodString>>;
     TopicArn: z.ZodString;
@@ -128,3 +128,3 @@ UnsubscribeUrl: z.ZodString;
     Timestamp: string;
-    Subject?: string | undefined;
+    Subject?: string | null | undefined;
     UnsubscribeURL?: string | undefined;
@@ -144,3 +144,3 @@ SigningCertURL?: string | undefined;
     Timestamp: string;
-    Subject?: string | undefined;
+    Subject?: string | null | undefined;
     UnsubscribeURL?: string | undefined;
@@ -163,3 +163,3 @@ SigningCertURL?: string | undefined;
     Sns: z.ZodObject<{
-        Subject: z.ZodOptional<z.ZodString>;
+        Subject: z.ZodOptional<z.ZodNullable<z.ZodString>>;
         TopicArn: z.ZodString;
@@ -193,3 +193,3 @@ UnsubscribeUrl: z.ZodString;
         Timestamp: string;
-        Subject?: string | undefined;
+        Subject?: string | null | undefined;
         UnsubscribeURL?: string | undefined;
@@ -211,3 +211,3 @@ SigningCertUrl?: string | undefined;
         Timestamp: string;
-        Subject?: string | undefined;
+        Subject?: string | null | undefined;
         UnsubscribeURL?: string | undefined;
@@ -234,3 +234,3 @@ SigningCertUrl?: string | undefined;
         Timestamp: string;
-        Subject?: string | undefined;
+        Subject?: string | null | undefined;
         UnsubscribeURL?: string | undefined;
@@ -257,3 +257,3 @@ SigningCertUrl?: string | undefined;
         Timestamp: string;
-        Subject?: string | undefined;
+        Subject?: string | null | undefined;
         UnsubscribeURL?: string | undefined;
@@ -317,3 +317,3 @@ SigningCertUrl?: string | undefined;
         Sns: z.ZodObject<{
-            Subject: z.ZodOptional<z.ZodString>;
+            Subject: z.ZodOptional<z.ZodNullable<z.ZodString>>;
             TopicArn: z.ZodString;
@@ -347,3 +347,3 @@ UnsubscribeUrl: z.ZodString;
             Timestamp: string;
-            Subject?: string | undefined;
+            Subject?: string | null | undefined;
             UnsubscribeURL?: string | undefined;
@@ -365,3 +365,3 @@ SigningCertUrl?: string | undefined;
             Timestamp: string;
-            Subject?: string | undefined;
+            Subject?: string | null | undefined;
             UnsubscribeURL?: string | undefined;
@@ -388,3 +388,3 @@ SigningCertUrl?: string | undefined;
             Timestamp: string;
-            Subject?: string | undefined;
+            Subject?: string | null | undefined;
             UnsubscribeURL?: string | undefined;
@@ -411,3 +411,3 @@ SigningCertUrl?: string | undefined;
             Timestamp: string;
-            Subject?: string | undefined;
+            Subject?: string | null | undefined;
             UnsubscribeURL?: string | undefined;
@@ -436,3 +436,3 @@ SigningCertUrl?: string | undefined;
             Timestamp: string;
-            Subject?: string | undefined;
+            Subject?: string | null | undefined;
             UnsubscribeURL?: string | undefined;
@@ -461,3 +461,3 @@ SigningCertUrl?: string | undefined;
             Timestamp: string;
-            Subject?: string | undefined;
+            Subject?: string | null | undefined;
             UnsubscribeURL?: string | undefined;
@@ -464,0 +464,0 @@ SigningCertUrl?: string | undefined;

lib/cjs/schemas/sns.js

@@ -13,3 +13,3 @@ "use strict";
 const SnsNotificationSchema = zod_1.z.object({
-    Subject: zod_1.z.string().optional(),
+    Subject: zod_1.z.string().nullish(),
     TopicArn: zod_1.z.string(),
@@ -16,0 +16,0 @@ UnsubscribeUrl: zod_1.z.string().url(),

lib/cjs/types/index.d.ts

 export type { ParserOptions, ParsedResult, ParsedResultSuccess, ParsedResultError, } from '../types/parser.js';
 export type { Envelope } from './envelope.js';
-export type { ALBEvent, APIGatewayProxyEvent, ALBMultiValueHeadersEvent, APIGatewayProxyEventV2, APIGatewayRequestContextV2, APIGatewayRequestAuthorizerV2, S3Event, S3EventNotificationEventBridge, S3SqsEventNotification, SnsEvent, SqsEvent, DynamoDBStreamEvent, CloudWatchLogsEvent, CloudFormationCustomResourceCreateEvent, CloudFormationCustomResourceDeleteEvent, CloudFormationCustomResourceUpdateEvent, EventBridgeEvent, KafkaSelfManagedEvent, KafkaMskEvent, KinesisDataStreamEvent, KinesisFireHoseEvent, KinesisFireHoseSqsEvent, LambdaFunctionUrlEvent, SesEvent, SnsSqsNotification, S3ObjectLambdaEvent, VpcLatticeEvent, VpcLatticeEventV2, } from './schema.js';
+export type { ALBEvent, APIGatewayProxyEvent, ALBMultiValueHeadersEvent, APIGatewayProxyEventV2, APIGatewayRequestContextV2, APIGatewayRequestAuthorizerV2, AppSyncResolverEvent, AppSyncBatchResolverEvent, S3Event, S3EventNotificationEventBridge, S3SqsEventNotification, SnsEvent, SqsEvent, DynamoDBStreamEvent, DynamoDBStreamToKinesisRecordEvent, CloudWatchLogsEvent, CloudFormationCustomResourceCreateEvent, CloudFormationCustomResourceDeleteEvent, CloudFormationCustomResourceUpdateEvent, EventBridgeEvent, KafkaSelfManagedEvent, KafkaMskEvent, KinesisDataStreamEvent, KinesisDynamoDBStreamEvent, KinesisFireHoseEvent, KinesisFireHoseSqsEvent, LambdaFunctionUrlEvent, SesEvent, SnsSqsNotification, S3ObjectLambdaEvent, VpcLatticeEvent, VpcLatticeEventV2, } from './schema.js';
 //# sourceMappingURL=index.d.ts.map

lib/cjs/types/schema.d.ts

 import type { z } from 'zod';
-import type { APIGatewayProxyEventSchema, APIGatewayProxyEventV2Schema, APIGatewayRequestAuthorizerV2Schema, APIGatewayRequestContextV2Schema, AlbMultiValueHeadersSchema, AlbSchema, CloudFormationCustomResourceCreateSchema, CloudFormationCustomResourceDeleteSchema, CloudFormationCustomResourceUpdateSchema, CloudWatchLogsSchema, DynamoDBStreamSchema, EventBridgeSchema, KafkaMskEventSchema, KafkaRecordSchema, KafkaSelfManagedEventSchema, KinesisDataStreamSchema, KinesisFirehoseRecordSchema, KinesisFirehoseSchema, KinesisFirehoseSqsRecordSchema, KinesisFirehoseSqsSchema, LambdaFunctionUrlSchema, S3EventNotificationEventBridgeSchema, S3ObjectLambdaEventSchema, S3Schema, S3SqsEventNotificationSchema, SesRecordSchema, SesSchema, SnsNotificationSchema, SnsRecordSchema, SnsSchema, SnsSqsNotificationSchema, SqsRecordSchema, SqsSchema, VpcLatticeSchema, VpcLatticeV2Schema } from '../schemas/index.js';
+import type { APIGatewayProxyEventSchema, APIGatewayProxyEventV2Schema, APIGatewayRequestAuthorizerV2Schema, APIGatewayRequestContextV2Schema, AlbMultiValueHeadersSchema, AlbSchema, AppSyncBatchResolverSchema, AppSyncResolverSchema, CloudFormationCustomResourceCreateSchema, CloudFormationCustomResourceDeleteSchema, CloudFormationCustomResourceUpdateSchema, CloudWatchLogsSchema, DynamoDBStreamSchema, DynamoDBStreamToKinesisRecord, EventBridgeSchema, KafkaMskEventSchema, KafkaRecordSchema, KafkaSelfManagedEventSchema, KinesisDataStreamSchema, KinesisDynamoDBStreamSchema, KinesisFirehoseRecordSchema, KinesisFirehoseSchema, KinesisFirehoseSqsRecordSchema, KinesisFirehoseSqsSchema, LambdaFunctionUrlSchema, S3EventNotificationEventBridgeSchema, S3ObjectLambdaEventSchema, S3Schema, S3SqsEventNotificationSchema, SesRecordSchema, SesSchema, SnsNotificationSchema, SnsRecordSchema, SnsSchema, SnsSqsNotificationSchema, SqsRecordSchema, SqsSchema, VpcLatticeSchema, VpcLatticeV2Schema } from '../schemas/index.js';
 type ALBEvent = z.infer<typeof AlbSchema>;
@@ -9,2 +9,4 @@ type ALBMultiValueHeadersEvent = z.infer<typeof AlbMultiValueHeadersSchema>;
 type APIGatewayRequestContextV2 = z.infer<typeof APIGatewayRequestContextV2Schema>;
+type AppSyncResolverEvent = z.infer<typeof AppSyncResolverSchema>;
+type AppSyncBatchResolverEvent = z.infer<typeof AppSyncBatchResolverSchema>;
 type CloudFormationCustomResourceCreateEvent = z.infer<typeof CloudFormationCustomResourceCreateSchema>;
@@ -15,2 +17,3 @@ type CloudFormationCustomResourceDeleteEvent = z.infer<typeof CloudFormationCustomResourceDeleteSchema>;
 type DynamoDBStreamEvent = z.infer<typeof DynamoDBStreamSchema>;
+type DynamoDBStreamToKinesisRecordEvent = z.infer<typeof DynamoDBStreamToKinesisRecord>;
 type EventBridgeEvent = z.infer<typeof EventBridgeSchema>;
@@ -21,2 +24,3 @@ type KafkaSelfManagedEvent = z.infer<typeof KafkaSelfManagedEventSchema>;
 type KinesisDataStreamEvent = z.infer<typeof KinesisDataStreamSchema>;
+type KinesisDynamoDBStreamEvent = z.infer<typeof KinesisDynamoDBStreamSchema>;
 type KinesisFireHoseEvent = z.infer<typeof KinesisFirehoseSchema>;
@@ -41,3 +45,3 @@ type KinesisFirehoseRecord = z.infer<typeof KinesisFirehoseRecordSchema>;
 type VpcLatticeEventV2 = z.infer<typeof VpcLatticeV2Schema>;
-export type { ALBEvent, ALBMultiValueHeadersEvent, APIGatewayProxyEvent, APIGatewayProxyEventV2, APIGatewayRequestAuthorizerV2, APIGatewayRequestContextV2, CloudFormationCustomResourceCreateEvent, CloudFormationCustomResourceDeleteEvent, CloudFormationCustomResourceUpdateEvent, CloudWatchLogsEvent, DynamoDBStreamEvent, EventBridgeEvent, KafkaSelfManagedEvent, KafkaMskEvent, KafkaRecord, KinesisDataStreamEvent, KinesisFireHoseEvent, KinesisFirehoseRecord, KinesisFireHoseSqsEvent, KinesisFirehoseSqsRecord, LambdaFunctionUrlEvent, S3Event, S3EventNotificationEventBridge, S3SqsEventNotification, S3ObjectLambdaEvent, SesEvent, SesRecord, SnsEvent, SnsSqsNotification, SnsNotification, SnsRecord, SqsEvent, SqsRecord, VpcLatticeEvent, VpcLatticeEventV2, };
+export type { ALBEvent, ALBMultiValueHeadersEvent, APIGatewayProxyEvent, APIGatewayProxyEventV2, APIGatewayRequestAuthorizerV2, APIGatewayRequestContextV2, AppSyncResolverEvent, AppSyncBatchResolverEvent, CloudFormationCustomResourceCreateEvent, CloudFormationCustomResourceDeleteEvent, CloudFormationCustomResourceUpdateEvent, CloudWatchLogsEvent, DynamoDBStreamEvent, DynamoDBStreamToKinesisRecordEvent, EventBridgeEvent, KafkaSelfManagedEvent, KafkaMskEvent, KafkaRecord, KinesisDataStreamEvent, KinesisDynamoDBStreamEvent, KinesisFireHoseEvent, KinesisFirehoseRecord, KinesisFireHoseSqsEvent, KinesisFirehoseSqsRecord, LambdaFunctionUrlEvent, S3Event, S3EventNotificationEventBridge, S3SqsEventNotification, S3ObjectLambdaEvent, SesEvent, SesRecord, SnsEvent, SnsSqsNotification, SnsNotification, SnsRecord, SqsEvent, SqsRecord, VpcLatticeEvent, VpcLatticeEventV2, };
 //# sourceMappingURL=schema.d.ts.map

lib/esm/envelopes/envelope.d.ts

@@ -19,3 +19,3 @@ import type { ZodSchema, z } from 'zod';
      */
-    safeParse<T extends ZodSchema>(input: unknown, schema: T): ParsedResult;
+    safeParse<T extends ZodSchema>(input: unknown, schema: T): ParsedResult<unknown, z.infer<T>>;
 };
@@ -22,0 +22,0 @@ /**

lib/esm/envelopes/event-bridge.d.ts

@@ -14,4 +14,4 @@ import type { ZodSchema, z } from 'zod';
     parse<T extends ZodSchema>(data: unknown, schema: T): z.infer<T>;
-    safeParse<T extends ZodSchema>(data: unknown, schema: T): ParsedResult;
+    safeParse<T extends ZodSchema>(data: unknown, schema: T): ParsedResult<unknown, z.infer<T>>;
 };
 //# sourceMappingURL=event-bridge.d.ts.map

lib/esm/envelopes/lambda.d.ts

@@ -14,4 +14,4 @@ import type { ZodSchema, z } from 'zod';
     parse<T extends ZodSchema>(data: unknown, schema: T): z.infer<T>;
-    safeParse<T extends ZodSchema>(data: unknown, schema: T): ParsedResult;
+    safeParse<T extends ZodSchema>(data: unknown, schema: T): ParsedResult<unknown, z.infer<T>>;
 };
 //# sourceMappingURL=lambda.d.ts.map

lib/esm/envelopes/vpc-lattice.d.ts

@@ -14,4 +14,4 @@ import type { ZodSchema, z } from 'zod';
     parse<T extends ZodSchema>(data: unknown, schema: T): z.infer<T>;
-    safeParse<T extends ZodSchema>(data: unknown, schema: T): ParsedResult;
+    safeParse<T extends ZodSchema>(data: unknown, schema: T): ParsedResult<unknown, z.infer<T>>;
 };
 //# sourceMappingURL=vpc-lattice.d.ts.map

lib/esm/envelopes/vpc-latticev2.d.ts

@@ -14,4 +14,4 @@ import type { ZodSchema, z } from 'zod';
     parse<T extends ZodSchema>(data: unknown, schema: T): z.infer<T>;
-    safeParse<T extends ZodSchema>(data: unknown, schema: T): ParsedResult;
+    safeParse<T extends ZodSchema>(data: unknown, schema: T): ParsedResult<unknown, z.infer<T>>;
 };
 //# sourceMappingURL=vpc-latticev2.d.ts.map

lib/esm/schemas/dynamodb.d.ts

@@ -120,2 +120,115 @@ import { z } from 'zod';
 }>;
+declare const DynamoDBStreamToKinesisRecord: z.ZodObject<Omit<z.objectUtil.extendShape<{
+    eventID: z.ZodString;
+    eventName: z.ZodEnum<["INSERT", "MODIFY", "REMOVE"]>;
+    eventVersion: z.ZodString;
+    eventSource: z.ZodLiteral<"aws:dynamodb">;
+    awsRegion: z.ZodString;
+    eventSourceARN: z.ZodString;
+    dynamodb: z.ZodObject<{
+        ApproximateCreationDateTime: z.ZodOptional<z.ZodNumber>;
+        Keys: z.ZodRecord<z.ZodString, z.ZodRecord<z.ZodString, z.ZodAny>>;
+        NewImage: z.ZodOptional<z.ZodRecord<z.ZodString, z.ZodAny>>;
+        OldImage: z.ZodOptional<z.ZodRecord<z.ZodString, z.ZodAny>>;
+        SequenceNumber: z.ZodString;
+        SizeBytes: z.ZodNumber;
+        StreamViewType: z.ZodEnum<["NEW_IMAGE", "OLD_IMAGE", "NEW_AND_OLD_IMAGES", "KEYS_ONLY"]>;
+    }, "strip", z.ZodTypeAny, {
+        Keys: Record<string, Record<string, any>>;
+        SequenceNumber: string;
+        SizeBytes: number;
+        StreamViewType: "NEW_IMAGE" | "OLD_IMAGE" | "NEW_AND_OLD_IMAGES" | "KEYS_ONLY";
+        ApproximateCreationDateTime?: number | undefined;
+        NewImage?: Record<string, any> | undefined;
+        OldImage?: Record<string, any> | undefined;
+    }, {
+        Keys: Record<string, Record<string, any>>;
+        SequenceNumber: string;
+        SizeBytes: number;
+        StreamViewType: "NEW_IMAGE" | "OLD_IMAGE" | "NEW_AND_OLD_IMAGES" | "KEYS_ONLY";
+        ApproximateCreationDateTime?: number | undefined;
+        NewImage?: Record<string, any> | undefined;
+        OldImage?: Record<string, any> | undefined;
+    }>;
+    userIdentity: z.ZodOptional<z.ZodObject<{
+        type: z.ZodEnum<["Service"]>;
+        principalId: z.ZodLiteral<"dynamodb.amazonaws.com">;
+    }, "strip", z.ZodTypeAny, {
+        type: "Service";
+        principalId: "dynamodb.amazonaws.com";
+    }, {
+        type: "Service";
+        principalId: "dynamodb.amazonaws.com";
+    }>>;
+}, {
+    recordFormat: z.ZodLiteral<"application/json">;
+    tableName: z.ZodString;
+    userIdentity: z.ZodOptional<z.ZodNullable<z.ZodObject<{
+        type: z.ZodEnum<["Service"]>;
+        principalId: z.ZodLiteral<"dynamodb.amazonaws.com">;
+    }, "strip", z.ZodTypeAny, {
+        type: "Service";
+        principalId: "dynamodb.amazonaws.com";
+    }, {
+        type: "Service";
+        principalId: "dynamodb.amazonaws.com";
+    }>>>;
+    dynamodb: z.ZodObject<Omit<{
+        ApproximateCreationDateTime: z.ZodOptional<z.ZodNumber>;
+        Keys: z.ZodRecord<z.ZodString, z.ZodRecord<z.ZodString, z.ZodAny>>;
+        NewImage: z.ZodOptional<z.ZodRecord<z.ZodString, z.ZodAny>>;
+        OldImage: z.ZodOptional<z.ZodRecord<z.ZodString, z.ZodAny>>;
+        SequenceNumber: z.ZodString;
+        SizeBytes: z.ZodNumber;
+        StreamViewType: z.ZodEnum<["NEW_IMAGE", "OLD_IMAGE", "NEW_AND_OLD_IMAGES", "KEYS_ONLY"]>;
+    }, "SequenceNumber" | "StreamViewType">, "strip", z.ZodTypeAny, {
+        Keys: Record<string, Record<string, any>>;
+        SizeBytes: number;
+        ApproximateCreationDateTime?: number | undefined;
+        NewImage?: Record<string, any> | undefined;
+        OldImage?: Record<string, any> | undefined;
+    }, {
+        Keys: Record<string, Record<string, any>>;
+        SizeBytes: number;
+        ApproximateCreationDateTime?: number | undefined;
+        NewImage?: Record<string, any> | undefined;
+        OldImage?: Record<string, any> | undefined;
+    }>;
+}>, "eventVersion" | "eventSourceARN">, "strip", z.ZodTypeAny, {
+    eventID: string;
+    eventName: "INSERT" | "MODIFY" | "REMOVE";
+    eventSource: "aws:dynamodb";
+    awsRegion: string;
+    dynamodb: {
+        Keys: Record<string, Record<string, any>>;
+        SizeBytes: number;
+        ApproximateCreationDateTime?: number | undefined;
+        NewImage?: Record<string, any> | undefined;
+        OldImage?: Record<string, any> | undefined;
+    };
+    recordFormat: "application/json";
+    tableName: string;
+    userIdentity?: {
+        type: "Service";
+        principalId: "dynamodb.amazonaws.com";
+    } | null | undefined;
+}, {
+    eventID: string;
+    eventName: "INSERT" | "MODIFY" | "REMOVE";
+    eventSource: "aws:dynamodb";
+    awsRegion: string;
+    dynamodb: {
+        Keys: Record<string, Record<string, any>>;
+        SizeBytes: number;
+        ApproximateCreationDateTime?: number | undefined;
+        NewImage?: Record<string, any> | undefined;
+        OldImage?: Record<string, any> | undefined;
+    };
+    recordFormat: "application/json";
+    tableName: string;
+    userIdentity?: {
+        type: "Service";
+        principalId: "dynamodb.amazonaws.com";
+    } | null | undefined;
+}>;
 /**
@@ -325,3 +438,3 @@ * Zod schema for Amazon DynamoDB Stream event.
 }>;
-export { DynamoDBStreamSchema, DynamoDBStreamRecord, DynamoDBStreamChangeRecord, UserIdentity, };
+export { DynamoDBStreamToKinesisRecord, DynamoDBStreamSchema, DynamoDBStreamRecord, DynamoDBStreamChangeRecord, UserIdentity, };
 //# sourceMappingURL=dynamodb.d.ts.map

lib/esm/schemas/dynamodb.js

@@ -30,2 +30,14 @@ import { z } from 'zod';
 });
+const DynamoDBStreamToKinesisRecord = DynamoDBStreamRecord.extend({
+    recordFormat: z.literal('application/json'),
+    tableName: z.string(),
+    userIdentity: UserIdentity.nullish(),
+    dynamodb: DynamoDBStreamChangeRecord.omit({
+        SequenceNumber: true,
+        StreamViewType: true,
+    }),
+}).omit({
+    eventVersion: true,
+    eventSourceARN: true,
+});
 /**
@@ -109,2 +121,2 @@ * Zod schema for Amazon DynamoDB Stream event.
 });
-export { DynamoDBStreamSchema, DynamoDBStreamRecord, DynamoDBStreamChangeRecord, UserIdentity, };
+export { DynamoDBStreamToKinesisRecord, DynamoDBStreamSchema, DynamoDBStreamRecord, DynamoDBStreamChangeRecord, UserIdentity, };

lib/esm/schemas/eventbridge.d.ts

@@ -42,5 +42,5 @@ import { z } from 'zod';
     time: string;
+    source: string;
     version: string;
     id: string;
-    source: string;
     account: string;
@@ -54,5 +54,5 @@ region: string;
     time: string;
+    source: string;
     version: string;
     id: string;
-    source: string;
     account: string;
@@ -59,0 +59,0 @@ region: string;

lib/esm/schemas/index.d.ts

 export { AlbSchema, AlbMultiValueHeadersSchema } from './alb.js';
 export { APIGatewayProxyEventSchema, APIGatewayRequestAuthorizerEventSchema, APIGatewayTokenAuthorizerEventSchema, } from './apigw.js';
+export { AppSyncResolverSchema, AppSyncBatchResolverSchema, } from './appsync.js';
 export { APIGatewayProxyEventV2Schema, APIGatewayRequestAuthorizerEventV2Schema, APIGatewayRequestAuthorizerV2Schema, APIGatewayRequestContextV2Schema, } from './apigwv2.js';
 export { CloudFormationCustomResourceCreateSchema, CloudFormationCustomResourceDeleteSchema, CloudFormationCustomResourceUpdateSchema, } from './cloudformation-custom-resource.js';
 export { CloudWatchLogEventSchema, CloudWatchLogsDecodeSchema, CloudWatchLogsSchema, } from './cloudwatch.js';
-export { DynamoDBStreamSchema } from './dynamodb.js';
+export { DynamoDBStreamSchema, DynamoDBStreamToKinesisRecord, } from './dynamodb.js';
 export { EventBridgeSchema } from './eventbridge.js';
 export { KafkaMskEventSchema, KafkaSelfManagedEventSchema, KafkaRecordSchema, } from './kafka.js';
-export { KinesisDataStreamSchema, KinesisDataStreamRecord } from './kinesis.js';
+export { KinesisDataStreamSchema, KinesisDynamoDBStreamSchema, KinesisDataStreamRecord, } from './kinesis.js';
 export { KinesisFirehoseSchema, KinesisFirehoseSqsSchema, KinesisFirehoseRecordSchema, KinesisFirehoseSqsRecordSchema, } from './kinesis-firehose.js';
@@ -11,0 +12,0 @@ export { LambdaFunctionUrlSchema } from './lambda.js';

lib/esm/schemas/index.js

 export { AlbSchema, AlbMultiValueHeadersSchema } from './alb.js';
 export { APIGatewayProxyEventSchema, APIGatewayRequestAuthorizerEventSchema, APIGatewayTokenAuthorizerEventSchema, } from './apigw.js';
+export { AppSyncResolverSchema, AppSyncBatchResolverSchema, } from './appsync.js';
 export { APIGatewayProxyEventV2Schema, APIGatewayRequestAuthorizerEventV2Schema, APIGatewayRequestAuthorizerV2Schema, APIGatewayRequestContextV2Schema, } from './apigwv2.js';
 export { CloudFormationCustomResourceCreateSchema, CloudFormationCustomResourceDeleteSchema, CloudFormationCustomResourceUpdateSchema, } from './cloudformation-custom-resource.js';
 export { CloudWatchLogEventSchema, CloudWatchLogsDecodeSchema, CloudWatchLogsSchema, } from './cloudwatch.js';
-export { DynamoDBStreamSchema } from './dynamodb.js';
+export { DynamoDBStreamSchema, DynamoDBStreamToKinesisRecord, } from './dynamodb.js';
 export { EventBridgeSchema } from './eventbridge.js';
 export { KafkaMskEventSchema, KafkaSelfManagedEventSchema, KafkaRecordSchema, } from './kafka.js';
-export { KinesisDataStreamSchema, KinesisDataStreamRecord } from './kinesis.js';
+export { KinesisDataStreamSchema, KinesisDynamoDBStreamSchema, KinesisDataStreamRecord, } from './kinesis.js';
 export { KinesisFirehoseSchema, KinesisFirehoseSqsSchema, KinesisFirehoseRecordSchema, KinesisFirehoseSqsRecordSchema, } from './kinesis-firehose.js';
@@ -11,0 +12,0 @@ export { LambdaFunctionUrlSchema } from './lambda.js';

lib/esm/schemas/kinesis.d.ts

@@ -79,2 +79,284 @@ import { z } from 'zod';
 }>;
+declare const KinesisDynamoDBStreamSchema: z.ZodObject<{
+    Records: z.ZodArray<z.ZodObject<z.objectUtil.extendShape<{
+        eventSource: z.ZodLiteral<"aws:kinesis">;
+        eventVersion: z.ZodString;
+        eventID: z.ZodString;
+        eventName: z.ZodLiteral<"aws:kinesis:record">;
+        awsRegion: z.ZodString;
+        invokeIdentityArn: z.ZodString;
+        eventSourceARN: z.ZodString;
+        kinesis: z.ZodObject<{
+            kinesisSchemaVersion: z.ZodString;
+            partitionKey: z.ZodString;
+            sequenceNumber: z.ZodString;
+            approximateArrivalTimestamp: z.ZodNumber;
+            data: z.ZodEffects<z.ZodString, any, string>;
+        }, "strip", z.ZodTypeAny, {
+            kinesisSchemaVersion: string;
+            partitionKey: string;
+            sequenceNumber: string;
+            approximateArrivalTimestamp: number;
+            data?: any;
+        }, {
+            data: string;
+            kinesisSchemaVersion: string;
+            partitionKey: string;
+            sequenceNumber: string;
+            approximateArrivalTimestamp: number;
+        }>;
+    }, {
+        kinesis: z.ZodObject<z.objectUtil.extendShape<{
+            kinesisSchemaVersion: z.ZodString;
+            partitionKey: z.ZodString;
+            sequenceNumber: z.ZodString;
+            approximateArrivalTimestamp: z.ZodNumber;
+            data: z.ZodEffects<z.ZodString, any, string>;
+        }, {
+            data: z.ZodPipeline<z.ZodEffects<z.ZodString, any, string>, z.ZodObject<Omit<z.objectUtil.extendShape<{
+                eventID: z.ZodString;
+                eventName: z.ZodEnum<["INSERT", "MODIFY", "REMOVE"]>;
+                eventVersion: z.ZodString;
+                eventSource: z.ZodLiteral<"aws:dynamodb">;
+                awsRegion: z.ZodString;
+                eventSourceARN: z.ZodString;
+                dynamodb: z.ZodObject<{
+                    ApproximateCreationDateTime: z.ZodOptional<z.ZodNumber>;
+                    Keys: z.ZodRecord<z.ZodString, z.ZodRecord<z.ZodString, z.ZodAny>>;
+                    NewImage: z.ZodOptional<z.ZodRecord<z.ZodString, z.ZodAny>>;
+                    OldImage: z.ZodOptional<z.ZodRecord<z.ZodString, z.ZodAny>>;
+                    SequenceNumber: z.ZodString;
+                    SizeBytes: z.ZodNumber;
+                    StreamViewType: z.ZodEnum<["NEW_IMAGE", "OLD_IMAGE", "NEW_AND_OLD_IMAGES", "KEYS_ONLY"]>;
+                }, "strip", z.ZodTypeAny, {
+                    Keys: Record<string, Record<string, any>>;
+                    SequenceNumber: string;
+                    SizeBytes: number;
+                    StreamViewType: "NEW_IMAGE" | "OLD_IMAGE" | "NEW_AND_OLD_IMAGES" | "KEYS_ONLY";
+                    ApproximateCreationDateTime?: number | undefined;
+                    NewImage?: Record<string, any> | undefined;
+                    OldImage?: Record<string, any> | undefined;
+                }, {
+                    Keys: Record<string, Record<string, any>>;
+                    SequenceNumber: string;
+                    SizeBytes: number;
+                    StreamViewType: "NEW_IMAGE" | "OLD_IMAGE" | "NEW_AND_OLD_IMAGES" | "KEYS_ONLY";
+                    ApproximateCreationDateTime?: number | undefined;
+                    NewImage?: Record<string, any> | undefined;
+                    OldImage?: Record<string, any> | undefined;
+                }>;
+                userIdentity: z.ZodOptional<z.ZodObject<{
+                    type: z.ZodEnum<["Service"]>;
+                    principalId: z.ZodLiteral<"dynamodb.amazonaws.com">;
+                }, "strip", z.ZodTypeAny, {
+                    type: "Service";
+                    principalId: "dynamodb.amazonaws.com";
+                }, {
+                    type: "Service";
+                    principalId: "dynamodb.amazonaws.com";
+                }>>;
+            }, {
+                recordFormat: z.ZodLiteral<"application/json">;
+                tableName: z.ZodString;
+                userIdentity: z.ZodOptional<z.ZodNullable<z.ZodObject<{
+                    type: z.ZodEnum<["Service"]>;
+                    principalId: z.ZodLiteral<"dynamodb.amazonaws.com">;
+                }, "strip", z.ZodTypeAny, {
+                    type: "Service";
+                    principalId: "dynamodb.amazonaws.com";
+                }, {
+                    type: "Service";
+                    principalId: "dynamodb.amazonaws.com";
+                }>>>;
+                dynamodb: z.ZodObject<Omit<{
+                    ApproximateCreationDateTime: z.ZodOptional<z.ZodNumber>;
+                    Keys: z.ZodRecord<z.ZodString, z.ZodRecord<z.ZodString, z.ZodAny>>;
+                    NewImage: z.ZodOptional<z.ZodRecord<z.ZodString, z.ZodAny>>;
+                    OldImage: z.ZodOptional<z.ZodRecord<z.ZodString, z.ZodAny>>;
+                    SequenceNumber: z.ZodString;
+                    SizeBytes: z.ZodNumber;
+                    StreamViewType: z.ZodEnum<["NEW_IMAGE", "OLD_IMAGE", "NEW_AND_OLD_IMAGES", "KEYS_ONLY"]>;
+                }, "SequenceNumber" | "StreamViewType">, "strip", z.ZodTypeAny, {
+                    Keys: Record<string, Record<string, any>>;
+                    SizeBytes: number;
+                    ApproximateCreationDateTime?: number | undefined;
+                    NewImage?: Record<string, any> | undefined;
+                    OldImage?: Record<string, any> | undefined;
+                }, {
+                    Keys: Record<string, Record<string, any>>;
+                    SizeBytes: number;
+                    ApproximateCreationDateTime?: number | undefined;
+                    NewImage?: Record<string, any> | undefined;
+                    OldImage?: Record<string, any> | undefined;
+                }>;
+            }>, "eventVersion" | "eventSourceARN">, "strip", z.ZodTypeAny, {
+                eventID: string;
+                eventName: "INSERT" | "MODIFY" | "REMOVE";
+                eventSource: "aws:dynamodb";
+                awsRegion: string;
+                dynamodb: {
+                    Keys: Record<string, Record<string, any>>;
+                    SizeBytes: number;
+                    ApproximateCreationDateTime?: number | undefined;
+                    NewImage?: Record<string, any> | undefined;
+                    OldImage?: Record<string, any> | undefined;
+                };
+                recordFormat: "application/json";
+                tableName: string;
+                userIdentity?: {
+                    type: "Service";
+                    principalId: "dynamodb.amazonaws.com";
+                } | null | undefined;
+            }, {
+                eventID: string;
+                eventName: "INSERT" | "MODIFY" | "REMOVE";
+                eventSource: "aws:dynamodb";
+                awsRegion: string;
+                dynamodb: {
+                    Keys: Record<string, Record<string, any>>;
+                    SizeBytes: number;
+                    ApproximateCreationDateTime?: number | undefined;
+                    NewImage?: Record<string, any> | undefined;
+                    OldImage?: Record<string, any> | undefined;
+                };
+                recordFormat: "application/json";
+                tableName: string;
+                userIdentity?: {
+                    type: "Service";
+                    principalId: "dynamodb.amazonaws.com";
+                } | null | undefined;
+            }>>;
+        }>, "strip", z.ZodTypeAny, {
+            data: {
+                eventID: string;
+                eventName: "INSERT" | "MODIFY" | "REMOVE";
+                eventSource: "aws:dynamodb";
+                awsRegion: string;
+                dynamodb: {
+                    Keys: Record<string, Record<string, any>>;
+                    SizeBytes: number;
+                    ApproximateCreationDateTime?: number | undefined;
+                    NewImage?: Record<string, any> | undefined;
+                    OldImage?: Record<string, any> | undefined;
+                };
+                recordFormat: "application/json";
+                tableName: string;
+                userIdentity?: {
+                    type: "Service";
+                    principalId: "dynamodb.amazonaws.com";
+                } | null | undefined;
+            };
+            kinesisSchemaVersion: string;
+            partitionKey: string;
+            sequenceNumber: string;
+            approximateArrivalTimestamp: number;
+        }, {
+            data: string;
+            kinesisSchemaVersion: string;
+            partitionKey: string;
+            sequenceNumber: string;
+            approximateArrivalTimestamp: number;
+        }>;
+    }>, "strip", z.ZodTypeAny, {
+        eventID: string;
+        eventName: "aws:kinesis:record";
+        eventVersion: string;
+        eventSource: "aws:kinesis";
+        awsRegion: string;
+        eventSourceARN: string;
+        invokeIdentityArn: string;
+        kinesis: {
+            data: {
+                eventID: string;
+                eventName: "INSERT" | "MODIFY" | "REMOVE";
+                eventSource: "aws:dynamodb";
+                awsRegion: string;
+                dynamodb: {
+                    Keys: Record<string, Record<string, any>>;
+                    SizeBytes: number;
+                    ApproximateCreationDateTime?: number | undefined;
+                    NewImage?: Record<string, any> | undefined;
+                    OldImage?: Record<string, any> | undefined;
+                };
+                recordFormat: "application/json";
+                tableName: string;
+                userIdentity?: {
+                    type: "Service";
+                    principalId: "dynamodb.amazonaws.com";
+                } | null | undefined;
+            };
+            kinesisSchemaVersion: string;
+            partitionKey: string;
+            sequenceNumber: string;
+            approximateArrivalTimestamp: number;
+        };
+    }, {
+        eventID: string;
+        eventName: "aws:kinesis:record";
+        eventVersion: string;
+        eventSource: "aws:kinesis";
+        awsRegion: string;
+        eventSourceARN: string;
+        invokeIdentityArn: string;
+        kinesis: {
+            data: string;
+            kinesisSchemaVersion: string;
+            partitionKey: string;
+            sequenceNumber: string;
+            approximateArrivalTimestamp: number;
+        };
+    }>, "many">;
+}, "strip", z.ZodTypeAny, {
+    Records: {
+        eventID: string;
+        eventName: "aws:kinesis:record";
+        eventVersion: string;
+        eventSource: "aws:kinesis";
+        awsRegion: string;
+        eventSourceARN: string;
+        invokeIdentityArn: string;
+        kinesis: {
+            data: {
+                eventID: string;
+                eventName: "INSERT" | "MODIFY" | "REMOVE";
+                eventSource: "aws:dynamodb";
+                awsRegion: string;
+                dynamodb: {
+                    Keys: Record<string, Record<string, any>>;
+                    SizeBytes: number;
+                    ApproximateCreationDateTime?: number | undefined;
+                    NewImage?: Record<string, any> | undefined;
+                    OldImage?: Record<string, any> | undefined;
+                };
+                recordFormat: "application/json";
+                tableName: string;
+                userIdentity?: {
+                    type: "Service";
+                    principalId: "dynamodb.amazonaws.com";
+                } | null | undefined;
+            };
+            kinesisSchemaVersion: string;
+            partitionKey: string;
+            sequenceNumber: string;
+            approximateArrivalTimestamp: number;
+        };
+    }[];
+}, {
+    Records: {
+        eventID: string;
+        eventName: "aws:kinesis:record";
+        eventVersion: string;
+        eventSource: "aws:kinesis";
+        awsRegion: string;
+        eventSourceARN: string;
+        invokeIdentityArn: string;
+        kinesis: {
+            data: string;
+            kinesisSchemaVersion: string;
+            partitionKey: string;
+            sequenceNumber: string;
+            approximateArrivalTimestamp: number;
+        };
+    }[];
+}>;
 /**
@@ -220,3 +502,3 @@ * Zod schema for Kinesis Data Stream event
 }>;
-export { KinesisDataStreamSchema, KinesisDataStreamRecord, KinesisDataStreamRecordPayload, };
+export { KinesisDataStreamRecord, KinesisDataStreamRecordPayload, KinesisDataStreamSchema, KinesisDynamoDBStreamSchema, };
 //# sourceMappingURL=kinesis.d.ts.map

lib/esm/schemas/kinesis.js

 import { gunzipSync } from 'node:zlib';
 import { z } from 'zod';
+import { DynamoDBStreamToKinesisRecord } from './dynamodb.js';
 const KinesisDataStreamRecordPayload = z.object({
@@ -9,7 +10,7 @@ kinesisSchemaVersion: z.string(),
     data: z.string().transform((data) => {
-        const decompresed = decompress(data);
+        const decompressed = decompress(data);
         const decoded = Buffer.from(data, 'base64').toString('utf-8');
         try {
             // If data was not compressed, try to parse it as JSON otherwise it must be string
-            return decompresed === data ? JSON.parse(decoded) : decompresed;
+            return decompressed === data ? JSON.parse(decoded) : decompressed;
         }
@@ -39,2 +40,14 @@ catch (e) {
 });
+const KinesisDynamoDBStreamSchema = z.object({
+    Records: z.array(KinesisDataStreamRecord.extend({
+        kinesis: KinesisDataStreamRecordPayload.extend({
+            data: z
+                .string()
+                .transform((data) => {
+                return JSON.parse(Buffer.from(data, 'base64').toString('utf8'));
+            })
+                .pipe(DynamoDBStreamToKinesisRecord),
+        }),
+    })),
+});
 /**
@@ -89,2 +102,2 @@ * Zod schema for Kinesis Data Stream event
 });
-export { KinesisDataStreamSchema, KinesisDataStreamRecord, KinesisDataStreamRecordPayload, };
+export { KinesisDataStreamRecord, KinesisDataStreamRecordPayload, KinesisDataStreamSchema, KinesisDynamoDBStreamSchema, };

lib/esm/schemas/s3.d.ts

@@ -134,5 +134,5 @@ import { z } from 'zod';
     time: string;
+    source: string;
     version: string;
     id: string;
-    source: string;
     account: string;
@@ -167,5 +167,5 @@ region: string;
     time: string;
+    source: string;
     version: string;
     id: string;
-    source: string;
     account: string;
@@ -172,0 +172,0 @@ region: string;

lib/esm/schemas/ses.d.ts

@@ -65,4 +65,4 @@ import { z } from 'zod';
             messageId: string;
+            source: string;
             timestamp: string;
-            source: string;
             destination: string[];
@@ -88,4 +88,4 @@ headersTruncated: boolean;
             messageId: string;
+            source: string;
             timestamp: string;
-            source: string;
             destination: string[];
@@ -217,4 +217,4 @@ headersTruncated: boolean;
             messageId: string;
+            source: string;
             timestamp: string;
-            source: string;
             destination: string[];
@@ -268,4 +268,4 @@ headersTruncated: boolean;
             messageId: string;
+            source: string;
             timestamp: string;
-            source: string;
             destination: string[];
@@ -323,4 +323,4 @@ headersTruncated: boolean;
             messageId: string;
+            source: string;
             timestamp: string;
-            source: string;
             destination: string[];
@@ -378,4 +378,4 @@ headersTruncated: boolean;
             messageId: string;
+            source: string;
             timestamp: string;
-            source: string;
             destination: string[];
@@ -596,4 +596,4 @@ headersTruncated: boolean;
                 messageId: string;
+                source: string;
                 timestamp: string;
-                source: string;
                 destination: string[];
@@ -619,4 +619,4 @@ headersTruncated: boolean;
                 messageId: string;
+                source: string;
                 timestamp: string;
-                source: string;
                 destination: string[];
@@ -748,4 +748,4 @@ headersTruncated: boolean;
                 messageId: string;
+                source: string;
                 timestamp: string;
-                source: string;
                 destination: string[];
@@ -799,4 +799,4 @@ headersTruncated: boolean;
                 messageId: string;
+                source: string;
                 timestamp: string;
-                source: string;
                 destination: string[];
@@ -854,4 +854,4 @@ headersTruncated: boolean;
                 messageId: string;
+                source: string;
                 timestamp: string;
-                source: string;
                 destination: string[];
@@ -909,4 +909,4 @@ headersTruncated: boolean;
                 messageId: string;
+                source: string;
                 timestamp: string;
-                source: string;
                 destination: string[];
@@ -966,4 +966,4 @@ headersTruncated: boolean;
                 messageId: string;
+                source: string;
                 timestamp: string;
-                source: string;
                 destination: string[];
@@ -1023,4 +1023,4 @@ headersTruncated: boolean;
                 messageId: string;
+                source: string;
                 timestamp: string;
-                source: string;
                 destination: string[];
@@ -1027,0 +1027,0 @@ headersTruncated: boolean;

lib/esm/schemas/sns.d.ts

@@ -6,3 +6,3 @@ import { z } from 'zod';
 declare const SnsNotificationSchema: z.ZodObject<{
-    Subject: z.ZodOptional<z.ZodString>;
+    Subject: z.ZodOptional<z.ZodNullable<z.ZodString>>;
     TopicArn: z.ZodString;
@@ -36,3 +36,3 @@ UnsubscribeUrl: z.ZodString;
     Timestamp: string;
-    Subject?: string | undefined;
+    Subject?: string | null | undefined;
     UnsubscribeURL?: string | undefined;
@@ -54,3 +54,3 @@ SigningCertUrl?: string | undefined;
     Timestamp: string;
-    Subject?: string | undefined;
+    Subject?: string | null | undefined;
     UnsubscribeURL?: string | undefined;
@@ -96,3 +96,3 @@ SigningCertUrl?: string | undefined;
 declare const SnsSqsNotificationSchema: z.ZodObject<Omit<z.objectUtil.extendShape<{
-    Subject: z.ZodOptional<z.ZodString>;
+    Subject: z.ZodOptional<z.ZodNullable<z.ZodString>>;
     TopicArn: z.ZodString;
@@ -128,3 +128,3 @@ UnsubscribeUrl: z.ZodString;
     Timestamp: string;
-    Subject?: string | undefined;
+    Subject?: string | null | undefined;
     UnsubscribeURL?: string | undefined;
@@ -144,3 +144,3 @@ SigningCertURL?: string | undefined;
     Timestamp: string;
-    Subject?: string | undefined;
+    Subject?: string | null | undefined;
     UnsubscribeURL?: string | undefined;
@@ -163,3 +163,3 @@ SigningCertURL?: string | undefined;
     Sns: z.ZodObject<{
-        Subject: z.ZodOptional<z.ZodString>;
+        Subject: z.ZodOptional<z.ZodNullable<z.ZodString>>;
         TopicArn: z.ZodString;
@@ -193,3 +193,3 @@ UnsubscribeUrl: z.ZodString;
         Timestamp: string;
-        Subject?: string | undefined;
+        Subject?: string | null | undefined;
         UnsubscribeURL?: string | undefined;
@@ -211,3 +211,3 @@ SigningCertUrl?: string | undefined;
         Timestamp: string;
-        Subject?: string | undefined;
+        Subject?: string | null | undefined;
         UnsubscribeURL?: string | undefined;
@@ -234,3 +234,3 @@ SigningCertUrl?: string | undefined;
         Timestamp: string;
-        Subject?: string | undefined;
+        Subject?: string | null | undefined;
         UnsubscribeURL?: string | undefined;
@@ -257,3 +257,3 @@ SigningCertUrl?: string | undefined;
         Timestamp: string;
-        Subject?: string | undefined;
+        Subject?: string | null | undefined;
         UnsubscribeURL?: string | undefined;
@@ -317,3 +317,3 @@ SigningCertUrl?: string | undefined;
         Sns: z.ZodObject<{
-            Subject: z.ZodOptional<z.ZodString>;
+            Subject: z.ZodOptional<z.ZodNullable<z.ZodString>>;
             TopicArn: z.ZodString;
@@ -347,3 +347,3 @@ UnsubscribeUrl: z.ZodString;
             Timestamp: string;
-            Subject?: string | undefined;
+            Subject?: string | null | undefined;
             UnsubscribeURL?: string | undefined;
@@ -365,3 +365,3 @@ SigningCertUrl?: string | undefined;
             Timestamp: string;
-            Subject?: string | undefined;
+            Subject?: string | null | undefined;
             UnsubscribeURL?: string | undefined;
@@ -388,3 +388,3 @@ SigningCertUrl?: string | undefined;
             Timestamp: string;
-            Subject?: string | undefined;
+            Subject?: string | null | undefined;
             UnsubscribeURL?: string | undefined;
@@ -411,3 +411,3 @@ SigningCertUrl?: string | undefined;
             Timestamp: string;
-            Subject?: string | undefined;
+            Subject?: string | null | undefined;
             UnsubscribeURL?: string | undefined;
@@ -436,3 +436,3 @@ SigningCertUrl?: string | undefined;
             Timestamp: string;
-            Subject?: string | undefined;
+            Subject?: string | null | undefined;
             UnsubscribeURL?: string | undefined;
@@ -461,3 +461,3 @@ SigningCertUrl?: string | undefined;
             Timestamp: string;
-            Subject?: string | undefined;
+            Subject?: string | null | undefined;
             UnsubscribeURL?: string | undefined;
@@ -464,0 +464,0 @@ SigningCertUrl?: string | undefined;

lib/esm/schemas/sns.js

@@ -10,3 +10,3 @@ import { z } from 'zod';
 const SnsNotificationSchema = z.object({
-    Subject: z.string().optional(),
+    Subject: z.string().nullish(),
     TopicArn: z.string(),
@@ -13,0 +13,0 @@ UnsubscribeUrl: z.string().url(),

lib/esm/types/index.d.ts

 export type { ParserOptions, ParsedResult, ParsedResultSuccess, ParsedResultError, } from '../types/parser.js';
 export type { Envelope } from './envelope.js';
-export type { ALBEvent, APIGatewayProxyEvent, ALBMultiValueHeadersEvent, APIGatewayProxyEventV2, APIGatewayRequestContextV2, APIGatewayRequestAuthorizerV2, S3Event, S3EventNotificationEventBridge, S3SqsEventNotification, SnsEvent, SqsEvent, DynamoDBStreamEvent, CloudWatchLogsEvent, CloudFormationCustomResourceCreateEvent, CloudFormationCustomResourceDeleteEvent, CloudFormationCustomResourceUpdateEvent, EventBridgeEvent, KafkaSelfManagedEvent, KafkaMskEvent, KinesisDataStreamEvent, KinesisFireHoseEvent, KinesisFireHoseSqsEvent, LambdaFunctionUrlEvent, SesEvent, SnsSqsNotification, S3ObjectLambdaEvent, VpcLatticeEvent, VpcLatticeEventV2, } from './schema.js';
+export type { ALBEvent, APIGatewayProxyEvent, ALBMultiValueHeadersEvent, APIGatewayProxyEventV2, APIGatewayRequestContextV2, APIGatewayRequestAuthorizerV2, AppSyncResolverEvent, AppSyncBatchResolverEvent, S3Event, S3EventNotificationEventBridge, S3SqsEventNotification, SnsEvent, SqsEvent, DynamoDBStreamEvent, DynamoDBStreamToKinesisRecordEvent, CloudWatchLogsEvent, CloudFormationCustomResourceCreateEvent, CloudFormationCustomResourceDeleteEvent, CloudFormationCustomResourceUpdateEvent, EventBridgeEvent, KafkaSelfManagedEvent, KafkaMskEvent, KinesisDataStreamEvent, KinesisDynamoDBStreamEvent, KinesisFireHoseEvent, KinesisFireHoseSqsEvent, LambdaFunctionUrlEvent, SesEvent, SnsSqsNotification, S3ObjectLambdaEvent, VpcLatticeEvent, VpcLatticeEventV2, } from './schema.js';
 //# sourceMappingURL=index.d.ts.map

lib/esm/types/schema.d.ts

 import type { z } from 'zod';
-import type { APIGatewayProxyEventSchema, APIGatewayProxyEventV2Schema, APIGatewayRequestAuthorizerV2Schema, APIGatewayRequestContextV2Schema, AlbMultiValueHeadersSchema, AlbSchema, CloudFormationCustomResourceCreateSchema, CloudFormationCustomResourceDeleteSchema, CloudFormationCustomResourceUpdateSchema, CloudWatchLogsSchema, DynamoDBStreamSchema, EventBridgeSchema, KafkaMskEventSchema, KafkaRecordSchema, KafkaSelfManagedEventSchema, KinesisDataStreamSchema, KinesisFirehoseRecordSchema, KinesisFirehoseSchema, KinesisFirehoseSqsRecordSchema, KinesisFirehoseSqsSchema, LambdaFunctionUrlSchema, S3EventNotificationEventBridgeSchema, S3ObjectLambdaEventSchema, S3Schema, S3SqsEventNotificationSchema, SesRecordSchema, SesSchema, SnsNotificationSchema, SnsRecordSchema, SnsSchema, SnsSqsNotificationSchema, SqsRecordSchema, SqsSchema, VpcLatticeSchema, VpcLatticeV2Schema } from '../schemas/index.js';
+import type { APIGatewayProxyEventSchema, APIGatewayProxyEventV2Schema, APIGatewayRequestAuthorizerV2Schema, APIGatewayRequestContextV2Schema, AlbMultiValueHeadersSchema, AlbSchema, AppSyncBatchResolverSchema, AppSyncResolverSchema, CloudFormationCustomResourceCreateSchema, CloudFormationCustomResourceDeleteSchema, CloudFormationCustomResourceUpdateSchema, CloudWatchLogsSchema, DynamoDBStreamSchema, DynamoDBStreamToKinesisRecord, EventBridgeSchema, KafkaMskEventSchema, KafkaRecordSchema, KafkaSelfManagedEventSchema, KinesisDataStreamSchema, KinesisDynamoDBStreamSchema, KinesisFirehoseRecordSchema, KinesisFirehoseSchema, KinesisFirehoseSqsRecordSchema, KinesisFirehoseSqsSchema, LambdaFunctionUrlSchema, S3EventNotificationEventBridgeSchema, S3ObjectLambdaEventSchema, S3Schema, S3SqsEventNotificationSchema, SesRecordSchema, SesSchema, SnsNotificationSchema, SnsRecordSchema, SnsSchema, SnsSqsNotificationSchema, SqsRecordSchema, SqsSchema, VpcLatticeSchema, VpcLatticeV2Schema } from '../schemas/index.js';
 type ALBEvent = z.infer<typeof AlbSchema>;
@@ -9,2 +9,4 @@ type ALBMultiValueHeadersEvent = z.infer<typeof AlbMultiValueHeadersSchema>;
 type APIGatewayRequestContextV2 = z.infer<typeof APIGatewayRequestContextV2Schema>;
+type AppSyncResolverEvent = z.infer<typeof AppSyncResolverSchema>;
+type AppSyncBatchResolverEvent = z.infer<typeof AppSyncBatchResolverSchema>;
 type CloudFormationCustomResourceCreateEvent = z.infer<typeof CloudFormationCustomResourceCreateSchema>;
@@ -15,2 +17,3 @@ type CloudFormationCustomResourceDeleteEvent = z.infer<typeof CloudFormationCustomResourceDeleteSchema>;
 type DynamoDBStreamEvent = z.infer<typeof DynamoDBStreamSchema>;
+type DynamoDBStreamToKinesisRecordEvent = z.infer<typeof DynamoDBStreamToKinesisRecord>;
 type EventBridgeEvent = z.infer<typeof EventBridgeSchema>;
@@ -21,2 +24,3 @@ type KafkaSelfManagedEvent = z.infer<typeof KafkaSelfManagedEventSchema>;
 type KinesisDataStreamEvent = z.infer<typeof KinesisDataStreamSchema>;
+type KinesisDynamoDBStreamEvent = z.infer<typeof KinesisDynamoDBStreamSchema>;
 type KinesisFireHoseEvent = z.infer<typeof KinesisFirehoseSchema>;
@@ -41,3 +45,3 @@ type KinesisFirehoseRecord = z.infer<typeof KinesisFirehoseRecordSchema>;
 type VpcLatticeEventV2 = z.infer<typeof VpcLatticeV2Schema>;
-export type { ALBEvent, ALBMultiValueHeadersEvent, APIGatewayProxyEvent, APIGatewayProxyEventV2, APIGatewayRequestAuthorizerV2, APIGatewayRequestContextV2, CloudFormationCustomResourceCreateEvent, CloudFormationCustomResourceDeleteEvent, CloudFormationCustomResourceUpdateEvent, CloudWatchLogsEvent, DynamoDBStreamEvent, EventBridgeEvent, KafkaSelfManagedEvent, KafkaMskEvent, KafkaRecord, KinesisDataStreamEvent, KinesisFireHoseEvent, KinesisFirehoseRecord, KinesisFireHoseSqsEvent, KinesisFirehoseSqsRecord, LambdaFunctionUrlEvent, S3Event, S3EventNotificationEventBridge, S3SqsEventNotification, S3ObjectLambdaEvent, SesEvent, SesRecord, SnsEvent, SnsSqsNotification, SnsNotification, SnsRecord, SqsEvent, SqsRecord, VpcLatticeEvent, VpcLatticeEventV2, };
+export type { ALBEvent, ALBMultiValueHeadersEvent, APIGatewayProxyEvent, APIGatewayProxyEventV2, APIGatewayRequestAuthorizerV2, APIGatewayRequestContextV2, AppSyncResolverEvent, AppSyncBatchResolverEvent, CloudFormationCustomResourceCreateEvent, CloudFormationCustomResourceDeleteEvent, CloudFormationCustomResourceUpdateEvent, CloudWatchLogsEvent, DynamoDBStreamEvent, DynamoDBStreamToKinesisRecordEvent, EventBridgeEvent, KafkaSelfManagedEvent, KafkaMskEvent, KafkaRecord, KinesisDataStreamEvent, KinesisDynamoDBStreamEvent, KinesisFireHoseEvent, KinesisFirehoseRecord, KinesisFireHoseSqsEvent, KinesisFirehoseSqsRecord, LambdaFunctionUrlEvent, S3Event, S3EventNotificationEventBridge, S3SqsEventNotification, S3ObjectLambdaEvent, SesEvent, SesRecord, SnsEvent, SnsSqsNotification, SnsNotification, SnsRecord, SqsEvent, SqsRecord, VpcLatticeEvent, VpcLatticeEventV2, };
 //# sourceMappingURL=schema.d.ts.map

package.json

 {
   "name": "@aws-lambda-powertools/parser",
-  "version": "2.11.0",
+  "version": "2.12.0",
   "description": "The parser package for the Powertools for AWS Lambda (TypeScript) library.",
@@ -35,3 +35,3 @@ "author": {
   "peerDependencies": {
-    "@middy/core": "4.x || 5.x",
+    "@middy/core": "4.x || 5.x || 6.x",
     "zod": ">=3.x"
@@ -84,2 +84,6 @@ },
     },
+    "./schemas/appsync": {
+      "require": "./lib/cjs/schemas/appsync.js",
+      "import": "./lib/esm/schemas/appsync.js"
+    },
     "./schemas/cloudformation-custom-resources": {
@@ -232,2 +236,6 @@ "require": "./lib/cjs/schemas/cloudformation-custom-resources.js",
       ],
+      "schemas/appsync": [
+        "./lib/cjs/schemas/appsync.d.ts",
+        "./lib/esm/schemas/appsync.d.ts"
+      ],
       "schemas/cloudformation-custom-resources": [
@@ -234,0 +242,0 @@ "./lib/cjs/schemas/cloudformation-custom-resources.d.ts",

No alert changes

Improved metrics

Total package byte prevSize

1064473

increased by10.27%

Number of package files

276

increased by2.22%

Lines of code

26252

increased by10.56%

No dependency changes