New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More →
node-cls - npm Package Compare versions
Comparing version 1.0.2 to 1.0.3
| ## Release notes | ||
| __1.0.3__ | ||
| Saving node_cls on process. | ||
| __1.0.2__ | ||
@@ -3,0 +5,0 @@ Travis CI and code coverage. |
171
index.js
@@ -1,164 +0,9 @@ | ||
| let fs = require('fs'); | ||
| let ah = require('async_hooks'); | ||
| let major = require('./major'); | ||
| let NODE_CLS = 'node_cls.d8b58a39'; | ||
| let stack = {}; | ||
| let cls = function(ns) { | ||
| let wrapper = { | ||
| run: (fn) => { | ||
| let c = cls.create(ns); | ||
| return c.run(fn); | ||
| } | ||
| }; | ||
| return wrapper; | ||
| }; | ||
| cls._stack = stack; | ||
| cls.create = createContext; | ||
| cls.getContext = getContext; | ||
| cls.get = getContext; | ||
| cls.exit = exitContext; | ||
| cls.debug = false; | ||
| Object.defineProperty(cls, 'active', { | ||
| enumerable: true, | ||
| get: getContext | ||
| }); | ||
| function createContext(ns) { | ||
| let c = {}; | ||
| Object.defineProperty(c, 'run', { | ||
| enumerable: false, | ||
| writable: false, | ||
| value: run | ||
| }); | ||
| Object.defineProperty(c, 'start', { | ||
| enumerable: false, | ||
| writable: false, | ||
| value: start | ||
| }); | ||
| return c; | ||
| function run(cb) { | ||
| return Promise.resolve(1) | ||
| .then(() => { | ||
| log('start context ' + ah.executionAsyncId()); | ||
| stack[ah.executionAsyncId()].contexts[ns] = c; | ||
| return cb(); | ||
| }); | ||
| } | ||
| function start() { | ||
| if (major < 12) | ||
| throw new Error('start() is not supported in nodejs < v12.0.0'); | ||
| return Promise.resolve(1).then(() => { | ||
| stack[ah.executionAsyncId()].contexts[ns] = c; | ||
| }); | ||
| } | ||
| } | ||
| function getAllContexts(asyncId, obj) { | ||
| obj = obj || {}; | ||
| if (!stack[asyncId]) | ||
| return; | ||
| for (var ns in stack[asyncId].contexts) { | ||
| if (!obj[ns]) { | ||
| obj[ns] = stack[asyncId].contexts[ns]; | ||
| } | ||
| } | ||
| getAllContexts(stack[asyncId].parent, obj); | ||
| return obj; | ||
| } | ||
| function getContext(ns, asyncId, cur = []) { | ||
| asyncId = asyncId || ah.executionAsyncId(); | ||
| let current = stack[asyncId]; | ||
| if (!current) | ||
| return; | ||
| if (current.contexts[ns]) | ||
| return current.contexts[ns]; | ||
| if (current.parent) { | ||
| cur.push(current.parent); | ||
| return getContext(ns, current.parent, cur); | ||
| } | ||
| } | ||
| async function exitContext(ns) { | ||
| log('exit Context'); | ||
| let asyncId = ah.executionAsyncId(); | ||
| let context = getContext(ns); | ||
| if (!context) | ||
| return; | ||
| let node = stack[asyncId]; | ||
| if (node && node.contexts[ns] === context) | ||
| delete node.contexts[ns]; | ||
| exitContextUp(context, ns, asyncId); | ||
| return Promise.resolve(); | ||
| } | ||
| function exitContextUp(context, ns, asyncId) { | ||
| if (!stack[asyncId]) | ||
| return; | ||
| log('exit ' + asyncId); | ||
| let parentId = stack[asyncId].parent; | ||
| let parent = stack[parentId]; | ||
| if (parent) { | ||
| if (parent.contexts[ns] === context) | ||
| delete parent.contexts[ns]; | ||
| else if (parent.contexts[ns]) | ||
| return; | ||
| exitContextUp(context, ns, parentId); | ||
| } | ||
| } | ||
| let hook = ah.createHook({ | ||
| init, | ||
| destroy | ||
| }); | ||
| hook.enable(); | ||
| function init(asyncId, type, triggerId) { | ||
| let node = { | ||
| contexts: {} | ||
| }; | ||
| Object.defineProperty(node, 'id', { | ||
| enumerable: false, | ||
| value: asyncId | ||
| }); | ||
| Object.defineProperty(node, 'parent', { | ||
| enumerable: false, | ||
| value: triggerId | ||
| }); | ||
| Object.defineProperty(node, 'children', { | ||
| enumerable: false, | ||
| value: {} | ||
| }); | ||
| stack[asyncId] = node; | ||
| if (stack[triggerId]) { | ||
| stack[triggerId].children[asyncId] = node; | ||
| } | ||
| } | ||
| function log(str) { | ||
| if (cls.debug) | ||
| fs.writeSync(1, `${str}\n`); | ||
| } | ||
| function destroy(asyncId) { | ||
| log('destroy ' + asyncId); | ||
| if (stack[asyncId]) { | ||
| let contexts = getAllContexts(asyncId); | ||
| for (let childId in stack[asyncId].children) { | ||
| let child = stack[asyncId].children[childId]; | ||
| for (let ns in contexts) { | ||
| child.contexts[ns] = child.contexts[ns] || contexts[ns]; | ||
| } | ||
| } | ||
| } | ||
| delete stack[asyncId]; | ||
| } | ||
| module.exports = cls; | ||
| if (process[NODE_CLS]) | ||
| module.exports = process[NODE_CLS]; | ||
| else { | ||
| let cls = require('./index-core'); | ||
| process[NODE_CLS] = cls; | ||
| module.exports = process[NODE_CLS]; | ||
| } |
| { | ||
| "name": "node-cls", | ||
| "version": "1.0.2", | ||
| "version": "1.0.3", | ||
| "description": "Continuation Local Storage based on async_hooks", | ||
@@ -32,4 +32,4 @@ "main": "index.js", | ||
| "coveralls": "^3.0.6", | ||
| "eslint": "^6.1.0", | ||
| "eslint-plugin-jest": "^22.15.1", | ||
| "eslint": "^6.6.0", | ||
| "eslint-plugin-jest": "^23.0.4", | ||
| "jest": "^24.9.0" | ||
@@ -36,0 +36,0 @@ }, |
New alerts
Major refactor
Supply chain riskPackage has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.
Found 1 instance in 1 package
Fixed alerts
Major refactor
Supply chain riskPackage has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.
Found 1 instance in 1 package
Network access
Supply chain riskThis module accesses the network.
Found 1 instance in 1 package
Improved metrics
- Number of medium supply chain risk alerts
- decreased by-50%
1
Worsened metrics
- Total package byte prevSize
- decreased by-83.55%
15542
- Number of package files
- decreased by-60.87%
9
- Lines of code
- decreased by-65.45%
323
No dependency changes