frodovdr/node-red
1
0
Fork 0
mirror of https://github.com/node-red/node-red.git synced 2025-03-01 10:36:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

Refactor: extract method createLoadPromise

Browse Source 
No variable renames, just lines moved.
This commit is contained in:
Håkon Løvdal 2023-09-17 18:58:00 +02:00
parent 71bdd65b8a
commit 3bf1667181
1 changed files with 26 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
packages/node_modules/@node-red/registry/lib/loader.js vendored
View File

@ -344,30 +344,9 @@ function loadNodeSet(node) {
} else { } else {
} }
try { try {
var loadPromise = null;
var r = require(node.file); var r = require(node.file);
r = r.__esModule ? r.default : r; r = r.__esModule ? r.default : r;
if (typeof r === "function") { return createLoadPromise(node, r);
var red = registryUtil.createNodeApi(node);
var promise = r(red);
if (promise != null && typeof promise.then === "function") {
loadPromise = promise.then(function() {
node.enabled = true;
node.loaded = true;
return node;
}).catch(function(err) {
node.err = err;
return node;
});
}
}
if (loadPromise == null) {
node.enabled = true;
node.loaded = true;
loadPromise = Promise.resolve(node);
}
return loadPromise;
} catch(err) { } catch(err) {
node.err = err; node.err = err;
var stack = err.stack; var stack = err.stack;
@ -391,6 +370,31 @@ function loadNodeSet(node) {
} }
return Promise.resolve(node); return Promise.resolve(node);
} }
function createLoadPromise(node, r) {
var loadPromise = null;
if (typeof r === "function") {
var red = registryUtil.createNodeApi(node);
var promise = r(red);
if (promise != null && typeof promise.then === "function") {
loadPromise = promise.then(function () {
node.enabled = true;
node.loaded = true;
return node;
}).catch(function (err) {
node.err = err;
return node;
});
}
}
if (loadPromise == null) {
node.enabled = true;
node.loaded = true;
loadPromise = Promise.resolve(node);
}
return loadPromise;
}
} }
async function loadPlugin(plugin) { async function loadPlugin(plugin) {