stratumn-agent
Advanced tools
Comparing version 0.8.0 to 0.9.0
@@ -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 @@ }, |
{ | ||
"name": "stratumn-agent", | ||
"version": "0.8.0", | ||
"version": "0.9.0", | ||
"description": "", | ||
@@ -5,0 +5,0 @@ "main": "lib/index.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 @@ }, |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
61676
1565