aws-lambda-stream - npm Package Compare versions

Comparing version 0.5.0 to 0.6.0

lib/connectors/index.js

@@ -20,2 +20,8 @@ "use strict";
 });
+Object.defineProperty(exports, "FirehoseConnector", {
+  enumerable: true,
+  get: function () {
+    return _firehose.default;
+  }
+});
 Object.defineProperty(exports, "KinesisConnector", {
@@ -50,2 +56,4 @@ enumerable: true,
 
+var _firehose = _interopRequireDefault(require("./firehose"));
+
 var _kinesis = _interopRequireDefault(require("./kinesis"));
@@ -52,0 +60,0 @@

lib/flavors/evaluate.js

@@ -115,4 +115,3 @@ "use strict";
       ':data': uow.meta.data
-    },
-    ConsistentRead: true // TODO filter out expired events
+    } // TODO filter out expired events
 
@@ -119,0 +118,0 @@ }

lib/flavors/index.js

@@ -31,5 +31,5 @@ "use strict";
 
-var _crud = require("./crud");
+var _cdc = require("./cdc");
 
-Object.keys(_crud).forEach(function (key) {
+Object.keys(_cdc).forEach(function (key) {
   if (key === "default" || key === "__esModule") return;
@@ -39,3 +39,3 @@ Object.defineProperty(exports, key, {
     get: function () {
-      return _crud[key];
+      return _cdc[key];
     }
@@ -42,0 +42,0 @@ });

lib/utils/index.js

@@ -55,2 +55,14 @@ "use strict";
 
+var _firehose = require("./firehose");
+
+Object.keys(_firehose).forEach(function (key) {
+  if (key === "default" || key === "__esModule") return;
+  Object.defineProperty(exports, key, {
+    enumerable: true,
+    get: function () {
+      return _firehose[key];
+    }
+  });
+});
+
 var _handler = require("./handler");
@@ -57,0 +69,0 @@

package.json

 {
   "name": "aws-lambda-stream",
-  "version": "0.5.0",
+  "version": "0.6.0",
   "description": "Create stream processors with AWS Lambda functions.",
@@ -5,0 +5,0 @@ "keywords": [

README.md

@@ -285,3 +285,3 @@ # aws-lambda-stream
 * `materialize` - used in `listener` functions to materialize an `entity` from an `event` into a DynamoDB single table
-* `crud` - used in `trigger` functions to `publish` events to Kinesis as entities are maintained in a DynamoDB single table
+* `cdc` - used in `trigger` functions to `publish` events to Kinesis as entities are maintained in a DynamoDB single table
 * `collect` - used in `listener` functions to collect events in a micro event store for complex event processing
@@ -288,0 +288,0 @@ * `correlate` - used in `trigger` functions to correlate related events for complex event processing

New alerts

Environment variable access

Supply chain risk

Package accesses environment variables, which may be a sign of credential stuffing or data theft.

Found 4 instances in 1 package

Improved metrics

Total package byte prevSize

103920

3.77%

Number of package files

46

4.55%

Lines of code

2176

5.02%

Worsened metrics

Number of low supply chain risk alerts

73

12.31%

No dependency changes