models-provider/src/test/java/org/onap/policy/models/provider/impl/DatabasePolicyModelsProviderTest.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  *  Copyright (C) 2019 Nordix Foundation.
   4  * ================================================================================
   5  * Licensed under the Apache License, Version 2.0 (the "License");
   6  * you may not use this file except in compliance with the License.
   7  * You may obtain a copy of the License at
   8  *
   9  *      http://www.apache.org/licenses/LICENSE-2.0
  10  *
  11  * Unless required by applicable law or agreed to in writing, software
  12  * distributed under the License is distributed on an "AS IS" BASIS,
  13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14  * See the License for the specific language governing permissions and
  15  * limitations under the License.
  16  *
  17  * SPDX-License-Identifier: Apache-2.0
  18  * ============LICENSE_END=========================================================
  19  */
  20
  21 package org.onap.policy.models.provider.impl;
  22
  23 import static org.assertj.core.api.Assertions.assertThatThrownBy;
  24 import static org.junit.Assert.assertEquals;
  25 import static org.junit.Assert.assertNotNull;
  26 import static org.junit.Assert.fail;
  27
  28 import java.util.ArrayList;
  29 import java.util.Base64;
  30
  31 import org.junit.Before;
  32 import org.junit.Test;
  33 import org.onap.policy.models.provider.PolicyModelsProvider;
  34 import org.onap.policy.models.provider.PolicyModelsProviderFactory;
  35 import org.onap.policy.models.provider.PolicyModelsProviderParameters;
  36 import org.onap.policy.models.tosca.authorative.concepts.ToscaServiceTemplate;
  37 import org.onap.policy.models.tosca.legacy.concepts.LegacyGuardPolicyInput;
  38 import org.onap.policy.models.tosca.legacy.concepts.LegacyOperationalPolicy;
  39 import org.slf4j.Logger;
  40 import org.slf4j.LoggerFactory;
  41
  42 /**
  43  * Test the database models provider implementation.
  44  *
  45  * @author Liam Fallon (liam.fallon@est.tech)
  46  */
  47 public class DatabasePolicyModelsProviderTest {
  48     private static final Logger LOGGER = LoggerFactory.getLogger(DatabasePolicyModelsProviderTest.class);
  49
  50     PolicyModelsProviderParameters parameters;
  51
  52     /**
  53      * Initialize parameters.
  54      */
  55     @Before
  56     public void setupParameters() {
  57         parameters = new PolicyModelsProviderParameters();
  58         parameters.setDatabaseUrl("jdbc:h2:mem:testdb");
  59         parameters.setDatabaseUser("policy");
  60         parameters.setDatabasePassword(Base64.getEncoder().encodeToString("P01icY".getBytes()));
  61         parameters.setPersistenceUnit("ToscaConceptTest");
  62
  63     }
  64
  65     @Test
  66     public void testInitAndClose() throws Exception {
  67         PolicyModelsProvider databaseProvider =
  68                 new PolicyModelsProviderFactory().createPolicyModelsProvider(parameters);
  69
  70         parameters.setDatabaseUrl("jdbc://www.acmecorp.nonexist");
  71
  72         assertThatThrownBy(() -> {
  73             databaseProvider.close();
  74             databaseProvider.init();
  75         }).hasMessage("could not connect to database with URL \"jdbc://www.acmecorp.nonexist\"");
  76
  77         parameters.setDatabaseUrl("jdbc:h2:mem:testdb");
  78
  79         try {
  80             databaseProvider.init();
  81             databaseProvider.close();
  82         } catch (Exception pfme) {
  83             fail("test shold not throw an exception here");
  84         }
  85
  86         parameters.setPersistenceUnit("WileECoyote");
  87
  88         String errorMessage = "could not create Data Access Object (DAO) using url "
  89                 + "\"jdbc:h2:mem:testdb\" and persistence unit \"WileECoyote\"";
  90         assertThatThrownBy(() -> {
  91             databaseProvider.init();
  92         }).hasMessage(errorMessage);
  93
  94         parameters.setPersistenceUnit("ToscaConceptTest");
  95
  96         try {
  97             databaseProvider.init();
  98             databaseProvider.close();
  99         } catch (Exception pfme) {
 100             fail("test shold not throw an exception here");
 101         }
 102
 103         try {
 104             databaseProvider.close();
 105         } catch (Exception pfme) {
 106             fail("test shold not throw an exception here");
 107         }
 108
 109         assertThatThrownBy(() -> {
 110             DatabasePolicyModelsProviderImpl databaseProviderImpl = (DatabasePolicyModelsProviderImpl) databaseProvider;
 111             databaseProvider.init();
 112             databaseProviderImpl.setConnection(new DummyConnection());
 113             databaseProvider.close();
 114         }).hasMessage("could not close connection to database with URL \"jdbc:h2:mem:testdb\"");
 115     }
 116
 117     @Test
 118     public void testProviderMethodsNull() throws Exception {
 119         PolicyModelsProvider databaseProvider =
 120                 new PolicyModelsProviderFactory().createPolicyModelsProvider(parameters);
 121
 122         assertThatThrownBy(() -> {
 123             databaseProvider.getPolicyTypes(null, null);
 124         }).hasMessage("name is marked @NonNull but is null");
 125
 126         assertThatThrownBy(() -> {
 127             databaseProvider.getPolicyTypes("aaa", null);
 128         }).hasMessage("version is marked @NonNull but is null");
 129
 130         assertThatThrownBy(() -> {
 131             databaseProvider.getPolicyTypes(null, "aaa");
 132         }).hasMessage("name is marked @NonNull but is null");
 133
 134         assertThatThrownBy(() -> {
 135             databaseProvider.createPolicyTypes(null);
 136         }).hasMessage("serviceTemplate is marked @NonNull but is null");
 137
 138         assertThatThrownBy(() -> {
 139             databaseProvider.updatePolicyTypes(null);
 140         }).hasMessage("serviceTemplate is marked @NonNull but is null");
 141
 142         assertThatThrownBy(() -> {
 143             databaseProvider.deletePolicyType(null, null);
 144         }).hasMessage("name is marked @NonNull but is null");
 145
 146         assertThatThrownBy(() -> {
 147             databaseProvider.deletePolicyType("aaa", null);
 148         }).hasMessage("version is marked @NonNull but is null");
 149
 150         assertThatThrownBy(() -> {
 151             databaseProvider.deletePolicyType(null, "aaa");
 152         }).hasMessage("name is marked @NonNull but is null");
 153
 154         assertThatThrownBy(() -> {
 155             databaseProvider.getPolicies(null, null);
 156         }).hasMessage("name is marked @NonNull but is null");
 157
 158         assertThatThrownBy(() -> {
 159             databaseProvider.getPolicies(null, "aaa");
 160         }).hasMessage("name is marked @NonNull but is null");
 161
 162         assertThatThrownBy(() -> {
 163             databaseProvider.getPolicies("aaa", null);
 164         }).hasMessage("version is marked @NonNull but is null");
 165
 166         assertThatThrownBy(() -> {
 167             databaseProvider.createPolicies(null);
 168         }).hasMessage("serviceTemplate is marked @NonNull but is null");
 169
 170         assertThatThrownBy(() -> {
 171             databaseProvider.updatePolicies(null);
 172         }).hasMessage("serviceTemplate is marked @NonNull but is null");
 173
 174         assertThatThrownBy(() -> {
 175             databaseProvider.deletePolicy(null, null);
 176         }).hasMessage("name is marked @NonNull but is null");
 177
 178         assertThatThrownBy(() -> {
 179             databaseProvider.deletePolicy(null, "aaa");
 180         }).hasMessage("name is marked @NonNull but is null");
 181
 182         assertThatThrownBy(() -> {
 183             databaseProvider.deletePolicy("aaa", null);
 184         }).hasMessage("version is marked @NonNull but is null");
 185
 186         assertThatThrownBy(() -> {
 187             databaseProvider.getOperationalPolicy(null);
 188         }).hasMessage("policyId is marked @NonNull but is null");
 189
 190         assertThatThrownBy(() -> {
 191             databaseProvider.createOperationalPolicy(null);
 192         }).hasMessage("legacyOperationalPolicy is marked @NonNull but is null");
 193
 194         assertThatThrownBy(() -> {
 195             databaseProvider.updateOperationalPolicy(null);
 196         }).hasMessage("legacyOperationalPolicy is marked @NonNull but is null");
 197
 198         assertThatThrownBy(() -> {
 199             databaseProvider.deleteOperationalPolicy(null);
 200         }).hasMessage("policyId is marked @NonNull but is null");
 201
 202         assertThatThrownBy(() -> {
 203             databaseProvider.getGuardPolicy(null);
 204         }).hasMessage("policyId is marked @NonNull but is null");
 205
 206         assertThatThrownBy(() -> {
 207             databaseProvider.createGuardPolicy(null);
 208         }).hasMessage("legacyGuardPolicy is marked @NonNull but is null");
 209
 210         assertThatThrownBy(() -> {
 211             databaseProvider.updateGuardPolicy(null);
 212         }).hasMessage("legacyGuardPolicy is marked @NonNull but is null");
 213
 214         assertThatThrownBy(() -> {
 215             databaseProvider.deleteGuardPolicy(null);
 216         }).hasMessage("policyId is marked @NonNull but is null");
 217
 218         assertThatThrownBy(() -> {
 219             databaseProvider.createPdpGroups(null);
 220         }).hasMessage("pdpGroups is marked @NonNull but is null");
 221
 222         assertThatThrownBy(() -> {
 223             databaseProvider.updatePdpGroups(null);
 224         }).hasMessage("pdpGroups is marked @NonNull but is null");
 225
 226         assertThatThrownBy(() -> {
 227             databaseProvider.deletePdpGroup(null, null);
 228         }).hasMessage("name is marked @NonNull but is null");
 229
 230         databaseProvider.close();
 231
 232     }
 233
 234     @Test
 235     public void testProviderMethodsNotInit() throws Exception {
 236         PolicyModelsProvider databaseProvider =
 237                 new PolicyModelsProviderFactory().createPolicyModelsProvider(parameters);
 238
 239         databaseProvider.close();
 240
 241         assertThatThrownBy(() -> {
 242             databaseProvider.getPolicyTypes("name", "version");
 243         }).hasMessage("policy models provider is not initilaized");
 244     }
 245
 246     @Test
 247     public void testProviderMethods() {
 248         try (PolicyModelsProvider databaseProvider =
 249                 new PolicyModelsProviderFactory().createPolicyModelsProvider(parameters)) {
 250
 251             assertThatThrownBy(() -> {
 252                 databaseProvider.getPolicyTypes("name", "version");
 253             }).hasMessage("policy type not found: name:version");
 254
 255             assertThatThrownBy(() -> {
 256                 databaseProvider.createPolicyTypes(new ToscaServiceTemplate());
 257             }).hasMessage("no policy types specified on service template");
 258
 259             assertThatThrownBy(() -> {
 260                 databaseProvider.updatePolicyTypes(new ToscaServiceTemplate());
 261             }).hasMessage("no policy types specified on service template");
 262
 263             assertThatThrownBy(() -> {
 264                 databaseProvider.deletePolicyType("name", "version");
 265             }).hasMessage("policy type not found: name:version");
 266
 267             assertThatThrownBy(() -> {
 268                 databaseProvider.getPolicies("name", "version");
 269             }).hasMessage("policy not found: name:version");
 270
 271             assertThatThrownBy(() -> {
 272                 databaseProvider.createPolicies(new ToscaServiceTemplate());
 273             }).hasMessage("topology template not specified on service template");
 274
 275             assertThatThrownBy(() -> {
 276                 databaseProvider.updatePolicies(new ToscaServiceTemplate());
 277             }).hasMessage("topology template not specified on service template");
 278
 279             assertThatThrownBy(() -> {
 280                 databaseProvider.deletePolicy("name", "version");
 281             }).hasMessage("policy not found: name:version");
 282
 283             assertThatThrownBy(() -> {
 284                 databaseProvider.getOperationalPolicy("policy_id");
 285             }).hasMessage("no policy found for policy ID: policy_id");
 286
 287             assertThatThrownBy(() -> {
 288                 databaseProvider.createOperationalPolicy(new LegacyOperationalPolicy());
 289             }).hasMessage("name is marked @NonNull but is null");
 290
 291             assertThatThrownBy(() -> {
 292                 databaseProvider.updateOperationalPolicy(new LegacyOperationalPolicy());
 293             }).hasMessage("no policy found for policy ID: null");
 294
 295             assertThatThrownBy(() -> {
 296                 databaseProvider.deleteOperationalPolicy("policy_id");
 297             }).hasMessage("no policy found for policy ID: policy_id");
 298
 299             assertThatThrownBy(() -> {
 300                 databaseProvider.getGuardPolicy("policy_id");
 301             }).hasMessage("no policy found for policy ID: policy_id");
 302
 303             assertThatThrownBy(() -> {
 304                 databaseProvider.createGuardPolicy(new LegacyGuardPolicyInput());
 305             }).hasMessage("policy type for guard policy \"null\" unknown");
 306
 307             assertThatThrownBy(() -> {
 308                 databaseProvider.updateGuardPolicy(new LegacyGuardPolicyInput());
 309             }).hasMessage("policy type for guard policy \"null\" unknown");
 310
 311             assertThatThrownBy(() -> {
 312                 databaseProvider.deleteGuardPolicy("policy_id");
 313             }).hasMessage("no policy found for policy ID: policy_id");
 314
 315             assertEquals(0, databaseProvider.getPdpGroups("name", "version").size());
 316
 317             assertNotNull(databaseProvider.createPdpGroups(new ArrayList<>()));
 318             assertNotNull(databaseProvider.updatePdpGroups(new ArrayList<>()));
 319
 320             assertThatThrownBy(() -> {
 321                 databaseProvider.deletePdpGroup("name", "version");
 322             }).hasMessage("delete of PDP group \"name:version\" failed, PDP group does not exist");
 323
 324         } catch (Exception exc) {
 325             LOGGER.warn("test should not throw an exception", exc);
 326             fail("test should not throw an exception");
 327         }
 328     }
 329 }