@alpha-lambda/aws-drivers - npm Package Compare versions

Comparing version 1.0.1 to 1.1.0

index.js

 'use strict';
 
 const S3 = require('./lib/s3');
+const SQS = require('./lib/sqs');
 
 module.exports = {
-  S3
+  S3,
+  SQS
 };

lib/driver.js

 'use strict';
 
 const assert = require('assert');
-const AWS = require('aws-sdk');
 const logMeGently = require('@alpha-lambda/log-me-gently');
@@ -18,3 +17,3 @@
 
-      this._client = new AWS[service](clientOptions);
+      this._client = new service(clientOptions); // eslint-disable-line new-cap
     }
@@ -21,0 +20,0 @@

lib/s3.js

 'use strict';
 
 const assert = require('assert');
+const AWS = require('aws-sdk');
 const uuid = require('uuid');
@@ -15,6 +16,7 @@
     };
-    super('S3', clientOpts, options);
+    super(AWS.S3, clientOpts, options);
   }
 
   getSignedUrl(context, { operation, parameters, urlTTL }) {
+    assert(context, 'missing context');
     assert(operation, 'missing operation');
@@ -54,2 +56,3 @@ assert(urlTTL !== undefined, 'missing urlTTL');
   putObject(context, { bucket, data, key }) {
+    assert(context, 'missing context');
     assert(bucket, 'missing bucket');
@@ -56,0 +59,0 @@ assert(data, 'missing data');

package.json

 {
   "name": "@alpha-lambda/aws-drivers",
-  "version": "1.0.1",
+  "version": "1.1.0",
   "description": "Wrappers for AWS SDK services that make life easier (sometimes)",
@@ -51,4 +51,7 @@ "repository": {
     "@alpha-lambda/log-me-gently": "^1.0.0",
+    "ajv": "^6.10.0",
+    "lodash.chunk": "^4.2.0",
+    "throat": "^5.0.0",
     "uuid": "^3.3.2"
   }
 }

README.md

@@ -36,2 +36,43 @@ # aws-drivers
 
+### SQS
+
+Additional config properties:
+  - **[maxConcurrency]** - { Number } - max number of concurrent AWS API calls [defaults to `Infinity`]
+
+#### parse(context, input)
+Validates and parses input, where input can be SQS message or SQS event. Sample output:
+
+```json
+[
+  {
+    "body": {
+      "foo": "foo",
+      "bar": "bar"
+    },
+    "messageAttributes": {
+      "baz": 12345
+    },
+    "messageId": 1234567890
+  }
+]
+```
+
+#### send(context, queueUrl, messages)
+Sends messages to the specified queue using batch API to reduce number of calls.
+  - **queueUrl** - { String } - the URL of the SQS queue to which batched messages are sent
+  - **messages** - { Any | Any[] } - messages to be sent
+
+#### sendToDLQ(context, dlqUrl, items)
+Formats and sends messages to the specified deadletter queue.
+  - **dlqUrl** - { String } - the deadletter queue URL to which messages are sent
+  - **items** - { Object | Object[] } - items to send to the deadletter queue, where:
+    - **event** - { Any } - original payload that can't be processed
+    - **error** - { Object } - error that occured during processing
+
+These message attributes are added to each message:
+  - **err.message** - error message
+  - **err.stack** - error stack trace
+  - **context.awsRequestId** - requestId for the current request, provided by Amazon
+  - **origin.messageId** - original messageId (if payload is SQS message)
+
 ## License
@@ -38,0 +79,0 @@

Fixed alerts

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

135091

increased by7.51%

Number of package files

11

increased by22.22%

Lines of code

3511

increased by7.7%

Number of lines in readme file

99

increased by70.69%

Number of medium supply chain risk alerts

0

decreased by-100%

Worsened metrics

Dependency count

6

increased by100%

Dependency changes

• + Addedajv@^6.10.0

• + Addedlodash.chunk@^4.2.0

• + Addedthroat@^5.0.0

• + Addedajv@6.12.6(transitive)

• + Addedfast-deep-equal@3.1.3(transitive)

• + Addedfast-json-stable-stringify@2.1.0(transitive)

• + Addedjson-schema-traverse@0.4.1(transitive)

• + Addedlodash.chunk@4.2.0(transitive)

• + Addedpunycode@2.3.1(transitive)

• + Addedthroat@5.0.0(transitive)

• + Addeduri-js@4.4.1(transitive)