leo-connector-common - npm Package Compare versions

leo-connector-common

Advanced tools

Install Socket

Detect and block malicious and high-risk dependencies

Comparing version 4.0.11-beta to 4.0.11-rc

datawarehouse/load.js

		@@ -12,3 +12,3 @@ 'use strict';

		module.exports = function(ID, source, client, tableConfig, stream, callback) {
		module.exports = function (ID, source, client, tableConfig, stream, callback) {

		@@ -43,3 +43,3 @@ // adding backwards compatibility for ID and source

		let checkforDelete = ls.through(function(obj, done) {
		let checkforDelete = ls.through(function (obj, done) {
		if (obj.payload.type === 'delete') {
		@@ -73,3 +73,3 @@ let data = obj.payload.data \|\| {};

		let validateData = ls.through(function(obj, done) {
		let validateData = ls.through(function (obj, done) {
		let eventObj = obj.payload.data;
		@@ -342,3 +342,3 @@ let invalid = false;
		*/
		function handleFailedValidation(ID, source, eventObj, error) {
		function handleFailedValidation (ID, source, eventObj, error) {
		if (!errorStream \|\| !errorStream.Writable) {
		@@ -352,8 +352,8 @@ errorStream = streams.passthrough({

		ls.process(ID, function(obj) {
		ls.process(ID, obj => {
		return obj;
		}, `${source}_error`),
		ls.toLeo(ID),
		ls.devnull(),
		}),

		leo.load(ID, `${source}_error`),

		(err) => {
		@@ -360,0 +360,0 @@ err && logger.error('GOT ERROR', err);

package.json

		{
		"name": "leo-connector-common",
		"version": "4.0.11-beta",
		"version": "4.0.11-rc",
		"description": "Common package for all Leo Platform database connectors",
		@@ -23,9 +23,12 @@ "main": "index.js",
		"eslint": "^4.17.0",
		"mocha": "^5.0.0"
		"mocha": "^5.0.0",
		"leo-sdk": "5.0.32-latest-v5"
		},
		"peerDependencies": {
		"leo-sdk": ">=5.0.27-latest-v5"
		},
		"dependencies": {
		"async": "2.6.3",
		"leo-aws": "2.0.1",
		"leo-aws": "^2.0.3",
		"leo-logger": "1.0.1",
		"leo-sdk": "5.0.16",
		"leo-streams": "2.0.0",
		@@ -32,0 +35,0 @@ "moment": "2.24.0",

Improved metrics