stratumn-agent - npm Package Compare versions

Comparing version 0.8.0 to 0.9.0

lib/create.js

@@ -70,2 +70,13 @@ 'use strict';
 
+  function saveSegment(segment1) {
+    return storeClient.saveSegment(segment1).then(fossilizeSegment).then(function (segment2) {
+      // Call didAppend event if present.
+      if (_typeof(actions.events) === 'object' && typeof actions.events.didAppend === 'function') {
+        (0, _stratumnMockAgent.mockAgent)(actions, segment2.link).events.didAppend(segment2);
+      }
+
+      return segment2;
+    });
+  }
+
   return {
@@ -78,2 +89,8 @@ /**
       return storeClient.getInfo().then(function (storeInfo) {
+        if (fossilizerClient) {
+          return fossilizerClient.getInfo().then(function (fossilizerInfo) {
+            return { agentInfo: agentInfo, storeInfo: storeInfo, fossilizerInfo: fossilizerInfo };
+          });
+        }
+
         return { agentInfo: agentInfo, storeInfo: storeInfo };
@@ -98,3 +115,8 @@ });
 
-      return (_mockAgent = (0, _stratumnMockAgent.mockAgent)(actions, initialLink)).init.apply(_mockAgent, args).then(function (l) {
+      return (_mockAgent = (0, _stratumnMockAgent.mockAgent)(actions, initialLink)).init.apply(_mockAgent, args).catch(function (err) {
+        /*eslint-disable*/
+        err.status = 400;
+        /*eslint-enable*/
+        throw err;
+      }).then(function (l) {
         var link = l;
@@ -120,8 +142,3 @@
 
-        return storeClient.saveSegment(segment);
-      }).then(fossilizeSegment).catch(function (err) {
-        /*eslint-disable*/
-        err.status = 400;
-        /*eslint-enable*/
-        throw err;
+        return saveSegment(segment);
       });
@@ -161,3 +178,8 @@ },
 
-        return (_mockAgent2 = (0, _stratumnMockAgent.mockAgent)(actions, initialLink))[action].apply(_mockAgent2, args);
+        return (_mockAgent2 = (0, _stratumnMockAgent.mockAgent)(actions, initialLink))[action].apply(_mockAgent2, args).catch(function (err) {
+          /*eslint-disable*/
+          err.status = 400;
+          /*eslint-enable*/
+          throw err;
+        });
       }).then(function (l) {
@@ -184,8 +206,3 @@ var link = l;
 
-        return storeClient.saveSegment(segment);
-      }).then(fossilizeSegment).catch(function (err) {
-        /*eslint-disable*/
-        err.status = 400;
-        /*eslint-enable*/
-        throw err;
+        return saveSegment(segment);
       });
@@ -192,0 +209,0 @@ },

package.json

 {
   "name": "stratumn-agent",
-  "version": "0.8.0",
+  "version": "0.9.0",
   "description": "",
@@ -5,0 +5,0 @@ "main": "lib/index.js",

src/create.js

@@ -41,2 +41,17 @@ import uuid from 'node-uuid';
 
+  function saveSegment(segment1) {
+    return storeClient
+      .saveSegment(segment1)
+      .then(fossilizeSegment)
+      .then(segment2 => {
+        // Call didAppend event if present.
+        if (typeof actions.events === 'object' &&
+            typeof actions.events.didAppend === 'function') {
+          mockAgent(actions, segment2.link).events.didAppend(segment2);
+        }
+
+        return segment2;
+      });
+  }
+
   return {
@@ -50,3 +65,11 @@ /**
         .getInfo()
-        .then(storeInfo => ({ agentInfo, storeInfo }));
+        .then(storeInfo => {
+          if (fossilizerClient) {
+            return fossilizerClient
+              .getInfo()
+              .then(fossilizerInfo => ({ agentInfo, storeInfo, fossilizerInfo }));
+          }
+
+          return { agentInfo, storeInfo };
+        });
     },
@@ -64,2 +87,8 @@
         .init(...args)
+        .catch(err => {
+          /*eslint-disable*/
+          err.status = 400;
+          /*eslint-enable*/
+          throw err;
+        })
         .then(l => {
@@ -86,10 +115,3 @@ const link = l;
 
-          return storeClient.saveSegment(segment);
-        })
-        .then(fossilizeSegment)
-        .catch(err => {
-          /*eslint-disable*/
-          err.status = 400;
-          /*eslint-enable*/
-          throw err;
+          return saveSegment(segment);
         });
@@ -124,3 +146,9 @@ },
 
-          return mockAgent(actions, initialLink)[action](...args);
+          return mockAgent(actions, initialLink)[action](...args)
+            .catch(err => {
+              /*eslint-disable*/
+              err.status = 400;
+              /*eslint-enable*/
+              throw err;
+            });
         })
@@ -148,10 +176,3 @@ .then(l => {
 
-          return storeClient.saveSegment(segment);
-        })
-        .then(fossilizeSegment)
-        .catch(err => {
-          /*eslint-disable*/
-          err.status = 400;
-          /*eslint-enable*/
-          throw err;
+          return saveSegment(segment);
         });
@@ -158,0 +179,0 @@ },

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

61676

increased by1.92%

Lines of code

1565

increased by2.09%

No dependency changes