leo-connector-common - npm Package Compare versions

Comparing version 2.1.2 to 2.1.3

datawarehouse/load.js

@@ -6,2 +6,3 @@ "use strict";
 const ls = leo.streams;
+const streams = require('leo-streams');
 const combine = require("./combine.js");
@@ -323,12 +324,26 @@ const async = require("async");
 {
-	logger.debug('Adding failed event', eventObj);
-	// sent the event to an error queue
-	eventObj.error = error;
+	if (!errorStream) {
+		errorStream = streams.passthrough({
+			objectMode: true
+		});
 
-	if (!errorStream) {
-		errorStream = leo.load(ID, `${source}_error`);
+		streams.pipe(
+			errorStream,
+
+			ls.process(ID, obj => {
+				return obj;
+			}),
+
+			leo.load(ID, `${source}_error`),
+
+			(err) => {
+				err && logger.err('GOT ERROR', err);
+			}
+		);
 	}
+
+	logger.debug('Adding failed event', eventObj);
+	// write the error to the payload so it gets passed on
+	eventObj.payload.error = error;
 	errorStream.write(eventObj);
-
-	return true;
 }

package.json

 {
 	"name": "leo-connector-common",
-	"version": "2.1.2",
+	"version": "2.1.3",
 	"description": "Common package for all Leo Platform database connectors",
@@ -30,2 +30,3 @@ "main": "index.js",
 		"leo-sdk": "^3.0.1",
+		"leo-streams": "^1.1.1",
 		"moment": "^2.24.0",
@@ -32,0 +33,0 @@ "sqlstring": "^2.3.1"

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

109228

increased by0.26%

Lines of code

3901

increased by0.31%

Worsened metrics

Dependency count

7

increased by16.67%

Dependency changes

• + Addedleo-streams@^1.1.1