github/oneuptime
1
1
Fork 0
mirror of https://github.com/OneUptime/oneuptime.git synced 2026-04-06 00:32:12 +02:00
Code Issues 193 Packages Projects Releases Wiki Activity

add support for arrays in workflows

Browse Source
This commit is contained in:
Simon Larsen
2023-06-07 11:39:44 +01:00
parent 7a2e44a404
commit 05d20e200f
1 changed files with 27 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
Workflow/Services/RunWorkflow.ts
View File

@@ -9,7 +9,6 @@ import ComponentMetadata, {
NodeType,
Port,
} from 'Common/Types/Workflow/Component';
import JSONFunctions from 'Common/Types/JSONFunctions';
import WorkflowService from 'CommonServer/Services/WorkflowService';
import ComponentCode, {
RunReturnType,
@@ -388,20 +387,38 @@ export default class RunWorkflow {
path: string
): JSONValue => {
const paths: Array<string> = path.split('.');
let current: any = JSONFunctions.parse(JSON.stringify(obj));
let current: any = JSON.parse(JSON.stringify(obj));
for (let i: number = 0; i < paths.length; ++i) {
if (
current &&
paths[i] &&
(current[(paths as any)[i] as any] as any) === undefined
) {
const key: string | undefined = paths[i];
if (!key) {
return undefined;
}
const openBracketIndex: number = key.indexOf('[');
const closeBracketIndex: number = key.indexOf(']');
if (openBracketIndex !== -1 && closeBracketIndex !== -1) {
const arrayKey: string = key.slice(0, openBracketIndex);
const index: number = parseInt(
key.slice(openBracketIndex + 1, closeBracketIndex)
);
if (
Array.isArray(current[arrayKey]) &&
current[arrayKey][index]
) {
current = current[arrayKey][index];
} else {
return undefined;
}
} else if (current && current[key] !== undefined) {
current = current[key];
} else {
return undefined;
} else if (current[paths[i] as string] === null) {
return null;
}
current = current[paths[i] as string];
}
return current;
};