fh-wfm-result - npm Package Compare versions

Comparing version 0.2.3-alpha.504.2 to 0.2.3

lib/client/mediator-subscribers/index.js

@@ -7,10 +7,5 @@ var _ = require('lodash');
   list: require('./list'),
-  read: require('./read'),
-
-  //sync notification subscribe handlers
-  syncEvent: require('./sync-events')
+  read: require('./read')
 };
-
 var CONSTANTS = require('../../constants');
-var config = require('../../config');
 
@@ -20,3 +15,2 @@ var MediatorTopicUtility = require('fh-wfm-mediator/lib/topics');
 var resultSubscribers;
-var syncSubscribers;
 
@@ -47,13 +41,2 @@ module.exports = {
 
-    if (syncSubscribers) {
-      return syncSubscribers;
-    }
-    syncSubscribers = new MediatorTopicUtility(mediator);
-    syncSubscribers.prefix(CONSTANTS.SYNC_TOPIC_PREFIX).entity(config.datasetId);
-
-    _.each(CONSTANTS.SYNC_TOPICS, function(topicName) {
-      syncSubscribers.on(topicName, topicHandlers.syncEvent());
-    });
-
-
     return resultSubscribers;
@@ -66,7 +49,3 @@ },
     }
-    if (syncSubscribers) {
-      syncSubscribers.unsubscribeAll();
-      syncSubscribers = null;
-    }
   }
-};
+};

lib/client/mediator-subscribers/list.js

 var CONSTANTS = require('../../constants');
-var SyncEvents = require('../result-client/sync-events-store');
-var debug = require('../../utils/logger')(__filename);
 
@@ -30,4 +28,2 @@ /**
     .then(function(arrayOfResults) {
-      SyncEvents.mapResultsToEvents(arrayOfResults);
-      debug("all results mapped with sync events: %O", arrayOfResults);
       self.mediator.publish(resultListDoneTopic, arrayOfResults);
@@ -38,2 +34,2 @@ }).catch(function(error) {
   };
-};
+};

lib/client/mediator-subscribers/read.js

 var CONSTANTS = require('../../constants');
-var SyncEvents = require('../result-client/sync-events-store');
-var debug = require('../../utils/logger')(__filename);
 
@@ -38,4 +36,2 @@ /**
     .then(function(result) {
-      result.syncStatus = SyncEvents.getSyncStatus(result.id);
-      debug('read result ',  result);
       self.mediator.publish(resultReadDoneTopic, result);
@@ -47,2 +43,2 @@ }).catch(function(error) {
 
-};
+};

lib/client/result-client/index.js

@@ -151,7 +151,7 @@ var q = require('q');
 function forceSync() {
-  var donePromise = mediator.promise(resultSyncSubscribers.getTopic(CONSTANTS.SYNC_TOPICS.FORCE_SYNC, CONSTANTS.DONE_PREFIX));
+  var donePromise = mediator.promise(resultSyncSubscribers.getTopic(CONSTANTS.TOPICS.FORCE_SYNC, CONSTANTS.DONE_PREFIX));
 
-  var errorPromise = mediator.promise(resultSyncSubscribers.getTopic(CONSTANTS.SYNC_TOPICS.FORCE_SYNC, CONSTANTS.ERROR_PREFIX));
+  var errorPromise = mediator.promise(resultSyncSubscribers.getTopic(CONSTANTS.TOPICS.FORCE_SYNC, CONSTANTS.ERROR_PREFIX));
 
-  mediator.publish(resultSyncSubscribers.getTopic(CONSTANTS.SYNC_TOPICS.FORCE_SYNC));
+  mediator.publish(resultSyncSubscribers.getTopic(CONSTANTS.TOPICS.FORCE_SYNC));
 
@@ -174,3 +174,3 @@ return getTopicPromises(donePromise, errorPromise);
 function waitForSync() {
-  return mediator.promise(resultSyncSubscribers.getTopic(CONSTANTS.SYNC_TOPICS.SYNC_COMPLETE));
+  return mediator.promise(resultSyncSubscribers.getTopic(CONSTANTS.TOPICS.SYNC_COMPLETE));
 }
@@ -226,2 +226,2 @@
   return manager;
-};
+};

lib/constants.js

@@ -15,11 +15,6 @@ module.exports = {
     START: "start",
-    STOP: "stop"
-  },
-  SYNC_TOPICS:{
-    COLLISION_DETECTED: "collision_detected",
-    REMOTE_UPDATE_APPLIED: "remote_update_applied",
-    REMOTE_UPDATE_FAILED: "remote_update_failed",
-    SYNC_COMPLETE: "sync_complete",
-    FORCE_SYNC: "force_sync"
+    STOP: "stop",
+    FORCE_SYNC: "force_sync",
+    SYNC_COMPLETE: "sync_complete"
   }
-};
+};

package.json

 {
   "name": "fh-wfm-result",
-  "version": "0.2.3-alpha.504.2",
+  "version": "0.2.3",
   "description": "A result module for WFM, for working with the results of pushing a workorder through a workflow",
@@ -20,7 +20,5 @@ "repository": {
     "angular-messages": "1.5.3",
-    "bluebird": "^3.5.0",
-    "debug": "^2.6.3",
     "express": "4.15.2",
-    "fh-wfm-mediator": "0.3.2",
-    "lodash": "4.7.0",
+    "fh-wfm-mediator": "0.3.3",
+    "lodash": "4.17.4",
     "q": "1.4.1",
@@ -27,0 +25,0 @@ "shortid": "^2.2.6"

New alerts

New author

Supply chain risk

A new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.

Found 1 instance in 1 package

Improved metrics

Dependency count

6

decreased by-25%

Worsened metrics

Total package byte prevSize

50019

decreased by-10.69%

Number of package files

26

decreased by-21.21%

Lines of code

921

decreased by-15.74%

Number of medium supply chain risk alerts

1

increased byInfinity%

Dependency changes

• + Addedfh-wfm-mediator@0.3.3(transitive)

• + Addedlodash@4.17.4(transitive)

• - Removedbluebird@^3.5.0

• - Removeddebug@^2.6.3

• - Removedfh-wfm-mediator@0.3.2(transitive)

• - Removedlodash@4.7.0(transitive)

• Updatedfh-wfm-mediator@0.3.3

• Updatedlodash@4.17.4