Skip to content

Commit 70291c5

Browse files
asprousegodu
authored andcommitted
Add eventSourceARN to Dynamo stream records
1 parent dd1ba4d commit 70291c5

File tree

2 files changed

+7
-2
lines changed
  • packages
    • serverless-offline-dynamodb-streams/src
    • serverless-offline-kinesis/src

2 files changed

+7
-2
lines changed

packages/serverless-offline-dynamodb-streams/src/index.js

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -106,7 +106,12 @@ class ServerlessOfflineDynamoDBStreams {
106106
cb(err, data);
107107
});
108108
const event = {
109-
Records
109+
Records: Records.map(
110+
assign({
111+
eventSourceARN: streamARN,
112+
awsRegion: get('service.provider.region', this)
113+
})
114+
)
110115
};
111116

112117
const x = handler(event, lambdaContext, lambdaContext.done);

packages/serverless-offline-kinesis/src/index.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -115,7 +115,7 @@ class ServerlessOfflineKinesis {
115115
eventVersion: '1.0',
116116
eventName: 'aws:kinesis:record',
117117
eventSourceARN: streamEvent.arn,
118-
awsRegion: 'us-west-2'
118+
awsRegion: get('service.provider.region', this)
119119
}))
120120
};
121121

0 commit comments

Comments
 (0)