blob: 4512443926bf273f901b4664e170b9b70497cf95 (
plain)
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
|
/*-
* ============LICENSE_START=======================================================
* controlloop processor
* ================================================================================
* Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
* ============LICENSE_END=========================================================
*/
package org.onap.policy.controlloop.processor;
import org.onap.policy.controlloop.ControlLoopException;
import org.onap.policy.controlloop.policy.ControlLoop;
import org.onap.policy.controlloop.policy.ControlLoopPolicy;
import org.onap.policy.controlloop.policy.FinalResult;
import org.onap.policy.controlloop.policy.Policy;
import org.onap.policy.controlloop.policy.PolicyResult;
import org.yaml.snakeyaml.Yaml;
import org.yaml.snakeyaml.constructor.CustomClassLoaderConstructor;
public class ControlLoopProcessor {
private final String yaml;
private final ControlLoopPolicy policy;
private String currentNestedPolicyID = null;
public ControlLoopProcessor(String yaml) throws ControlLoopException {
this.yaml = yaml;
try {
final Yaml y = new Yaml(new CustomClassLoaderConstructor(ControlLoopPolicy.class, ControlLoopPolicy.class.getClassLoader()));
final Object obj = y.load(this.yaml);
this.policy = (ControlLoopPolicy) obj;
this.currentNestedPolicyID = this.policy.getControlLoop().getTrigger_policy();
} catch (final Exception e) {
//
// Most likely this is a YAML Exception
//
throw new ControlLoopException(e);
}
}
public ControlLoop getControlLoop() {
return this.policy.getControlLoop();
}
public FinalResult checkIsCurrentPolicyFinal() {
return FinalResult.toResult(this.currentNestedPolicyID);
}
public Policy getCurrentPolicy() throws ControlLoopException {
if (this.policy == null || this.policy.getPolicies() == null) {
throw new ControlLoopException("There are no policies defined.");
}
for (final Policy nestedPolicy : this.policy.getPolicies()) {
if (nestedPolicy.getId().equals(this.currentNestedPolicyID)) {
return nestedPolicy;
}
}
return null;
}
public void nextPolicyForResult(PolicyResult result) throws ControlLoopException {
final Policy currentPolicy = this.getCurrentPolicy();
try {
if (currentPolicy == null) {
throw new ControlLoopException("There is no current policy to determine where to go to.");
}
switch (result) {
case SUCCESS:
this.currentNestedPolicyID = currentPolicy.getSuccess();
break;
case FAILURE:
this.currentNestedPolicyID = currentPolicy.getFailure();
break;
case FAILURE_TIMEOUT:
this.currentNestedPolicyID = currentPolicy.getFailure_timeout();
break;
case FAILURE_RETRIES:
this.currentNestedPolicyID = currentPolicy.getFailure_retries();
break;
case FAILURE_EXCEPTION:
this.currentNestedPolicyID = currentPolicy.getFailure_exception();
break;
case FAILURE_GUARD:
this.currentNestedPolicyID = currentPolicy.getFailure_guard();
break;
}
} catch (final ControlLoopException e) {
this.currentNestedPolicyID = FinalResult.FINAL_FAILURE_EXCEPTION.toString();
throw e;
}
}
}
|
