@capriza/connector-controller - npm Package Compare versions

Comparing version 1.0.33 to 1.0.34

index.js

 var Connector = require ("./lib/connector.js").Connector;
 
 module.exports.Connector = Connector;

lib/com.js

@@ -46,3 +46,10 @@ /**
 
-        this.memoryUsageInterval = setInterval (this.monitorMemoryUsage.bind(this), this.config.controllerConfig.monitorMemoryInterval);
+        this.memoryUsageInterval = setInterval(this.monitorMemoryUsage.bind(this), this.config.controllerConfig.monitorMemoryInterval);
+		
+		if (this.config.controllerConfig.partialSyncInterval) {
+			setInterval(() => {
+				var logger = this.logger.child({ taskType : "partialSync" });
+				this._doSync({ logger, syncType : "partial" });
+			}, this.config.controllerConfig.partialSyncInterval);
+		}
     }
@@ -148,6 +155,8 @@
 
-    async _doSync({ logger }){
+    async _doSync({ logger, syncType }){
 		var sendPromise = Promise.resolve();
+		await this._syncData({ logger });
 		await this.connector.sync({
 			logger,
+			syncType,
 			send : approvals => { return sendPromise = sendPromise.then(() => this._sendApprovals(approvals, { logger })); }
@@ -221,3 +230,2 @@ });
                     this._updateApprovalInCache(serverApproval);
-
                 });
@@ -228,3 +236,2 @@
 
-
             this.currSyncData = response.data;
@@ -331,3 +338,2 @@ return this.currSyncData;
                 case "sync":
-                    await this._syncData({logger: taskLogger});
                     await Promise.race([this._doSync({logger: taskLogger}), this._taskTimeout(taskLogger)]);
@@ -334,0 +340,0 @@ break;

lib/connector.js

@@ -175,3 +175,3 @@ var Syncher = require ("./syncher.js");
 
-			var fetchRes = this.BL.fetch({ signatureList, blLogger }, (err, approvalsChunk, hasMore) => {
+			var fetchRes = this.BL.fetch({ signatureList, blLogger, fetchType : action.syncType }, (err, approvalsChunk, hasMore) => {
 				if (err) return reject(err);
@@ -178,0 +178,0 @@ processChunk(approvalsChunk, hasMore);

lib/errors.js

@@ -0,0 +0,0 @@ module.exports = {

lib/log.js

@@ -0,0 +0,0 @@ var fs = require ('fs');

lib/syncher.js

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

outpost/genModule.js

@@ -0,0 +0,0 @@ var fs = require('fs');

outpost/jsonMerger.js

@@ -0,0 +0,0 @@ var fs = require('fs');

outpost/module/configure.js

@@ -0,0 +0,0 @@ const fs = require("fs");

outpost/module/install.js

 const fs = require("fs");
 fs.writeFileSync("connector/resources/_vanilla.json", fs.readFileSync("connector/resources/config.json"));
 outpost.done();

outpost/module/module.json

@@ -0,0 +0,0 @@ {

outpost/module/start.js

@@ -0,0 +0,0 @@ const util = require("util");

outpost/module/stop.js

@@ -0,0 +0,0 @@ var {name, version} = require ("./module.json");

package.json

 {
   "name": "@capriza/connector-controller",
-  "version": "1.0.33",
+  "version": "1.0.34",
   "description": "Capriza connectors controller",
@@ -5,0 +5,0 @@ "main": "index.js",

README.md

@@ -0,0 +0,0 @@ # Capriza Connectors

start.js

@@ -0,0 +0,0 @@ var path = require('path');

test/base-connector.js

@@ -0,0 +0,0 @@ var chai = require('chai');

test/BLTester/business-logic-tester.js

@@ -0,0 +0,0 @@ var fse = require ("fs-extra");

test/BLTester/server.js

@@ -0,0 +0,0 @@ var validate = require('capriza-schema').validate;

test/integration/scheme.js

@@ -0,0 +0,0 @@ var expect = require('chai').expect;

test/syncher.js

@@ -0,0 +0,0 @@ var should = require('chai').should();

No alert changes

Improved metrics

Total package byte prevSize

153697

increased by20.29%

Number of package files

27

increased by8%

Lines of code

2107

increased by43.14%

No dependency changes