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
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
|
package org.openecomp.sdc.toscaparser.api;
import java.util.LinkedHashMap;
import org.openecomp.sdc.toscaparser.api.common.ExceptionCollector;
import org.openecomp.sdc.toscaparser.api.utils.ThreadLocalsHolder;
import org.openecomp.sdc.toscaparser.api.utils.ValidateUtils;
public class Triggers extends EntityTemplate {
private static final String DESCRIPTION = "description";
private static final String EVENT = "event_type";
private static final String SCHEDULE = "schedule";
private static final String TARGET_FILTER = "target_filter";
private static final String CONDITION = "condition";
private static final String ACTION = "action";
private static final String SECTIONS[] = {
DESCRIPTION, EVENT, SCHEDULE, TARGET_FILTER, CONDITION, ACTION
};
private static final String METER_NAME = "meter_name";
private static final String CONSTRAINT = "constraint";
private static final String PERIOD = "period";
private static final String EVALUATIONS = "evaluations";
private static final String METHOD = "method";
private static final String THRESHOLD = "threshold";
private static final String COMPARISON_OPERATOR = "comparison_operator";
private static final String CONDITION_KEYNAMES[] = {
METER_NAME, CONSTRAINT, PERIOD, EVALUATIONS, METHOD, THRESHOLD, COMPARISON_OPERATOR
};
private String name;
private LinkedHashMap<String,Object> triggerTpl;
public Triggers(String _name,LinkedHashMap<String,Object> _triggerTpl) {
super(); // dummy. don't want super
name = _name;
triggerTpl = _triggerTpl;
_validateKeys();
_validateCondition();
_validateInput();
}
public String getDescription() {
return (String)triggerTpl.get("description");
}
public String getEvent() {
return (String)triggerTpl.get("event_type");
}
public LinkedHashMap<String,Object> getSchedule() {
return (LinkedHashMap<String,Object>)triggerTpl.get("schedule");
}
public LinkedHashMap<String,Object> getTargetFilter() {
return (LinkedHashMap<String,Object>)triggerTpl.get("target_filter");
}
public LinkedHashMap<String,Object> getCondition() {
return (LinkedHashMap<String,Object>)triggerTpl.get("condition");
}
public LinkedHashMap<String,Object> getAction() {
return (LinkedHashMap<String,Object>)triggerTpl.get("action");
}
private void _validateKeys() {
for(String key: triggerTpl.keySet()) {
boolean bFound = false;
for(int i=0; i<SECTIONS.length; i++) {
if(key.equals(SECTIONS[i])) {
bFound = true;
break;
}
}
if(!bFound) {
ThreadLocalsHolder.getCollector().appendException(String.format(
"UnknownFieldError: Triggers \"%s\" contains unknown field \"%s\"",
name,key));
}
}
}
private void _validateCondition() {
for(String key: getCondition().keySet()) {
boolean bFound = false;
for(int i=0; i<CONDITION_KEYNAMES.length; i++) {
if(key.equals(CONDITION_KEYNAMES[i])) {
bFound = true;
break;
}
}
if(!bFound) {
ThreadLocalsHolder.getCollector().appendException(String.format(
"UnknownFieldError: Triggers \"%s\" contains unknown field \"%s\"",
name,key));
}
}
}
private void _validateInput() {
for(String key: getCondition().keySet()) {
Object value = getCondition().get(key);
if(key.equals(PERIOD) || key.equals(EVALUATIONS)) {
ValidateUtils.validateInteger(value);
}
else if(key.equals(THRESHOLD)) {
ValidateUtils.validateNumeric(value);
}
else if(key.equals(METER_NAME) || key.equals(METHOD)) {
ValidateUtils.validateString(value);
}
}
}
@Override
public String toString() {
return "Triggers{" +
"name='" + name + '\'' +
", triggerTpl=" + triggerTpl +
'}';
}
}
/*python
from toscaparser.common.exception import ExceptionCollector
from toscaparser.common.exception import UnknownFieldError
from toscaparser.entity_template import EntityTemplate
SECTIONS = (DESCRIPTION, EVENT, SCHEDULE, TARGET_FILTER, CONDITION, ACTION) = \
('description', 'event_type', 'schedule',
'target_filter', 'condition', 'action')
CONDITION_KEYNAMES = (CONTRAINT, PERIOD, EVALUATIONS, METHOD) = \
('constraint', 'period', 'evaluations', 'method')
log = logging.getLogger('tosca')
class Triggers(EntityTemplate):
'''Triggers defined in policies of topology template'''
def __init__(self, name, trigger_tpl):
self.name = name
self.trigger_tpl = trigger_tpl
self._validate_keys()
self._validate_condition()
def get_description(self):
return self.trigger_tpl['description']
def get_event(self):
return self.trigger_tpl['event_type']
def get_schedule(self):
return self.trigger_tpl['schedule']
def get_target_filter(self):
return self.trigger_tpl['target_filter']
def get_condition(self):
return self.trigger_tpl['condition']
def get_action(self):
return self.trigger_tpl['action']
def _validate_keys(self):
for key in self.trigger_tpl.keys():
if key not in SECTIONS:
ExceptionCollector.appendException(
UnknownFieldError(what='Triggers "%s"' % self.name,
field=key))
def _validate_condition(self):
for key in self.get_condition():
if key not in CONDITION_KEYNAMES:
ExceptionCollector.appendException(
UnknownFieldError(what='Triggers "%s"' % self.name,
field=key))
*/
|
