2 * ============LICENSE_START=======================================================
3 * Copyright (C) 2019-2021 Nordix Foundation.
4 * Modifications Copyright (C) 2019-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
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.LinkedHashMap;
30 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.base.Validated;
42 import org.onap.policy.models.dao.DaoParameters;
43 import org.onap.policy.models.dao.PfDao;
44 import org.onap.policy.models.dao.PfDaoFactory;
45 import org.onap.policy.models.dao.impl.DefaultPfDao;
46 import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicy;
47 import org.onap.policy.models.tosca.authorative.concepts.ToscaServiceTemplate;
48 import org.onap.policy.models.tosca.authorative.provider.AuthorativeToscaProvider;
49 import org.onap.policy.models.tosca.simple.concepts.JpaToscaDataType;
50 import org.onap.policy.models.tosca.simple.concepts.JpaToscaDataTypes;
51 import org.onap.policy.models.tosca.simple.concepts.JpaToscaPolicies;
52 import org.onap.policy.models.tosca.simple.concepts.JpaToscaPolicy;
53 import org.onap.policy.models.tosca.simple.concepts.JpaToscaPolicyType;
54 import org.onap.policy.models.tosca.simple.concepts.JpaToscaPolicyTypes;
55 import org.onap.policy.models.tosca.simple.concepts.JpaToscaProperty;
56 import org.onap.policy.models.tosca.simple.concepts.JpaToscaServiceTemplate;
57 import org.onap.policy.models.tosca.simple.concepts.JpaToscaTopologyTemplate;
58 import org.yaml.snakeyaml.Yaml;
61 * Test the {@link SimpleToscaProvider} class.
63 * @author Liam Fallon (liam.fallon@est.tech)
65 public class SimpleToscaProviderTest {
66 private static final String TEMPLATE_IS_NULL = "^serviceTemplate is marked .*on.*ull but is null$";
67 private static final String INCOMING_TEMPLATE_IS_NULL = "^incomingServiceTemplate is marked .*on.*ull but is null$";
68 private static final String VCPE_INPUT_JSON = "policies/vCPE.policy.monitoring.input.tosca.json";
69 private static final String DAO_IS_NULL = "^dao is marked .*on.*ull but is null$";
72 private StandardCoder standardCoder;
75 * Set up the DAO towards the database.
77 * @throws Exception on database errors
80 public void setupDao() throws Exception {
81 final DaoParameters daoParameters = new DaoParameters();
82 daoParameters.setPluginClass(DefaultPfDao.class.getName());
84 daoParameters.setPersistenceUnit("ToscaConceptTest");
86 Properties jdbcProperties = new Properties();
87 jdbcProperties.setProperty(PersistenceUnitProperties.JDBC_USER, "policy");
88 jdbcProperties.setProperty(PersistenceUnitProperties.JDBC_PASSWORD, "P01icY");
90 if (System.getProperty("USE-MARIADB") != null) {
91 jdbcProperties.setProperty(PersistenceUnitProperties.JDBC_DRIVER, "org.mariadb.jdbc.Driver");
92 jdbcProperties.setProperty(PersistenceUnitProperties.JDBC_URL, "jdbc:mariadb://localhost:3306/policy");
94 jdbcProperties.setProperty(PersistenceUnitProperties.JDBC_DRIVER, "org.h2.Driver");
95 jdbcProperties.setProperty(PersistenceUnitProperties.JDBC_URL, "jdbc:h2:mem:SimpleToscaProviderTest");
98 daoParameters.setJdbcProperties(jdbcProperties);
100 pfDao = new PfDaoFactory().createPfDao(daoParameters);
101 pfDao.init(daoParameters);
108 public void setupGson() {
109 standardCoder = new StandardCoder();
113 public void teardown() {
118 public void testCreateUpdateGetDeleteDataType() throws PfModelException {
119 JpaToscaServiceTemplate serviceTemplate = new JpaToscaServiceTemplate();
121 PfConceptKey dataType0Key = new PfConceptKey("DataType0", "0.0.1");
122 JpaToscaDataType dataType0 = new JpaToscaDataType();
123 dataType0.setKey(dataType0Key);
124 serviceTemplate.setDataTypes(new JpaToscaDataTypes());
125 serviceTemplate.getDataTypes().getConceptMap().put(dataType0Key, dataType0);
127 JpaToscaServiceTemplate createdServiceTemplate =
128 new SimpleToscaProvider().createDataTypes(pfDao, serviceTemplate);
130 assertEquals(1, createdServiceTemplate.getDataTypes().getConceptMap().size());
131 assertEquals(dataType0, createdServiceTemplate.getDataTypes().get(dataType0Key));
132 assertEquals(null, createdServiceTemplate.getDataTypes().get(dataType0Key).getDescription());
134 dataType0.setDescription("Updated Description");
136 JpaToscaServiceTemplate updatedServiceTemplate =
137 new SimpleToscaProvider().updateDataTypes(pfDao, serviceTemplate);
139 assertEquals(dataType0, updatedServiceTemplate.getDataTypes().get(dataType0Key));
140 assertEquals("Updated Description", updatedServiceTemplate.getDataTypes().get(dataType0Key).getDescription());
142 JpaToscaServiceTemplate gotServiceTemplate =
143 new SimpleToscaProvider().getDataTypes(pfDao, dataType0Key.getName(), dataType0Key.getVersion());
145 assertEquals(dataType0, gotServiceTemplate.getDataTypes().get(dataType0Key));
146 assertEquals("Updated Description", gotServiceTemplate.getDataTypes().get(dataType0Key).getDescription());
148 assertThatThrownBy(() -> new SimpleToscaProvider().deleteDataType(pfDao, new PfConceptKey("IDontExist:0.0.1")))
149 .hasMessage("data type IDontExist:0.0.1 not found");
151 JpaToscaServiceTemplate deletedServiceTemplate = new SimpleToscaProvider().deleteDataType(pfDao, dataType0Key);
153 assertEquals(dataType0, deletedServiceTemplate.getDataTypes().get(dataType0Key));
154 assertEquals("Updated Description", deletedServiceTemplate.getDataTypes().get(dataType0Key).getDescription());
156 // Create the data type again
157 new SimpleToscaProvider().createDataTypes(pfDao, serviceTemplate);
159 updatedServiceTemplate.setPolicyTypes(new JpaToscaPolicyTypes());
160 JpaToscaPolicyType pt0 = new JpaToscaPolicyType(new PfConceptKey("pt0:0.0.1"));
161 updatedServiceTemplate.getPolicyTypes().getConceptMap().put(pt0.getKey(), pt0);
162 new SimpleToscaProvider().createPolicyTypes(pfDao, updatedServiceTemplate);
164 deletedServiceTemplate = new SimpleToscaProvider().deleteDataType(pfDao, dataType0Key);
166 assertEquals(dataType0, deletedServiceTemplate.getDataTypes().get(dataType0Key));
167 assertEquals("Updated Description", deletedServiceTemplate.getDataTypes().get(dataType0Key).getDescription());
169 assertThatThrownBy(() -> new SimpleToscaProvider().deleteDataType(pfDao, dataType0Key))
170 .hasMessage("no data types found");
172 // Create the data type again
173 new SimpleToscaProvider().createDataTypes(pfDao, serviceTemplate);
175 JpaToscaPolicyType pt0v2 = new JpaToscaPolicyType(new PfConceptKey("pt0:0.0.2"));
176 JpaToscaProperty prop0 = new JpaToscaProperty(new PfReferenceKey(pt0v2.getKey(), "prop0"));
177 prop0.setType(dataType0Key);
178 pt0v2.setProperties(new LinkedHashMap<>());
179 pt0v2.getProperties().put(prop0.getKey().getLocalName(), prop0);
180 updatedServiceTemplate.getPolicyTypes().getConceptMap().put(pt0v2.getKey(), pt0v2);
181 new SimpleToscaProvider().createPolicyTypes(pfDao, updatedServiceTemplate);
183 assertThatThrownBy(() -> new SimpleToscaProvider().deleteDataType(pfDao, dataType0Key))
184 .hasMessage("data type DataType0:0.0.1 is in use, it is referenced in policy type pt0:0.0.2");
186 JpaToscaDataType dataType0v2 = new JpaToscaDataType(new PfConceptKey("DataType0:0.0.2"));
187 updatedServiceTemplate.getDataTypes().getConceptMap().put(dataType0v2.getKey(), dataType0v2);
188 new SimpleToscaProvider().createDataTypes(pfDao, updatedServiceTemplate);
190 deletedServiceTemplate = new SimpleToscaProvider().deleteDataType(pfDao, dataType0v2.getKey());
192 assertEquals(dataType0v2, deletedServiceTemplate.getDataTypes().get(dataType0v2.getKey()));
193 assertNull(deletedServiceTemplate.getDataTypes().get(dataType0v2.getKey()).getDescription());
195 assertThatThrownBy(() -> new SimpleToscaProvider().deleteDataType(pfDao, dataType0Key))
196 .hasMessage("data type DataType0:0.0.1 is in use, it is referenced in policy type pt0:0.0.2");
198 JpaToscaDataType dataType1 = new JpaToscaDataType(new PfConceptKey("DataType1:0.0.3"));
199 JpaToscaProperty prop1 = new JpaToscaProperty(new PfReferenceKey(dataType1.getKey(), "prop1"));
200 prop1.setType(dataType0v2.getKey());
201 dataType1.setProperties(new LinkedHashMap<>());
202 dataType1.getProperties().put(prop1.getKey().getLocalName(), prop1);
203 updatedServiceTemplate.getDataTypes().getConceptMap().put(dataType1.getKey(), dataType1);
204 new SimpleToscaProvider().createDataTypes(pfDao, updatedServiceTemplate);
206 assertThatThrownBy(() -> new SimpleToscaProvider().deleteDataType(pfDao, dataType0v2.getKey()))
207 .hasMessage("data type DataType0:0.0.2 is in use, it is referenced in data type DataType1:0.0.3");
211 public void testCreateUpdateGetDeletePolicyType() throws PfModelException {
212 JpaToscaServiceTemplate serviceTemplate = new JpaToscaServiceTemplate();
214 PfConceptKey dataType0Key = new PfConceptKey("DataType0", "0.0.1");
215 JpaToscaDataType dataType0 = new JpaToscaDataType();
216 dataType0.setKey(dataType0Key);
217 serviceTemplate.setDataTypes(new JpaToscaDataTypes());
218 serviceTemplate.getDataTypes().getConceptMap().put(dataType0Key, dataType0);
220 PfConceptKey policyType0Key = new PfConceptKey("PolicyType0", "0.0.1");
221 JpaToscaPolicyType policyType0 = new JpaToscaPolicyType();
222 policyType0.setKey(policyType0Key);
223 serviceTemplate.setPolicyTypes(new JpaToscaPolicyTypes());
224 serviceTemplate.getPolicyTypes().getConceptMap().put(policyType0Key, policyType0);
226 JpaToscaServiceTemplate createdServiceTemplate =
227 new SimpleToscaProvider().createPolicyTypes(pfDao, serviceTemplate);
229 assertEquals(1, createdServiceTemplate.getPolicyTypes().getConceptMap().size());
230 assertEquals(policyType0, createdServiceTemplate.getPolicyTypes().get(policyType0Key));
231 assertEquals(null, createdServiceTemplate.getPolicyTypes().get(policyType0Key).getDescription());
233 policyType0.setDescription("Updated Description");
235 JpaToscaServiceTemplate updatedServiceTemplate =
236 new SimpleToscaProvider().updatePolicyTypes(pfDao, serviceTemplate);
238 assertEquals(policyType0, updatedServiceTemplate.getPolicyTypes().get(policyType0Key));
239 assertEquals("Updated Description",
240 updatedServiceTemplate.getPolicyTypes().get(policyType0Key).getDescription());
242 JpaToscaServiceTemplate gotServiceTemplate =
243 new SimpleToscaProvider().getPolicyTypes(pfDao, policyType0Key.getName(), policyType0Key.getVersion());
245 assertEquals(policyType0, gotServiceTemplate.getPolicyTypes().get(policyType0Key));
246 assertEquals("Updated Description", gotServiceTemplate.getPolicyTypes().get(policyType0Key).getDescription());
248 assertThatThrownBy(() -> {
249 new SimpleToscaProvider().deletePolicyType(pfDao, new PfConceptKey("IDontExist:0.0.1"));
250 }).hasMessage("policy type IDontExist:0.0.1 not found");
252 JpaToscaPolicyType pt1 = new JpaToscaPolicyType(new PfConceptKey("pt1:0.0.2"));
253 pt1.setDerivedFrom(policyType0Key);
254 serviceTemplate.getPolicyTypes().getConceptMap().put(pt1.getKey(), pt1);
255 new SimpleToscaProvider().createPolicyTypes(pfDao, serviceTemplate);
257 assertThatThrownBy(() -> new SimpleToscaProvider().deletePolicyType(pfDao, policyType0Key))
258 .hasMessage("policy type PolicyType0:0.0.1 is in use, it is referenced in policy type pt1:0.0.2");
260 serviceTemplate.setTopologyTemplate(new JpaToscaTopologyTemplate());
261 serviceTemplate.getTopologyTemplate().setPolicies(new JpaToscaPolicies());
263 JpaToscaPolicy p0 = new JpaToscaPolicy(new PfConceptKey("p0:0.0.1"));
264 p0.setType(policyType0Key);
265 serviceTemplate.getTopologyTemplate().getPolicies().getConceptMap().put(p0.getKey(), p0);
267 JpaToscaPolicy p1 = new JpaToscaPolicy(new PfConceptKey("p1:0.0.1"));
268 p1.setType(pt1.getKey());
269 serviceTemplate.getTopologyTemplate().getPolicies().getConceptMap().put(p1.getKey(), p1);
270 new SimpleToscaProvider().createPolicies(pfDao, serviceTemplate);
272 assertThatThrownBy(() -> new SimpleToscaProvider().deletePolicyType(pfDao, policyType0Key))
273 .hasMessage("policy type PolicyType0:0.0.1 is in use, it is referenced in policy type pt1:0.0.2");
275 assertThatThrownBy(() -> new SimpleToscaProvider().deletePolicyType(pfDao, pt1.getKey()))
276 .hasMessage("policy type pt1:0.0.2 is in use, it is referenced in policy p1:0.0.1");
278 new SimpleToscaProvider().deletePolicy(pfDao, p1.getKey());
280 new SimpleToscaProvider().deletePolicyType(pfDao, pt1.getKey());
282 new SimpleToscaProvider().deletePolicy(pfDao, p0.getKey());
284 JpaToscaServiceTemplate deletedServiceTemplate =
285 new SimpleToscaProvider().deletePolicyType(pfDao, policyType0Key);
287 assertEquals(policyType0, deletedServiceTemplate.getPolicyTypes().get(policyType0Key));
288 assertEquals("Updated Description",
289 deletedServiceTemplate.getPolicyTypes().get(policyType0Key).getDescription());
291 assertThatThrownBy(() -> new SimpleToscaProvider().deletePolicyType(pfDao, policyType0Key))
292 .hasMessage("no policy types found");
294 JpaToscaServiceTemplate newServiceTemplate =
295 new SimpleToscaProvider().createPolicyTypes(pfDao, serviceTemplate);
296 assertEquals(serviceTemplate, newServiceTemplate);
300 public void testCreateUpdateGetDeletePolicyTypeWithDataType() throws PfModelException {
301 JpaToscaServiceTemplate serviceTemplate = new JpaToscaServiceTemplate();
303 PfConceptKey policyType0Key = new PfConceptKey("PolicyType0", "0.0.1");
304 JpaToscaPolicyType policyType0 = new JpaToscaPolicyType();
305 policyType0.setKey(policyType0Key);
306 serviceTemplate.setPolicyTypes(new JpaToscaPolicyTypes());
307 serviceTemplate.getPolicyTypes().getConceptMap().put(policyType0Key, policyType0);
309 JpaToscaServiceTemplate createdServiceTemplate =
310 new SimpleToscaProvider().createPolicyTypes(pfDao, serviceTemplate);
312 assertEquals(policyType0, createdServiceTemplate.getPolicyTypes().get(policyType0Key));
313 assertEquals(null, createdServiceTemplate.getPolicyTypes().get(policyType0Key).getDescription());
315 policyType0.setDescription("Updated Description");
317 JpaToscaServiceTemplate updatedServiceTemplate =
318 new SimpleToscaProvider().updatePolicyTypes(pfDao, serviceTemplate);
320 assertEquals(policyType0, updatedServiceTemplate.getPolicyTypes().get(policyType0Key));
321 assertEquals("Updated Description",
322 updatedServiceTemplate.getPolicyTypes().get(policyType0Key).getDescription());
324 JpaToscaServiceTemplate gotServiceTemplate =
325 new SimpleToscaProvider().getPolicyTypes(pfDao, policyType0Key.getName(), policyType0Key.getVersion());
327 assertEquals(policyType0, gotServiceTemplate.getPolicyTypes().get(policyType0Key));
328 assertEquals("Updated Description", gotServiceTemplate.getPolicyTypes().get(policyType0Key).getDescription());
330 JpaToscaServiceTemplate deletedServiceTemplate =
331 new SimpleToscaProvider().deletePolicyType(pfDao, policyType0Key);
333 assertEquals(policyType0, deletedServiceTemplate.getPolicyTypes().get(policyType0Key));
334 assertEquals("Updated Description",
335 deletedServiceTemplate.getPolicyTypes().get(policyType0Key).getDescription());
337 assertThatThrownBy(() -> new SimpleToscaProvider().deletePolicyType(pfDao, policyType0Key))
338 .hasMessage("no policy types found");
342 public void testPoliciesGet() throws Exception {
343 ToscaServiceTemplate toscaServiceTemplate =
344 standardCoder.decode(ResourceUtils.getResourceAsString(VCPE_INPUT_JSON), ToscaServiceTemplate.class);
348 JpaToscaServiceTemplate originalServiceTemplate = new JpaToscaServiceTemplate();
349 originalServiceTemplate.fromAuthorative(toscaServiceTemplate);
351 assertNotNull(originalServiceTemplate);
352 JpaToscaServiceTemplate createdServiceTemplate =
353 new SimpleToscaProvider().createPolicies(pfDao, originalServiceTemplate);
355 assertEquals(originalServiceTemplate.getTopologyTemplate().getPolicies(),
356 createdServiceTemplate.getTopologyTemplate().getPolicies());
358 PfConceptKey policyKey = new PfConceptKey("onap.restart.tca:1.0.0");
360 JpaToscaServiceTemplate gotServiceTemplate =
361 new SimpleToscaProvider().getPolicies(pfDao, policyKey.getName(), policyKey.getVersion());
363 assertEquals(0, originalServiceTemplate.getTopologyTemplate().getPolicies().get(policyKey)
364 .compareTo(gotServiceTemplate.getTopologyTemplate().getPolicies().get(policyKey)));
366 JpaToscaServiceTemplate deletedServiceTemplate = new SimpleToscaProvider().deletePolicy(pfDao, policyKey);
367 assertEquals(1, deletedServiceTemplate.getTopologyTemplate().getPolicies().getConceptMap().size());
371 public void testPolicyCreate() throws Exception {
372 ToscaServiceTemplate toscaServiceTemplate =
373 standardCoder.decode(ResourceUtils.getResourceAsString(VCPE_INPUT_JSON), ToscaServiceTemplate.class);
377 JpaToscaServiceTemplate originalServiceTemplate = new JpaToscaServiceTemplate();
378 originalServiceTemplate.fromAuthorative(toscaServiceTemplate);
380 assertNotNull(originalServiceTemplate);
381 JpaToscaServiceTemplate createdServiceTemplate =
382 new SimpleToscaProvider().createPolicies(pfDao, originalServiceTemplate);
384 assertEquals(originalServiceTemplate.getTopologyTemplate().getPolicies(),
385 createdServiceTemplate.getTopologyTemplate().getPolicies());
389 public void testPolicyCreateTypeAndVersion() throws Exception {
390 ToscaServiceTemplate toscaServiceTemplate =
391 standardCoder.decode(ResourceUtils.getResourceAsString(VCPE_INPUT_JSON), ToscaServiceTemplate.class);
395 ToscaPolicy toscaPolicy =
396 toscaServiceTemplate.getToscaTopologyTemplate().getPoliciesAsMap().values().iterator().next();
398 JpaToscaServiceTemplate originalServiceTemplate = new JpaToscaServiceTemplate();
400 final String originalPolicyType = toscaPolicy.getType();
401 final String originalPolicyTypeVersion = toscaPolicy.getTypeVersion();
402 toscaPolicy.setType(null);
403 toscaPolicy.setTypeVersion(null);
405 assertThatThrownBy(() -> {
406 originalServiceTemplate.fromAuthorative(toscaServiceTemplate);
407 }).hasMessage("Type not specified, the type of this TOSCA entity must be specified in the type field");
409 toscaPolicy.setType("IDontExist");
410 assertThatThrownBy(() -> {
411 originalServiceTemplate.fromAuthorative(toscaServiceTemplate);
412 }).hasMessage("Version not specified, the version of this TOSCA entity must be "
413 + "specified in the type_version field");
415 toscaPolicy.setTypeVersion("hello");
416 assertThatThrownBy(() -> {
417 originalServiceTemplate.fromAuthorative(toscaServiceTemplate);
418 }).hasMessageContaining("value \"hello\", does not match regular expression");
420 toscaPolicy.setTypeVersion("99.100.101");
421 originalServiceTemplate.fromAuthorative(toscaServiceTemplate);
423 assertThatThrownBy(() -> {
424 new SimpleToscaProvider().createPolicies(pfDao, originalServiceTemplate);
425 }).hasMessageContaining("policy type").hasMessageContaining("IDontExist:99.100.101")
426 .hasMessageContaining(Validated.NOT_FOUND);
428 toscaPolicy.setType("IDontExist");
429 originalServiceTemplate.fromAuthorative(toscaServiceTemplate);
431 toscaPolicy.setType(null);
433 assertThatThrownBy(() -> {
434 originalServiceTemplate.fromAuthorative(toscaServiceTemplate);
435 }).hasMessage("Type not specified, the type of this TOSCA entity must be specified in the type field");
437 toscaPolicy.setType(originalPolicyType);
438 toscaPolicy.setTypeVersion(originalPolicyTypeVersion);
440 originalServiceTemplate.fromAuthorative(toscaServiceTemplate);
441 JpaToscaServiceTemplate createdServiceTemplate =
442 new SimpleToscaProvider().createPolicies(pfDao, originalServiceTemplate);
443 assertEquals(originalServiceTemplate.getTopologyTemplate().getPolicies(),
444 createdServiceTemplate.getTopologyTemplate().getPolicies());
448 public void testPolicyUpdate() throws Exception {
449 ToscaServiceTemplate toscaServiceTemplate =
450 standardCoder.decode(ResourceUtils.getResourceAsString(VCPE_INPUT_JSON), ToscaServiceTemplate.class);
454 JpaToscaServiceTemplate originalServiceTemplate = new JpaToscaServiceTemplate();
455 originalServiceTemplate.fromAuthorative(toscaServiceTemplate);
457 assertNotNull(originalServiceTemplate);
458 JpaToscaServiceTemplate updatedServiceTemplate =
459 new SimpleToscaProvider().updatePolicies(pfDao, originalServiceTemplate);
461 assertEquals(originalServiceTemplate, updatedServiceTemplate);
465 public void testPoliciesDelete() throws Exception {
466 ToscaServiceTemplate toscaServiceTemplate =
467 standardCoder.decode(ResourceUtils.getResourceAsString(VCPE_INPUT_JSON), ToscaServiceTemplate.class);
471 JpaToscaServiceTemplate originalServiceTemplate = new JpaToscaServiceTemplate();
472 originalServiceTemplate.fromAuthorative(toscaServiceTemplate);
474 assertNotNull(originalServiceTemplate);
475 JpaToscaServiceTemplate createdServiceTemplate =
476 new SimpleToscaProvider().createPolicies(pfDao, originalServiceTemplate);
478 assertEquals(originalServiceTemplate.getTopologyTemplate(), createdServiceTemplate.getTopologyTemplate());
480 PfConceptKey policyKey = new PfConceptKey("onap.restart.tca:1.0.0");
482 assertThatThrownBy(() -> new SimpleToscaProvider().deletePolicy(pfDao, new PfConceptKey("IDontExist:0.0.1")))
483 .hasMessage("policy IDontExist:0.0.1 not found");
485 JpaToscaServiceTemplate deletedServiceTemplate = new SimpleToscaProvider().deletePolicy(pfDao, policyKey);
487 assertEquals(0, originalServiceTemplate.getTopologyTemplate().getPolicies().get(policyKey)
488 .compareTo(deletedServiceTemplate.getTopologyTemplate().getPolicies().get(policyKey)));
490 assertThatThrownBy(() -> {
491 new SimpleToscaProvider().getPolicies(pfDao, policyKey.getName(), policyKey.getVersion());
492 }).hasMessage("policies for onap.restart.tca:1.0.0 do not exist");
494 assertThatThrownBy(() -> new SimpleToscaProvider().deletePolicy(pfDao, policyKey))
495 .hasMessage("no policies found");
497 new SimpleToscaProvider().createPolicies(pfDao, originalServiceTemplate);
501 public void testAssertPoliciesExist() {
502 JpaToscaServiceTemplate testServiceTemplate = new JpaToscaServiceTemplate();
504 assertThatThrownBy(() -> new SimpleToscaProvider().createPolicies(pfDao, testServiceTemplate))
505 .hasMessage("topology template not specified on service template");
507 testServiceTemplate.setTopologyTemplate(new JpaToscaTopologyTemplate());
508 assertThatThrownBy(() -> new SimpleToscaProvider().createPolicies(pfDao, testServiceTemplate))
509 .hasMessage("no policies specified on topology template of service template");
511 testServiceTemplate.getTopologyTemplate().setPolicies(new JpaToscaPolicies());
512 assertThatThrownBy(() -> new SimpleToscaProvider().createPolicies(pfDao, testServiceTemplate))
513 .hasMessage("list of policies specified on topology template of service template is empty");
517 public void testGetServiceTemplate() throws PfModelException {
518 assertThatThrownBy(() -> new SimpleToscaProvider().getServiceTemplate(pfDao))
519 .hasMessage("service template not found in database");
523 public void testAppendToServiceTemplate() throws PfModelException {
524 JpaToscaServiceTemplate serviceTemplateFragment = new JpaToscaServiceTemplate();
525 serviceTemplateFragment.setPolicyTypes(new JpaToscaPolicyTypes());
526 JpaToscaPolicyType badPt = new JpaToscaPolicyType();
527 serviceTemplateFragment.getPolicyTypes().getConceptMap().put(badPt.getKey(), badPt);
529 assertThatThrownBy(() -> new SimpleToscaProvider().appendToServiceTemplate(pfDao, serviceTemplateFragment))
530 .hasMessageContaining("key on concept entry").hasMessageContaining("NULL:0.0.0")
531 .hasMessageContaining(Validated.IS_A_NULL_KEY);
535 public void testGetDataTypesCornerCases() throws PfModelException {
536 assertThatThrownBy(() -> {
537 new SimpleToscaProvider().getDataTypes(pfDao, "hello", "0.0.1");
538 }).hasMessageMatching("service template not found in database");
540 JpaToscaServiceTemplate serviceTemplate = new JpaToscaServiceTemplate();
541 serviceTemplate.setPolicyTypes(new JpaToscaPolicyTypes());
542 JpaToscaPolicyType p0 = new JpaToscaPolicyType(new PfConceptKey("p0:0.0.1"));
543 serviceTemplate.getPolicyTypes().getConceptMap().put(p0.getKey(), p0);
545 new SimpleToscaProvider().createPolicyTypes(pfDao, serviceTemplate);
547 assertThatThrownBy(() -> {
548 new SimpleToscaProvider().getDataTypes(pfDao, "hello", "0.0.1");
549 }).hasMessageMatching("data types for hello:0.0.1 do not exist");
551 serviceTemplate.setDataTypes(new JpaToscaDataTypes());
553 JpaToscaDataType p01 = new JpaToscaDataType(new PfConceptKey("dt0:0.0.1"));
554 serviceTemplate.getDataTypes().getConceptMap().put(p01.getKey(), p01);
556 new SimpleToscaProvider().createDataTypes(pfDao, serviceTemplate);
558 assertThatThrownBy(() -> {
559 new SimpleToscaProvider().getDataTypes(pfDao, "hello", "0.0.1");
560 }).hasMessageMatching("data types for hello:0.0.1 do not exist");
562 JpaToscaServiceTemplate gotSt = new SimpleToscaProvider().getDataTypes(pfDao, p01.getName(), p01.getVersion());
564 assertEquals(p01, gotSt.getDataTypes().get(p01.getKey()));
565 assertEquals(p01, gotSt.getDataTypes().get(p01.getName()));
566 assertEquals(p01, gotSt.getDataTypes().get(p01.getName(), null));
567 assertEquals(p01, gotSt.getDataTypes().get(p01.getName(), p01.getVersion()));
568 assertEquals(1, gotSt.getDataTypes().getAll(null).size());
569 assertEquals(1, gotSt.getDataTypes().getAll(null, null).size());
570 assertEquals(1, gotSt.getDataTypes().getAll(p01.getName(), null).size());
571 assertEquals(1, gotSt.getDataTypes().getAll(p01.getName(), p01.getVersion()).size());
573 JpaToscaDataType p02 = new JpaToscaDataType(new PfConceptKey("dt0:0.0.2"));
574 serviceTemplate.getDataTypes().getConceptMap().put(p02.getKey(), p02);
576 new SimpleToscaProvider().createDataTypes(pfDao, serviceTemplate);
577 gotSt = new SimpleToscaProvider().getDataTypes(pfDao, p01.getName(), null);
579 assertEquals(p01, gotSt.getDataTypes().get(p01.getKey()));
580 assertEquals(p02, gotSt.getDataTypes().get(p01.getName()));
581 assertEquals(p02, gotSt.getDataTypes().get(p01.getName(), null));
582 assertEquals(p01, gotSt.getDataTypes().get(p01.getName(), p01.getVersion()));
583 assertEquals(p02, gotSt.getDataTypes().get(p01.getName(), p02.getVersion()));
584 assertEquals(2, gotSt.getDataTypes().getAll(null).size());
585 assertEquals(2, gotSt.getDataTypes().getAll(null, null).size());
586 assertEquals(2, gotSt.getDataTypes().getAll(p01.getName(), null).size());
587 assertEquals(1, gotSt.getDataTypes().getAll(p01.getName(), p02.getVersion()).size());
591 public void testGetPolicyTypesCornerCases() throws PfModelException {
592 assertThatThrownBy(() -> {
593 new SimpleToscaProvider().getPolicyTypes(pfDao, "hello", "0.0.1");
594 }).hasMessageMatching("service template not found in database");
596 JpaToscaServiceTemplate serviceTemplate = new JpaToscaServiceTemplate();
597 serviceTemplate.setDataTypes(new JpaToscaDataTypes());
598 JpaToscaDataType dt0 = new JpaToscaDataType(new PfConceptKey("dt0:0.0.1"));
599 serviceTemplate.getDataTypes().getConceptMap().put(dt0.getKey(), dt0);
601 new SimpleToscaProvider().createDataTypes(pfDao, serviceTemplate);
603 assertThatThrownBy(() -> {
604 new SimpleToscaProvider().getPolicyTypes(pfDao, "hello", "0.0.1");
605 }).hasMessageMatching("policy types for hello:0.0.1 do not exist");
607 serviceTemplate.setPolicyTypes(new JpaToscaPolicyTypes());
609 JpaToscaPolicyType pt01 = new JpaToscaPolicyType(new PfConceptKey("p0:0.0.1"));
610 serviceTemplate.getPolicyTypes().getConceptMap().put(pt01.getKey(), pt01);
612 new SimpleToscaProvider().createPolicyTypes(pfDao, serviceTemplate);
614 assertThatThrownBy(() -> {
615 new SimpleToscaProvider().getPolicyTypes(pfDao, "hello", "0.0.1");
616 }).hasMessageMatching("policy types for hello:0.0.1 do not exist");
618 JpaToscaServiceTemplate gotSt =
619 new SimpleToscaProvider().getPolicyTypes(pfDao, pt01.getName(), pt01.getVersion());
621 assertEquals(pt01, gotSt.getPolicyTypes().get(pt01.getKey()));
622 assertEquals(pt01, gotSt.getPolicyTypes().get(pt01.getName()));
623 assertEquals(pt01, gotSt.getPolicyTypes().get(pt01.getName(), null));
624 assertEquals(pt01, gotSt.getPolicyTypes().get(pt01.getName(), pt01.getVersion()));
625 assertEquals(1, gotSt.getPolicyTypes().getAll(null).size());
626 assertEquals(1, gotSt.getPolicyTypes().getAll(null, null).size());
627 assertEquals(1, gotSt.getPolicyTypes().getAll(pt01.getName(), null).size());
628 assertEquals(1, gotSt.getPolicyTypes().getAll(pt01.getName(), pt01.getVersion()).size());
630 JpaToscaPolicyType pt02 = new JpaToscaPolicyType(new PfConceptKey("p0:0.0.2"));
631 serviceTemplate.getPolicyTypes().getConceptMap().put(pt02.getKey(), pt02);
633 new SimpleToscaProvider().createPolicyTypes(pfDao, serviceTemplate);
634 gotSt = new SimpleToscaProvider().getPolicyTypes(pfDao, pt01.getName(), null);
636 assertEquals(pt01, gotSt.getPolicyTypes().get(pt01.getKey()));
637 assertEquals(pt02, gotSt.getPolicyTypes().get(pt01.getName()));
638 assertEquals(pt02, gotSt.getPolicyTypes().get(pt01.getName(), null));
639 assertEquals(pt01, gotSt.getPolicyTypes().get(pt01.getName(), pt01.getVersion()));
640 assertEquals(pt02, gotSt.getPolicyTypes().get(pt01.getName(), pt02.getVersion()));
641 assertEquals(2, gotSt.getPolicyTypes().getAll(null).size());
642 assertEquals(2, gotSt.getPolicyTypes().getAll(null, null).size());
643 assertEquals(2, gotSt.getPolicyTypes().getAll(pt01.getName(), null).size());
644 assertEquals(1, gotSt.getPolicyTypes().getAll(pt01.getName(), pt02.getVersion()).size());
648 public void testGetPoliciesCornerCases() throws PfModelException {
649 assertThatThrownBy(() -> {
650 new SimpleToscaProvider().getPolicies(pfDao, "hello", "0.0.1");
651 }).hasMessageMatching("service template not found in database");
653 JpaToscaServiceTemplate serviceTemplate = new JpaToscaServiceTemplate();
654 serviceTemplate.setDataTypes(new JpaToscaDataTypes());
655 JpaToscaDataType dt0 = new JpaToscaDataType(new PfConceptKey("dt0:0.0.1"));
656 serviceTemplate.getDataTypes().getConceptMap().put(dt0.getKey(), dt0);
658 new SimpleToscaProvider().createDataTypes(pfDao, serviceTemplate);
660 assertThatThrownBy(() -> {
661 new SimpleToscaProvider().getPolicies(pfDao, "hello", "0.0.1");
662 }).hasMessageMatching("policies for hello:0.0.1 do not exist");
664 serviceTemplate.setPolicyTypes(new JpaToscaPolicyTypes());
666 JpaToscaPolicyType pt01 = new JpaToscaPolicyType(new PfConceptKey("pt0:0.0.1"));
667 serviceTemplate.getPolicyTypes().getConceptMap().put(pt01.getKey(), pt01);
669 serviceTemplate.setTopologyTemplate(new JpaToscaTopologyTemplate());
670 serviceTemplate.getTopologyTemplate().setPolicies(new JpaToscaPolicies());
672 JpaToscaPolicy p01 = new JpaToscaPolicy(new PfConceptKey("p0:0.0.1"));
673 p01.setType(pt01.getKey());
674 serviceTemplate.getTopologyTemplate().getPolicies().getConceptMap().put(p01.getKey(), p01);
676 new SimpleToscaProvider().createPolicies(pfDao, serviceTemplate);
678 assertThatThrownBy(() -> {
679 new SimpleToscaProvider().getPolicies(pfDao, "hello", "0.0.1");
680 }).hasMessageMatching("policies for hello:0.0.1 do not exist");
682 JpaToscaServiceTemplate gotSt = new SimpleToscaProvider().getPolicies(pfDao, p01.getName(), p01.getVersion());
684 assertEquals(0, p01.compareTo(gotSt.getTopologyTemplate().getPolicies().get(p01.getKey())));
685 assertEquals(0, p01.compareTo(gotSt.getTopologyTemplate().getPolicies().get(p01.getName())));
686 assertEquals(0, p01.compareTo(gotSt.getTopologyTemplate().getPolicies().get(p01.getName(), null)));
687 assertEquals(0, p01.compareTo(gotSt.getTopologyTemplate().getPolicies().get(p01.getName(), p01.getVersion())));
688 assertEquals(1, gotSt.getTopologyTemplate().getPolicies().getAll(null).size());
689 assertEquals(1, gotSt.getTopologyTemplate().getPolicies().getAll(null, null).size());
690 assertEquals(1, gotSt.getTopologyTemplate().getPolicies().getAll(p01.getName(), null).size());
691 assertEquals(1, gotSt.getTopologyTemplate().getPolicies().getAll(p01.getName(), p01.getVersion()).size());
693 JpaToscaPolicy p02 = new JpaToscaPolicy(new PfConceptKey("p0:0.0.2"));
694 p02.setType(pt01.getKey());
695 serviceTemplate.getTopologyTemplate().getPolicies().getConceptMap().put(p02.getKey(), p02);
697 new SimpleToscaProvider().createPolicies(pfDao, serviceTemplate);
698 gotSt = new SimpleToscaProvider().getPolicies(pfDao, p01.getName(), null);
700 assertEquals(p01, gotSt.getTopologyTemplate().getPolicies().get(p01.getKey()));
701 assertEquals(p02, gotSt.getTopologyTemplate().getPolicies().get(p01.getName()));
702 assertEquals(p02, gotSt.getTopologyTemplate().getPolicies().get(p01.getName(), null));
703 assertEquals(p01, gotSt.getTopologyTemplate().getPolicies().get(p01.getName(), p01.getVersion()));
704 assertEquals(p02, gotSt.getTopologyTemplate().getPolicies().get(p01.getName(), p02.getVersion()));
705 assertEquals(2, gotSt.getTopologyTemplate().getPolicies().getAll(null).size());
706 assertEquals(2, gotSt.getTopologyTemplate().getPolicies().getAll(null, null).size());
707 assertEquals(2, gotSt.getTopologyTemplate().getPolicies().getAll(p01.getName(), null).size());
708 assertEquals(1, gotSt.getTopologyTemplate().getPolicies().getAll(p01.getName(), p02.getVersion()).size());
712 public void testNonNullsDataType() {
713 assertThatThrownBy(() -> {
714 new SimpleToscaProvider().getServiceTemplate(null);
715 }).hasMessageMatching(DAO_IS_NULL);
717 assertThatThrownBy(() -> {
718 new SimpleToscaProvider().appendToServiceTemplate(null, null);
719 }).hasMessageMatching(DAO_IS_NULL);
721 assertThatThrownBy(() -> {
722 new SimpleToscaProvider().appendToServiceTemplate(null, new JpaToscaServiceTemplate());
723 }).hasMessageMatching(DAO_IS_NULL);
725 assertThatThrownBy(() -> {
726 new SimpleToscaProvider().appendToServiceTemplate(pfDao, null);
727 }).hasMessageMatching("^incomingServiceTemplateFragment is marked .*on.*ull but is null$");
729 assertThatThrownBy(() -> {
730 new SimpleToscaProvider().getDataTypes(null, null, null);
731 }).hasMessageMatching(DAO_IS_NULL);
733 assertThatThrownBy(() -> {
734 new SimpleToscaProvider().createDataTypes(null, null);
735 }).hasMessageMatching(DAO_IS_NULL);
737 assertThatThrownBy(() -> {
738 new SimpleToscaProvider().createDataTypes(null, new JpaToscaServiceTemplate());
739 }).hasMessageMatching(DAO_IS_NULL);
741 assertThatThrownBy(() -> {
742 new SimpleToscaProvider().createDataTypes(pfDao, null);
743 }).hasMessageMatching(INCOMING_TEMPLATE_IS_NULL);
745 assertThatThrownBy(() -> {
746 new SimpleToscaProvider().updateDataTypes(null, null);
747 }).hasMessageMatching(DAO_IS_NULL);
749 assertThatThrownBy(() -> {
750 new SimpleToscaProvider().updateDataTypes(null, new JpaToscaServiceTemplate());
751 }).hasMessageMatching(DAO_IS_NULL);
753 assertThatThrownBy(() -> {
754 new SimpleToscaProvider().updateDataTypes(pfDao, null);
755 }).hasMessageMatching(TEMPLATE_IS_NULL);
757 assertThatThrownBy(() -> {
758 new SimpleToscaProvider().deleteDataType(null, null);
759 }).hasMessageMatching(DAO_IS_NULL);
761 assertThatThrownBy(() -> {
762 new SimpleToscaProvider().deleteDataType(null, new PfConceptKey());
763 }).hasMessageMatching(DAO_IS_NULL);
765 assertThatThrownBy(() -> {
766 new SimpleToscaProvider().deleteDataType(pfDao, null);
767 }).hasMessageMatching("^dataTypeKey is marked .*on.*ull but is null$");
771 public void testNotNullsPolicyTypes() {
772 assertThatThrownBy(() -> {
773 new SimpleToscaProvider().getPolicyTypes(null, null, null);
774 }).hasMessageMatching(DAO_IS_NULL);
776 assertThatThrownBy(() -> {
777 new SimpleToscaProvider().createPolicyTypes(null, null);
778 }).hasMessageMatching(DAO_IS_NULL);
780 assertThatThrownBy(() -> {
781 new SimpleToscaProvider().createPolicyTypes(null, new JpaToscaServiceTemplate());
782 }).hasMessageMatching(DAO_IS_NULL);
784 assertThatThrownBy(() -> {
785 new SimpleToscaProvider().createPolicyTypes(pfDao, null);
786 }).hasMessageMatching(INCOMING_TEMPLATE_IS_NULL);
788 assertThatThrownBy(() -> {
789 new SimpleToscaProvider().updatePolicyTypes(null, null);
790 }).hasMessageMatching(DAO_IS_NULL);
792 assertThatThrownBy(() -> {
793 new SimpleToscaProvider().updatePolicyTypes(null, new JpaToscaServiceTemplate());
794 }).hasMessageMatching(DAO_IS_NULL);
796 assertThatThrownBy(() -> {
797 new SimpleToscaProvider().updatePolicyTypes(pfDao, null);
798 }).hasMessageMatching(TEMPLATE_IS_NULL);
800 assertThatThrownBy(() -> {
801 new SimpleToscaProvider().deletePolicyType(null, null);
802 }).hasMessageMatching(DAO_IS_NULL);
804 assertThatThrownBy(() -> {
805 new SimpleToscaProvider().deletePolicyType(null, new PfConceptKey());
806 }).hasMessageMatching(DAO_IS_NULL);
808 assertThatThrownBy(() -> {
809 new SimpleToscaProvider().deletePolicyType(pfDao, null);
810 }).hasMessageMatching("^policyTypeKey is marked .*on.*ull but is null$");
812 assertThatThrownBy(() -> {
813 new SimpleToscaProvider().getPolicies(null, null, null);
814 }).hasMessageMatching(DAO_IS_NULL);
816 assertThatThrownBy(() -> {
817 new SimpleToscaProvider().createPolicies(null, null);
818 }).hasMessageMatching(DAO_IS_NULL);
820 assertThatThrownBy(() -> {
821 new SimpleToscaProvider().createPolicies(null, new JpaToscaServiceTemplate());
822 }).hasMessageMatching(DAO_IS_NULL);
824 assertThatThrownBy(() -> {
825 new SimpleToscaProvider().createPolicies(pfDao, null);
826 }).hasMessageMatching(INCOMING_TEMPLATE_IS_NULL);
828 assertThatThrownBy(() -> {
829 new SimpleToscaProvider().updatePolicies(null, null);
830 }).hasMessageMatching(DAO_IS_NULL);
832 assertThatThrownBy(() -> {
833 new SimpleToscaProvider().updatePolicies(null, new JpaToscaServiceTemplate());
834 }).hasMessageMatching(DAO_IS_NULL);
836 assertThatThrownBy(() -> {
837 new SimpleToscaProvider().updatePolicies(pfDao, null);
838 }).hasMessageMatching(TEMPLATE_IS_NULL);
840 assertThatThrownBy(() -> {
841 new SimpleToscaProvider().deletePolicy(null, null);
842 }).hasMessageMatching(DAO_IS_NULL);
844 assertThatThrownBy(() -> {
845 new SimpleToscaProvider().deletePolicy(null, new PfConceptKey());
846 }).hasMessageMatching(DAO_IS_NULL);
848 assertThatThrownBy(() -> {
849 new SimpleToscaProvider().deletePolicy(pfDao, null);
850 }).hasMessageMatching("^policyKey is marked .*on.*ull but is null$");
854 public void testDeleteServiceTemplate() throws PfModelException {
855 assertThatThrownBy(() -> {
856 new SimpleToscaProvider().deleteServiceTemplate(null);
857 }).hasMessageMatching("^dao is marked .*on.*ull but is null$");
859 assertThatThrownBy(() -> {
860 new SimpleToscaProvider().deleteServiceTemplate(pfDao);
861 }).hasMessage("service template not found in database");
863 JpaToscaServiceTemplate serviceTemplate = new JpaToscaServiceTemplate();
865 PfConceptKey dataType0Key = new PfConceptKey("DataType0", "0.0.1");
866 JpaToscaDataType dataType0 = new JpaToscaDataType();
867 dataType0.setKey(dataType0Key);
868 serviceTemplate.setDataTypes(new JpaToscaDataTypes());
869 serviceTemplate.getDataTypes().getConceptMap().put(dataType0Key, dataType0);
871 JpaToscaServiceTemplate createdServiceTemplate =
872 new SimpleToscaProvider().createDataTypes(pfDao, serviceTemplate);
874 assertEquals(1, createdServiceTemplate.getDataTypes().getConceptMap().size());
875 assertEquals(dataType0, createdServiceTemplate.getDataTypes().get(dataType0Key));
876 assertEquals(null, createdServiceTemplate.getDataTypes().get(dataType0Key).getDescription());
878 JpaToscaServiceTemplate deletedServiceTemplate = new SimpleToscaProvider().deleteServiceTemplate(pfDao);
880 assertEquals(dataType0, deletedServiceTemplate.getDataTypes().get(dataType0Key));
884 public void testNullParameters() {
885 assertThatThrownBy(() -> {
886 new SimpleToscaProvider().getCascadedDataTypes(null, null, null);
887 }).hasMessageMatching("^dbServiceTemplate is marked .*on.*ull but is null$");
890 private void createPolicyTypes() throws CoderException, PfModelException {
892 new Yaml().load(ResourceUtils.getResourceAsString("policytypes/onap.policies.monitoring.tcagen2.yaml"));
893 String yamlAsJsonString = new StandardCoder().encode(yamlObject);
895 ToscaServiceTemplate toscaServiceTemplatePolicyType =
896 standardCoder.decode(yamlAsJsonString, ToscaServiceTemplate.class);
898 assertNotNull(toscaServiceTemplatePolicyType);
899 new AuthorativeToscaProvider().createPolicyTypes(pfDao, toscaServiceTemplatePolicyType);