Do you want to add this suggestion?
{
setVariableInfo({
"name": variable.name,
"description": variable.description,
"value": variable.value,
"index": index,
})
if (type === "normal") {
setVariablesModalOpen(true);
} else if (type === "exec") {
setExecutionVariablesModalOpen(true);
} else {
console.log("Unknown type: ", type)
}
}}
>
Name: {variable.name}
What are{" "}
Workflow variables?
{workflow.workflow_variables === null
? null
: workflow.workflow_variables.map((variable, varindex) => {
return (
{thisview}
{triggers.map((trigger, index) => {
/*
if (trigger.trigger_type === "PIPELINE") {
if (userdata.support !== true) {
return null
}
}
*/
// Hiding since March 2024
if (trigger.trigger_type === "EMAIL") {
return null
}
const imagesize = isMobile ? 40 : trigger.large_image.includes("svg") ? 50 : 50
var imageline = trigger.large_image.length === 0 ? ![]()
:
const title = trigger.trigger_type === "WEBHOOK" ? "Workflow starters" : trigger.trigger_type === "SUBFLOW" ? "Mid-Workflow" : ""
const color = trigger.is_valid ? green : yellow;
return (
{title.length > 0 ?
{title}
: null}
{
handleTriggerDrag(e, trigger);
}}
onStop={(e) => {
handleDragStop(e);
}}
dragging={false}
position={{
x: 0,
y: 0,
}}
>
{ }}>
{imageline}
{isMobile ? null :
{trigger.name}
{trigger.description}
}
);
})}
-
{hits.length === 0 ?
{
clickedApp(hit)
}}>
{
setMouseHoverIndex(index)
}}>
{avatar}
*/}
{visibleApps.map((app, index) => {
if (app.invalid) {
return null
}
if (app.trigger_type === "PIPELINE" && userdata.support !== true) {
return null
}
if (app.id === "integration" && userdata.support !== true) {
return null
}
if (viewedApps.includes(app.id)) {
return null
}
viewedApps.push(app.id)
var extraMessage = ""
if (index == 2) {
extraMessage =
}
delay += 75
return (
runDelay ?
{/**/}
*/}
:
Apps need to be activated before they can be used. Search from our 2500+ apps to activate them for your organisation.
}
) : apps.length > 0 ? (
{extraMessage}
)
})}
{visibleApps.length <= 2 ?
{
}}
>
Click one of the relevant public apps below to Activate it for your organization.
{
console.log("CLICKED")
}}>
:
{
console.log("Should load in extra apps?")
}}
>
Couldn't find the apps you were looking for? Searching unactivated apps. Click one of these apps to Activate it for your organisation.
{
console.log("CLICKED")
}}>
) : (
{data.name}
{
setSourceValue(condition.source);
setConditionValue(condition.condition);
setDestinationValue(condition.destination);
setConditionsModalOpen(true);
}}
>
{condition.source.value}
{ }}
>
{condition.condition.value}
{condition.destination.value}
Branch: Conditions - {selectedEdgeIndex}
What are conditions?Conditions
{injectedData}
{/* Check if dest is the same as start */}
{conditionsDisabled ?
{selectedTrigger.status === "running" ? null : (
{outlookButton}
{gmailButton}
If you have trouble using this trigger, please contact us to get access
)}
{triggerFolders === undefined || triggerFolders === null ? null : (
{triggerFolders.length === 0 ?
No folders found. Please authenticate first. If this persists, contact us.
:
}
)}
);
} else if (triggerAuthentication.type === "gmail") {
console.log("AUTH: ", triggerAuthentication);
triggerInfo = "SPECIAL GMAIL";
}
}
// Check
const argumentView =
Object.getOwnPropertyNames(triggerAuthentication).length > 0 ? (
Change auth
Select {triggerAuthentication.type === "gmail" ? "labels" : "a folder"}
{triggerInfo}
) : (
Login
{selectedTrigger.app_name}: {selectedTrigger.status}
What are email triggers?Name
Environment:
*/}
{Object.entries(transformedAuthData).map(([appId, authList]) => (
))}
);
};
const SubflowSidebar = () => {
const [menuPosition, setMenuPosition] = useState(null);
const [showDropdown, setShowDropdown] = React.useState(false);
const [actionlist, setActionlist] = React.useState([]);
if (actionlist.length === 0) {
// FIXME: Have previous execution values in here
actionlist.push({
type: "Execution Argument",
name: "Execution Argument",
value: "$exec",
highlight: "exec",
autocomplete: "exec",
example: "hello",
})
actionlist.push({
type: "Shuffle Database",
name: "Shuffle Database",
value: "$shuffle_cache",
highlight: "shuffle_db",
autocomplete: "shuffle_cache",
example: "hello",
})
if (
workflow.workflow_variables !== null &&
workflow.workflow_variables !== undefined &&
workflow.workflow_variables.length > 0
) {
for (let varkey in workflow.workflow_variables) {
const item = workflow.workflow_variables[varkey];
actionlist.push({
type: "workflow_variable",
name: item.name,
value: item.value,
id: item.id,
autocomplete: `${item.name.split(" ").join("_")}`,
example: item.value,
});
}
}
// FIXME: Add values from previous executions if they exist
if (
workflow.execution_variables !== null &&
workflow.execution_variables !== undefined &&
workflow.execution_variables.length > 0
) {
for (let varkey in workflow.execution_variables) {
const item = workflow.execution_variables[varkey];
actionlist.push({
type: "execution_variable",
name: item.name,
value: item.value,
id: item.id,
autocomplete: `${item.name.split(" ").join("_")}`,
example: "",
});
}
}
var parents = getParents(selectedTrigger);
if (parents.length > 1) {
for (let parentkey in parents) {
const item = parents[parentkey];
if (item.label === "Execution Argument") {
continue;
}
var exampledata = item.example === undefined ? "" : item.example;
// Find previous execution and their variables
if (workflowExecutions.length > 0) {
// Look for the ID
for (let execkey in workflowExecutions) {
if (
workflowExecutions[execkey].results === undefined ||
workflowExecutions[execkey].results === null
) {
continue;
}
var foundResult = workflowExecutions[execkey].results.find(
(result) => result.action.id === item.id
);
if (foundResult === undefined) {
continue;
}
const validated = validateJson(foundResult.result)
if (validated.valid) {
exampledata = validateJson.result
break
}
}
}
// 1. Take
const actionvalue = {
type: "action",
id: item.id,
name: item.label,
autocomplete: `${item.label.split(" ").join("_")}`,
example: exampledata,
}
actionlist.push(actionvalue);
}
}
setActionlist(actionlist);
}
const handleMenuClose = () => {
setUpdate(Math.random());
setMenuPosition(null);
};
const handleItemClick = (values) => {
console.log("VALUES: ", values)
if (values === undefined || values === null || values.length === 0) {
return;
}
/*
workflow.triggers[selectedTriggerIndex].parameters[1].value
.trim()
.endsWith("$")
? values[0].autocomplete
: "$" + values[0].autocomplete;
for (var key in values) {
if (key === 0 || values[key].autocomplete.length === 0) {
continue;
}
toComplete += values[key].autocomplete
}
*/
console.log("SELECTED TRIGGER: ", selectedTrigger)
if (selectedTrigger.name === "Shuffle Workflow") {
const toComplete = selectedTrigger.parameters[1].value + "$" + values[0].autocomplete
selectedTrigger.parameters[1].value = toComplete
setSelectedTrigger(selectedTrigger)
}
setUpdate(Math.random());
setShowDropdown(false);
setMenuPosition(null);
};
const iconStyle = {
marginRight: 15,
};
if (Object.getOwnPropertyNames(selectedTrigger).length > 0) {
if (workflow.triggers[selectedTriggerIndex] === undefined) {
return null;
}
if (
workflow.triggers[selectedTriggerIndex].parameters === undefined ||
workflow.triggers[selectedTriggerIndex].parameters === null ||
workflow.triggers[selectedTriggerIndex].parameters.length === 0
) {
workflow.triggers[selectedTriggerIndex].parameters = [];
workflow.triggers[selectedTriggerIndex].parameters[0] = {
name: "workflow",
value: "",
};
workflow.triggers[selectedTriggerIndex].parameters[1] = {
name: "argument",
value: "",
};
workflow.triggers[selectedTriggerIndex].parameters[2] = {
name: "user_apikey",
value: "",
};
workflow.triggers[selectedTriggerIndex].parameters[3] = {
name: "startnode",
value: "",
};
workflow.triggers[selectedTriggerIndex].parameters[4] = {
name: "check_result",
value: "false",
};
workflow.triggers[selectedTriggerIndex].parameters[5] = {
name: "auth_override",
value: "",
};
/*
// API-key has been replaced by auth key for the execution.
// Parents can now automatically execute children without auth from a user, as long as the subflow in question is owned by the same org and the subflow is actually referencing it during checkin.
console.log("SETTINGS: ", userSettings);
if (
userSettings !== undefined &&
userSettings !== null &&
userSettings.apikey !== null &&
userSettings.apikey !== undefined &&
userSettings.apikey.length > 0
) {
workflow.triggers[selectedTriggerIndex].parameters[2] = {
name: "user_apikey",
value: userSettings.apikey,
};
}
*/
}
const handleSubflowStartnodeSelection = (e) => {
setSubworkflowStartnode(e.target.value);
if (e.target.value === null || e.target.value === undefined) {
return
}
const branchId = uuidv4();
const newbranch = {
source_id: workflow.triggers[selectedTriggerIndex].id,
destination_id: e.target.value.id,
source: workflow.triggers[selectedTriggerIndex].id,
target: e.target.value.id,
has_errors: false,
id: branchId,
_id: branchId,
label: "Subflow",
decorator: true,
};
if (workflow.visual_branches !== undefined) {
if (workflow.visual_branches === null) {
workflow.visual_branches = [newbranch];
} else if (workflow.visual_branches.length === 0) {
workflow.visual_branches.push(newbranch);
} else {
const foundIndex = workflow.visual_branches.findIndex(
(branch) => branch.source_id === newbranch.source_id
);
if (foundIndex !== -1) {
const currentEdge = cy.getElementById(
workflow.visual_branches[foundIndex].id
);
if (
currentEdge !== undefined &&
currentEdge !== null
) {
currentEdge.remove();
}
}
workflow.visual_branches.splice(foundIndex, 1);
workflow.visual_branches.push(newbranch);
}
}
if (workflow.id === subworkflow.id) {
const cybranch = {
group: "edges",
source: newbranch.source_id,
target: newbranch.destination_id,
id: branchId,
data: newbranch,
};
cy.add(cybranch);
}
console.log("Value to be set: ", e.target.value);
try {
workflow.triggers[
selectedTriggerIndex
].parameters[3].value = e.target.value.id;
} catch {
workflow.triggers[selectedTriggerIndex].parameters[3] =
{
name: "startnode",
value: e.target.value.id,
};
}
setWorkflow(workflow);
}
const subflowtypes = [
{
name: "Any",
},
{
name: "Enrich",
}
]
return (
{selectedTrigger.app_name}
Wait for results
}
/>
Select a workflow to execute
Select the Startnode
Execution Argument
API-key
Auth Override
Comment
What are comments?Name
Height
Width
Background
Text Color
Background-Image
{selectedTrigger.app_name}: {selectedTrigger.status}
What are webhooks?Name
Parameters
{
}}
helperText={
workflow.triggers[selectedTriggerIndex].parameters[0].value !== undefined &&
workflow.triggers[selectedTriggerIndex].parameters[0].value !== null &&
(workflow.triggers[
selectedTriggerIndex
].parameters[0].value.includes("localhost") ||
workflow.triggers[
selectedTriggerIndex
].parameters[0].value.includes("127.0.0.1")) ? (
PS: This does NOT work with localhost. Use your local IP
instead.
) : null
}
InputProps={{
style: {
},
endAdornment:
{
var copyText = document.getElementById("webhook_uri_field");
if (copyText !== undefined && copyText !== null) {
console.log("NAVIGATOR: ", navigator);
const clipboard = navigator.clipboard;
if (clipboard === undefined) {
toast("Can only copy over HTTPS (port 3443)");
return;
}
navigator.clipboard.writeText(copyText.value);
copyText.select();
copyText.setSelectionRange(
0,
99999
); /* For mobile devices */
/* Copy the text inside the text field */
document.execCommand("copy");
toast("Copied Webhook URL");
} else {
console.log("Couldn't find webhook URI field: ", copyText);
}
}}
edge="end"
>
}}
fullWidth
disabled
value={
workflow.triggers[selectedTriggerIndex].parameters[0].value
}
color="primary"
placeholder="10"
onBlur={(e) => {
setTriggerCronWrapper(e.target.value);
}}
/>
{ }}
InputProps={{
style: {
},
}}
fullWidth
multiline
rows="4"
defaultValue={trigger_header_auth}
color="primary"
disabled={selectedTrigger.status === "running"}
placeholder={"AUTH_HEADER=AUTH_VALUE1"}
onBlur={(e) => {
const value = e.target.value;
if (selectedTrigger.parameters === null) {
selectedTrigger.parameters = [];
}
workflow.triggers[selectedTriggerIndex].parameters[2] = {
value: value,
name: "auth_headers",
};
setWorkflow(workflow);
}}
/>
{ }}
InputProps={{
style: {
},
}}
fullWidth
multiline
rows="2"
color="primary"
disabled={selectedTrigger.status === "running"}
placeholder={"OK"}
onBlur={(e) => {
const value = e.target.value;
if (selectedTrigger.parameters === null) {
selectedTrigger.parameters = [];
}
workflow.triggers[selectedTriggerIndex].parameters[3] = {
value: value,
name: "custom_response_body",
};
setWorkflow(workflow);
}}
/>
{workflow.triggers[selectedTriggerIndex].parameters.length > 4 ?
{
if (selectedTrigger.parameters === null) {
selectedTrigger.parameters = [];
}
// Sets the webhook to run as version 2.. kinda
var value = "v2"
if (workflow.triggers[selectedTriggerIndex].parameters[4].value.includes("v2")) {
value = "v1"
}
workflow.triggers[selectedTriggerIndex].parameters[4] = {
name: "await_response",
value: value
}
setWorkflow(workflow)
setUpdate(Math.random())
}}
color="primary"
value="await_response"
/>
}
label={
: null}
Webhook URI
Authentication headers
Custom Response
Wait For Response
}
/>
{selectedTrigger.app_name}
What is the user input trigger?Name
Environment:
*/}
Information
The information you want to show the user. Supports variables.
Input options
Use subflows to connect to any app you want, or use the default email and sms options
Subflow
}
/>
Email
}
/>
SMS
}
/>
{workflows === undefined ||
workflows === null ||
workflows.length === 0 ? null : (
option.id === value.id}
getOptionLabel={(option) => {
if (option === undefined || option === null || option.name === undefined || option.name === null) {
return "No Workflow Selected";
}
const newname = (option.name.charAt(0).toUpperCase() + option.name.substring(1)).replaceAll("_", " ");
return newname;
}}
options={workflows}
fullWidth
style={{
backgroundColor: theme.palette.inputColor,
height: 50,
borderRadius: theme.palette.borderRadius,
marginTop: 15,
marginBottom: 15,
}}
onChange={(event, newValue) => {
console.log("Changed autocomplete!")
handleWorkflowSelectionUpdate({ target: { value: newValue } }, true)
event.target.blur();
}}
renderOption={(props, data, state) => {
if (data.id === workflow.id) {
data = workflow;
}
return (
{data.image !== undefined && data.image !== null && data.image.length > 0 ?
: null}
Choose Trigger '{data.name}'
}>
)
}}
renderInput={(params) => {
return (
) : null}
{workflow.triggers[selectedTriggerIndex].parameters[2] !==
undefined &&
workflow.triggers[selectedTriggerIndex].parameters[2].value.includes("email") ? (
{selectedTrigger.app_name}: {selectedTrigger.status}
What are pipelines?Name
Parameters
{
// setSelectedOption("Syslog listener")
// setTenzirConfigModalOpen(true);
}}
style={{
border: "1px solid rgba(255,255,255,0.3)",
borderRadius: theme.palette.borderRadius,
padding: 10,
cursor: "not-allowed",
marginTop: 5,
display: "flex",
alignItems: "center",
}}
>
setSelectedOption("Syslog listener")}
value={"Syslog listener"}
name="option"
disabled={true}
/>
}
label="Start Syslog listener"
/>
{
// setSelectedOption("Sigma Rulesearch")
// setTenzirConfigModalOpen(true);
}}
style={{
border: "1px solid rgba(255,255,255,0.3)",
borderRadius: theme.palette.borderRadius,
padding: 10,
cursor: "not-allowed",
marginTop: 5,
display: "flex",
alignItems: "center",
}}
>
setSelectedOption("Sigma Rulesearch")}
value={"Sigma Rulesearch"}
name="option"
disabled={true}
/>
}
label="Run Sigma Rulesearch"
/>
{
if(selectedTrigger.status === "running"){
toast("please stop the trigger to edit the configuration");
return;
} else {
setSelectedOption("Kafka Queue");
setTenzirConfigModalOpen(true);
}}}
style={{
border: "1px solid rgba(255,255,255,0.3)",
borderRadius: theme.palette.borderRadius,
padding: 10,
cursor: "pointer",
marginTop: 5,
display: "flex",
alignItems: "center",
}}
>
setSelectedOption("Kafka Queue")}
value={"Kafka Queue"}
name="option"
/>
}
label="Follow Kafka Queue"
/>
{selectedTrigger.app_name}: {selectedTrigger.status}
What are schedules?Name
Parameters
{
setTriggerCronWrapper(e.target.value);
}}
/>
{/*selectedTrigger.environment === "cloud" ?
1 ? workflow.triggers[selectedTriggerIndex].parameters[1].value : ""
}
placeholder='{"example": {"json": "is cool"}}'
onBlur={(e) => {
setTriggerBodyWrapper(e.target.value);
}}
/>
Interval (UTC)
Execution argument:
{workflow.name}
{parentWorkflows.slice(0,5).map((wf, index) => {
return (
{wf.image !== undefined && wf.image !== null && wf.image.length > 0 ?
: null}
Parent workflow: '{wf.name}'
} placement="bottom">
{
console.log("Click: ", wf)
}}>
)
})}
{connectedUsers.map((user) => {
return (
)
}
const shownErrors = !distributedFromParent && !isMobile && workflow.errors !== undefined && workflow.errors !== null && workflow.errors.length > 0 && showErrors && (!workflow.public || userdata.support === true) ?
- {newerror}
)
})}
setHovered(true)}
onMouseLeave={() => setHovered(false)}
onClick={() => {
setExecutionModalOpen(true);
getWorkflowExecution(props.match.params.key, "");
}}
>
Explore runs
)
}
// Used for handling suborg workflow distribution management
const updateCurrentWorkflow = (inputworkflow) => {
setLastSaved(false)
setSelectedAction({});
setSelectedApp({})
setWorkflow(inputworkflow)
// Update props match key
if (inputworkflow.parentorg_workflow !== undefined && inputworkflow.parentorg_workflow !== null && inputworkflow.parentorg_workflow !== "") {
setDistributedFromParent(inputworkflow.parentorg_workflow)
} else {
setDistributedFromParent("")
}
if (cy !== undefined) {
cy.removeListener("select");
cy.removeListener("unselect");
cy.removeListener("add");
cy.removeListener("remove");
cy.removeListener("mouseover");
cy.removeListener("mouseout");
cy.removeListener("drag");
cy.removeListener("free");
cy.removeListener("cxttap");
setElements([])
// Remove all edges
cy.edges().remove()
cy.nodes().remove()
}
// Remove all cytoscape triggers first?
/*
setTimeout(() => {
setupGraph(inputworkflow)
cy.on("select", "node", (e) => {
onNodeSelect(e, appAuthentication);
});
cy.on("select", "edge", (e) => onEdgeSelect(e));
cy.on("unselect", (e) => onUnselect(e));
cy.on("add", "node", (e) => onNodeAdded(e));
cy.on("add", "edge", (e) => onEdgeAdded(e));
cy.on("remove", "node", (e) => onNodeRemoved(e));
cy.on("remove", "edge", (e) => onEdgeRemoved(e));
cy.on("mouseover", "edge", (e) => onEdgeHover(e));
cy.on("mouseout", "edge", (e) => onEdgeHoverOut(e));
cy.on("mouseover", "node", (e) => onNodeHover(e));
cy.on("mouseout", "node", (e) => onNodeHoverOut(e));
// Handles dragging
cy.on("drag", "node", (e) => onNodeDrag(e, selectedAction));
cy.on("free", "node", (e) => onNodeDragStop(e, selectedAction));
cy.on("cxttap", "node", (e) => onCtxTap(e));
}, 25)
*/
}
// Uses Org-Id referencing header to create a workflow while getting it in realtime
// This further ensures the user needs access to GET the workflow properly
const duplicateParentWorkflow = (inputWorkflow, org_id, setWorkflow) => {
fetch(`${globalUrl}/api/v1/workflows/${inputWorkflow.id}`, {
method: "GET",
headers: {
"Org-Id": org_id,
"Content-Type": "application/json",
},
credentials: "include",
})
.then((response) => {
if (response.status === 200) {
getChildWorkflows(inputWorkflow.id)
}
return response.json();
})
.then((responseJson) => {
if (responseJson.success === false) {
//toast("Failed to duplicate workflow")
} else {
//toast("Successfully duplicated workflow. Reloading child workflows.")
if (setWorkflow === true) {
updateCurrentWorkflow(responseJson)
}
}
})
.catch((error) => {
console.log("Dupe workflow for suborg error: ", error.toString())
})
}
const BottomCytoscapeBar = () => {
if (workflow.id === undefined || workflow.id === null || (!workflow.public && apps.length === 0)) {
return null;
}
const boxSize = isMobile ? 50 : 100;
const executionButton = executionRunning ? (
{executionButton}
);
};
const addCommentNode = () => {
const newId = uuidv4();
const position = {
x: 300,
y: 300,
};
cy.add({
group: "nodes",
data: {
id: newId,
label: "Click to write a comment",
type: "COMMENT",
is_valid: true,
decorator: true,
width: 250,
height: 150,
position: position,
backgroundcolor: "#1f2023",
color: "#ffffff",
},
position: position,
});
};
const RightSideBar = (props) => {
var defaultReturn = null
if (Object.getOwnPropertyNames(selectedComment).length > 0) {
defaultReturn =
{isMobile || workflow.public ? null : (
{
setExecutionText(e.target.value);
}}
/>
)}
{/*userdata.avatar === creatorProfile.github_avatar ? null :*/}
{workflow.public || userdata.support == true ? (
) : null}
{workflow.configuration !== null &&
workflow.configuration !== undefined &&
workflow.configuration.exit_on_error !== undefined ? (
{defaultReturn}
{workflow.tags.map((tag, index) => {
if (index >= 3) {
return null;
}
return (
{
setLeftViewOpen(true);
setLeftBarSize(350);
}}
>
Execution Argument
{executionData.execution_argument}
{workflowExecutions.map((data, index) => {
executionDelay += 50
const statusColor =
data.status === "FINISHED"
? green : data.status === "ABORTED" || data.status === "FAILED"
? "red"
: yellow;
const successActions =
data.results !== undefined && data.results !== null
? data.results.filter((result) => result.status === "SUCCESS").length
: 0
const skippedActions = data.results !== undefined && data.results !== null ?
data.results.filter((result) => result.status === "SKIPPED").length
: 0
const timestamp = new Date(data.started_at * 1000)
.toLocaleString("en-GB")
.split(".")[0]
.split("T")
.join(" ");
var calculatedResult =
data.workflow.actions !== undefined &&
data.workflow.actions !== null
? data.workflow.actions.length
: 0;
if (data.workflow.triggers !== undefined && data.workflow.triggers !== null) {
for (let triggerkey in data.workflow.triggers) {
const trigger = data.workflow.triggers[triggerkey];
if (
(trigger.app_name === "User Input" &&
trigger.trigger_type === "USERINPUT") ||
(trigger.app_name === "Shuffle Workflow" &&
trigger.trigger_type === "SUBFLOW")
) {
calculatedResult += 1;
}
}
}
const foundnotifications = data.notifications_created === undefined || data.notifications_created === null ? 0 : data.notifications_created
return (
{/**/}
{ }}
onMouseOut={() => { }}
onClick={() => {
if ((data.result === undefined || data.result === null || data.result.length === 0) && data.status !== "FINISHED" && data.status !== "ABORTED") {
start()
setExecutionRunning(true)
setExecutionRequestStarted(false)
}
navigate(`?execution_id=${data.execution_id}`)
// Ensuring we have the latest version of the result.
// Especially important IF the result is > 1 Mb in cloud
var checkStarted = false
if (data.results !== undefined && data.results !== null && data.results.length > 0) {
if (data.execution_argument !== undefined && data.execution_argument !== null && data.execution_argument.includes("too large")) {
setExecutionData({});
checkStarted = true
start();
setExecutionRunning(true);
setExecutionRequestStarted(false);
} else {
if (data.results !== undefined && data.results !== null) {
for (let resultkey in data.results) {
if (data.results[resultkey].status !== "SUCCESS") {
continue
}
if (data.results[resultkey].result.includes("too large")) {
setExecutionData({});
checkStarted = true
start();
setExecutionRunning(true);
setExecutionRequestStarted(false);
break
}
}
}
}
}
const cur_execution = {
execution_id: data.execution_id,
authorization: data.authorization,
}
setExecutionRequest(cur_execution)
setExecutionModalView(1)
if (!checkStarted) {
handleUpdateResults(data, cur_execution)
if (cy !== undefined && cy !== null) {
cy.elements().removeClass("success-highlight failure-highlight executing-highlight");
for (let actionKey in data.workflow.actions) {
var actionitem = data.workflow.actions[actionKey]
handleColoring(actionitem.id, "", actionitem.label)
}
for (let resultKey in data.results) {
var item = data.results[resultKey]
handleColoring(item.action.id, item.status, item.action.label)
}
}
setExecutionData(data)
}
}}
>
0 ? ` Authgroup: ${data.authgroup}` : '')}
placement="left"
>
) : null}
{foundnotifications > 0 ?
{
e.preventDefault()
e.stopPropagation()
window.open(`/admin?admin_tab=priorities&workflow=${data.workflow.id}&execution_id=${data.execution_id}`, "_blank")
}}
/>
: null}
{lastExecution === data.execution_id ? (
);
})}
) : (
{getExecutionSourceImage(data)}
{timestamp}
{data.workflow.actions !== null ? (
{successActions} + {skippedActions > 0 ? skippedActions : {skippedActions}} = {calculatedResult}
{ const cursearch = typeof window === "undefined" || window.location === undefined ? "" : window.location.search; const newitem = removeParam("execution_id", cursearch); navigate(curpath + newitem) setExecutionRunning(false); stop() }} > See more runs
Details
{executionData.status !== undefined &&
executionData.status !== "ABORTED" &&
executionData.status !== "FINISHED" &&
executionData.status !== "FAILURE" &&
executionData.status !== "WAITING" &&
!(executionData.results === undefined || executionData.results === null || (executionData.results.length === 0 && executionData.status === "EXECUTING")) ? (
{
console.log(environments, defaultEnvironmentIndex, nonskippedResults)
}} />
{environments.length > 0 && defaultEnvironmentIndex < environments.length && nonskippedResults.length === 0 && environments[defaultEnvironmentIndex].Name !== "Cloud" ?
No results yet. Is Orborus running for the "{environments[defaultEnvironmentIndex].Name}" environment? Find out here. If the Workflow doesn't start within 30 seconds with Orborus running, contact support: support@shuffler.io
: null}
) : null}
{
if (cy == undefined || cy == null) {
return
}
var currentnode = cy.getElementById(data.action.id);
if (currentnode !== undefined && currentnode !== null && currentnode.length !== 0) {
currentnode.addClass("shuffle-hover-highlight");
}
// Add a hover highlight
//var copyText = document.getElementById(
// "copy_element_shuffle"
//)
}}
onMouseOut={() => {
if (cy == undefined || cy == null) {
return
}
var currentnode = cy.getElementById(data.action.id);
if (currentnode.length !== 0) {
currentnode.removeClass("shuffle-hover-highlight");
}
}}
>
{
if (cy !== undefined) {
const oldstartnode = cy.getElementById(data.action.id);
//console.log("FOUND NODe: ", oldstartnode)
if (oldstartnode !== undefined && oldstartnode !== null) {
const foundname = oldstartnode.data("label")
if (foundname !== undefined && foundname !== null) {
data.action.label = foundname
}
}
//console.log("Click data: ", data)
//data.action.label = ""
setSelectedResult(data);
setCodeModalOpen(true);
} else {
toast("Please wait until the workflow is loaded and try again")
setCodeModalOpen(true)
setSelectedResult(data)
}
}}
>
{actionimg}
{data.action.name}
{data.action.app_name === "shuffle-subflow" &&
validate.result.success !== undefined &&
validate.result.success === true ? (
{validate.valid &&
data.action.parameters !== undefined &&
data.action.parameters !== null &&
data.action.parameters.length > 0 ? (
data.action.parameters[0].value ===
props.match.params.key ? (
{
getWorkflowExecution(
props.match.params.key,
validate.result.execution_id
);
}}
>
Status
{data.status}
{similarActionsView}
: null}
{validate.valid ? (
{
handleReactJsonClipboard(copy);
}}
displayDataTypes={false}
onSelect={(select) => {
HandleJsonCopy(showResult, select, data.action.label);
console.log("SELECTED!: ", select);
}}
name={"Results for " + data.action.label}
/>
) : (
Result
{data.result}
)}
);
})
)}
)}
{data.action.label === undefined || data.action.label === null || data.action.label === "" ? data.action.label : data.action.label.replaceAll("_", " ")}
{data.value.length > 60 || checked.valid ?
{
if (!showVariable) {
setOpen(!open)
}
}}
>
{data.name}
{checked.valid ?
:
{data.name}: {showVariable ? data.value : null}
}
{open ?
checked.valid ?
{
if (showlink) {
e.preventDefault()
e.stopPropagation()
window.open(data.value, "_blank")
}
}}
color={showlink ? "inherit" : "textSecondary"}
>
{data.value}
: null}
)
}
var draggingDisabled = false;
// Should probably put this on the backend instead when notifications are made :))
const getErrorSuggestion = (result) => {
if (result === undefined || result === null) {
return ""
}
// Check if array with json inside to handle one item at a time~
if (typeof result === "object" && result.length !== undefined) {
if (result.length > 0) {
// Check type inside
if (typeof result[0] === "object") {
result = result[0]
}
}
}
if (result.success === true && result.status === 200) {
if (result.body !== undefined && result.body !== null) {
const stringbody = result.body.toString()
if ((stringbody.startsWith("{") && stringbody.endsWith("}")) || (stringbody.startsWith("[") && stringbody.endsWith("]"))) {
return ""
}
if (stringbody.length > 1000) {
return "Body looks to be big in a standard format. Consider using the 'To File' parameter to automatically make it into a file."
}
}
}
if (result.status === 429) {
return "Rate limit exceeded. Consider using a different API key or wait a bit before trying again."
}
if (result.status === 405) {
return "Method not allowed. Check the URL to ensure it has all the required parameters. If you keep getting a 405, please forward a screenshot of this to support@shuffler.io"
}
if (result.status === 415) {
return "Content-Type header missing or wrong. Please add the correct Content-Type header and save the workflow."
}
if (result.status === 401) {
return "Authentication failed (401). The URL or auth key is wrong. Check the body of the result for more information."
}
if (result.status === 403) {
return "Authorization failed (403). The API user most likely doesn't have the correct permissions. Check the body of the result for more information."
}
if (result.status === 404) {
return "The URL, or content of the URL is incorrect. Check it and try again."
}
if (result.status === 400) {
return "The queries or data sent to the API is most likely wrong (400). Check the body of the result for more information."
}
if (result.status === 200 || result.status === 201 || result.status === 204) {
return "It looks like the result was successful! If it didn't work, make sure to check if the body you are sending was correct."
}
// Validate and check for newlines
if (result.success !== false) {
var stringjson = result
const valid = validateJson(stringjson, true)
if (valid.valid === false) {
if (stringjson.startsWith("{") && stringjson.endsWith("}")) {
// Look for newline
if (stringjson.includes("\n") && !stringjson.includes("\n")) {
return "Looks like you have a newline problem. Consider using the | replace: '\n', '\\n' }} filter in Liquid."
} else {
return "The result looks like it should be JSON, but is invalid. Look for potential"
}
}
}
//return ""
}
try {
stringjson = JSON.stringify(result)
} catch (e) {
}
stringjson = stringjson.toLowerCase()
if (stringjson.includes("localhost")) {
return "You can't use localhost in apps. Use the external ip or url of the server instead"
}
if (stringjson.includes("manifest unknown")) {
return "The app's Docker Image is not available in the environment yet. Re-run the app to force a re-download of the app. If the problem persists, contact support"
}
if (result.status !== 200 && result.url !== undefined && result.url !== null && (result.url.includes("192.168") || result.url.includes("172.16") || result.url.includes("10.0"))) {
return "Consider whether your Orborus environment can connect to a local IP or not."
}
if (stringjson.includes("kms/")) {
return "KMS authentication most likely failed. Check your notifications for more details on this page: /admin?admin_tab=priorities. If you need help with KMS, please contact support@shuffler.io"
}
if (stringjson.includes("invalidurl")) {
// IF count of "http" is more than one, 1, it's prolly invalid
var additionalinfo = ""
if (stringjson.includes("http") && stringjson.match(/http/g).length > 1) {
additionalinfo = "You may be using multiple 'http' in the URL. "
}
return "The URL is invalid. Change the URL to a valid one, and try again. "+additionalinfo
}
if (stringjson.includes("result too large to handle")) {
return "Execution loading failed. Reload the execution by closing it and clicking it again"
}
if (isCloud && stringjson.toLowerCase().includes("timeout error")) {
return "Run this workflow in a local environment to increase the timeout. Go to https://shuffler.io/admin?tab=environments to create an environment to connect to"
}
if (stringjson.toLowerCase().includes("invalid header")) {
return "A header or authentication token in the app is invalid. Check the app's configuration"
}
if (stringjson.includes("connectionerror")) {
if (stringjson.includes("kms")) {
return "KMS authentication most likely failed (2). Check your notifications for more details on this page: /admin?admin_tab=priorities&kms=true. If you need help with KMS, please contact support@shuffler.io"
}
return "The URL is incorrect, or Shuffle can't reach it. Set up a Shuffle Environment in the same VLAN, or whitelist Shuffle's IPs."
}
return ""
}
const currentSuggestion = getErrorSuggestion(validate.result)
const codePopoutModal = !codeModalOpen ? null : (
);
const newView = (
{/*isMobile ? null : leftView*/}
{leftView}
{workflow.id === undefined || workflow.id === null || appsLoaded === false ? (
Loading Workflow
) : (
{/**/}
{
// FIXME: There's something specific loading when
// you do the first hover of a node. Why is this different?
setCy(incy);
}}
/>
)}
{executionModal}
{Object.getOwnPropertyNames(selectedTrigger).length > 0 ?
selectedTrigger.trigger_type === "SCHEDULE" ?
ScheduleSidebar
: selectedTrigger.trigger_type === "PIPELINE" ?
PipelineSidebar
: selectedTrigger.trigger_type === "WEBHOOK" ?
WebhookSidebar
: selectedTrigger.trigger_type === "USERINPUT" ?
UserinputSidebar
: null
: null}
: null}
{
rightSideBarOpen && selectedTrigger.trigger_type === "SUBFLOW"&& Object.getOwnPropertyNames(selectedTrigger).length > 0 ?
Authentication for {selectedApp.name.replaceAll("_", " ", -1)}
{/*
{
e.preventDefault();
setSuggestionBox({
"position": {
"top": 500,
"left": 500,
},
"open": false,
"value": "",
"loading": false,
});
}}
>
{suggestionLoading === true ?
{responseMsg}
: null}
)
}
/*else if (selectedRevision === undefined || selectedRevision === null || selectedRevision == {} && originalWorkflow !== undefined && originalWorkflow !== null && originalWorkflow !== {}) {
console.log("Setting original workflow as selected revision")
setSelectedRevision(originalWorkflow)
}*/
const RevisionBox = (props) => {
const { revision, } = props
if (revision === undefined || revision === null || revision === {}) {
return null
}
var newrevision = JSON.parse(JSON.stringify(revision))
// Make unix timestamp into ISO timestamp in the format July 27th, 3:05 AM
// Format: July 27th, 3:05 AM
//console.log("Edited time: ", revision.edited)
// Convert 1692128391 to valid timestamp
const validTimestamp = newrevision.edited.toString().length === 10 ? newrevision.edited * 1000 : newrevision.edited
const translatedDate = new Date(validTimestamp).toLocaleString('en-US', { month: 'long', day: 'numeric', hour: 'numeric', minute: 'numeric', hour12: true })
var workflowStatus = newrevision.status !== undefined && newrevision.status !== null && newrevision.status !== "" ? newrevision.status : "test"
if (newrevision.name !== undefined && newrevision.name !== null && newrevision.name !== "") {
if (newrevision.name.toLowerCase().includes("test")) {
workflowStatus = "test"
}
if (newrevision.name.toLowerCase().includes("dev") || newrevision.name.toLowerCase().includes("staging") || newrevision.name.toLowerCase().includes("rollback")) {
workflowStatus = "dev"
}
if (newrevision.name.toLowerCase().includes("prod") || newrevision.name.toLowerCase().includes("main")) {
workflowStatus = "prod"
}
}
return (
{revision.actions !== undefined && revision.actions !== null ?
{revision.actions.length}
: null}
{revision.triggers !== undefined && revision.triggers !== null ?
{revision.triggers.length}
: null}
{revision.updated_by !== undefined && revision.updated_by !== null && revision.updated_by !== "" ?
{/*selectedRevision.edited !== undefined && selectedRevision.edited !== null && selectedRevision.edited !== originalWorkflow.edited ?
: null*/}
{newView}
{
setSelectionOpen(false)
}}
>
{
setShowVideo("")
}}
>
: null}
) : (
{/* Removed due to missing react router features
);
};
export default AngularWorkflow;