leo-connector-common - npm Package Compare versions

Comparing version 2.0.0-RC3 to 2.0.0-RC4

checksum/index.js

		let leo = require("leo-sdk");
		const aws = require("aws-sdk");
		const checksum = require("./lib/checksumNibbler.js");
		let dynamodb = leo.aws.dynamodb;
		const leoaws = require('leo-aws');
		let cron = leo.bot;
		@@ -23,15 +23,7 @@
		function saveProgress(systemId, botId, data) {
		return new Promise((resolve, reject) => {
		dynamodb.merge(tableName, botId, {
		checksum: data,
		system: {
		id: systemId
		}
		}, function(err, result) {
		if (err) {
		reject(err);
		} else {
		resolve(data);
		}
		});
		return leoaws.dynamodb.merge(tableName, botId, {
		checksum: data,
		system: {
		id: systemId
		}
		});
		@@ -88,20 +80,14 @@ }
		} else {
		return new Promise((resolve, reject) => {
		logger.log("Getting Session", systemId, botId);
		dynamodb.get(tableName, botId, function(err, result) {
		if (err) {
		reject(err);
		} else {
		try {
		let session = emptySession;
		if (result && result.checksum && result.checksum.restart !== true && result.checksum.status !== 'complete') {
		session = result.checksum;
		}
		resolve(session);
		} catch (err) {
		reject(err);
		}

		logger.log("Getting Session", systemId, botId);

		return leoaws.dynamodb.get(tableName, botId)
		.then(result => {
		let session = emptySession;
		if (result && result.checksum && result.checksum.restart !== true && result.checksum.status !== 'complete') {
		session = result.checksum;
		}

		return session;
		});
		});
		}
		@@ -108,0 +94,0 @@ },

checksum/lib/basicConnector.js

		@@ -5,4 +5,3 @@ "use strict";
		const moment = require("moment");
		require("moment-timezone");
		const logger = require("leo-sdk/lib/logger")("leo-checksum.basic");
		const logger = require("leo-logger")("leo-checksum.basic");
		const Stream = require('stream').Stream;
		@@ -9,0 +8,0 @@

checksum/lib/checksumNibbler.js

		@@ -5,3 +5,3 @@ "use strict";

		let logger = require("leo-sdk/lib/logger")("leo-checksum.nibbler");
		let logger = require("leo-logger")("leo-checksum.nibbler");

		@@ -8,0 +8,0 @@ module.exports = function(local, remote, opts) {

checksum/lib/nibbler.js

		@@ -1,3 +0,3 @@
		var async = require("async");
		let logger = require("leo-sdk/lib/logger")("leo-nibbler");
		const async = require("async");
		const logger = require("leo-logger")("leo-nibbler");

		@@ -4,0 +4,0 @@ /**

package.json

		{
		"name": "leo-connector-common",
		"version": "2.0.0-RC3",
		"version": "2.0.0-RC4",
		"description": "Common package for all Leo Platform database connectors",
		@@ -5,0 +5,0 @@ "main": "index.js",

New alerts