/*-
* ============LICENSE_START=======================================================
- * Copyright (C) 2019 Nordix Foundation.
+ * Copyright (C) 2019-2020 Nordix Foundation.
* Modifications Copyright (C) 2019 AT&T Intellectual Property.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
package org.onap.policy.pap.main.comm;
+import java.util.Arrays;
import java.util.List;
import java.util.Optional;
import org.onap.policy.models.pdp.concepts.PdpGroup;
import org.onap.policy.models.pdp.concepts.PdpGroupFilter;
import org.onap.policy.models.pdp.concepts.PdpStateChange;
+import org.onap.policy.models.pdp.concepts.PdpStatistics;
import org.onap.policy.models.pdp.concepts.PdpStatus;
import org.onap.policy.models.pdp.concepts.PdpSubGroup;
import org.onap.policy.models.pdp.concepts.PdpUpdate;
} else {
handlePdpHeartbeat(message, databaseProvider);
}
-
/*
* Indicate that a heart beat was received from the PDP. This is invoked only if handleXxx() does not
* throw an exception.
} else if (validatePdpDetails(message, pdpGroup, pdpSubGroup, pdpInstance)) {
LOGGER.debug("PdpInstance details are correct. Saving current state in DB - {}", pdpInstance);
updatePdpHealthStatus(message, pdpSubGroup, pdpInstance, pdpGroup, databaseProvider);
+
+ if (validatePdpStatisticsDetails(message, pdpInstance, pdpGroup, pdpSubGroup)) {
+ LOGGER.debug("PdpStatistics details are correct. Saving current statistics in DB - {}",
+ message.getStatistics());
+ createPdpStatistics(message.getStatistics(), databaseProvider);
+ } else {
+ LOGGER.debug("PdpStatistics details are not correct - {}", message.getStatistics());
+ }
} else {
LOGGER.debug("PdpInstance details are not correct. Sending PdpUpdate message - {}", pdpInstance);
sendPdpMessage(pdpGroup.getName(), pdpSubGroup, pdpInstance.getInstanceId(), pdpInstance.getPdpState(),
private boolean validatePdpDetails(final PdpStatus message, final PdpGroup pdpGroup, final PdpSubGroup subGroup,
final Pdp pdpInstanceDetails) {
-
/*
* "EqualsBuilder" is a bit of a misnomer, as it uses containsAll() to check policies. Nevertheless, it does the
* job and provides a convenient way to build a bunch of comparisons.
.append(subGroup.getPolicies().containsAll(message.getPolicies()), true).build();
}
+ private boolean validatePdpStatisticsDetails(final PdpStatus message, final Pdp pdpInstanceDetails,
+ final PdpGroup pdpGroup, final PdpSubGroup pdpSubGroup) {
+ if (message.getStatistics() != null) {
+ return new EqualsBuilder()
+ .append(message.getStatistics().getPdpInstanceId(), pdpInstanceDetails.getInstanceId())
+ .append(message.getStatistics().getPdpGroupName(), pdpGroup.getName())
+ .append(message.getStatistics().getPdpSubGroupName(), pdpSubGroup.getPdpType())
+ .append(message.getStatistics().getPolicyDeployCount() < 0, false)
+ .append(message.getStatistics().getPolicyDeployFailCount() < 0, false)
+ .append(message.getStatistics().getPolicyDeploySuccessCount() < 0, false)
+ .append(message.getStatistics().getPolicyExecutedCount() < 0, false)
+ .append(message.getStatistics().getPolicyExecutedFailCount() < 0, false)
+ .append(message.getStatistics().getPolicyExecutedSuccessCount() < 0, false).build();
+ } else {
+ LOGGER.debug("PdpStatistics is null");
+ return false;
+ }
+ }
+
private void updatePdpHealthStatus(final PdpStatus message, final PdpSubGroup pdpSubgroup, final Pdp pdpInstance,
final PdpGroup pdpGroup, final PolicyModelsProvider databaseProvider) throws PfModelException {
pdpInstance.setHealthy(message.getHealthy());
LOGGER.debug("Updated Pdp in DB - {}", pdpInstance);
}
+ private void createPdpStatistics(final PdpStatistics pdpStatistics, final PolicyModelsProvider databaseProvider)
+ throws PfModelException {
+ databaseProvider.createPdpStatistics(Arrays.asList(pdpStatistics));
+ LOGGER.debug("Created PdpStatistics in DB - {}", pdpStatistics);
+ }
+
private void sendPdpMessage(final String pdpGroupName, final PdpSubGroup subGroup, final String pdpInstanceId,
final PdpState pdpState, final PolicyModelsProvider databaseProvider) throws PfModelException {
final PdpUpdate pdpUpdatemessage =
LOGGER.debug("Sent PdpUpdate message - {}", pdpUpdatemessage);
LOGGER.debug("Sent PdpStateChange message - {}", pdpStateChangeMessage);
}
-}
+}
\ No newline at end of file
/*-
* ============LICENSE_START=======================================================
- * Copyright (C) 2019 Nordix Foundation.
+ * Copyright (C) 2019-2020 Nordix Foundation.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
import static org.junit.Assert.assertEquals;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
import java.util.Arrays;
+import java.util.Date;
import java.util.List;
import org.junit.Test;
import org.onap.policy.common.utils.coder.CoderException;
import org.onap.policy.models.base.PfModelException;
import org.onap.policy.models.pdp.concepts.PdpGroup;
+import org.onap.policy.models.pdp.concepts.PdpStatistics;
import org.onap.policy.models.pdp.concepts.PdpStatus;
import org.onap.policy.models.pdp.concepts.PdpSubGroup;
import org.onap.policy.models.pdp.enums.PdpHealthStatus;
private static final CommInfrastructure INFRA = CommInfrastructure.NOOP;
private static final String TOPIC = "my-topic";
+ private Date timeStamp;
private PdpHeartbeatListener pdpHeartbeatListener;
@Test
status9.setPolicies(idents9);
pdpHeartbeatListener.onTopicEvent(INFRA, TOPIC, status9);
verifyPdpGroup(DEFAULT_GROUP, 0);
+ }
+
+ @Test
+ public void testPdpStatistics() throws CoderException, PfModelException, ParseException {
+ addGroups("PdpGroups.json");
+ pdpHeartbeatListener = new PdpHeartbeatListener();
+ timeStamp = new SimpleDateFormat("yyyy-MM-dd").parse("2020-01-01");
+
+ // init default pdp group
+ final PdpStatus status1 = new PdpStatus();
+ status1.setName(PDP_NAME);
+ status1.setState(PdpState.ACTIVE);
+ status1.setPdpGroup(DEFAULT_GROUP);
+ status1.setPdpType(APEX_TYPE);
+ status1.setHealthy(PdpHealthStatus.HEALTHY);
+ final List<ToscaPolicyIdentifier> idents1 =
+ Arrays.asList(new ToscaPolicyIdentifier(POLICY_NAME, POLICY_VERSION));
+ status1.setPolicies(idents1);
+ pdpHeartbeatListener.onTopicEvent(INFRA, TOPIC, status1);
+ verifyPdpGroup(DEFAULT_GROUP, 1);
+
+ // init pdp instance
+ final PdpStatus status2 = new PdpStatus();
+ status2.setName(PDP_NAME);
+ status2.setState(PdpState.ACTIVE);
+ status2.setPdpGroup(DEFAULT_GROUP);
+ status2.setPdpType(APEX_TYPE);
+ status2.setHealthy(PdpHealthStatus.HEALTHY);
+ status2.setPdpSubgroup(APEX_TYPE);
+ final List<ToscaPolicyIdentifier> idents2 =
+ Arrays.asList(new ToscaPolicyIdentifier(POLICY_NAME, POLICY_VERSION));
+ status2.setPolicies(idents2);
+ pdpHeartbeatListener.onTopicEvent(INFRA, TOPIC, status2);
+
+ // Testing passing pdp statistics success case
+ final PdpStatus status3 = new PdpStatus();
+ status3.setName(PDP_NAME);
+ status3.setState(PdpState.ACTIVE);
+ status3.setPdpGroup(DEFAULT_GROUP);
+ status3.setPdpType(APEX_TYPE);
+ status3.setHealthy(PdpHealthStatus.HEALTHY);
+ status3.setPdpSubgroup(APEX_TYPE);
+ final List<ToscaPolicyIdentifier> idents3 =
+ Arrays.asList(new ToscaPolicyIdentifier(POLICY_NAME, POLICY_VERSION));
+ status3.setPolicies(idents3);
+ PdpStatistics pdpStatistics03 = new PdpStatistics();
+ pdpStatistics03.setPdpInstanceId(PDP_NAME);
+ pdpStatistics03.setPdpGroupName(DEFAULT_GROUP);
+ pdpStatistics03.setPdpSubGroupName(APEX_TYPE);
+ pdpStatistics03.setTimeStamp(timeStamp);
+ status3.setStatistics(pdpStatistics03);
+ pdpHeartbeatListener.onTopicEvent(INFRA, TOPIC, status3);
+ verifyPdpStatistics(PDP_NAME, DEFAULT_GROUP, null, 1);
+
+ // Testing pdp statistics failure having the pdpStatistics null in the heartbeat for already registered pdp
+ final PdpStatus status4 = new PdpStatus();
+ status4.setName(PDP_NAME);
+ status4.setState(PdpState.ACTIVE);
+ status4.setPdpGroup(DEFAULT_GROUP);
+ status4.setPdpType(APEX_TYPE);
+ status4.setHealthy(PdpHealthStatus.HEALTHY);
+ status4.setPdpSubgroup(APEX_TYPE);
+ final List<ToscaPolicyIdentifier> idents4 =
+ Arrays.asList(new ToscaPolicyIdentifier(POLICY_NAME, POLICY_VERSION));
+ status4.setPolicies(idents4);
+ status4.setStatistics(null);
+ pdpHeartbeatListener.onTopicEvent(INFRA, TOPIC, status4);
+ verifyPdpStatistics(PDP_NAME, DEFAULT_GROUP, null, 1);
+
+ // Testing pdp statistics failure passing different pdpGroup, PdpSubGroup & pdpInstanceId
+ final PdpStatus status5 = new PdpStatus();
+ status5.setName(PDP_NAME);
+ status5.setState(PdpState.ACTIVE);
+ status5.setPdpGroup(DEFAULT_GROUP);
+ status5.setPdpType(APEX_TYPE);
+ status5.setHealthy(PdpHealthStatus.HEALTHY);
+ status5.setPdpSubgroup(APEX_TYPE);
+ final List<ToscaPolicyIdentifier> idents5 =
+ Arrays.asList(new ToscaPolicyIdentifier(POLICY_NAME, POLICY_VERSION));
+ status5.setPolicies(idents5);
+
+ PdpStatistics pdpStatistics05 = new PdpStatistics();
+ pdpStatistics05.setPdpInstanceId("pdp_2");
+ pdpStatistics05.setPdpGroupName("defaultGroup_1");
+ pdpStatistics05.setPdpSubGroupName("apex_1");
+ pdpStatistics03.setTimeStamp(timeStamp);
+ status5.setStatistics(pdpStatistics05);
+
+ pdpHeartbeatListener.onTopicEvent(INFRA, TOPIC, status5);
+ verifyPdpStatistics(null, DEFAULT_GROUP, null, 1);
+
+ // Test pdp statistics failure passing negative values
+ final PdpStatus status6 = new PdpStatus();
+ status6.setName(PDP_NAME);
+ status6.setState(PdpState.ACTIVE);
+ status6.setPdpGroup(DEFAULT_GROUP);
+ status6.setPdpType(APEX_TYPE);
+ status6.setHealthy(PdpHealthStatus.HEALTHY);
+ status6.setPdpSubgroup(APEX_TYPE);
+ final List<ToscaPolicyIdentifier> idents6 =
+ Arrays.asList(new ToscaPolicyIdentifier(POLICY_NAME, POLICY_VERSION));
+ status5.setPolicies(idents6);
+
+ PdpStatistics pdpStatistics06 = new PdpStatistics();
+ pdpStatistics06.setPdpInstanceId(PDP_NAME);
+ pdpStatistics06.setPdpGroupName(DEFAULT_GROUP);
+ pdpStatistics06.setPdpSubGroupName(APEX_TYPE);
+ pdpStatistics03.setTimeStamp(timeStamp);
+
+ pdpStatistics06.setPolicyDeployCount(-1);
+ pdpStatistics06.setPolicyDeployFailCount(-1);
+ status5.setStatistics(pdpStatistics06);
+
+ pdpHeartbeatListener.onTopicEvent(INFRA, TOPIC, status5);
+ verifyPdpStatistics(null, DEFAULT_GROUP, null, 1);
}
private void verifyPdpGroup(final String name, final int count) throws PfModelException {
}
}
}
+
+ private void verifyPdpStatistics(final String pdpInstanceId, final String pdpGroupName,
+ final String pdpSubGroupName, final int count) throws PfModelException {
+ final List<PdpStatistics> fetchedPdpStatistics =
+ fetchPdpStatistics(pdpInstanceId, pdpGroupName, pdpSubGroupName);
+ assertEquals(count, fetchedPdpStatistics.size());
+ }
}
Code Review / policy / pap.git / commitdiff