in ui-modules/app-inspector/app/components/workflow/workflow-step.directive.js [48:215]
function controller($sce, $scope) {
try {
let vm = this;
let step = $scope.step;
let index = $scope.stepIndex;
$scope.workflowId = ($scope.workflow && $scope.workflow.data || {}).workflowId;
vm.toggleExpandState = () => {
$scope.expanded = !$scope.expanded;
if ($scope.onSizeChange) $scope.onSizeChange();
}
vm.stringify = stringify;
vm.yaml = (data) => jsyaml.dump(data);
vm.yamlOrPrimitive = (data) => typeof data === "string" ? data : vm.yaml(data);
vm.nonEmpty = (data) => data && (data.length || Object.keys(data).length);
vm.isNullish = _.isNil;
vm.getWorkflowNameFromReference = (ref, suffixIfFound) => {
// would be nice to get a name, but all we have is appId, entityId, workflowId; and no lookup table;
// could look it up or store at server, but seems like overkill
if (ref && $scope.task && $scope.task.children) {
var matchingChild = $scope.task.children.find(c => c.metadata && c.metadata.id === ref.workflowId);
if (matchingChild && matchingChild.metadata.taskName) {
return matchingChild.metadata.taskName + (suffixIfFound ? " "+suffixIfFound+" " : "");
}
}
return null;
};
vm.hasInterestingWorkflowNameFromReference = (ref, suffixIfFound) => {
const wn = vm.getWorkflowNameFromReference(ref, suffixIfFound);
return wn && wn.toLowerCase()!='sub-workflow';
};
vm.classForCodeMaybeMultiline = (obj) => {
let os = vm.yamlOrPrimitive(obj);
if (!os) return "simple-code";
os = ''+os;
if (os.endsWith('\n')) os = os.substring(0, os.length-1);
const lines = os.split('\n');
if (lines.length==1) return "simple-code";
if (lines.length <= 5) return "multiline-code lines-"+lines.length;
return "multiline-code multiline-code-resizable lines-"+lines.length;
};
$scope.json = null;
$scope.jsonMode = null;
vm.showAdditional = (title, mode, obj) => {
$scope.jsonTitle = title;
$scope.jsonMode = mode;
$scope.json = obj==undefined ? null : vm.yamlOrPrimitive(obj);
}
$scope.stepTitle = {
index: index+1,
};
if (typeof step === 'string') {
$scope.stepTitle.code = step;
} else {
let shorthand = step.userSuppliedShorthand || step.step || step.s || step.shorthand;
$scope.stepTitle.code = shorthand;
if (!shorthand) {
$scope.stepTitle.code = step.shorthandTypeName || step.type || '';
if (step.input) $scope.stepTitle.code += ' ...';
}
if ("workflow" === $scope.stepTitle.code) {
$scope.stepTitle.code = null;
$scope.stepTitle.leftExtra = "nested workflow";
}
if (step.name) {
$scope.stepTitle.name = step.name;
}
if (step.id) {
$scope.stepTitle.id = step.id;
}
}
function gatherOutputAndScratchForStep(osi, result, visited, isPrevious) {
if (result.output!=undefined && result.workflowScratch!=undefined) return ;
if (osi==undefined) {
if (result.workflowScratchPartial != undefined) result.workflowScratch = result.workflowScratchPartial;
delete result['workflowScratchPartial'];
return;
}
// osi.woSc
let output = osi.context && osi.context.output;
if (isPrevious && output != undefined && result.output == undefined) result.output = output;
if (isPrevious && osi.workflowScratchUpdates != undefined) result.workflowScratchPartial =
Object.assign({}, osi.workflowScratchUpdates, result.workflowScratchPartial);
if (osi.workflowScratch != undefined) result.workflowScratchPartial =
Object.assign({}, osi.workflowScratchUpdates, result.workflowScratchPartial);
let next = undefined;
if (osi.previous && osi.previous.length) {
const pp = osi.previous[0];
if (!visited.includes(pp)) {
visited.push(pp);
next = $scope.workflow.data.oldStepInfo[pp];
}
}
gatherOutputAndScratchForStep(next, result, visited, true);
}
const resultForStep = {};
vm.getOutputAndScratchForStep = (i) => {
if (!resultForStep[i]) {
if (!$scope.workflow || !$scope.workflow.data || !$scope.workflow.data.oldStepInfo) return {};
const osi = $scope.workflow.data.oldStepInfo[i] || null;
if (!osi) return {};
resultForStep[i] = {};
gatherOutputAndScratchForStep(osi, resultForStep[i], [i], false);
}
return resultForStep[i];
}
function updateData() {
let workflow = $scope.workflow;
workflow.data = workflow.data || {};
$scope.workflowStepClasses = [];
if (workflow.data.currentStepIndex === index) $scope.workflowStepClasses.push('current-step');
$scope.isRunning = (workflow.data.status === 'RUNNING');
$scope.isCurrentMaybeInactive = (workflow.data.currentStepIndex === index);
$scope.isCurrentAndActive = ($scope.isCurrentMaybeInactive && $scope.isRunning);
$scope.isWorkflowError = (workflow.data.status && workflow.data.status.startsWith('ERROR'));
$scope.osi = workflow.data.oldStepInfo[index] || {};
$scope.stepContext = ($scope.isCurrentMaybeInactive ? workflow.data.currentStepInstance : $scope.osi.context) || {};
$scope.isFocusStep = $scope.workflow.tag && ($scope.workflow.tag.stepIndex === index);
$scope.isFocusTask = false;
$scope.isErrorHandler = $scope.workflow.tag && ($scope.workflow.tag.errorHandlerForTask);
if ($scope.task) {
if (!vm.isNullish($scope.stepContext.taskId) && $scope.stepContext.taskId === $scope.task.id) {
$scope.isFocusTask = true;
} else if ($scope.isFocusStep) {
// careful -- other instance of this step selected
}
}
$scope.stepCurrentError =
($scope.stepContext.error && !$scope.isFocusTask)
? 'This step had an error.'
: ($scope.isWorkflowError && $scope.isCurrentMaybeInactive)
? 'The workflow encountered an error at this step.' /* odd */
: null;
const incomplete = $scope.osi.countStarted - $scope.osi.countCompleted > ($scope.isCurrentAndActive ? 1 : 0);
$scope.stepCurrentWarning = $scope.stepCurrentError ? null :
$scope.stepContext.errorHandlerTaskId
? 'This step had an error which was handled.'
: incomplete
? 'This step has previously had an error'
: null;
$scope.stepCurrentSuccess = $scope.stepCurrentError || $scope.stepCurrentWarning ? null :
(!$scope.isCurrentAndActive && !incomplete && $scope.osi.countCompleted > 0)
? 'This step has completed without errors.' : null;
}
$scope.$watch('workflow', updateData);
updateData();
} catch (error) {
console.log("error showing workflow step", error);
// the ng-repeat seems to swallow and mask any error in the above - can't understand why! but log it here in case something breaks.
throw error;
}
}