CompensateEventDefinition.js
4.17 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
'use strict';
var entryFactory = require('../../../../factory/EntryFactory');
var cmdHelper = require('../../../../helper/CmdHelper'),
eventDefinitionHelper = require('../../../../helper/EventDefinitionHelper'),
utils = require('../../../../Utils');
var getBusinessObject = require('bpmn-js/lib/util/ModelUtil').getBusinessObject,
is = require('bpmn-js/lib/util/ModelUtil').is;
var forEach = require('lodash/forEach'),
find = require('lodash/find'),
filter = require('lodash/filter');
function getContainedActivities(element) {
return getFlowElements(element, 'bpmn:Activity');
}
function getContainedBoundaryEvents(element) {
return getFlowElements(element, 'bpmn:BoundaryEvent');
}
function getFlowElements(element, type) {
return utils.filterElementsByType(element.flowElements, type);
}
function isCompensationEventAttachedToActivity(activity, boundaryEvents) {
var activityId = activity.id;
var boundaryEvent = find(boundaryEvents, function(boundaryEvent) {
var compensateEventDefinition = eventDefinitionHelper.getCompensateEventDefinition(boundaryEvent);
var attachedToRef = boundaryEvent.attachedToRef;
return compensateEventDefinition && attachedToRef && attachedToRef.id === activityId;
});
return !!boundaryEvent;
}
// subprocess: only when it is not triggeredByEvent
// activity: only when it attach a compensation boundary event
// callActivity: no limitation
function canActivityBeCompensated(activity, boundaryEvents) {
return (is(activity, 'bpmn:SubProcess') && !activity.triggeredByEvent) ||
is(activity, 'bpmn:CallActivity') ||
isCompensationEventAttachedToActivity(activity, boundaryEvents);
}
function getActivitiesForCompensation(element) {
var boundaryEvents = getContainedBoundaryEvents(element);
return filter(getContainedActivities(element), function(activity) {
return canActivityBeCompensated(activity, boundaryEvents);
});
}
function getActivitiesForActivityRef(element) {
var bo = getBusinessObject(element);
var parent = bo.$parent;
var activitiesForActivityRef = getActivitiesForCompensation(parent);
// if throwing compensation event is in an event sub process:
// get also all activities outside of the event sub process
if (is(parent, 'bpmn:SubProcess') && parent.triggeredByEvent) {
parent = parent.$parent;
if (parent) {
activitiesForActivityRef = activitiesForActivityRef.concat(getActivitiesForCompensation(parent));
}
}
return activitiesForActivityRef;
}
function createActivityRefOptions(element) {
var options = [ { value: '' } ];
var activities = getActivitiesForActivityRef(element);
forEach(activities, function(activity) {
var activityId = activity.id;
var name = (activity.name ? (activity.name + ' ') : '') + '(id=' + activityId + ')';
options.push({ value: activityId, name: name });
});
return options;
}
module.exports = function(group, element, bpmnFactory, compensateEventDefinition, elementRegistry, translate) {
group.entries.push(entryFactory.checkbox({
id: 'wait-for-completion',
label: translate('Wait for Completion'),
modelProperty: 'waitForCompletion',
get: function(element, node) {
return {
waitForCompletion: compensateEventDefinition.waitForCompletion
};
},
set: function(element, values) {
values.waitForCompletion = values.waitForCompletion || false;
return cmdHelper.updateBusinessObject(element, compensateEventDefinition, values);
}
}));
group.entries.push(entryFactory.selectBox({
id: 'activity-ref',
label: translate('Activity Ref'),
selectOptions: createActivityRefOptions(element),
modelProperty: 'activityRef',
get: function(element, node) {
var activityRef = compensateEventDefinition.activityRef;
activityRef = activityRef && activityRef.id;
return {
activityRef: activityRef || ''
};
},
set: function(element, values) {
var activityRef = values.activityRef || undefined;
activityRef = activityRef && getBusinessObject(elementRegistry.get(activityRef));
return cmdHelper.updateBusinessObject(element, compensateEventDefinition, {
activityRef: activityRef
});
}
}));
};