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 class NcmpEventsServiceSpec extends Specification {
31 def mockInventoryPersistence = Mock(InventoryPersistence)
32 def mockNcmpEventsPublisher = Mock(NcmpEventsPublisher)
33 def mockNcmpEventsMapper = Mock(NcmpEventsCreator)
35 def objectUnderTest = new NcmpEventsService(mockInventoryPersistence, mockNcmpEventsPublisher, mockNcmpEventsMapper)
37 def 'Create and Publish event for #operation'() {
38 given: 'a cm handle id and operation and responses are mocked'
39 mockResponses('test-cm-handle-id', 'test-topic')
40 when: 'service is called to publish ncmp event'
41 objectUnderTest.publishNcmpEvent('test-cm-handle-id')
42 then: 'no exception is thrown'
46 def mockResponses(cmHandleId, topicName) {
48 def yangModelCmHandle = new YangModelCmHandle(id: cmHandleId, publicProperties: [new YangModelCmHandle.Property('publicProperty1', 'value1')], dmiProperties: [])
49 def ncmpEvent = new NcmpEvent(eventId: UUID.randomUUID().toString(), eventCorrelationId: cmHandleId)
50 def ncmpServiceCmhandle = YangDataConverter.convertYangModelCmHandleToNcmpServiceCmHandle(yangModelCmHandle)
52 mockInventoryPersistence.getYangModelCmHandle(cmHandleId) >> yangModelCmHandle
53 mockNcmpEventsMapper.populateNcmpEvent(cmHandleId, ncmpServiceCmhandle) >> ncmpEvent
54 mockNcmpEventsPublisher.publishEvent(topicName, cmHandleId, ncmpEvent) >> {}