2 * ============LICENSE_START=======================================================
3 * Copyright (C) 2019-2020 Nordix Foundation.
4 * Modifications Copyright (C) 2019 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
10 * http://www.apache.org/licenses/LICENSE-2.0
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.
18 * SPDX-License-Identifier: Apache-2.0
19 * ============LICENSE_END=========================================================
22 package org.onap.policy.models.tosca.simple.provider;
24 import static org.assertj.core.api.Assertions.assertThatThrownBy;
25 import static org.junit.Assert.assertEquals;
26 import static org.junit.Assert.assertNotNull;
27 import static org.junit.Assert.assertNull;
29 import java.util.Properties;
31 import org.eclipse.persistence.config.PersistenceUnitProperties;
32 import org.junit.After;
33 import org.junit.Before;
34 import org.junit.Test;
35 import org.onap.policy.common.utils.coder.CoderException;
36 import org.onap.policy.common.utils.coder.StandardCoder;
37 import org.onap.policy.common.utils.resources.ResourceUtils;
38 import org.onap.policy.models.base.PfConceptKey;
39 import org.onap.policy.models.base.PfModelException;
40 import org.onap.policy.models.base.PfReferenceKey;
41 import org.onap.policy.models.dao.DaoParameters;
42 import org.onap.policy.models.dao.PfDao;
43 import org.onap.policy.models.dao.PfDaoFactory;
44 import org.onap.policy.models.dao.impl.DefaultPfDao;
45 import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicy;
46 import org.onap.policy.models.tosca.authorative.concepts.ToscaServiceTemplate;
47 import org.onap.policy.models.tosca.authorative.provider.AuthorativeToscaProvider;
48 import org.onap.policy.models.tosca.simple.concepts.JpaToscaDataType;
49 import org.onap.policy.models.tosca.simple.concepts.JpaToscaDataTypes;
50 import org.onap.policy.models.tosca.simple.concepts.JpaToscaPolicies;
51 import org.onap.policy.models.tosca.simple.concepts.JpaToscaPolicy;
52 import org.onap.policy.models.tosca.simple.concepts.JpaToscaPolicyType;
53 import org.onap.policy.models.tosca.simple.concepts.JpaToscaPolicyTypes;
54 import org.onap.policy.models.tosca.simple.concepts.JpaToscaProperty;
55 import org.onap.policy.models.tosca.simple.concepts.JpaToscaServiceTemplate;
56 import org.onap.policy.models.tosca.simple.concepts.JpaToscaTopologyTemplate;
57 import org.yaml.snakeyaml.Yaml;
60 * Test the {@link SimpleToscaProvider} class.
62 * @author Liam Fallon (liam.fallon@est.tech)
64 public class SimpleToscaProviderTest {
65 private static final String TEMPLATE_IS_NULL = "^serviceTemplate is marked .*on.*ull but is null$";
66 private static final String INCOMING_TEMPLATE_IS_NULL = "^incomingServiceTemplate is marked .*on.*ull but is null$";
67 private static final String VCPE_INPUT_JSON = "policies/vCPE.policy.monitoring.input.tosca.json";
68 private static final String DAO_IS_NULL = "^dao is marked .*on.*ull but is null$";
71 private StandardCoder standardCoder;
74 * Set up the DAO towards the database.
76 * @throws Exception on database errors
79 public void setupDao() throws Exception {
80 final DaoParameters daoParameters = new DaoParameters();
81 daoParameters.setPluginClass(DefaultPfDao.class.getName());
83 daoParameters.setPersistenceUnit("ToscaConceptTest");
85 Properties jdbcProperties = new Properties();
86 jdbcProperties.setProperty(PersistenceUnitProperties.JDBC_USER, "policy");
87 jdbcProperties.setProperty(PersistenceUnitProperties.JDBC_PASSWORD, "P01icY");
89 // H2, use "org.mariadb.jdbc.Driver" and "jdbc:mariadb://localhost:3306/policy" for locally installed MariaDB
90 jdbcProperties.setProperty(PersistenceUnitProperties.JDBC_DRIVER, "org.h2.Driver");
91 jdbcProperties.setProperty(PersistenceUnitProperties.JDBC_URL, "jdbc:h2:mem:testdb");
93 daoParameters.setJdbcProperties(jdbcProperties);
95 pfDao = new PfDaoFactory().createPfDao(daoParameters);
96 pfDao.init(daoParameters);
103 public void setupGson() {
104 standardCoder = new StandardCoder();
108 public void teardown() {
113 public void testCreateUpdateGetDeleteDataType() throws PfModelException {
114 JpaToscaServiceTemplate serviceTemplate = new JpaToscaServiceTemplate();
116 PfConceptKey dataType0Key = new PfConceptKey("DataType0", "0.0.1");
117 JpaToscaDataType dataType0 = new JpaToscaDataType();
118 dataType0.setKey(dataType0Key);
119 serviceTemplate.setDataTypes(new JpaToscaDataTypes());
120 serviceTemplate.getDataTypes().getConceptMap().put(dataType0Key, dataType0);
122 JpaToscaServiceTemplate createdServiceTemplate =
123 new SimpleToscaProvider().createDataTypes(pfDao, serviceTemplate);
125 assertEquals(1, createdServiceTemplate.getDataTypes().getConceptMap().size());
126 assertEquals(dataType0, createdServiceTemplate.getDataTypes().get(dataType0Key));
127 assertEquals(null, createdServiceTemplate.getDataTypes().get(dataType0Key).getDescription());
129 dataType0.setDescription("Updated Description");
131 JpaToscaServiceTemplate updatedServiceTemplate =
132 new SimpleToscaProvider().updateDataTypes(pfDao, serviceTemplate);
134 assertEquals(dataType0, updatedServiceTemplate.getDataTypes().get(dataType0Key));
135 assertEquals("Updated Description", updatedServiceTemplate.getDataTypes().get(dataType0Key).getDescription());
137 JpaToscaServiceTemplate gotServiceTemplate =
138 new SimpleToscaProvider().getDataTypes(pfDao, dataType0Key.getName(), dataType0Key.getVersion());
140 assertEquals(dataType0, gotServiceTemplate.getDataTypes().get(dataType0Key));
141 assertEquals("Updated Description", gotServiceTemplate.getDataTypes().get(dataType0Key).getDescription());
143 assertThatThrownBy(() -> new SimpleToscaProvider().deleteDataType(pfDao, new PfConceptKey("IDontExist:0.0.1")))
144 .hasMessage("data type IDontExist:0.0.1 not found");
146 JpaToscaServiceTemplate deletedServiceTemplate = new SimpleToscaProvider().deleteDataType(pfDao, dataType0Key);
148 assertEquals(dataType0, deletedServiceTemplate.getDataTypes().get(dataType0Key));
149 assertEquals("Updated Description", deletedServiceTemplate.getDataTypes().get(dataType0Key).getDescription());
151 // Create the data type again
152 new SimpleToscaProvider().createDataTypes(pfDao, serviceTemplate);
154 updatedServiceTemplate.setPolicyTypes(new JpaToscaPolicyTypes());
155 JpaToscaPolicyType pt0 = new JpaToscaPolicyType(new PfConceptKey("pt0:0.0.1"));
156 updatedServiceTemplate.getPolicyTypes().getConceptMap().put(pt0.getKey(), pt0);
157 new SimpleToscaProvider().createPolicyTypes(pfDao, updatedServiceTemplate);
159 deletedServiceTemplate = new SimpleToscaProvider().deleteDataType(pfDao, dataType0Key);
161 assertEquals(dataType0, deletedServiceTemplate.getDataTypes().get(dataType0Key));
162 assertEquals("Updated Description", deletedServiceTemplate.getDataTypes().get(dataType0Key).getDescription());
164 assertThatThrownBy(() -> new SimpleToscaProvider().deleteDataType(pfDao, dataType0Key))
165 .hasMessage("no data types found");
167 // Create the data type again
168 new SimpleToscaProvider().createDataTypes(pfDao, serviceTemplate);
170 JpaToscaPolicyType pt0v2 = new JpaToscaPolicyType(new PfConceptKey("pt0:0.0.2"));
171 JpaToscaProperty prop0 = new JpaToscaProperty(new PfReferenceKey(pt0v2.getKey(), "prop0"));
172 prop0.setType(dataType0Key);
173 pt0v2.getProperties().put(prop0.getKey().getLocalName(), prop0);
174 updatedServiceTemplate.getPolicyTypes().getConceptMap().put(pt0v2.getKey(), pt0v2);
175 new SimpleToscaProvider().createPolicyTypes(pfDao, updatedServiceTemplate);
177 assertThatThrownBy(() -> new SimpleToscaProvider().deleteDataType(pfDao, dataType0Key))
178 .hasMessage("data type DataType0:0.0.1 is in use, it is referenced in policy type pt0:0.0.2");
180 JpaToscaDataType dataType0v2 = new JpaToscaDataType(new PfConceptKey("DataType0:0.0.2"));
181 updatedServiceTemplate.getDataTypes().getConceptMap().put(dataType0v2.getKey(), dataType0v2);
182 new SimpleToscaProvider().createDataTypes(pfDao, updatedServiceTemplate);
184 deletedServiceTemplate = new SimpleToscaProvider().deleteDataType(pfDao, dataType0v2.getKey());
186 assertEquals(dataType0v2, deletedServiceTemplate.getDataTypes().get(dataType0v2.getKey()));
187 assertNull(deletedServiceTemplate.getDataTypes().get(dataType0v2.getKey()).getDescription());
189 assertThatThrownBy(() -> new SimpleToscaProvider().deleteDataType(pfDao, dataType0Key))
190 .hasMessage("data type DataType0:0.0.1 is in use, it is referenced in policy type pt0:0.0.2");
192 JpaToscaDataType dataType1 = new JpaToscaDataType(new PfConceptKey("DataType1:0.0.3"));
193 JpaToscaProperty prop1 = new JpaToscaProperty(new PfReferenceKey(dataType1.getKey(), "prop1"));
194 prop1.setType(dataType0v2.getKey());
195 dataType1.getProperties().put(prop1.getKey().getLocalName(), prop1);
196 updatedServiceTemplate.getDataTypes().getConceptMap().put(dataType1.getKey(), dataType1);
197 new SimpleToscaProvider().createDataTypes(pfDao, updatedServiceTemplate);
199 assertThatThrownBy(() -> new SimpleToscaProvider().deleteDataType(pfDao, dataType0v2.getKey()))
200 .hasMessage("data type DataType0:0.0.2 is in use, it is referenced in data type DataType1:0.0.3");
204 public void testCreateUpdateGetDeletePolicyType() throws PfModelException {
205 JpaToscaServiceTemplate serviceTemplate = new JpaToscaServiceTemplate();
207 PfConceptKey dataType0Key = new PfConceptKey("DataType0", "0.0.1");
208 JpaToscaDataType dataType0 = new JpaToscaDataType();
209 dataType0.setKey(dataType0Key);
210 serviceTemplate.setDataTypes(new JpaToscaDataTypes());
211 serviceTemplate.getDataTypes().getConceptMap().put(dataType0Key, dataType0);
213 PfConceptKey policyType0Key = new PfConceptKey("PolicyType0", "0.0.1");
214 JpaToscaPolicyType policyType0 = new JpaToscaPolicyType();
215 policyType0.setKey(policyType0Key);
216 serviceTemplate.setPolicyTypes(new JpaToscaPolicyTypes());
217 serviceTemplate.getPolicyTypes().getConceptMap().put(policyType0Key, policyType0);
219 JpaToscaServiceTemplate createdServiceTemplate =
220 new SimpleToscaProvider().createPolicyTypes(pfDao, serviceTemplate);
222 assertEquals(1, createdServiceTemplate.getPolicyTypes().getConceptMap().size());
223 assertEquals(policyType0, createdServiceTemplate.getPolicyTypes().get(policyType0Key));
224 assertEquals(null, createdServiceTemplate.getPolicyTypes().get(policyType0Key).getDescription());
226 policyType0.setDescription("Updated Description");
228 JpaToscaServiceTemplate updatedServiceTemplate =
229 new SimpleToscaProvider().updatePolicyTypes(pfDao, serviceTemplate);
231 assertEquals(policyType0, updatedServiceTemplate.getPolicyTypes().get(policyType0Key));
232 assertEquals("Updated Description",
233 updatedServiceTemplate.getPolicyTypes().get(policyType0Key).getDescription());
235 JpaToscaServiceTemplate gotServiceTemplate =
236 new SimpleToscaProvider().getPolicyTypes(pfDao, policyType0Key.getName(), policyType0Key.getVersion());
238 assertEquals(policyType0, gotServiceTemplate.getPolicyTypes().get(policyType0Key));
239 assertEquals("Updated Description", gotServiceTemplate.getPolicyTypes().get(policyType0Key).getDescription());
241 assertThatThrownBy(() -> {
242 new SimpleToscaProvider().deletePolicyType(pfDao, new PfConceptKey("IDontExist:0.0.1"));
243 }).hasMessage("policy type IDontExist:0.0.1 not found");
245 JpaToscaPolicyType pt1 = new JpaToscaPolicyType(new PfConceptKey("pt1:0.0.2"));
246 pt1.setDerivedFrom(policyType0Key);
247 serviceTemplate.getPolicyTypes().getConceptMap().put(pt1.getKey(), pt1);
248 new SimpleToscaProvider().createPolicyTypes(pfDao, serviceTemplate);
250 assertThatThrownBy(() -> new SimpleToscaProvider().deletePolicyType(pfDao, policyType0Key))
251 .hasMessage("policy type PolicyType0:0.0.1 is in use, it is referenced in policy type pt1:0.0.2");
253 serviceTemplate.setTopologyTemplate(new JpaToscaTopologyTemplate());
254 serviceTemplate.getTopologyTemplate().setPolicies(new JpaToscaPolicies());
256 JpaToscaPolicy p0 = new JpaToscaPolicy(new PfConceptKey("p0:0.0.1"));
257 p0.setType(policyType0Key);
258 serviceTemplate.getTopologyTemplate().getPolicies().getConceptMap().put(p0.getKey(), p0);
260 JpaToscaPolicy p1 = new JpaToscaPolicy(new PfConceptKey("p1:0.0.1"));
261 p1.setType(pt1.getKey());
262 serviceTemplate.getTopologyTemplate().getPolicies().getConceptMap().put(p1.getKey(), p1);
263 new SimpleToscaProvider().createPolicies(pfDao, serviceTemplate);
265 assertThatThrownBy(() -> new SimpleToscaProvider().deletePolicyType(pfDao, policyType0Key))
266 .hasMessage("policy type PolicyType0:0.0.1 is in use, it is referenced in policy type pt1:0.0.2");
268 assertThatThrownBy(() -> new SimpleToscaProvider().deletePolicyType(pfDao, pt1.getKey()))
269 .hasMessage("policy type pt1:0.0.2 is in use, it is referenced in policy p1:0.0.1");
271 new SimpleToscaProvider().deletePolicy(pfDao, p1.getKey());
273 new SimpleToscaProvider().deletePolicyType(pfDao, pt1.getKey());
275 new SimpleToscaProvider().deletePolicy(pfDao, p0.getKey());
277 JpaToscaServiceTemplate deletedServiceTemplate =
278 new SimpleToscaProvider().deletePolicyType(pfDao, policyType0Key);
280 assertEquals(policyType0, deletedServiceTemplate.getPolicyTypes().get(policyType0Key));
281 assertEquals("Updated Description",
282 deletedServiceTemplate.getPolicyTypes().get(policyType0Key).getDescription());
284 assertThatThrownBy(() -> new SimpleToscaProvider().deletePolicyType(pfDao, policyType0Key))
285 .hasMessage("no policy types found");
287 JpaToscaServiceTemplate newServiceTemplate =
288 new SimpleToscaProvider().createPolicyTypes(pfDao, serviceTemplate);
289 assertEquals(serviceTemplate, newServiceTemplate);
293 public void testCreateUpdateGetDeletePolicyTypeWithDataType() throws PfModelException {
294 JpaToscaServiceTemplate serviceTemplate = new JpaToscaServiceTemplate();
296 PfConceptKey policyType0Key = new PfConceptKey("PolicyType0", "0.0.1");
297 JpaToscaPolicyType policyType0 = new JpaToscaPolicyType();
298 policyType0.setKey(policyType0Key);
299 serviceTemplate.setPolicyTypes(new JpaToscaPolicyTypes());
300 serviceTemplate.getPolicyTypes().getConceptMap().put(policyType0Key, policyType0);
302 JpaToscaServiceTemplate createdServiceTemplate =
303 new SimpleToscaProvider().createPolicyTypes(pfDao, serviceTemplate);
305 assertEquals(policyType0, createdServiceTemplate.getPolicyTypes().get(policyType0Key));
306 assertEquals(null, createdServiceTemplate.getPolicyTypes().get(policyType0Key).getDescription());
308 policyType0.setDescription("Updated Description");
310 JpaToscaServiceTemplate updatedServiceTemplate =
311 new SimpleToscaProvider().updatePolicyTypes(pfDao, serviceTemplate);
313 assertEquals(policyType0, updatedServiceTemplate.getPolicyTypes().get(policyType0Key));
314 assertEquals("Updated Description",
315 updatedServiceTemplate.getPolicyTypes().get(policyType0Key).getDescription());
317 JpaToscaServiceTemplate gotServiceTemplate =
318 new SimpleToscaProvider().getPolicyTypes(pfDao, policyType0Key.getName(), policyType0Key.getVersion());
320 assertEquals(policyType0, gotServiceTemplate.getPolicyTypes().get(policyType0Key));
321 assertEquals("Updated Description", gotServiceTemplate.getPolicyTypes().get(policyType0Key).getDescription());
323 JpaToscaServiceTemplate deletedServiceTemplate =
324 new SimpleToscaProvider().deletePolicyType(pfDao, policyType0Key);
326 assertEquals(policyType0, deletedServiceTemplate.getPolicyTypes().get(policyType0Key));
327 assertEquals("Updated Description",
328 deletedServiceTemplate.getPolicyTypes().get(policyType0Key).getDescription());
330 assertThatThrownBy(() -> new SimpleToscaProvider().deletePolicyType(pfDao, policyType0Key))
331 .hasMessage("no policy types found");
335 public void testPoliciesGet() throws Exception {
336 ToscaServiceTemplate toscaServiceTemplate =
337 standardCoder.decode(ResourceUtils.getResourceAsString(VCPE_INPUT_JSON), ToscaServiceTemplate.class);
341 JpaToscaServiceTemplate originalServiceTemplate = new JpaToscaServiceTemplate();
342 originalServiceTemplate.fromAuthorative(toscaServiceTemplate);
344 assertNotNull(originalServiceTemplate);
345 JpaToscaServiceTemplate createdServiceTemplate =
346 new SimpleToscaProvider().createPolicies(pfDao, originalServiceTemplate);
348 assertEquals(originalServiceTemplate.getTopologyTemplate().getPolicies(),
349 createdServiceTemplate.getTopologyTemplate().getPolicies());
351 PfConceptKey policyKey = new PfConceptKey("onap.restart.tca:1.0.0");
353 JpaToscaServiceTemplate gotServiceTemplate =
354 new SimpleToscaProvider().getPolicies(pfDao, policyKey.getName(), policyKey.getVersion());
356 assertEquals(originalServiceTemplate.getTopologyTemplate().getPolicies().get(policyKey),
357 gotServiceTemplate.getTopologyTemplate().getPolicies().get(policyKey));
359 JpaToscaServiceTemplate deletedServiceTemplate = new SimpleToscaProvider().deletePolicy(pfDao, policyKey);
360 assertEquals(1, deletedServiceTemplate.getTopologyTemplate().getPolicies().getConceptMap().size());
364 public void testPolicyCreate() throws Exception {
365 ToscaServiceTemplate toscaServiceTemplate =
366 standardCoder.decode(ResourceUtils.getResourceAsString(VCPE_INPUT_JSON), ToscaServiceTemplate.class);
370 JpaToscaServiceTemplate originalServiceTemplate = new JpaToscaServiceTemplate();
371 originalServiceTemplate.fromAuthorative(toscaServiceTemplate);
373 assertNotNull(originalServiceTemplate);
374 JpaToscaServiceTemplate createdServiceTemplate =
375 new SimpleToscaProvider().createPolicies(pfDao, originalServiceTemplate);
377 assertEquals(originalServiceTemplate.getTopologyTemplate().getPolicies(),
378 createdServiceTemplate.getTopologyTemplate().getPolicies());
382 public void testPolicyCreateTypeAndVersion() throws Exception {
383 ToscaServiceTemplate toscaServiceTemplate =
384 standardCoder.decode(ResourceUtils.getResourceAsString(VCPE_INPUT_JSON), ToscaServiceTemplate.class);
388 ToscaPolicy toscaPolicy =
389 toscaServiceTemplate.getToscaTopologyTemplate().getPoliciesAsMap().values().iterator().next();
391 JpaToscaServiceTemplate originalServiceTemplate = new JpaToscaServiceTemplate();
393 final String originalPolicyType = toscaPolicy.getType();
394 final String originalPolicyTypeVersion = toscaPolicy.getTypeVersion();
395 toscaPolicy.setType(null);
396 toscaPolicy.setTypeVersion(null);
398 assertThatThrownBy(() -> {
399 originalServiceTemplate.fromAuthorative(toscaServiceTemplate);
400 }).hasMessage("PolicyType type not specified, the type of the PolicyType for this policy must be "
401 + "specified in the type field");
403 toscaPolicy.setType("IDontExist");
404 assertThatThrownBy(() -> {
405 originalServiceTemplate.fromAuthorative(toscaServiceTemplate);
406 }).hasMessage("PolicyType version not specified, the version of the PolicyType for this policy must be "
407 + "specified in the type_version field");
409 toscaPolicy.setTypeVersion("hello");
410 assertThatThrownBy(() -> {
411 originalServiceTemplate.fromAuthorative(toscaServiceTemplate);
412 }).hasMessageContaining("value \"hello\", does not match regular expression");
414 toscaPolicy.setTypeVersion("99.100.101");
415 originalServiceTemplate.fromAuthorative(toscaServiceTemplate);
417 assertThatThrownBy(() -> {
418 new SimpleToscaProvider().createPolicies(pfDao, originalServiceTemplate);
419 }).hasMessageContaining("policy type IDontExist:99.100.101 referenced in policy not found");
421 toscaPolicy.setType("IDontExist");
422 originalServiceTemplate.fromAuthorative(toscaServiceTemplate);
424 toscaPolicy.setType(null);
426 assertThatThrownBy(() -> {
427 originalServiceTemplate.fromAuthorative(toscaServiceTemplate);
428 }).hasMessage("PolicyType type not specified, the type of the PolicyType for this policy must be "
429 + "specified in the type field");
431 toscaPolicy.setType(originalPolicyType);
432 toscaPolicy.setTypeVersion(originalPolicyTypeVersion);
434 originalServiceTemplate.fromAuthorative(toscaServiceTemplate);
435 JpaToscaServiceTemplate createdServiceTemplate =
436 new SimpleToscaProvider().createPolicies(pfDao, originalServiceTemplate);
437 assertEquals(originalServiceTemplate.getTopologyTemplate().getPolicies(),
438 createdServiceTemplate.getTopologyTemplate().getPolicies());
442 public void testPolicyUpdate() throws Exception {
443 ToscaServiceTemplate toscaServiceTemplate =
444 standardCoder.decode(ResourceUtils.getResourceAsString(VCPE_INPUT_JSON), ToscaServiceTemplate.class);
448 JpaToscaServiceTemplate originalServiceTemplate = new JpaToscaServiceTemplate();
449 originalServiceTemplate.fromAuthorative(toscaServiceTemplate);
451 assertNotNull(originalServiceTemplate);
452 JpaToscaServiceTemplate updatedServiceTemplate =
453 new SimpleToscaProvider().updatePolicies(pfDao, originalServiceTemplate);
455 assertEquals(originalServiceTemplate, updatedServiceTemplate);
459 public void testPoliciesDelete() throws Exception {
460 ToscaServiceTemplate toscaServiceTemplate =
461 standardCoder.decode(ResourceUtils.getResourceAsString(VCPE_INPUT_JSON), ToscaServiceTemplate.class);
465 JpaToscaServiceTemplate originalServiceTemplate = new JpaToscaServiceTemplate();
466 originalServiceTemplate.fromAuthorative(toscaServiceTemplate);
468 assertNotNull(originalServiceTemplate);
469 JpaToscaServiceTemplate createdServiceTemplate =
470 new SimpleToscaProvider().createPolicies(pfDao, originalServiceTemplate);
472 assertEquals(originalServiceTemplate.getTopologyTemplate(), createdServiceTemplate.getTopologyTemplate());
474 PfConceptKey policyKey = new PfConceptKey("onap.restart.tca:1.0.0");
476 assertThatThrownBy(() -> new SimpleToscaProvider().deletePolicy(pfDao, new PfConceptKey("IDontExist:0.0.1")))
477 .hasMessage("policy IDontExist:0.0.1 not found");
479 JpaToscaServiceTemplate deletedServiceTemplate = new SimpleToscaProvider().deletePolicy(pfDao, policyKey);
481 assertEquals(originalServiceTemplate.getTopologyTemplate().getPolicies().get(policyKey),
482 deletedServiceTemplate.getTopologyTemplate().getPolicies().get(policyKey));
484 assertThatThrownBy(() -> {
485 new SimpleToscaProvider().getPolicies(pfDao, policyKey.getName(), policyKey.getVersion());
486 }).hasMessage("policies for onap.restart.tca:1.0.0 do not exist");
488 assertThatThrownBy(() -> new SimpleToscaProvider().deletePolicy(pfDao, policyKey))
489 .hasMessage("no policies found");
491 new SimpleToscaProvider().createPolicies(pfDao, originalServiceTemplate);
495 public void testAssertPoliciesExist() {
496 JpaToscaServiceTemplate testServiceTemplate = new JpaToscaServiceTemplate();
498 assertThatThrownBy(() -> new SimpleToscaProvider().createPolicies(pfDao, testServiceTemplate))
499 .hasMessage("topology template not specified on service template");
501 testServiceTemplate.setTopologyTemplate(new JpaToscaTopologyTemplate());
502 assertThatThrownBy(() -> new SimpleToscaProvider().createPolicies(pfDao, testServiceTemplate))
503 .hasMessage("no policies specified on topology template of service template");
505 testServiceTemplate.getTopologyTemplate().setPolicies(new JpaToscaPolicies());
506 assertThatThrownBy(() -> new SimpleToscaProvider().createPolicies(pfDao, testServiceTemplate))
507 .hasMessage("list of policies specified on topology template of service template is empty");
511 public void testGetServiceTemplate() throws PfModelException {
512 assertThatThrownBy(() -> new SimpleToscaProvider().getServiceTemplate(pfDao))
513 .hasMessage("service template not found in database");
517 public void testAppendToServiceTemplate() throws PfModelException {
518 JpaToscaServiceTemplate serviceTemplateFragment = new JpaToscaServiceTemplate();
519 serviceTemplateFragment.setPolicyTypes(new JpaToscaPolicyTypes());
520 JpaToscaPolicyType badPt = new JpaToscaPolicyType();
521 serviceTemplateFragment.getPolicyTypes().getConceptMap().put(badPt.getKey(), badPt);
523 assertThatThrownBy(() -> new SimpleToscaProvider().appendToServiceTemplate(pfDao, serviceTemplateFragment))
524 .hasMessageContaining(
525 "key on concept entry PfConceptKey(name=NULL, version=0.0.0) may not be the null key");
529 public void testGetDataTypesCornerCases() throws PfModelException {
530 assertThatThrownBy(() -> {
531 new SimpleToscaProvider().getDataTypes(pfDao, "hello", "0.0.1");
532 }).hasMessageMatching("service template not found in database");
534 JpaToscaServiceTemplate serviceTemplate = new JpaToscaServiceTemplate();
535 serviceTemplate.setPolicyTypes(new JpaToscaPolicyTypes());
536 JpaToscaPolicyType p0 = new JpaToscaPolicyType(new PfConceptKey("p0:0.0.1"));
537 serviceTemplate.getPolicyTypes().getConceptMap().put(p0.getKey(), p0);
539 new SimpleToscaProvider().createPolicyTypes(pfDao, serviceTemplate);
541 assertThatThrownBy(() -> {
542 new SimpleToscaProvider().getDataTypes(pfDao, "hello", "0.0.1");
543 }).hasMessageMatching("data types for hello:0.0.1 do not exist");
545 serviceTemplate.setDataTypes(new JpaToscaDataTypes());
547 JpaToscaDataType p01 = new JpaToscaDataType(new PfConceptKey("dt0:0.0.1"));
548 serviceTemplate.getDataTypes().getConceptMap().put(p01.getKey(), p01);
550 new SimpleToscaProvider().createDataTypes(pfDao, serviceTemplate);
552 assertThatThrownBy(() -> {
553 new SimpleToscaProvider().getDataTypes(pfDao, "hello", "0.0.1");
554 }).hasMessageMatching("data types for hello:0.0.1 do not exist");
556 JpaToscaServiceTemplate gotSt = new SimpleToscaProvider().getDataTypes(pfDao, p01.getName(), p01.getVersion());
558 assertEquals(p01, gotSt.getDataTypes().get(p01.getKey()));
559 assertEquals(p01, gotSt.getDataTypes().get(p01.getName()));
560 assertEquals(p01, gotSt.getDataTypes().get(p01.getName(), null));
561 assertEquals(p01, gotSt.getDataTypes().get(p01.getName(), p01.getVersion()));
562 assertEquals(1, gotSt.getDataTypes().getAll(null).size());
563 assertEquals(1, gotSt.getDataTypes().getAll(null, null).size());
564 assertEquals(1, gotSt.getDataTypes().getAll(p01.getName(), null).size());
565 assertEquals(1, gotSt.getDataTypes().getAll(p01.getName(), p01.getVersion()).size());
567 JpaToscaDataType p02 = new JpaToscaDataType(new PfConceptKey("dt0:0.0.2"));
568 serviceTemplate.getDataTypes().getConceptMap().put(p02.getKey(), p02);
570 new SimpleToscaProvider().createDataTypes(pfDao, serviceTemplate);
571 gotSt = new SimpleToscaProvider().getDataTypes(pfDao, p01.getName(), null);
573 assertEquals(p01, gotSt.getDataTypes().get(p01.getKey()));
574 assertEquals(p02, gotSt.getDataTypes().get(p01.getName()));
575 assertEquals(p02, gotSt.getDataTypes().get(p01.getName(), null));
576 assertEquals(p01, gotSt.getDataTypes().get(p01.getName(), p01.getVersion()));
577 assertEquals(p02, gotSt.getDataTypes().get(p01.getName(), p02.getVersion()));
578 assertEquals(2, gotSt.getDataTypes().getAll(null).size());
579 assertEquals(2, gotSt.getDataTypes().getAll(null, null).size());
580 assertEquals(2, gotSt.getDataTypes().getAll(p01.getName(), null).size());
581 assertEquals(1, gotSt.getDataTypes().getAll(p01.getName(), p02.getVersion()).size());
585 public void testGetPolicyTypesCornerCases() throws PfModelException {
586 assertThatThrownBy(() -> {
587 new SimpleToscaProvider().getPolicyTypes(pfDao, "hello", "0.0.1");
588 }).hasMessageMatching("service template not found in database");
590 JpaToscaServiceTemplate serviceTemplate = new JpaToscaServiceTemplate();
591 serviceTemplate.setDataTypes(new JpaToscaDataTypes());
592 JpaToscaDataType dt0 = new JpaToscaDataType(new PfConceptKey("dt0:0.0.1"));
593 serviceTemplate.getDataTypes().getConceptMap().put(dt0.getKey(), dt0);
595 new SimpleToscaProvider().createDataTypes(pfDao, serviceTemplate);
597 assertThatThrownBy(() -> {
598 new SimpleToscaProvider().getPolicyTypes(pfDao, "hello", "0.0.1");
599 }).hasMessageMatching("policy types for hello:0.0.1 do not exist");
601 serviceTemplate.setPolicyTypes(new JpaToscaPolicyTypes());
603 JpaToscaPolicyType pt01 = new JpaToscaPolicyType(new PfConceptKey("p0:0.0.1"));
604 serviceTemplate.getPolicyTypes().getConceptMap().put(pt01.getKey(), pt01);
606 new SimpleToscaProvider().createPolicyTypes(pfDao, serviceTemplate);
608 assertThatThrownBy(() -> {
609 new SimpleToscaProvider().getPolicyTypes(pfDao, "hello", "0.0.1");
610 }).hasMessageMatching("policy types for hello:0.0.1 do not exist");
612 JpaToscaServiceTemplate gotSt =
613 new SimpleToscaProvider().getPolicyTypes(pfDao, pt01.getName(), pt01.getVersion());
615 assertEquals(pt01, gotSt.getPolicyTypes().get(pt01.getKey()));
616 assertEquals(pt01, gotSt.getPolicyTypes().get(pt01.getName()));
617 assertEquals(pt01, gotSt.getPolicyTypes().get(pt01.getName(), null));
618 assertEquals(pt01, gotSt.getPolicyTypes().get(pt01.getName(), pt01.getVersion()));
619 assertEquals(1, gotSt.getPolicyTypes().getAll(null).size());
620 assertEquals(1, gotSt.getPolicyTypes().getAll(null, null).size());
621 assertEquals(1, gotSt.getPolicyTypes().getAll(pt01.getName(), null).size());
622 assertEquals(1, gotSt.getPolicyTypes().getAll(pt01.getName(), pt01.getVersion()).size());
624 JpaToscaPolicyType pt02 = new JpaToscaPolicyType(new PfConceptKey("p0:0.0.2"));
625 serviceTemplate.getPolicyTypes().getConceptMap().put(pt02.getKey(), pt02);
627 new SimpleToscaProvider().createPolicyTypes(pfDao, serviceTemplate);
628 gotSt = new SimpleToscaProvider().getPolicyTypes(pfDao, pt01.getName(), null);
630 assertEquals(pt01, gotSt.getPolicyTypes().get(pt01.getKey()));
631 assertEquals(pt02, gotSt.getPolicyTypes().get(pt01.getName()));
632 assertEquals(pt02, gotSt.getPolicyTypes().get(pt01.getName(), null));
633 assertEquals(pt01, gotSt.getPolicyTypes().get(pt01.getName(), pt01.getVersion()));
634 assertEquals(pt02, gotSt.getPolicyTypes().get(pt01.getName(), pt02.getVersion()));
635 assertEquals(2, gotSt.getPolicyTypes().getAll(null).size());
636 assertEquals(2, gotSt.getPolicyTypes().getAll(null, null).size());
637 assertEquals(2, gotSt.getPolicyTypes().getAll(pt01.getName(), null).size());
638 assertEquals(1, gotSt.getPolicyTypes().getAll(pt01.getName(), pt02.getVersion()).size());
642 public void testGetPoliciesCornerCases() throws PfModelException {
643 assertThatThrownBy(() -> {
644 new SimpleToscaProvider().getPolicies(pfDao, "hello", "0.0.1");
645 }).hasMessageMatching("service template not found in database");
647 JpaToscaServiceTemplate serviceTemplate = new JpaToscaServiceTemplate();
648 serviceTemplate.setDataTypes(new JpaToscaDataTypes());
649 JpaToscaDataType dt0 = new JpaToscaDataType(new PfConceptKey("dt0:0.0.1"));
650 serviceTemplate.getDataTypes().getConceptMap().put(dt0.getKey(), dt0);
652 new SimpleToscaProvider().createDataTypes(pfDao, serviceTemplate);
654 assertThatThrownBy(() -> {
655 new SimpleToscaProvider().getPolicies(pfDao, "hello", "0.0.1");
656 }).hasMessageMatching("policies for hello:0.0.1 do not exist");
658 serviceTemplate.setPolicyTypes(new JpaToscaPolicyTypes());
660 JpaToscaPolicyType pt01 = new JpaToscaPolicyType(new PfConceptKey("pt0:0.0.1"));
661 serviceTemplate.getPolicyTypes().getConceptMap().put(pt01.getKey(), pt01);
663 serviceTemplate.setTopologyTemplate(new JpaToscaTopologyTemplate());
664 serviceTemplate.getTopologyTemplate().setPolicies(new JpaToscaPolicies());
666 JpaToscaPolicy p01 = new JpaToscaPolicy(new PfConceptKey("p0:0.0.1"));
667 p01.setType(pt01.getKey());
668 serviceTemplate.getTopologyTemplate().getPolicies().getConceptMap().put(p01.getKey(), p01);
670 new SimpleToscaProvider().createPolicies(pfDao, serviceTemplate);
672 assertThatThrownBy(() -> {
673 new SimpleToscaProvider().getPolicies(pfDao, "hello", "0.0.1");
674 }).hasMessageMatching("policies for hello:0.0.1 do not exist");
676 JpaToscaServiceTemplate gotSt = new SimpleToscaProvider().getPolicies(pfDao, p01.getName(), p01.getVersion());
678 assertEquals(p01, gotSt.getTopologyTemplate().getPolicies().get(p01.getKey()));
679 assertEquals(p01, gotSt.getTopologyTemplate().getPolicies().get(p01.getName()));
680 assertEquals(p01, gotSt.getTopologyTemplate().getPolicies().get(p01.getName(), null));
681 assertEquals(p01, gotSt.getTopologyTemplate().getPolicies().get(p01.getName(), p01.getVersion()));
682 assertEquals(1, gotSt.getTopologyTemplate().getPolicies().getAll(null).size());
683 assertEquals(1, gotSt.getTopologyTemplate().getPolicies().getAll(null, null).size());
684 assertEquals(1, gotSt.getTopologyTemplate().getPolicies().getAll(p01.getName(), null).size());
685 assertEquals(1, gotSt.getTopologyTemplate().getPolicies().getAll(p01.getName(), p01.getVersion()).size());
687 JpaToscaPolicy p02 = new JpaToscaPolicy(new PfConceptKey("p0:0.0.2"));
688 p02.setType(pt01.getKey());
689 serviceTemplate.getTopologyTemplate().getPolicies().getConceptMap().put(p02.getKey(), p02);
691 new SimpleToscaProvider().createPolicies(pfDao, serviceTemplate);
692 gotSt = new SimpleToscaProvider().getPolicies(pfDao, p01.getName(), null);
694 assertEquals(p01, gotSt.getTopologyTemplate().getPolicies().get(p01.getKey()));
695 assertEquals(p02, gotSt.getTopologyTemplate().getPolicies().get(p01.getName()));
696 assertEquals(p02, gotSt.getTopologyTemplate().getPolicies().get(p01.getName(), null));
697 assertEquals(p01, gotSt.getTopologyTemplate().getPolicies().get(p01.getName(), p01.getVersion()));
698 assertEquals(p02, gotSt.getTopologyTemplate().getPolicies().get(p01.getName(), p02.getVersion()));
699 assertEquals(2, gotSt.getTopologyTemplate().getPolicies().getAll(null).size());
700 assertEquals(2, gotSt.getTopologyTemplate().getPolicies().getAll(null, null).size());
701 assertEquals(2, gotSt.getTopologyTemplate().getPolicies().getAll(p01.getName(), null).size());
702 assertEquals(1, gotSt.getTopologyTemplate().getPolicies().getAll(p01.getName(), p02.getVersion()).size());
706 public void testNonNulls() {
707 assertThatThrownBy(() -> {
708 new SimpleToscaProvider().getServiceTemplate(null);
709 }).hasMessageMatching(DAO_IS_NULL);
711 assertThatThrownBy(() -> {
712 new SimpleToscaProvider().appendToServiceTemplate(null, null);
713 }).hasMessageMatching(DAO_IS_NULL);
715 assertThatThrownBy(() -> {
716 new SimpleToscaProvider().appendToServiceTemplate(null, new JpaToscaServiceTemplate());
717 }).hasMessageMatching(DAO_IS_NULL);
719 assertThatThrownBy(() -> {
720 new SimpleToscaProvider().appendToServiceTemplate(pfDao, null);
721 }).hasMessageMatching("^incomingServiceTemplateFragment is marked .*on.*ull but is null$");
723 assertThatThrownBy(() -> {
724 new SimpleToscaProvider().getDataTypes(null, null, null);
725 }).hasMessageMatching(DAO_IS_NULL);
727 assertThatThrownBy(() -> {
728 new SimpleToscaProvider().createDataTypes(null, null);
729 }).hasMessageMatching(DAO_IS_NULL);
731 assertThatThrownBy(() -> {
732 new SimpleToscaProvider().createDataTypes(null, new JpaToscaServiceTemplate());
733 }).hasMessageMatching(DAO_IS_NULL);
735 assertThatThrownBy(() -> {
736 new SimpleToscaProvider().createDataTypes(pfDao, null);
737 }).hasMessageMatching(INCOMING_TEMPLATE_IS_NULL);
739 assertThatThrownBy(() -> {
740 new SimpleToscaProvider().updateDataTypes(null, null);
741 }).hasMessageMatching(DAO_IS_NULL);
743 assertThatThrownBy(() -> {
744 new SimpleToscaProvider().updateDataTypes(null, new JpaToscaServiceTemplate());
745 }).hasMessageMatching(DAO_IS_NULL);
747 assertThatThrownBy(() -> {
748 new SimpleToscaProvider().updateDataTypes(pfDao, null);
749 }).hasMessageMatching(TEMPLATE_IS_NULL);
751 assertThatThrownBy(() -> {
752 new SimpleToscaProvider().deleteDataType(null, null);
753 }).hasMessageMatching(DAO_IS_NULL);
755 assertThatThrownBy(() -> {
756 new SimpleToscaProvider().deleteDataType(null, new PfConceptKey());
757 }).hasMessageMatching(DAO_IS_NULL);
759 assertThatThrownBy(() -> {
760 new SimpleToscaProvider().deleteDataType(pfDao, null);
761 }).hasMessageMatching("^dataTypeKey is marked .*on.*ull but is null$");
763 assertThatThrownBy(() -> {
764 new SimpleToscaProvider().getPolicyTypes(null, null, null);
765 }).hasMessageMatching(DAO_IS_NULL);
767 assertThatThrownBy(() -> {
768 new SimpleToscaProvider().createPolicyTypes(null, null);
769 }).hasMessageMatching(DAO_IS_NULL);
771 assertThatThrownBy(() -> {
772 new SimpleToscaProvider().createPolicyTypes(null, new JpaToscaServiceTemplate());
773 }).hasMessageMatching(DAO_IS_NULL);
775 assertThatThrownBy(() -> {
776 new SimpleToscaProvider().createPolicyTypes(pfDao, null);
777 }).hasMessageMatching(INCOMING_TEMPLATE_IS_NULL);
779 assertThatThrownBy(() -> {
780 new SimpleToscaProvider().updatePolicyTypes(null, null);
781 }).hasMessageMatching(DAO_IS_NULL);
783 assertThatThrownBy(() -> {
784 new SimpleToscaProvider().updatePolicyTypes(null, new JpaToscaServiceTemplate());
785 }).hasMessageMatching(DAO_IS_NULL);
787 assertThatThrownBy(() -> {
788 new SimpleToscaProvider().updatePolicyTypes(pfDao, null);
789 }).hasMessageMatching(TEMPLATE_IS_NULL);
791 assertThatThrownBy(() -> {
792 new SimpleToscaProvider().deletePolicyType(null, null);
793 }).hasMessageMatching(DAO_IS_NULL);
795 assertThatThrownBy(() -> {
796 new SimpleToscaProvider().deletePolicyType(null, new PfConceptKey());
797 }).hasMessageMatching(DAO_IS_NULL);
799 assertThatThrownBy(() -> {
800 new SimpleToscaProvider().deletePolicyType(pfDao, null);
801 }).hasMessageMatching("^policyTypeKey is marked .*on.*ull but is null$");
803 assertThatThrownBy(() -> {
804 new SimpleToscaProvider().getPolicies(null, null, null);
805 }).hasMessageMatching(DAO_IS_NULL);
807 assertThatThrownBy(() -> {
808 new SimpleToscaProvider().createPolicies(null, null);
809 }).hasMessageMatching(DAO_IS_NULL);
811 assertThatThrownBy(() -> {
812 new SimpleToscaProvider().createPolicies(null, new JpaToscaServiceTemplate());
813 }).hasMessageMatching(DAO_IS_NULL);
815 assertThatThrownBy(() -> {
816 new SimpleToscaProvider().createPolicies(pfDao, null);
817 }).hasMessageMatching(INCOMING_TEMPLATE_IS_NULL);
819 assertThatThrownBy(() -> {
820 new SimpleToscaProvider().updatePolicies(null, null);
821 }).hasMessageMatching(DAO_IS_NULL);
823 assertThatThrownBy(() -> {
824 new SimpleToscaProvider().updatePolicies(null, new JpaToscaServiceTemplate());
825 }).hasMessageMatching(DAO_IS_NULL);
827 assertThatThrownBy(() -> {
828 new SimpleToscaProvider().updatePolicies(pfDao, null);
829 }).hasMessageMatching(TEMPLATE_IS_NULL);
831 assertThatThrownBy(() -> {
832 new SimpleToscaProvider().deletePolicy(null, null);
833 }).hasMessageMatching(DAO_IS_NULL);
835 assertThatThrownBy(() -> {
836 new SimpleToscaProvider().deletePolicy(null, new PfConceptKey());
837 }).hasMessageMatching(DAO_IS_NULL);
839 assertThatThrownBy(() -> {
840 new SimpleToscaProvider().deletePolicy(pfDao, null);
841 }).hasMessageMatching("^policyKey is marked .*on.*ull but is null$");
844 private void createPolicyTypes() throws CoderException, PfModelException {
845 Object yamlObject = new Yaml()
846 .load(ResourceUtils.getResourceAsString("policytypes/onap.policies.monitoring.cdap.tca.hi.lo.app.yaml"));
847 String yamlAsJsonString = new StandardCoder().encode(yamlObject);
849 ToscaServiceTemplate toscaServiceTemplatePolicyType =
850 standardCoder.decode(yamlAsJsonString, ToscaServiceTemplate.class);
852 assertNotNull(toscaServiceTemplatePolicyType);
853 new AuthorativeToscaProvider().createPolicyTypes(pfDao, toscaServiceTemplatePolicyType);