|
17 | 17 | package com.cloud.network.router; |
18 | 18 |
|
19 | 19 | import com.cloud.agent.api.routing.VmDataCommand; |
| 20 | +import com.cloud.agent.manager.Commands; |
| 21 | +import com.cloud.configuration.ConfigurationManager; |
| 22 | +import com.cloud.dc.DataCenter; |
| 23 | +import com.cloud.dc.DataCenterVO; |
| 24 | +import com.cloud.dc.VlanVO; |
| 25 | +import com.cloud.dc.dao.DataCenterDao; |
| 26 | +import com.cloud.dc.dao.VlanDao; |
| 27 | +import com.cloud.network.NetworkModel; |
| 28 | +import com.cloud.network.PublicIpAddress; |
| 29 | +import com.cloud.network.addr.PublicIp; |
| 30 | +import com.cloud.network.dao.IPAddressDao; |
| 31 | +import com.cloud.network.dao.IPAddressVO; |
| 32 | +import com.cloud.network.dao.NetworkDao; |
| 33 | +import com.cloud.network.dao.NetworkDetailsDao; |
| 34 | +import com.cloud.network.dao.NetworkVO; |
| 35 | +import com.cloud.network.guru.PublicNetworkGuru; |
| 36 | +import com.cloud.network.vpc.VpcVO; |
| 37 | +import com.cloud.network.vpc.dao.VpcDao; |
| 38 | +import com.cloud.offering.NetworkOffering; |
| 39 | +import com.cloud.offerings.NetworkOfferingVO; |
| 40 | +import com.cloud.offerings.dao.NetworkOfferingDao; |
| 41 | +import com.cloud.offerings.dao.NetworkOfferingDetailsDao; |
| 42 | +import com.cloud.utils.net.Ip; |
| 43 | +import com.cloud.vm.NicVO; |
| 44 | +import com.cloud.vm.VirtualMachine; |
| 45 | +import com.cloud.vm.dao.NicDao; |
20 | 46 | import org.junit.Assert; |
| 47 | +import org.junit.Before; |
21 | 48 | import org.junit.Test; |
22 | 49 | import org.junit.runner.RunWith; |
| 50 | +import org.mockito.ArgumentMatchers; |
23 | 51 | import org.mockito.InjectMocks; |
| 52 | +import org.mockito.Mock; |
| 53 | +import org.mockito.Mockito; |
24 | 54 | import org.mockito.junit.MockitoJUnitRunner; |
| 55 | +import org.springframework.test.util.ReflectionTestUtils; |
25 | 56 |
|
26 | 57 | import java.util.ArrayList; |
| 58 | +import java.util.HashMap; |
27 | 59 | import java.util.List; |
| 60 | +import java.util.Map; |
28 | 61 |
|
29 | 62 | @RunWith(MockitoJUnitRunner.class) |
30 | 63 | public class CommandSetupHelperTest { |
31 | 64 |
|
32 | 65 | @InjectMocks |
33 | 66 | protected CommandSetupHelper commandSetupHelper = new CommandSetupHelper(); |
| 67 | + @Mock |
| 68 | + NicDao nicDao; |
| 69 | + @Mock |
| 70 | + NetworkDao networkDao; |
| 71 | + @Mock |
| 72 | + IPAddressDao ipAddressDao; |
| 73 | + @Mock |
| 74 | + VlanDao vlanDao; |
| 75 | + @Mock |
| 76 | + NetworkModel networkModel; |
| 77 | + @Mock |
| 78 | + NetworkOfferingDao networkOfferingDao; |
| 79 | + @Mock |
| 80 | + ConfigurationManager configurationManager; |
| 81 | + @Mock |
| 82 | + NetworkOfferingDetailsDao networkOfferingDetailsDao; |
| 83 | + @Mock |
| 84 | + NetworkDetailsDao networkDetailsDao; |
| 85 | + @Mock |
| 86 | + VpcDao vpcDao; |
| 87 | + @Mock |
| 88 | + RouterControlHelper routerControlHelper; |
| 89 | + @Mock |
| 90 | + DataCenterDao dcDao; |
| 91 | + |
| 92 | + @Before |
| 93 | + public void setUp() { |
| 94 | + ReflectionTestUtils.setField(commandSetupHelper, "_nicDao", nicDao); |
| 95 | + ReflectionTestUtils.setField(commandSetupHelper, "_networkDao", networkDao); |
| 96 | + ReflectionTestUtils.setField(commandSetupHelper, "_ipAddressDao", ipAddressDao); |
| 97 | + ReflectionTestUtils.setField(commandSetupHelper, "_vlanDao", vlanDao); |
| 98 | + ReflectionTestUtils.setField(commandSetupHelper, "_networkModel", networkModel); |
| 99 | + ReflectionTestUtils.setField(commandSetupHelper, "_networkOfferingDao", networkOfferingDao); |
| 100 | + ReflectionTestUtils.setField(commandSetupHelper, "networkOfferingDetailsDao", networkOfferingDetailsDao); |
| 101 | + ReflectionTestUtils.setField(commandSetupHelper, "networkDetailsDao", networkDetailsDao); |
| 102 | + ReflectionTestUtils.setField(commandSetupHelper, "_vpcDao", vpcDao); |
| 103 | + ReflectionTestUtils.setField(commandSetupHelper, "_routerControlHelper", routerControlHelper); |
| 104 | + ReflectionTestUtils.setField(commandSetupHelper, "_dcDao", dcDao); |
| 105 | + } |
34 | 106 |
|
35 | 107 | @Test |
36 | 108 | public void testUserDataDetails() { |
@@ -79,4 +151,45 @@ public void testUserDataDetailsWithWhiteSpaces() { |
79 | 151 | Assert.assertEquals("value1", metadataFile1[2]); |
80 | 152 | Assert.assertEquals("value2", metadataFile2[2]); |
81 | 153 | } |
| 154 | + |
| 155 | + @Test |
| 156 | + public void testCreateVpcAssociatePublicIP() { |
| 157 | + VirtualRouter router = Mockito.mock(VirtualRouter.class); |
| 158 | + Ip ip = new Ip("10.10.10.10"); |
| 159 | + IPAddressVO ipAddressVO = new IPAddressVO(ip, 1L, 0x0ac00000L, 2L, true); |
| 160 | + VlanVO vlanVO = new VlanVO(); |
| 161 | + vlanVO.setNetworkId(15L); |
| 162 | + PublicIpAddress publicIpAddress = new PublicIp(ipAddressVO, vlanVO, 0x0ac00000L); |
| 163 | + List<PublicIpAddress> pubIpList = new ArrayList<>(1); |
| 164 | + pubIpList.add(publicIpAddress); |
| 165 | + Commands commands = Mockito.mock(Commands.class); |
| 166 | + Map<String, String> vlanMacAddress = new HashMap<>(); |
| 167 | + NicVO nicVO = new NicVO("nic", 1L, 2L, VirtualMachine.Type.User); |
| 168 | + NetworkVO networkVO = new NetworkVO(); |
| 169 | + networkVO.setNetworkOfferingId(12L); |
| 170 | + List<IPAddressVO> userIps = List.of(ipAddressVO); |
| 171 | + NetworkOfferingVO networkOfferingVO = new NetworkOfferingVO(); |
| 172 | + Map<NetworkOffering.Detail, String> details = new HashMap<>(); |
| 173 | + VpcVO vpc = new VpcVO(); |
| 174 | + DataCenterVO dc = new DataCenterVO(1L, null, null, null, null, null, null, null, null, null, DataCenter.NetworkType.Advanced, null, null); |
| 175 | + |
| 176 | + Mockito.when(router.getId()).thenReturn(14L); |
| 177 | + Mockito.when(router.getDataCenterId()).thenReturn(4L); |
| 178 | + Mockito.when(nicDao.listByVmId(ArgumentMatchers.anyLong())).thenReturn(List.of(nicVO)); |
| 179 | + Mockito.when(networkDao.findById(ArgumentMatchers.anyLong())).thenReturn(networkVO); |
| 180 | + Mockito.when(ipAddressDao.listByAssociatedVpc(ArgumentMatchers.anyLong(), ArgumentMatchers.nullable(Boolean.class))).thenReturn(userIps); |
| 181 | + Mockito.when(vlanDao.findById(ArgumentMatchers.anyLong())).thenReturn(vlanVO); |
| 182 | + Mockito.when(networkModel.getNetworkRate(ArgumentMatchers.anyLong(), ArgumentMatchers.anyLong())).thenReturn(1200); |
| 183 | + Mockito.when(networkModel.getNetwork(ArgumentMatchers.anyLong())).thenReturn(networkVO); |
| 184 | + Mockito.when(networkOfferingDao.findById(ArgumentMatchers.anyLong())).thenReturn(networkOfferingVO); |
| 185 | + Mockito.when(configurationManager.getNetworkOfferingNetworkRate(ArgumentMatchers.anyLong(), ArgumentMatchers.anyLong())).thenReturn(1200); |
| 186 | + Mockito.when(networkModel.isSecurityGroupSupportedInNetwork(networkVO)).thenReturn(false); |
| 187 | + Mockito.when(networkOfferingDetailsDao.getNtwkOffDetails(ArgumentMatchers.anyLong())).thenReturn(details); |
| 188 | + Mockito.when(networkDetailsDao.findDetail(ArgumentMatchers.anyLong(), ArgumentMatchers.anyString())).thenReturn(null); |
| 189 | + Mockito.when(vpcDao.findById(ArgumentMatchers.anyLong())).thenReturn(vpc); |
| 190 | + Mockito.when(routerControlHelper.getRouterControlIp(ArgumentMatchers.anyLong())).thenReturn("10.1.11.101"); |
| 191 | + Mockito.when(dcDao.findById(ArgumentMatchers.anyLong())).thenReturn(dc); |
| 192 | + |
| 193 | + commandSetupHelper.createVpcAssociatePublicIPCommands(router, pubIpList, commands, vlanMacAddress); |
| 194 | + } |
82 | 195 | } |
0 commit comments