dennii/dbgate
1
0
Fork 0
mirror of https://github.com/DeNNiiInc/dbgate.git synced 2026-04-18 00:56:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

yaml replace changed

Browse Source
This commit is contained in:
Jan Prochazka
2024-12-28 21:16:52 +01:00
parent bd0404fbaf
commit 2858bba8b2
2 changed files with 45 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files

58
common/processWorkflows.js
View File

@@ -42,6 +42,18 @@ function processJsonStep(json, args) {
if (conditionMatch(item._if, args)) {
res.push(_.omit(item, ['_if']));
}
} else if (item._replace || item._include) {
const replaceWith = item._replace ? args.replace?.[item._replace] : includes[item._include];
if (replaceWith) {
modified = true;
if (_.isArray(replaceWith)) {
res.push(...replaceWith);
} else {
res.push(replaceWith);
}
} else {
res.push(item);
}
} else {
res.push(item);
}
@@ -49,27 +61,27 @@ function processJsonStep(json, args) {
return res;
}
if (value?.run && _.isArray(value.run)) {
const newrun = [];
for (const item of value.run) {
let replaced = false;
for (const repl of args.run) {
if (item == repl.from) {
replaced = true;
modified = true;
newrun.push(...repl.to);
break;
}
}
if (!replaced) {
newrun.push(item);
}
}
return {
...value,
run: newrun,
};
}
// if (value?.run && _.isArray(value.run)) {
// const newrun = [];
// for (const item of value.run) {
// let replaced = false;
// for (const repl of args.run) {
// if (item == repl.from) {
// replaced = true;
// modified = true;
// newrun.push(...repl.to);
// break;
// }
// }
// if (!replaced) {
// newrun.push(item);
// }
// }
// return {
// ...value,
// run: newrun,
// };
// }
if (_.isPlainObject(value)) {
if (_.intersection(args.allNames ?? [], Object.keys(value))?.length > 0) {
@@ -81,6 +93,10 @@ function processJsonStep(json, args) {
if (value?._include) {
return includes[value?._include];
}
if (value?._replace) {
return args?.replace[value?._replace];
}
});
}