blob: 521413c8212c0821920578cc821c9f58e723b849 (
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
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
|
/*-
* ============LICENSE_START=======================================================
* Copyright (C) 2019 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.
*
* SPDX-License-Identifier: Apache-2.0
* ============LICENSE_END=========================================================
*/
package org.onap.policy.pdpx.main;
import java.util.Collections;
import org.onap.policy.common.utils.network.NetworkUtil;
import org.onap.policy.models.pdp.concepts.PdpMessage;
import org.onap.policy.models.pdp.concepts.PdpResponseDetails;
import org.onap.policy.models.pdp.concepts.PdpStateChange;
import org.onap.policy.models.pdp.concepts.PdpStatus;
import org.onap.policy.models.pdp.concepts.PdpUpdate;
import org.onap.policy.models.pdp.enums.PdpHealthStatus;
import org.onap.policy.models.pdp.enums.PdpResponseStatus;
import org.onap.policy.models.pdp.enums.PdpState;
import org.onap.policy.pdpx.main.rest.XacmlPdpApplicationManager;
import org.onap.policy.pdpx.main.startstop.XacmlPdpActivator;
/**
* Current state of this XACML PDP.
*/
public class XacmlState {
/**
* The application manager.
*/
private final XacmlPdpApplicationManager appManager;
/**
* Records the current state of this PDP.
*/
private final PdpStatus status;
/**
* Constructs the object, initializing the state.
*/
public XacmlState(XacmlPdpApplicationManager appManager) {
this.appManager = appManager;
this.status = new PdpStatus();
this.status.setName(NetworkUtil.getHostname());
this.status.setPdpType("xacml");
this.status.setState(PdpState.PASSIVE);
this.status.setSupportedPolicyTypes(appManager.getToscaPolicyTypeIdents());
this.status.setPolicies(Collections.emptyList());
}
/**
* Determines if this PDP should handle the given message.
*
* @param message message of interest
* @return {@code true} if this PDP should handle the message, {@code false} otherwise
*/
public boolean shouldHandle(PdpMessage message) {
return message.appliesTo(status.getName(), status.getPdpGroup(), status.getPdpSubgroup());
}
/**
* Generates a new heart beat message.
*
* @return a new heart beat message
*/
public PdpStatus genHeartbeat() {
// first, update status fields
status.setHealthy(XacmlPdpActivator.getCurrent().isAlive() ? PdpHealthStatus.HEALTHY
: PdpHealthStatus.NOT_HEALTHY);
return new PdpStatus(status);
}
/**
* Updates the internal state based on the given message.
*
* @param message message from which to update the internal state
* @return a response to the message
*/
public PdpStatus updateInternalState(PdpStateChange message) {
status.setState(message.getState());
/*
* NOTE: Do NOT update group & subgroup as state-change requests do not set those
* fields to indicate new values; they only set them to do broadcasts to all PDPs
* within a group/subgroup.
*/
PdpStatus status2 = makeResponse(message);
// these fields aren't needed in the response, so clear them out to avoid sending
status2.setPolicies(null);
return status2;
}
/**
* Updates the internal state based on the given message. Assumes that the policies
* have already been updated within the application manager.
*
* @param message message from which to update the internal state
* @return a response to the message
*/
public PdpStatus updateInternalState(PdpUpdate message) {
status.setPdpGroup(message.getPdpGroup());
status.setPdpSubgroup(message.getPdpSubgroup());
status.setPolicies(appManager.getToscaPolicyIdentifiers());
return makeResponse(message);
}
/**
* Makes a response to the given message, based on the current state.
*
* @param message message for which the response should be made
* @return a new response
*/
private PdpStatus makeResponse(PdpMessage message) {
PdpResponseDetails resp = new PdpResponseDetails();
resp.setResponseStatus(PdpResponseStatus.SUCCESS);
resp.setResponseTo(message.getRequestId());
PdpStatus status2 = new PdpStatus(status);
status2.setResponse(resp);
return status2;
}
}
|
