models-pdp/src/test/java/org/onap/policy/models/pdp/persistence/provider/PdpStatisticsProviderTest.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  *  Copyright (C) 2020-2021 Nordix Foundation.
   4  *  Modifications Copyright (C) 2020-2021 AT&T Intellectual Property. All rights reserved.
   5  * ================================================================================
   6  * Licensed under the Apache License, Version 2.0 (the "License");
   7  * you may not use this file except in compliance with the License.
   8  * You may obtain a copy of the License at
   9  *
  10  *      http://www.apache.org/licenses/LICENSE-2.0
  11  *
  12  * Unless required by applicable law or agreed to in writing, software
  13  * distributed under the License is distributed on an "AS IS" BASIS,
  14  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15  * See the License for the specific language governing permissions and
  16  * limitations under the License.
  17  *
  18  * SPDX-License-Identifier: Apache-2.0
  19  * ============LICENSE_END=========================================================
  20  */
  21
  22 package org.onap.policy.models.pdp.persistence.provider;
  23
  24 import static org.assertj.core.api.Assertions.assertThat;
  25 import static org.assertj.core.api.Assertions.assertThatThrownBy;
  26 import static org.junit.Assert.assertEquals;
  27
  28 import java.time.Instant;
  29 import java.util.ArrayList;
  30 import java.util.List;
  31 import java.util.Properties;
  32 import org.eclipse.persistence.config.PersistenceUnitProperties;
  33 import org.junit.After;
  34 import org.junit.Before;
  35 import org.junit.Test;
  36 import org.onap.policy.models.base.Validated;
  37 import org.onap.policy.models.dao.DaoParameters;
  38 import org.onap.policy.models.dao.PfDao;
  39 import org.onap.policy.models.dao.PfDaoFactory;
  40 import org.onap.policy.models.dao.impl.DefaultPfDao;
  41 import org.onap.policy.models.pdp.concepts.PdpEngineWorkerStatistics;
  42 import org.onap.policy.models.pdp.concepts.PdpStatistics;
  43
  44 public class PdpStatisticsProviderTest {
  45     private static final String DAO_IS_NULL = "dao is marked .*ull but is null";
  46     private static final String LIST_IS_NULL = "pdpStatisticsList is marked .*ull but is null";
  47     private static final String GROUP0 = "group0";
  48     private static final String NAME = "name";
  49     private static final String GROUP = "group";
  50     private static final String SUBGROUP = "subgroup";
  51     private static final Instant TIMESTAMP1 = Instant.ofEpochSecond(1078884319);
  52     private static final Instant TIMESTAMP2 = Instant.ofEpochSecond(1078884350);
  53     private static final String ORDER = "DESC";
  54
  55     private PfDao pfDao;
  56
  57     private ArrayList<PdpStatistics> pdpStatisticsTestList = new ArrayList<>();
  58     private List<PdpEngineWorkerStatistics> engineStats = new ArrayList<>();
  59     private String testListStr;
  60     private String name1ListStr;
  61     private String createdListStr;
  62
  63     /**
  64      * Set up test Dao.
  65      */
  66     @Before
  67     public void setupDao() throws Exception {
  68         final DaoParameters daoParameters = new DaoParameters();
  69         daoParameters.setPluginClass(DefaultPfDao.class.getName());
  70
  71         daoParameters.setPersistenceUnit("ToscaConceptTest");
  72
  73         Properties jdbcProperties = new Properties();
  74         jdbcProperties.setProperty(PersistenceUnitProperties.JDBC_USER, "policy");
  75         jdbcProperties.setProperty(PersistenceUnitProperties.JDBC_PASSWORD, "P01icY");
  76
  77         if (System.getProperty("USE-MARIADB") != null) {
  78             jdbcProperties.setProperty(PersistenceUnitProperties.JDBC_DRIVER, "org.mariadb.jdbc.Driver");
  79             jdbcProperties.setProperty(PersistenceUnitProperties.JDBC_URL, "jdbc:mariadb://localhost:3306/policy");
  80         } else {
  81             jdbcProperties.setProperty(PersistenceUnitProperties.JDBC_DRIVER, "org.h2.Driver");
  82             jdbcProperties.setProperty(PersistenceUnitProperties.JDBC_URL, "jdbc:h2:mem:PdpStatisticsProviderTest");
  83         }
  84
  85         daoParameters.setJdbcProperties(jdbcProperties);
  86
  87         pfDao = new PfDaoFactory().createPfDao(daoParameters);
  88         pfDao.init(daoParameters);
  89
  90         PdpStatistics pdpStatistics = new PdpStatistics();
  91         pdpStatistics.setPdpInstanceId(NAME);
  92         pdpStatistics.setTimeStamp(TIMESTAMP1);
  93         pdpStatistics.setPdpGroupName(GROUP);
  94         pdpStatistics.setPdpSubGroupName(SUBGROUP);
  95         pdpStatistics.setPolicyDeployCount(2);
  96         pdpStatistics.setPolicyDeployFailCount(1);
  97         pdpStatistics.setPolicyDeploySuccessCount(1);
  98         pdpStatistics.setPolicyExecutedCount(2);
  99         pdpStatistics.setPolicyExecutedFailCount(1);
 100         pdpStatistics.setPolicyExecutedSuccessCount(1);
 101         pdpStatistics.setEngineStats(engineStats);
 102         pdpStatisticsTestList.add(pdpStatistics);
 103         name1ListStr = pdpStatisticsTestList.toString();
 104
 105         PdpStatistics pdpStatistics2 = new PdpStatistics();
 106         pdpStatistics2.setPdpInstanceId("name2");
 107         pdpStatistics2.setTimeStamp(TIMESTAMP2);
 108         pdpStatistics2.setPdpGroupName(GROUP);
 109         pdpStatistics2.setPdpSubGroupName(SUBGROUP);
 110         pdpStatistics2.setPolicyDeployCount(2);
 111         pdpStatistics2.setPolicyDeployFailCount(1);
 112         pdpStatistics2.setPolicyDeploySuccessCount(1);
 113         pdpStatistics2.setPolicyExecutedCount(2);
 114         pdpStatistics2.setPolicyExecutedFailCount(1);
 115         pdpStatistics2.setPolicyExecutedSuccessCount(1);
 116         pdpStatistics2.setEngineStats(engineStats);
 117         pdpStatisticsTestList.add(pdpStatistics2);
 118         testListStr = pdpStatisticsTestList.toString();
 119
 120         List<PdpStatistics> createdPdpStatisticsList;
 121         createdPdpStatisticsList = new PdpStatisticsProvider().createPdpStatistics(pfDao, pdpStatisticsTestList);
 122         createdListStr = createdPdpStatisticsList.toString();
 123         assertEquals(createdListStr.replaceAll("\\s+", ""), testListStr.replaceAll("\\s+", ""));
 124
 125     }
 126
 127     @After
 128     public void teardown() {
 129         pfDao.close();
 130     }
 131
 132     @Test
 133     public void testNotOkPdpStatistics() {
 134         PdpStatistics pdpStatisticsErr = new PdpStatistics();
 135         pdpStatisticsErr.setPdpInstanceId("NULL");
 136         pdpStatisticsErr.setPdpGroupName(GROUP);
 137         ArrayList<PdpStatistics> pdpStatisticsNullList = new ArrayList<>();
 138         pdpStatisticsNullList.add(pdpStatisticsErr);
 139
 140         assertThatThrownBy(() -> {
 141             new PdpStatisticsProvider().createPdpStatistics(pfDao, null);
 142         }).hasMessageMatching(LIST_IS_NULL);
 143
 144         assertThatThrownBy(() -> {
 145             new PdpStatisticsProvider().updatePdpStatistics(pfDao, null);
 146         }).hasMessageMatching(LIST_IS_NULL);
 147
 148         assertThatThrownBy(() -> {
 149             new PdpStatisticsProvider().createPdpStatistics(pfDao, pdpStatisticsNullList);
 150         }).hasMessageContaining("pdp statistics").hasMessageContaining("key")
 151                         .hasMessageContaining(Validated.IS_A_NULL_KEY);
 152
 153         assertThatThrownBy(() -> {
 154             new PdpStatisticsProvider().updatePdpStatistics(pfDao, pdpStatisticsNullList);
 155         }).hasMessageContaining("pdp statistics").hasMessageContaining("key")
 156                         .hasMessageContaining(Validated.IS_A_NULL_KEY);
 157     }
 158
 159     @Test
 160     public void testGetPdpStatistics() throws Exception {
 161         assertThatThrownBy(() -> {
 162             new PdpStatisticsProvider().createPdpStatistics(null, null);
 163         }).hasMessageMatching(DAO_IS_NULL);
 164         assertThatThrownBy(() -> {
 165             new PdpStatisticsProvider().getPdpStatistics(null, null, null);
 166         }).hasMessageMatching(DAO_IS_NULL);
 167
 168         List<PdpStatistics> getPdpStatisticsList;
 169         getPdpStatisticsList = new PdpStatisticsProvider().getPdpStatistics(pfDao, NAME, TIMESTAMP1);
 170         assertThat(getPdpStatisticsList).hasSize(1);
 171         String gotListStr = getPdpStatisticsList.toString();
 172         assertEquals(name1ListStr.replaceAll("\\s+", ""), gotListStr.replaceAll("\\s+", ""));
 173
 174         // name is null
 175         getPdpStatisticsList = new PdpStatisticsProvider().getPdpStatistics(pfDao, null, TIMESTAMP1);
 176         gotListStr = getPdpStatisticsList.toString();
 177         assertEquals(testListStr.replaceAll("\\s+", ""), gotListStr.replaceAll("\\s+", ""));
 178     }
 179
 180     @Test
 181     public void testGetFilteredPdpStatistics() throws Exception {
 182         assertThatThrownBy(() -> {
 183             new PdpStatisticsProvider().getFilteredPdpStatistics(null, NAME, GROUP, SUBGROUP, TIMESTAMP1, TIMESTAMP2,
 184                     ORDER, 1);
 185         }).hasMessageMatching(DAO_IS_NULL);
 186
 187         assertThatThrownBy(() -> {
 188             new PdpStatisticsProvider().getFilteredPdpStatistics(pfDao, NAME, null, null, TIMESTAMP1, TIMESTAMP2, ORDER,
 189                     1);
 190         }).hasMessageMatching("pdpGroupName is marked .*ull but is null");
 191
 192
 193         List<PdpStatistics> createdPdpStatisticsList;
 194         createdPdpStatisticsList = new PdpStatisticsProvider().createPdpStatistics(pfDao, pdpStatisticsTestList);
 195         createdListStr = createdPdpStatisticsList.toString();
 196         assertEquals(createdListStr.replaceAll("\\s+", ""), testListStr.replaceAll("\\s+", ""));
 197
 198         List<PdpStatistics> getPdpStatisticsList;
 199         getPdpStatisticsList = new PdpStatisticsProvider().getFilteredPdpStatistics(pfDao, NAME, GROUP, null,
 200                 TIMESTAMP1, TIMESTAMP2, ORDER, 0);
 201         assertThat(getPdpStatisticsList).hasSize(1);
 202         getPdpStatisticsList = new PdpStatisticsProvider().getFilteredPdpStatistics(pfDao, "name2", GROUP, null,
 203                 TIMESTAMP1, TIMESTAMP2, ORDER, 0);
 204         assertThat(getPdpStatisticsList).hasSize(1);
 205         getPdpStatisticsList = new PdpStatisticsProvider().getFilteredPdpStatistics(pfDao, "name2", GROUP, SUBGROUP,
 206                 TIMESTAMP1, TIMESTAMP2, ORDER, 0);
 207         assertThat(getPdpStatisticsList).hasSize(1);
 208     }
 209
 210     @Test
 211     public void testUpdatePdpStatistics() throws Exception {
 212         assertThatThrownBy(() -> {
 213             new PdpStatisticsProvider().updatePdpStatistics(null, null);
 214         }).hasMessageMatching(DAO_IS_NULL);
 215
 216         pdpStatisticsTestList.get(0).setPdpGroupName(GROUP0);
 217         testListStr = pdpStatisticsTestList.toString();
 218         List<PdpStatistics> updatePdpStatisticsList =
 219                 new PdpStatisticsProvider().updatePdpStatistics(pfDao, pdpStatisticsTestList);
 220         String gotListStr = updatePdpStatisticsList.toString();
 221         assertEquals(testListStr.replaceAll("\\s+", ""), gotListStr.replaceAll("\\s+", ""));
 222
 223     }
 224
 225     @Test
 226     public void testDeletePdpStatistics() throws Exception {
 227         assertThatThrownBy(() -> {
 228             new PdpStatisticsProvider().deletePdpStatistics(null, null, null);
 229         }).hasMessageMatching(DAO_IS_NULL);
 230
 231         assertThatThrownBy(() -> {
 232             new PdpStatisticsProvider().deletePdpStatistics(pfDao, null, null);
 233         }).hasMessageMatching("name is marked .*ull but is null");
 234
 235         List<PdpStatistics> deletedPdpStatisticsList =
 236                 new PdpStatisticsProvider().deletePdpStatistics(pfDao, NAME, null);
 237         String gotListStr = deletedPdpStatisticsList.toString();
 238         assertEquals(name1ListStr.replaceAll("\\s+", ""), gotListStr.replaceAll("\\s+", ""));
 239     }
 240
 241 }