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.event
23 import org.onap.cps.ncmp.api.impl.utils.YangDataConverter
24 import org.onap.cps.ncmp.api.impl.yangmodels.YangModelCmHandle
25 import org.onap.cps.ncmp.api.inventory.InventoryPersistence
26 import org.onap.ncmp.cmhandle.lcm.event.NcmpEvent
27 import spock.lang.Specification
29 import static org.onap.ncmp.cmhandle.lcm.event.Event.Operation.CREATE
30 import static org.onap.ncmp.cmhandle.lcm.event.Event.Operation.DELETE
31 import static org.onap.ncmp.cmhandle.lcm.event.Event.Operation.UPDATE
33 class NcmpEventsServiceSpec extends Specification {
35 def mockInventoryPersistence = Mock(InventoryPersistence)
36 def mockNcmpEventsPublisher = Mock(NcmpEventsPublisher)
37 def mockNcmpEventsMapper = Mock(NcmpEventsCreator)
39 def objectUnderTest = new NcmpEventsService(mockInventoryPersistence, mockNcmpEventsPublisher, mockNcmpEventsMapper)
41 def 'Create and Publish event for #operation'() {
42 given: 'a cm handle id and operation and responses are mocked'
43 mockResponses('test-cm-handle-id', operation, 'test-topic')
44 when: 'service is called to publish ncmp event'
45 objectUnderTest.publishNcmpEvent('test-cm-handle-id', operation)
46 then: 'no exception is thrown'
48 where: 'for following operations'
49 operation << [CREATE, UPDATE, DELETE]
52 def mockResponses(cmHandleId, operation, topicName) {
54 def yangModelCmHandle = new YangModelCmHandle(id: cmHandleId, publicProperties: [new YangModelCmHandle.Property('publicProperty1', 'value1')], dmiProperties: [])
55 def ncmpEvent = new NcmpEvent(eventId: UUID.randomUUID().toString(), eventCorrelationId: cmHandleId)
56 def ncmpServiceCmhandle = YangDataConverter.convertYangModelCmHandleToNcmpServiceCmHandle(yangModelCmHandle)
58 mockInventoryPersistence.getYangModelCmHandle(cmHandleId) >> yangModelCmHandle
59 mockNcmpEventsMapper.populateNcmpEvent(cmHandleId, operation, ncmpServiceCmhandle) >> ncmpEvent
60 mockNcmpEventsPublisher.publishEvent(topicName, cmHandleId, ncmpEvent) >> {}