effects-as-data
Advanced tools
Comparing version 2.11.1 to 2.12.0
@@ -18,6 +18,7 @@ "use strict"; | ||
var el = newExecutionLog(); | ||
config.cid = config.cid || uuid(); | ||
config.stack = config.stack || []; | ||
config.stack.push({ | ||
config: config, | ||
var childConfig = Object.assign({}, config); | ||
childConfig.cid = childConfig.cid || uuid(); | ||
var stack = config.stack || []; | ||
childConfig.stack = stack.concat({ | ||
config: childConfig, | ||
handlers: handlers, | ||
@@ -28,4 +29,4 @@ fn: fn, | ||
var start = Date.now(); | ||
onCall({ args: args, fn: fn, config: config }); | ||
return run(config, handlers, fn, gen, null, el).then(function (result) { | ||
onCall({ args: args, fn: fn, config: childConfig }); | ||
return run(childConfig, handlers, fn, gen, null, el).then(function (result) { | ||
var end = Date.now(); | ||
@@ -36,3 +37,3 @@ onCallComplete({ | ||
result: result, | ||
config: config, | ||
config: childConfig, | ||
start: start, | ||
@@ -49,3 +50,3 @@ end: end, | ||
result: e, | ||
config: config, | ||
config: childConfig, | ||
start: start, | ||
@@ -52,0 +53,0 @@ end: end, |
@@ -53,8 +53,12 @@ "use strict"; | ||
await sleep(10); | ||
expect(telemetry.config.stack[0]).toEqual({ | ||
fn: basic, | ||
config: config, | ||
handlers: handlers, | ||
args: ["foo"] | ||
}); | ||
expect(telemetry.config.stack[0].fn).toEqual(basic); | ||
expect(telemetry.config.stack[0].handlers).toEqual(handlers); | ||
expect(telemetry.config.stack[0].args).toEqual(["foo"]); | ||
expect(telemetry.config.stack[0].config.onCommand).toEqual(onCommand); | ||
expect(telemetry.config.stack[0].config.name).toEqual("telemetry"); | ||
expect(telemetry.config.stack[0].config.cid.length).toEqual(36); | ||
expect(telemetry.config.stack[0].config.stack[0].handlers).toEqual(handlers); | ||
expect(telemetry.config.stack[0].config.stack[0].args).toEqual(["foo"]); | ||
expect(telemetry.config.stack[0].config.stack[0].fn).toEqual(basic); | ||
expect(telemetry.config.stack[0].config.stack[0].config.name).toEqual("telemetry"); | ||
}); | ||
@@ -71,8 +75,12 @@ | ||
await sleep(10); | ||
expect(telemetry.config.stack[0]).toEqual({ | ||
fn: basic, | ||
config: config, | ||
handlers: handlers, | ||
args: ["foo"] | ||
}); | ||
expect(telemetry.config.stack[0].fn).toEqual(basic); | ||
expect(telemetry.config.stack[0].handlers).toEqual(handlers); | ||
expect(telemetry.config.stack[0].args).toEqual(["foo"]); | ||
expect(telemetry.config.stack[0].config.onCommand).toEqual(onCommand); | ||
expect(telemetry.config.stack[0].config.name).toEqual("telemetry"); | ||
expect(telemetry.config.stack[0].config.cid.length).toEqual(36); | ||
expect(telemetry.config.stack[0].config.stack[0].handlers).toEqual(handlers); | ||
expect(telemetry.config.stack[0].config.stack[0].args).toEqual(["foo"]); | ||
expect(telemetry.config.stack[0].config.stack[0].fn).toEqual(basic); | ||
expect(telemetry.config.stack[0].config.stack[0].config.name).toEqual("telemetry"); | ||
}); | ||
@@ -97,3 +105,4 @@ | ||
expect(t.step).toEqual(i); | ||
expect(t.config).toEqual(config); | ||
expect(t.config.name).toEqual("telemetry"); | ||
expect(t.config.stack[0].fn).toEqual(basicMultistep); | ||
}); | ||
@@ -122,3 +131,4 @@ }); | ||
expect(t.result).toEqual(message); | ||
expect(t.config).toEqual(config); | ||
expect(t.config.name).toEqual("telemetry"); | ||
expect(t.config.stack[0].fn).toEqual(basicMultistep); | ||
expect(t.fn).toEqual(basicMultistep); | ||
@@ -133,3 +143,3 @@ }); | ||
}; | ||
var config = { onCommandComplete: onCommandComplete }; | ||
var config = { onCommandComplete: onCommandComplete, name: "badHandler" }; | ||
var now = Date.now(); | ||
@@ -149,3 +159,4 @@ var message = "oops"; | ||
expect(telemetry.result.message).toEqual("oops"); | ||
expect(telemetry.config).toEqual(config); | ||
expect(telemetry.config.name).toEqual("badHandler"); | ||
expect(telemetry.config.stack[0].fn).toEqual(badHandler); | ||
expect(telemetry.fn).toEqual(badHandler); | ||
@@ -152,0 +163,0 @@ }); |
{ | ||
"name": "effects-as-data", | ||
"version": "2.11.1", | ||
"version": "2.12.0", | ||
"description": "A micro abstraction layer for Javascript that makes writing, testing, and monitoring side-effects easy.", | ||
@@ -5,0 +5,0 @@ "main": "src/index.js", |
@@ -7,6 +7,7 @@ const { isGenerator, toArray, toPromise, delay, uuid } = require("./util") | ||
const el = newExecutionLog() | ||
config.cid = config.cid || uuid() | ||
config.stack = config.stack || [] | ||
config.stack.push({ | ||
config, | ||
const childConfig = Object.assign({}, config) | ||
childConfig.cid = childConfig.cid || uuid() | ||
const stack = config.stack || [] | ||
childConfig.stack = stack.concat({ | ||
config: childConfig, | ||
handlers, | ||
@@ -17,4 +18,4 @@ fn, | ||
const start = Date.now() | ||
onCall({ args, fn, config }) | ||
return run(config, handlers, fn, gen, null, el) | ||
onCall({ args, fn, config: childConfig }) | ||
return run(childConfig, handlers, fn, gen, null, el) | ||
.then(result => { | ||
@@ -26,3 +27,3 @@ const end = Date.now() | ||
result, | ||
config, | ||
config: childConfig, | ||
start, | ||
@@ -40,3 +41,3 @@ end, | ||
result: e, | ||
config, | ||
config: childConfig, | ||
start, | ||
@@ -43,0 +44,0 @@ end, |
@@ -39,8 +39,14 @@ const { call } = require("../index") | ||
await sleep(10) | ||
expect(telemetry.config.stack[0]).toEqual({ | ||
fn: basic, | ||
config, | ||
handlers, | ||
args: ["foo"] | ||
}) | ||
expect(telemetry.config.stack[0].fn).toEqual(basic) | ||
expect(telemetry.config.stack[0].handlers).toEqual(handlers) | ||
expect(telemetry.config.stack[0].args).toEqual(["foo"]) | ||
expect(telemetry.config.stack[0].config.onCommand).toEqual(onCommand) | ||
expect(telemetry.config.stack[0].config.name).toEqual("telemetry") | ||
expect(telemetry.config.stack[0].config.cid.length).toEqual(36) | ||
expect(telemetry.config.stack[0].config.stack[0].handlers).toEqual(handlers) | ||
expect(telemetry.config.stack[0].config.stack[0].args).toEqual(["foo"]) | ||
expect(telemetry.config.stack[0].config.stack[0].fn).toEqual(basic) | ||
expect(telemetry.config.stack[0].config.stack[0].config.name).toEqual( | ||
"telemetry" | ||
) | ||
}) | ||
@@ -57,8 +63,14 @@ | ||
await sleep(10) | ||
expect(telemetry.config.stack[0]).toEqual({ | ||
fn: basic, | ||
config, | ||
handlers, | ||
args: ["foo"] | ||
}) | ||
expect(telemetry.config.stack[0].fn).toEqual(basic) | ||
expect(telemetry.config.stack[0].handlers).toEqual(handlers) | ||
expect(telemetry.config.stack[0].args).toEqual(["foo"]) | ||
expect(telemetry.config.stack[0].config.onCommand).toEqual(onCommand) | ||
expect(telemetry.config.stack[0].config.name).toEqual("telemetry") | ||
expect(telemetry.config.stack[0].config.cid.length).toEqual(36) | ||
expect(telemetry.config.stack[0].config.stack[0].handlers).toEqual(handlers) | ||
expect(telemetry.config.stack[0].config.stack[0].args).toEqual(["foo"]) | ||
expect(telemetry.config.stack[0].config.stack[0].fn).toEqual(basic) | ||
expect(telemetry.config.stack[0].config.stack[0].config.name).toEqual( | ||
"telemetry" | ||
) | ||
}) | ||
@@ -83,3 +95,4 @@ | ||
expect(t.step).toEqual(i) | ||
expect(t.config).toEqual(config) | ||
expect(t.config.name).toEqual("telemetry") | ||
expect(t.config.stack[0].fn).toEqual(basicMultistep) | ||
}) | ||
@@ -108,3 +121,4 @@ }) | ||
expect(t.result).toEqual(message) | ||
expect(t.config).toEqual(config) | ||
expect(t.config.name).toEqual("telemetry") | ||
expect(t.config.stack[0].fn).toEqual(basicMultistep) | ||
expect(t.fn).toEqual(basicMultistep) | ||
@@ -119,3 +133,3 @@ }) | ||
} | ||
const config = { onCommandComplete } | ||
const config = { onCommandComplete, name: "badHandler" } | ||
const now = Date.now() | ||
@@ -135,3 +149,4 @@ const message = "oops" | ||
expect(telemetry.result.message).toEqual("oops") | ||
expect(telemetry.config).toEqual(config) | ||
expect(telemetry.config.name).toEqual("badHandler") | ||
expect(telemetry.config.stack[0].fn).toEqual(badHandler) | ||
expect(telemetry.fn).toEqual(badHandler) | ||
@@ -138,0 +153,0 @@ }) |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
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
233118
3751