1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
|
/*
* Copyright 2016-2017, Nokia Corporation
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.onap.vfc.nfvo.driver.vnfm.svnfm.nokia.ct;
import com.google.gson.JsonObject;
import com.nokia.cbam.lcm.v32.model.*;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.nokia.NokiaSvnfmApplication;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.nokia.onap.direct.AAIExternalSystemInfoProvider;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.nokia.onap.direct.notification.AAINotificationProcessor;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.nokia.vnfm.notification.ReportedAffectedConnectionPoints;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.nokia.vnfm.notification.ReportedAffectedCp;
import org.onap.vnfmdriver.model.VimInfo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.ActiveProfiles;
import org.springframework.test.context.junit4.SpringRunner;
import java.util.ArrayList;
import static java.util.Optional.of;
@RunWith(value = SpringRunner.class)
@SpringBootTest(classes = NokiaSvnfmApplication.class, webEnvironment = SpringBootTest.WebEnvironment.DEFINED_PORT)
@ActiveProfiles("direct")
public class CTDirectReal {
@Autowired
private AAIExternalSystemInfoProvider externalSystemInfoProvider;
@Autowired
private AAINotificationProcessor notificationProcessor;
/**
* The following is not a real test, but only start the driver locally.
* It takes parameters from application-real.properties
*/
@Test
public void testBasicWorkflow() throws Exception {
VimInfo nokia_regionOne = externalSystemInfoProvider.getVimInfo("Nokia_RegionOne");
VnfLifecycleChangeNotification recievedNot = new VnfLifecycleChangeNotification();
recievedNot.setVnfInstanceId("CBAM-d8deb02a7a51449dba576ac9eabb55b8");
ReportedAffectedConnectionPoints affectedConnectionPoints = new ReportedAffectedConnectionPoints();
recievedNot.setAffectedVirtualLinks(new ArrayList<>());
AffectedVirtualLink link = new AffectedVirtualLink();
recievedNot.getAffectedVirtualLinks().add(link);
link.setId("vlid1");
link.setChangeType(ChangeType.REMOVED);
link.setVirtualLinkDescId("vldId1");
link.setResource(new ResourceHandle());
link.getResource().setResourceId("netProviderId1");
link.getResource().setAdditionalData(additionalData("name", "networkName"));
recievedNot.setAffectedVnfcs(new ArrayList<>());
AffectedVnfc vnfc = new AffectedVnfc();
vnfc.setId("myVnfcId1");
vnfc.setChangeType(ChangeType.ADDED);
vnfc.setVduId("myVduId");
vnfc.setStorageResourceIds(new ArrayList<>());
vnfc.setComputeResource(new ResourceHandle());
vnfc.getComputeResource().setResourceId("serverProvId1");
JsonObject additionalData = additionalData("name", "serverName");
additionalData.addProperty("tenantId", "de8fd0d1d5874503a47b920c10f4322a");
vnfc.getComputeResource().setAdditionalData(additionalData);
recievedNot.getAffectedVnfcs().add(vnfc);
ReportedAffectedCp addedCp = new ReportedAffectedCp();
addedCp.setCpId("cpId");
addedCp.setIpAddress("1.2.3.4");
addedCp.setMacAddress("a:b:c:d:e:f");
addedCp.setNetworkProviderId("netProviderId1");
addedCp.setServerProviderId("serverProvId1");
addedCp.setProviderId("portId");
addedCp.setTenantId("de8fd0d1d5874503a47b920c10f4322a");
addedCp.setCpdId("cpdId");
affectedConnectionPoints.getPost().add(addedCp);
notificationProcessor.processNotification(recievedNot, null, of(affectedConnectionPoints), "Nokia_RegionOne");
Thread.sleep(10000000 * 1000L);
}
JsonObject additionalData(String key, String value) {
JsonObject jsonObject = new JsonObject();
jsonObject.addProperty(key, value);
return jsonObject;
}
}
|
