aws-lambda-stream
Advanced tools
Comparing version
@@ -22,2 +22,3 @@ "use strict"; | ||
timeout = Number(process.env.S3_TIMEOUT) || Number(process.env.TIMEOUT) || 1000, | ||
credentials, | ||
...opt | ||
@@ -27,9 +28,10 @@ }) { | ||
this.bucketName = bucketName || 'undefined'; | ||
this.client = Connector.getClient(pipelineId, debug, timeout); | ||
this.client = Connector.getClient(pipelineId, debug, timeout, credentials); | ||
this.opt = opt; | ||
} | ||
static clients = {}; | ||
static getClient(pipelineId, debug, timeout) { | ||
static getClient(pipelineId, debug, timeout, credentials) { | ||
if (!this.clients[pipelineId]) { | ||
this.clients[pipelineId] = new _clientS.S3Client({ | ||
credentials, | ||
requestHandler: new _nodeHttpHandler.NodeHttpHandler({ | ||
@@ -36,0 +38,0 @@ requestTimeout: timeout, |
{ | ||
"name": "aws-lambda-stream", | ||
"version": "1.0.15", | ||
"version": "1.0.16", | ||
"description": "Create stream processors with AWS Lambda functions.", | ||
@@ -70,2 +70,3 @@ "keywords": [ | ||
"@aws-sdk/client-sqs": "^3.450.0", | ||
"@aws-sdk/client-sts": "^3.450.0", | ||
"@aws-sdk/lib-dynamodb": "^3.450.0", | ||
@@ -72,0 +73,0 @@ "@aws-sdk/util-dynamodb": "^3.450.0", |
Environment variable access
Supply chain riskPackage accesses environment variables, which may be a sign of credential stuffing or data theft.
Found 2 instances in 1 package
220754
0.89%85
1.19%5364
1%49
2.08%179
2.29%