2 * ============LICENSE_START=======================================================
3 * Copyright (C) 2022 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
9 * http://www.apache.org/licenses/LICENSE-2.0
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.
17 * SPDX-License-Identifier: Apache-2.0
18 * ============LICENSE_END=========================================================
21 package org.onap.cps.ncmp.api.impl
23 import org.onap.cps.ncmp.api.NetworkCmProxyCmHandlerQueryService
24 import org.onap.cps.ncmp.api.inventory.InventoryPersistence
25 import org.onap.cps.spi.CpsAdminPersistenceService
26 import org.onap.cps.spi.CpsDataPersistenceService
27 import org.onap.cps.spi.model.Anchor
28 import org.onap.cps.spi.model.CmHandleQueryServiceParameters
29 import org.onap.cps.spi.model.ConditionProperties
30 import org.onap.cps.spi.model.DataNode
31 import spock.lang.Specification
33 import java.util.stream.Collectors
35 class NetworkCmProxyCmHandlerQueryServiceSpec extends Specification {
37 def inventoryPersistence = Mock(InventoryPersistence)
39 NetworkCmProxyCmHandlerQueryService objectUnderTest = new NetworkCmProxyCmHandlerQueryServiceImpl(inventoryPersistence)
41 def 'Retrieve cm handles with public properties when #scenario.'() {
42 given: 'a condition property'
43 def cmHandleQueryParameters = new CmHandleQueryServiceParameters()
44 def conditionProperties = new ConditionProperties()
45 conditionProperties.conditionName = 'hasAllProperties'
46 conditionProperties.conditionParameters = publicProperties
47 cmHandleQueryParameters.setCmHandleQueryParameters([conditionProperties])
50 when: 'a query is execute (with and without Data)'
51 def returnedCmHandlesJustIds = objectUnderTest.queryCmHandleIds(cmHandleQueryParameters)
52 def returnedCmHandlesWithData = objectUnderTest.queryCmHandles(cmHandleQueryParameters)
53 then: 'the correct expected cm handles ids are returned'
54 returnedCmHandlesJustIds == expectedCmHandleIds as Set
55 and: 'the correct cm handle data objects are returned'
56 returnedCmHandlesWithData.stream().map(dataNode -> dataNode.cmHandleId).collect(Collectors.toSet()) == expectedCmHandleIds as Set
57 where: 'the following data is used'
58 scenario | publicProperties || expectedCmHandleIds
59 'single property matches' | [['Contact' : 'newemailforstore@bookstore.com']] || ['PNFDemo1', 'PNFDemo2', 'PNFDemo4']
60 'public property does not match' | [['wont_match' : 'wont_match']] || []
61 '2 properties, only one match' | [['Contact' : 'newemailforstore@bookstore.com'], ['Contact2': 'newemailforstore2@bookstore.com']] || ['PNFDemo4']
62 '2 properties, no matches' | [['Contact' : 'newemailforstore@bookstore.com'], ['Contact2': '']] || []
65 def 'Retrieve cm handles with module names when #scenario.'() {
66 given: 'a condition property'
67 def cmHandleQueryParameters = new CmHandleQueryServiceParameters()
68 def conditionProperties = new ConditionProperties()
69 conditionProperties.conditionName = 'hasAllModules'
70 conditionProperties.conditionParameters = moduleNames
71 cmHandleQueryParameters.setCmHandleQueryParameters([conditionProperties])
74 when: 'the service is invoked'
75 def returnedCmHandlesJustIds = objectUnderTest.queryCmHandleIds(cmHandleQueryParameters)
76 def returnedCmHandlesWithData = objectUnderTest.queryCmHandles(cmHandleQueryParameters)
77 then: 'the correct expected cm handles are returned'
78 returnedCmHandlesJustIds == expectedCmHandleIds as Set
79 returnedCmHandlesWithData.stream().map(dataNode -> dataNode.cmHandleId).collect(Collectors.toSet()) == expectedCmHandleIds as Set
80 where: 'the following data is used'
81 scenario | moduleNames || expectedCmHandleIds
82 'single matching module name' | [['moduleName' : 'MODULE-NAME-001']] || ['PNFDemo3', 'PNFDemo1', 'PNFDemo2']
83 'module name dont match' | [['moduleName' : 'MODULE-NAME-004']] || []
84 '2 module names, only one match' | [['moduleName' : 'MODULE-NAME-002'], ['moduleName': 'MODULE-NAME-003']] || ['PNFDemo4']
85 '2 module names, no matches' | [['moduleName' : 'MODULE-NAME-002'], ['moduleName': 'MODULE-NAME-004']] || []
88 def 'Retrieve cm handles with combined queries when #scenario.'() {
89 given: 'condition properties'
90 def cmHandleQueryParameters = new CmHandleQueryServiceParameters()
91 def conditionProperties1 = new ConditionProperties()
92 conditionProperties1.conditionName = 'hasAllProperties'
93 conditionProperties1.conditionParameters = publicProperties
94 def conditionProperties2 = new ConditionProperties()
95 conditionProperties2.conditionName = 'hasAllModules'
96 conditionProperties2.conditionParameters = moduleNames
97 cmHandleQueryParameters.setCmHandleQueryParameters([conditionProperties1,conditionProperties2])
100 when: 'the service is invoked'
101 def returnedCmHandlesJustIds = objectUnderTest.queryCmHandleIds(cmHandleQueryParameters)
102 def returnedCmHandlesWithData = objectUnderTest.queryCmHandles(cmHandleQueryParameters)
103 then: 'the correct expected cm handles are returned'
104 returnedCmHandlesJustIds == expectedCmHandleIds as Set
105 returnedCmHandlesWithData.stream().map(d -> d.cmHandleId).collect(Collectors.toSet()) == expectedCmHandleIds as Set
106 where: 'the following data is used'
107 scenario | moduleNames | publicProperties || expectedCmHandleIds
108 'particularly intersect' | [['moduleName' : 'MODULE-NAME-001']] | [['Contact' : 'newemailforstore@bookstore.com']] || ['PNFDemo1', 'PNFDemo2']
109 'empty intersect' | [['moduleName' : 'MODULE-NAME-004']] | [['Contact' : 'newemailforstore@bookstore.com']] || []
110 'total intersect' | [['moduleName' : 'MODULE-NAME-002']] | [['Contact2' : 'newemailforstore2@bookstore.com']] || ['PNFDemo4']
113 def 'Retrieve cm handles when the query is empty.'() {
114 given: 'mock services'
116 when: 'the service is invoked'
117 def cmHandleQueryParameters = new CmHandleQueryServiceParameters()
118 def returnedCmHandlesJustIds = objectUnderTest.queryCmHandleIds(cmHandleQueryParameters)
119 def returnedCmHandlesWithData = objectUnderTest.queryCmHandles(cmHandleQueryParameters)
120 then: 'the correct expected cm handles are returned'
121 returnedCmHandlesJustIds == ['PNFDemo1', 'PNFDemo2', 'PNFDemo3', 'PNFDemo4'] as Set
122 returnedCmHandlesWithData.stream().map(d -> d.cmHandleId).collect(Collectors.toSet()) == ['PNFDemo1', 'PNFDemo2', 'PNFDemo3', 'PNFDemo4'] as Set
125 void mockResponses() {
126 def pNFDemo1 = new DataNode(xpath: '/dmi-registry/cm-handles[@id=\'PNFDemo1\']', leaves: ['id':'PNFDemo1'])
127 def pNFDemo2 = new DataNode(xpath: '/dmi-registry/cm-handles[@id=\'PNFDemo2\']', leaves: ['id':'PNFDemo2'])
128 def pNFDemo3 = new DataNode(xpath: '/dmi-registry/cm-handles[@id=\'PNFDemo3\']', leaves: ['id':'PNFDemo3'])
129 def pNFDemo4 = new DataNode(xpath: '/dmi-registry/cm-handles[@id=\'PNFDemo4\']', leaves: ['id':'PNFDemo4'])
130 def dmiRegistry = new DataNode(xpath: '/dmi-registry', childDataNodes: [pNFDemo1, pNFDemo2, pNFDemo3, pNFDemo4])
132 inventoryPersistence.queryDataNodes('//public-properties[@name=\'Contact\' and @value=\'newemailforstore@bookstore.com\']/ancestor::cm-handles')
133 >> [pNFDemo1, pNFDemo2, pNFDemo4]
134 inventoryPersistence.queryDataNodes('//public-properties[@name=\'wont_match\' and @value=\'wont_match\']/ancestor::cm-handles')
136 inventoryPersistence.queryDataNodes('//public-properties[@name=\'Contact2\' and @value=\'newemailforstore2@bookstore.com\']/ancestor::cm-handles')
138 inventoryPersistence.queryDataNodes('//public-properties[@name=\'Contact2\' and @value=\'\']/ancestor::cm-handles')
140 inventoryPersistence.queryDataNodes('//public-properties/ancestor::cm-handles')
141 >> [pNFDemo1, pNFDemo2, pNFDemo3, pNFDemo4]
143 inventoryPersistence.queryDataNodes('//cm-handles[@id=\'PNFDemo\']') >> [pNFDemo1]
144 inventoryPersistence.queryDataNodes('//cm-handles[@id=\'PNFDemo2\']') >> [pNFDemo2]
145 inventoryPersistence.queryDataNodes('//cm-handles[@id=\'PNFDemo3\']') >> [pNFDemo3]
146 inventoryPersistence.queryDataNodes('//cm-handles[@id=\'PNFDemo4\']') >> [pNFDemo4]
148 inventoryPersistence.getDataNode('/dmi-registry') >> dmiRegistry
150 inventoryPersistence.getDataNode('/dmi-registry/cm-handles[@id=\'PNFDemo1\']') >> pNFDemo1
151 inventoryPersistence.getDataNode('/dmi-registry/cm-handles[@id=\'PNFDemo2\']') >> pNFDemo2
152 inventoryPersistence.getDataNode('/dmi-registry/cm-handles[@id=\'PNFDemo3\']') >> pNFDemo3
153 inventoryPersistence.getDataNode('/dmi-registry/cm-handles[@id=\'PNFDemo4\']') >> pNFDemo4
155 inventoryPersistence.queryAnchors(['MODULE-NAME-001']) >> [new Anchor(name: 'PNFDemo1'), new Anchor(name: 'PNFDemo2'), new Anchor(name: 'PNFDemo3')]
156 inventoryPersistence.queryAnchors(['MODULE-NAME-004']) >> []
157 inventoryPersistence.queryAnchors(['MODULE-NAME-003', 'MODULE-NAME-002']) >> [new Anchor(name: 'PNFDemo4')]
158 inventoryPersistence.queryAnchors(['MODULE-NAME-002', 'MODULE-NAME-003']) >> [new Anchor(name: 'PNFDemo4')]
159 inventoryPersistence.queryAnchors(['MODULE-NAME-004', 'MODULE-NAME-002']) >> []
160 inventoryPersistence.queryAnchors(['MODULE-NAME-002', 'MODULE-NAME-004']) >> []
161 inventoryPersistence.queryAnchors(['MODULE-NAME-002']) >> [new Anchor(name: 'PNFDemo2'), new Anchor(name: 'PNFDemo4')]
162 inventoryPersistence.getAnchors() >> [new Anchor(name: 'PNFDemo1'), new Anchor(name: 'PNFDemo2'), new Anchor(name: 'PNFDemo3'), new Anchor(name: 'PNFDemo4')]