package org.onap.policy.pap.main.comm;
import java.util.ArrayList;
+import java.util.Collection;
+import java.util.Collections;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
+import lombok.Setter;
import org.onap.policy.models.base.PfModelException;
import org.onap.policy.models.pdp.concepts.Pdp;
import org.onap.policy.models.pdp.concepts.PdpGroup;
import org.onap.policy.models.pdp.concepts.PdpUpdate;
import org.onap.policy.models.pdp.enums.PdpState;
import org.onap.policy.models.provider.PolicyModelsProvider;
+import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicyIdentifier;
import org.onap.policy.pap.main.PolicyModelsProviderFactoryWrapper;
import org.onap.policy.pap.main.comm.msgdata.Request;
import org.onap.policy.pap.main.comm.msgdata.RequestListener;
*/
private final PolicyNotifier policyNotifier;
+ /**
+ * Used to undeploy policies from the system, when they cannot be deployed to a PDP.
+ *
+ * <p/>
+ * Note: there's a "catch-22" here. The request map needs an undeployer, but the
+ * undeployer needs the request map. Consequently, the request map is created first,
+ * then the undeployer, and finally, this field is set.
+ */
+ @Setter
+ private PolicyUndeployer policyUndeployer;
+
/**
* Constructs the object.
@Override
public void failure(String responsePdpName, String reason) {
- requestCompleted(responsePdpName);
+ Collection<ToscaPolicyIdentifier> undeployPolicies = requestCompleted(responsePdpName);
+ if (undeployPolicies.isEmpty()) {
+ // nothing to undeploy
+ return;
+ }
+
+ /*
+ * Undeploy the extra policies. Note: this will likely cause a new message to
+ * be assigned to the request, thus we must re-start it after making the
+ * change.
+ */
+ PdpMessage oldmsg = request.getMessage();
+
+ try {
+ logger.warn("undeploy policies from {}:{} that failed to deploy: {}", oldmsg.getPdpGroup(),
+ oldmsg.getPdpSubgroup(), undeployPolicies);
+ policyUndeployer.undeploy(oldmsg.getPdpGroup(), oldmsg.getPdpSubgroup(), undeployPolicies);
+ } catch (PfModelException | RuntimeException e) {
+ logger.error("cannot undeploy policies {}", undeployPolicies, e);
+ }
+
+ if (request.getMessage() == oldmsg) {
+ // message is unchanged - start the next request
+ startNextRequest(request);
+ } else {
+ // message changed - restart the request
+ request.startPublishing();
+ }
}
@Override
* Handles a request completion, starting the next request, if there is one.
*
* @param responsePdpName name of the PDP provided in the response
+ * @return a list of policies to be undeployed
*/
- private void requestCompleted(String responsePdpName) {
- if (pdpName.equals(responsePdpName)) {
- if (pdp2requests.get(pdpName) == requests) {
- startNextRequest(request);
-
- } else {
- logger.info("discard old requests for {}", responsePdpName);
- requests.stopPublishing();
- }
+ private Collection<ToscaPolicyIdentifier> requestCompleted(String responsePdpName) {
+ if (!pdpName.equals(responsePdpName)) {
+ return Collections.emptyList();
+ }
+
+ if (pdp2requests.get(pdpName) != requests) {
+ logger.info("discard old requests for {}", responsePdpName);
+ requests.stopPublishing();
+ return Collections.emptyList();
}
+
+ if (!requests.isFirstInQueue(request)) {
+ logger.error("request is not first in the queue {}", request.getMessage());
+ return Collections.emptyList();
+ }
+
+ Collection<ToscaPolicyIdentifier> undeployPolicies = request.getUndeployPolicies();
+ if (undeployPolicies.isEmpty()) {
+ // nothing to undeploy - just start the next request
+ startNextRequest(request);
+ }
+
+ return undeployPolicies;
}
@Override
}
}
+ /**
+ * Determines if a request is the first request in the queue.
+ *
+ * @param request request of interest
+ * @return {@code true} if the request is the first in the queue, {@code false}
+ * otherwise
+ */
+ public boolean isFirstInQueue(Request request) {
+ return (requests.peek() == request);
+ }
+
/**
* Starts publishing the next request in the queue.
*
--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP PAP
+ * ================================================================================
+ * 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.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.pap.main.comm;
+
+import java.util.Collection;
+import org.onap.policy.models.base.PfModelException;
+import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicyIdentifier;
+
+@FunctionalInterface
+public interface PolicyUndeployer {
+ /**
+ * Undeploys a list of policies.
+ *
+ * @param group name of the group from which to undeploy the policies
+ * @param subgroup name of the subgroup from which to undeploy the policies
+ * @param policies policies to be undeployed
+ * @throws PfModelException if an error occurs
+ */
+ public void undeploy(String group, String subgroup, Collection<ToscaPolicyIdentifier> policies)
+ throws PfModelException;
+}
package org.onap.policy.pap.main.comm.msgdata;
+import java.util.Collection;
import org.onap.policy.models.pdp.concepts.PdpMessage;
import org.onap.policy.models.pdp.concepts.PdpStatus;
+import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicyIdentifier;
import org.onap.policy.pap.main.notification.PolicyNotifier;
/**
* @return an error message, if a fatal error has occurred, {@code null} otherwise
*/
public String checkResponse(PdpStatus response);
+
+ /**
+ * If a request fails, this gets a list of the policies that should be undeployed.
+ *
+ * @return a list of policies to be undeployed
+ */
+ public Collection<ToscaPolicyIdentifier> getUndeployPolicies();
}
package org.onap.policy.pap.main.comm.msgdata;
+import java.util.Collection;
+import java.util.Collections;
import lombok.AccessLevel;
import lombok.Getter;
import lombok.NonNull;
import org.onap.policy.common.utils.services.ServiceManager;
import org.onap.policy.models.pdp.concepts.PdpMessage;
import org.onap.policy.models.pdp.concepts.PdpStatus;
+import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicyIdentifier;
import org.onap.policy.pap.main.comm.QueueToken;
import org.onap.policy.pap.main.comm.TimerManager;
import org.onap.policy.pap.main.notification.PolicyNotifier;
return null;
}
+
+ /**
+ * Just returns an empty list.
+ */
+ @Override
+ public Collection<ToscaPolicyIdentifier> getUndeployPolicies() {
+ return Collections.emptyList();
+ }
}
package org.onap.policy.pap.main.comm.msgdata;
+import java.util.Collection;
import java.util.Collections;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
import java.util.stream.Collectors;
+import lombok.Getter;
import org.apache.commons.lang3.StringUtils;
import org.onap.policy.models.pdp.concepts.PdpMessage;
import org.onap.policy.models.pdp.concepts.PdpStatus;
*/
public class UpdateReq extends RequestImpl {
+ /**
+ * Policies to be undeployed if the request fails.
+ */
+ @Getter
+ private Collection<ToscaPolicyIdentifier> undeployPolicies = Collections.emptyList();
+
/**
* Constructs the object, and validates the parameters.
*
@Override
public String checkResponse(PdpStatus response) {
+ // reset the list
+ undeployPolicies = Collections.emptyList();
+
String reason = super.checkResponse(response);
if (reason != null) {
// response isn't for this PDP - don't generate notifications
return "subgroup does not match";
}
+ if (message.getPdpSubgroup() == null) {
+ return null;
+ }
+
// see if the policies match
Set<ToscaPolicyIdentifier> expectedSet = new HashSet<>(alwaysList(message.getPolicies()).stream()
.map(ToscaPolicy::getIdentifier).collect(Collectors.toSet()));
if (!actualSet.equals(expectedSet)) {
+ // need to undeploy the policies that are expected, but missing from the
+ // response
+ undeployPolicies = expectedSet;
+ undeployPolicies.removeAll(actualSet);
+
return "policies do not match";
}
--- /dev/null
+/*
+ * ============LICENSE_START=======================================================
+ * ONAP PAP
+ * ================================================================================
+ * 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.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.pap.main.rest.depundep;
+
+import java.util.Collection;
+import java.util.Optional;
+import java.util.Set;
+import java.util.stream.Collectors;
+import org.onap.policy.models.base.PfModelException;
+import org.onap.policy.models.pdp.concepts.Pdp;
+import org.onap.policy.models.pdp.concepts.PdpGroup;
+import org.onap.policy.models.pdp.concepts.PdpSubGroup;
+import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicy;
+import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicyIdentifier;
+import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicyIdentifierOptVersion;
+import org.onap.policy.pap.main.comm.PolicyUndeployer;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * Implementation of policy undeployer.
+ */
+public class PolicyUndeployerImpl extends ProviderBase implements PolicyUndeployer {
+ private static final Logger logger = LoggerFactory.getLogger(PolicyUndeployerImpl.class);
+
+
+ /**
+ * Constructs the object.
+ */
+ public PolicyUndeployerImpl() {
+ super();
+ }
+
+ @Override
+ public void undeploy(String group, String subgroup, Collection<ToscaPolicyIdentifier> policies)
+ throws PfModelException {
+
+ process(new Info(group, subgroup, policies), this::undeployPolicies);
+ }
+
+ /**
+ * Undeploys policies from all PDPs within a subgroup.
+ *
+ * @param data session data
+ * @param policyInfo information about the policies to be undeployed
+ * @throws PfModelException if an error occurs
+ */
+ private void undeployPolicies(SessionData data, Info policyInfo) throws PfModelException {
+ // get group and subgroup
+ PdpGroup group = data.getGroup(policyInfo.group);
+ if (group == null) {
+ return;
+ }
+
+ Optional<PdpSubGroup> optsub = group.getPdpSubgroups().stream()
+ .filter(subgroup -> subgroup.getPdpType().equals(policyInfo.subgroup)).findAny();
+ if (!optsub.isPresent()) {
+ logger.warn("subgroup {} {} not found", policyInfo.group, policyInfo.subgroup);
+ return;
+ }
+
+ PdpSubGroup subgroup = optsub.get();
+
+ // remove the policies
+ boolean updated = false;
+ Set<String> pdps = subgroup.getPdpInstances().stream().map(Pdp::getInstanceId).collect(Collectors.toSet());
+
+ for (ToscaPolicyIdentifier ident : policyInfo.policies) {
+ if (!subgroup.getPolicies().remove(ident)) {
+ continue;
+ }
+
+ logger.info("remove policy {} {} from subgroup {} {} count={}", ident.getName(), ident.getVersion(),
+ group.getName(), subgroup.getPdpType(), subgroup.getPolicies().size());
+
+ updated = true;
+ data.trackUndeploy(ident, pdps);
+ }
+
+ // push the updates
+ if (updated) {
+ makeUpdates(data, group, subgroup);
+ data.update(group);
+ }
+ }
+
+ @Override
+ protected Updater makeUpdater(SessionData data, ToscaPolicy policy, ToscaPolicyIdentifierOptVersion desiredPolicy) {
+ throw new UnsupportedOperationException("makeUpdater should not be invoked");
+ }
+
+ private static class Info {
+ private String group;
+ private String subgroup;
+ private Collection<ToscaPolicyIdentifier> policies;
+
+ public Info(String group, String subgroup, Collection<ToscaPolicyIdentifier> policies) {
+ this.group = group;
+ this.subgroup = subgroup;
+ this.policies = policies;
+ }
+ }
+}
import org.onap.policy.pap.main.rest.StatisticsRestControllerV1;
import org.onap.policy.pap.main.rest.depundep.PdpGroupDeleteControllerV1;
import org.onap.policy.pap.main.rest.depundep.PdpGroupDeployControllerV1;
+import org.onap.policy.pap.main.rest.depundep.PolicyUndeployerImpl;
/**
* This class activates Policy Administration (PAP) as a complete service together with all its controllers, listeners &
.setStateChangeTimers(pdpStChgTimers.get())
.setUpdateTimers(pdpUpdTimers.get())));
Registry.register(PapConstants.REG_PDP_MODIFY_MAP, requestMap.get());
+
+ // now that it's registered, we can attach a "policy undeploy" provider
+ requestMap.get().setPolicyUndeployer(new PolicyUndeployerImpl());
},
() -> Registry.unregister(PapConstants.REG_PDP_MODIFY_MAP));
import static org.junit.Assert.assertTrue;
import static org.mockito.Matchers.any;
import static org.mockito.Matchers.eq;
+import static org.mockito.Mockito.doAnswer;
+import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.never;
import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify;
import java.util.ArrayList;
import java.util.Arrays;
+import java.util.Collection;
import java.util.Collections;
import java.util.List;
import java.util.stream.Collectors;
import org.onap.policy.models.pdp.concepts.PdpSubGroup;
import org.onap.policy.models.pdp.concepts.PdpUpdate;
import org.onap.policy.models.pdp.enums.PdpState;
+import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicy;
+import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicyIdentifier;
import org.onap.policy.pap.main.comm.msgdata.Request;
import org.onap.policy.pap.main.comm.msgdata.RequestListener;
import org.onap.policy.pap.main.parameters.PdpModifyRequestMapParams;
@Captor
private ArgumentCaptor<List<PdpGroup>> updateCaptor;
+ /**
+ * Used to capture input to undeployer.undeploy().
+ */
+ @Captor
+ private ArgumentCaptor<Collection<ToscaPolicyIdentifier>> undeployCaptor;
+
@Mock
private PdpRequests requests;
+ @Mock
+ private PolicyUndeployer undeployer;
+
private MyMap map;
private PdpUpdate update;
private PdpStateChange change;
change = makeStateChange(PDP1, MY_STATE);
when(requests.getPdpName()).thenReturn(PDP1);
+ when(requests.isFirstInQueue(any())).thenReturn(true);
response.setName(MY_NAME);
response.setState(MY_STATE);
response.setPolicies(Collections.emptyList());
map = new MyMap(mapParams);
+ map.setPolicyUndeployer(undeployer);
}
@Test
public void testRemoveFromGroup_DaoEx() throws Exception {
map.addRequest(change);
- when(dao.getFilteredPdpGroups(any())).thenThrow(new PfModelException(Status.BAD_REQUEST, "expected exception"));
+ when(dao.getFilteredPdpGroups(any())).thenThrow(makeException());
invokeLastRetryHandler(1);
assertEquals(2, map.nalloc);
}
+ protected PfModelException makeException() {
+ return new PfModelException(Status.BAD_REQUEST, "expected exception");
+ }
+
@Test
public void testRemoveFromGroup_NoGroups() throws Exception {
map.addRequest(change);
// invoke the method
invokeFailureHandler(1);
+ verify(undeployer, never()).undeploy(any(), any(), any());
verify(requests, never()).stopPublishing();
// requests should have been removed from the map so this should allocate another
assertEquals(2, map.nalloc);
}
+ /**
+ * Tests Listener.failure() when something has to be undeployed.
+ */
+ @Test
+ public void testSingletonListenerFailureUndeploy() throws Exception {
+
+ ToscaPolicyIdentifier ident = new ToscaPolicyIdentifier("undeployed", "2.3.4");
+ ToscaPolicy policy = mock(ToscaPolicy.class);
+ when(policy.getIdentifier()).thenReturn(ident);
+
+ // add some policies to the update
+ update.setPolicies(Arrays.asList(policy));
+
+ map.addRequest(update);
+
+ /*
+ * Reconfigure the request when undeploy() is called. Also arrange for undeploy()
+ * to throw an exception.
+ */
+ Request req = getSingletons(1).get(0);
+
+ doAnswer(ans -> {
+ PdpUpdate update2 = new PdpUpdate(update);
+ update2.setPolicies(Collections.emptyList());
+ assertTrue(req.reconfigure(update2));
+ throw makeException();
+ }).when(undeployer).undeploy(any(), any(), any());
+
+ // indicate that all policies failed (because response has no policies)
+ response.setName(PDP1);
+ req.setNotifier(notifier);
+ req.checkResponse(response);
+
+ // invoke the method
+ invokeFailureHandler(1);
+
+ verify(undeployer).undeploy(eq(MY_GROUP), eq(MY_SUBGROUP), undeployCaptor.capture());
+ assertEquals(Arrays.asList(ident).toString(), undeployCaptor.getValue().toString());
+
+ // no effect on the map
+ map.addRequest(update);
+ assertEquals(1, map.nalloc);
+ }
+
+ /**
+ * Tests Listener.failure() when something has to be undeployed, but the message
+ * remains unchanged.
+ */
+ @Test
+ public void testSingletonListenerFailureUndeployMessageUnchanged() throws Exception {
+
+ ToscaPolicyIdentifier ident = new ToscaPolicyIdentifier("msg-unchanged", "8.7.6");
+ ToscaPolicy policy = mock(ToscaPolicy.class);
+ when(policy.getIdentifier()).thenReturn(ident);
+
+ // add some policies to the update
+ update.setPolicies(Arrays.asList(policy));
+
+ map.addRequest(update);
+
+ // indicate that all policies failed (because response has no policies)
+ response.setName(PDP1);
+ Request req = getSingletons(1).get(0);
+ req.setNotifier(notifier);
+ req.checkResponse(response);
+
+ // invoke the method
+ invokeFailureHandler(1);
+
+ verify(undeployer).undeploy(eq(MY_GROUP), eq(MY_SUBGROUP), undeployCaptor.capture());
+ assertEquals(Arrays.asList(ident).toString(), undeployCaptor.getValue().toString());
+
+ // requests should have been removed from the map so this should allocate another
+ map.addRequest(update);
+ assertEquals(2, map.nalloc);
+ }
+
@Test
public void testSingletonListenerSuccess() throws Exception {
map.addRequest(change);
assertEquals(2, map.nalloc);
}
+ @Test
+ public void testRequestCompleted_NotFirstInQueue() throws Exception {
+ map.addRequest(change);
+
+ when(requests.isFirstInQueue(any())).thenReturn(false);
+
+ // invoke the method
+ invokeSuccessHandler(1);
+
+ // should not have called this
+ verify(requests, never()).stopPublishing();
+
+ // no effect on the map
+ map.addRequest(update);
+ assertEquals(1, map.nalloc);
+ }
+
@Test
public void testSingletonListenerRetryCountExhausted() throws Exception {
map.addRequest(change);
assertFalse(data.startNextRequest(change));
}
+ @Test
+ public void testIsFirstInQueue() {
+ // test with empty queue
+ assertFalse(data.isFirstInQueue(update));
+
+ data.addSingleton(update);
+ assertTrue(data.isFirstInQueue(update));
+
+ data.addSingleton(change);
+ assertTrue(data.isFirstInQueue(update));
+ assertFalse(data.isFirstInQueue(change));
+ }
+
@Test
public void testGetPdpName() {
assertEquals(PDP1, data.getPdpName());
assertSame(reqParams, req.getParams());
}
+ @Test
+ public void testGetUndeployPolicies() {
+ assertTrue(req.getUndeployPolicies().isEmpty());
+ }
+
private class MyRequest extends RequestImpl {
public MyRequest(RequestParams params, String name, PdpMessage message) {
import java.util.ArrayList;
import java.util.Arrays;
+import java.util.Collections;
import java.util.Set;
+import java.util.TreeSet;
import java.util.stream.Collectors;
import org.junit.Before;
import org.junit.Test;
@Test
public void testCheckResponse() {
assertNull(data.checkResponse(response));
+ assertTrue(data.getUndeployPolicies().isEmpty());
verifyResponse();
// both policy lists null
update.setPolicies(null);
response.setPolicies(null);
assertNull(data.checkResponse(response));
+ assertTrue(data.getUndeployPolicies().isEmpty());
}
@Test
response.setName(null);
assertEquals("null PDP name", data.checkResponse(response));
+ assertTrue(data.getUndeployPolicies().isEmpty());
verifyNoResponse();
}
update.setName(null);
assertEquals(null, data.checkResponse(response));
+ assertTrue(data.getUndeployPolicies().isEmpty());
verifyResponse();
}
response.setPdpGroup(DIFFERENT);
assertEquals("group does not match", data.checkResponse(response));
+ assertTrue(data.getUndeployPolicies().isEmpty());
verifyResponse();
}
response.setPdpSubgroup(DIFFERENT);
assertEquals("subgroup does not match", data.checkResponse(response));
+ assertTrue(data.getUndeployPolicies().isEmpty());
+ verifyResponse();
+ }
+
+ @Test
+ public void testCheckResponse_NullSubGroup() {
+ update.setPdpSubgroup(null);
+ response.setPdpSubgroup(null);
+
+ // different policy list - should have no impact
+ response.setPolicies(Collections.emptyList());
+
+ assertEquals(null, data.checkResponse(response));
+ assertTrue(data.getUndeployPolicies().isEmpty());
verifyResponse();
}
assertEquals("policies do not match", data.checkResponse(response));
verifyResponse();
+
+ // the first policy from the original update is all that should be undeployed
+ assertEquals(Collections.singleton(update.getPolicies().get(0).getIdentifier()).toString(),
+ data.getUndeployPolicies().toString());
}
@Test
update.setPolicies(null);
assertEquals("policies do not match", data.checkResponse(response));
+ assertTrue(data.getUndeployPolicies().isEmpty());
verifyResponse();
}
assertEquals("policies do not match", data.checkResponse(response));
verifyResponse();
+
+ // all policies in the update should be undeployed
+ assertEquals(update.getPolicies().stream().map(ToscaPolicy::getIdentifier).collect(Collectors.toList())
+ .toString(), new TreeSet<>(data.getUndeployPolicies()).toString());
}
@Test
--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP PAP
+ * ================================================================================
+ * 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.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.pap.main.rest.depundep;
+
+import static org.junit.Assert.assertEquals;
+import static org.mockito.Matchers.any;
+import static org.mockito.Mockito.never;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+
+import java.util.Arrays;
+import java.util.Collections;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.Set;
+import org.junit.AfterClass;
+import org.junit.Before;
+import org.junit.Test;
+import org.mockito.ArgumentCaptor;
+import org.mockito.Captor;
+import org.mockito.Mock;
+import org.onap.policy.common.utils.services.Registry;
+import org.onap.policy.models.base.PfModelException;
+import org.onap.policy.models.pdp.concepts.Pdp;
+import org.onap.policy.models.pdp.concepts.PdpGroup;
+import org.onap.policy.models.pdp.concepts.PdpSubGroup;
+import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicyIdentifier;
+
+public class TestPolicyUndeployerImpl extends ProviderSuper {
+ private static final String MY_GROUP = "my-group";
+ private static final String MY_SUBGROUP = "my-subgroup";
+ private static final String MY_SUBGROUP0 = "my-subgroup-0";
+ private static final String PDP1 = "my-pdp-a";
+
+ @Mock
+ private SessionData session;
+
+ @Captor
+ private ArgumentCaptor<Set<String>> pdpCaptor;
+
+ private ToscaPolicyIdentifier ident1;
+ private ToscaPolicyIdentifier ident2;
+ private ToscaPolicyIdentifier ident3;
+ private ToscaPolicyIdentifier ident4;
+ private PdpGroup group;
+ private PdpSubGroup subgroup;
+ private MyProvider prov;
+
+
+ @AfterClass
+ public static void tearDownAfterClass() {
+ Registry.newRegistry();
+ }
+
+ /**
+ * Configures mocks and objects.
+ *
+ * @throws Exception if an error occurs
+ */
+ @Before
+ public void setUp() throws Exception {
+
+ super.setUp();
+
+ ident1 = new ToscaPolicyIdentifier("ident-a", "2.3.1");
+ ident2 = new ToscaPolicyIdentifier("ident-b", "2.3.2");
+ ident3 = new ToscaPolicyIdentifier("ident-c", "2.3.3");
+ ident4 = new ToscaPolicyIdentifier("ident-d", "2.3.4");
+
+ group = new PdpGroup();
+ group.setName(MY_GROUP);
+
+ subgroup = new PdpSubGroup();
+ subgroup.setPdpType(MY_SUBGROUP);
+
+ Pdp pdp1 = new Pdp();
+ pdp1.setInstanceId(PDP1);
+
+ subgroup.setPdpInstances(Arrays.asList(pdp1));
+
+ // this subgroup should never be touched
+ PdpSubGroup subgroup0 = new PdpSubGroup();
+ subgroup0.setPdpType(MY_SUBGROUP0);
+ subgroup0.setPolicies(Collections.unmodifiableList(Arrays.asList(ident1, ident2, ident3, ident4)));
+ subgroup.setPdpInstances(Arrays.asList(pdp1));
+
+ group.setPdpSubgroups(Arrays.asList(subgroup0, subgroup));
+
+ when(session.getGroup(MY_GROUP)).thenReturn(group);
+ when(session.getPolicy(any())).thenReturn(policy1);
+
+ prov = new MyProvider();
+ }
+
+ @Test
+ public void testUndeployPolicies() throws PfModelException {
+ subgroup.setPolicies(new LinkedList<>(Arrays.asList(ident1, ident2, ident3, ident4)));
+
+ prov.undeploy(MY_GROUP, MY_SUBGROUP, Arrays.asList(ident1, ident2));
+
+ // group should have been updated
+ verify(session).update(group);
+
+ // subgroup should only have remaining policies
+ assertEquals(Arrays.asList(ident3, ident4).toString(), subgroup.getPolicies().toString());
+
+ // should have generated PDP-UPDATE for the PDP
+ verify(session).addUpdate(any());
+ }
+
+ /**
+ * Tests undeployPolicies() when the policies do not exist in the subgroup.
+ */
+ @Test
+ public void testUndeployPoliciesUnchanged() throws PfModelException {
+ List<ToscaPolicyIdentifier> origlist = Arrays.asList(ident3, ident4);
+ subgroup.setPolicies(new LinkedList<>(origlist));
+
+ prov.undeploy(MY_GROUP, MY_SUBGROUP, Arrays.asList(ident1, ident2));
+
+ // group NOT should have been updated
+ verify(session, never()).update(group);
+
+ // subgroup's policies should be unchanged
+ assertEquals(origlist.toString(), subgroup.getPolicies().toString());
+
+ // should NOT have generated PDP-UPDATE for the PDP
+ verify(session, never()).addUpdate(any());
+ }
+
+ /**
+ * Tests undeployPolicies() when the group is not found.
+ */
+ @Test
+ public void testUndeployPoliciesGroupNotFound() throws PfModelException {
+ // force exception to be thrown if the list is changed
+ subgroup.setPolicies(Collections.unmodifiableList(Arrays.asList(ident1, ident2, ident3, ident4)));
+
+ when(session.getGroup(any())).thenReturn(null);
+
+ prov.undeploy(MY_GROUP, MY_SUBGROUP, Arrays.asList(ident1, ident2));
+
+ // group should have been updated
+ verify(session, never()).update(group);
+
+ // should have generated PDP-UPDATE for the PDP
+ verify(session, never()).addUpdate(any());
+ }
+
+ /**
+ * Tests undeployPolicies() when the subgroup is not found.
+ */
+ @Test
+ public void testUndeployPoliciesSubGroupNotFound() throws PfModelException {
+ // force exception to be thrown if the list is changed
+ subgroup.setPolicies(Collections.unmodifiableList(Arrays.asList(ident1, ident2, ident3, ident4)));
+
+ subgroup.setPdpType(MY_SUBGROUP + "X");
+
+ prov.undeploy(MY_GROUP, MY_SUBGROUP, Arrays.asList(ident1, ident2));
+
+ // group should have been updated
+ verify(session, never()).update(group);
+
+ // should have generated PDP-UPDATE for the PDP
+ verify(session, never()).addUpdate(any());
+ }
+
+ @Test(expected = UnsupportedOperationException.class)
+ public void testMakeUpdater() {
+ prov.makeUpdater(null, null, null);
+ }
+
+
+ private class MyProvider extends PolicyUndeployerImpl {
+
+ @Override
+ protected <T> void process(T request, BiConsumerWithEx<SessionData, T> processor) throws PfModelException {
+ processor.accept(session, request);
+ }
+ }
+}
import static org.junit.Assert.assertNull;
import java.util.Collections;
+import java.util.List;
import javax.ws.rs.client.Entity;
import javax.ws.rs.client.Invocation;
import javax.ws.rs.core.Response;
import org.onap.policy.models.pap.concepts.PdpGroupStateChangeResponse;
import org.onap.policy.models.pdp.concepts.PdpStatus;
import org.onap.policy.models.pdp.enums.PdpState;
+import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicyIdentifier;
public class PdpGroupStateChangeTest extends End2EndBase {
private static final String PDP1 = "pdpAA_1";
public void testMakePassive() throws Exception {
addGroups("stateChangeGroupDeactivate.json");
+ ToscaPolicyIdentifier policy =
+ new ToscaPolicyIdentifier("onap.restart.tca", "1.0.0");
+ List<ToscaPolicyIdentifier> policies = Collections.singletonList(policy);
+
PdpStatus status11 = new PdpStatus();
status11.setName(PDP1);
status11.setState(PdpState.ACTIVE);
status11.setPdpGroup(DEACT_GROUP);
status11.setPdpType(SUBGROUP1);
status11.setPdpSubgroup(SUBGROUP1);
- status11.setPolicies(Collections.emptyList());
+ status11.setPolicies(policies);
PdpStatus status12 = makeCopy(status11);
status12.setState(PdpState.PASSIVE);
status21.setPdpGroup(DEACT_GROUP);
status21.setPdpType(SUBGROUP1);
status21.setPdpSubgroup(SUBGROUP1);
- status21.setPolicies(Collections.emptyList());
+ status21.setPolicies(policies);
PdpStatus status22 = makeCopy(status21);
status22.setState(PdpState.PASSIVE);
Code Review / policy / pap.git / commitdiff