http://git-wip-us.apache.org/repos/asf/jclouds-labs-openstack/blob/35142182/openstack-neutron/src/test/java/org/jclouds/openstack/neutron/v2/extensions/lbaas/v1/LBaaSApiLiveTest.java ---------------------------------------------------------------------- diff --git a/openstack-neutron/src/test/java/org/jclouds/openstack/neutron/v2/extensions/lbaas/v1/LBaaSApiLiveTest.java b/openstack-neutron/src/test/java/org/jclouds/openstack/neutron/v2/extensions/lbaas/v1/LBaaSApiLiveTest.java deleted file mode 100644 index 90564b9..0000000 --- a/openstack-neutron/src/test/java/org/jclouds/openstack/neutron/v2/extensions/lbaas/v1/LBaaSApiLiveTest.java +++ /dev/null @@ -1,634 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You 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.jclouds.openstack.neutron.v2.extensions.lbaas.v1; - -import static org.testng.Assert.assertEquals; -import static org.testng.Assert.assertFalse; -import static org.testng.Assert.assertNotEquals; -import static org.testng.Assert.assertNotNull; -import static org.testng.Assert.assertNull; -import static org.testng.Assert.assertTrue; - -import java.util.Map; -import java.util.concurrent.TimeUnit; - -import org.jclouds.logging.Logger; -import org.jclouds.openstack.neutron.v2.domain.Network; -import org.jclouds.openstack.neutron.v2.domain.NetworkType; -import org.jclouds.openstack.neutron.v2.domain.Subnet; -import org.jclouds.openstack.neutron.v2.domain.lbaas.v1.HealthMonitor; -import org.jclouds.openstack.neutron.v2.domain.lbaas.v1.HealthMonitors; -import org.jclouds.openstack.neutron.v2.domain.lbaas.v1.HttpMethod; -import org.jclouds.openstack.neutron.v2.domain.lbaas.v1.LBaaSStatus; -import org.jclouds.openstack.neutron.v2.domain.lbaas.v1.Member; -import org.jclouds.openstack.neutron.v2.domain.lbaas.v1.Members; -import org.jclouds.openstack.neutron.v2.domain.lbaas.v1.Pool; -import org.jclouds.openstack.neutron.v2.domain.lbaas.v1.Pools; -import org.jclouds.openstack.neutron.v2.domain.lbaas.v1.ProbeType; -import org.jclouds.openstack.neutron.v2.domain.lbaas.v1.Protocol; -import org.jclouds.openstack.neutron.v2.domain.lbaas.v1.SessionPersistence; -import org.jclouds.openstack.neutron.v2.domain.lbaas.v1.VIP; -import org.jclouds.openstack.neutron.v2.domain.lbaas.v1.VIPs; -import org.jclouds.openstack.neutron.v2.features.NetworkApi; -import org.jclouds.openstack.neutron.v2.features.SubnetApi; -import org.jclouds.openstack.neutron.v2.internal.BaseNeutronApiLiveTest; -import org.jclouds.openstack.v2_0.options.PaginationOptions; -import org.testng.annotations.AfterClass; -import org.testng.annotations.BeforeClass; -import org.testng.annotations.Test; - -import com.google.common.base.Optional; -import com.google.common.collect.ImmutableMap; -import com.google.common.collect.Maps; -import com.google.common.util.concurrent.Uninterruptibles; - -@Test(groups = "live", testName = "LBaaSApiLiveTest") -public class LBaaSApiLiveTest extends BaseNeutronApiLiveTest { - - private Logger logger = getLoggingModule().createLoggerFactory().getLogger(LBaaSApiLiveTest.class.getName()); - - private Map<String, Network> networks = Maps.newLinkedHashMap(); - private Map<String, Subnet> subnets = Maps.newLinkedHashMap(); - - public void testLBaaSPresence() throws Exception { - for (String region : api.getConfiguredRegions()) { - Optional<LBaaSApi> lBaaSv1Api = api.getLBaaSApi(region); - - /* - * Check response - */ - assertNotNull(lBaaSv1Api); - if (lBaaSv1Api.isPresent()) { - logger.info("LBaaS API Version 1 is available"); - } else { - logger.info("LBaaS API Version 1 is unavailable"); - } - } - } - - @BeforeClass - public void createSubnets() { - for (String region : api.getConfiguredRegions()) { - Optional<LBaaSApi> lbaasApiExtension = api.getLBaaSApi(region); - if (!lbaasApiExtension.isPresent()) { - continue; - } - NetworkApi networkApi = api.getNetworkApi(region); - SubnetApi subnetApi = api.getSubnetApi(region); - - Network network = networkApi.create(Network.createBuilder("jclouds-lbaas-test-network").networkType(NetworkType.LOCAL).build()); - assertNotNull(network); - networks.put(region, network); - - Subnet subnet = subnetApi.create(Subnet.createBuilder(network.getId(), "10.0.0.0/24").ipVersion(4).name("jclouds-lbaas-test-subnet").build()); - assertNotNull(subnet); - subnets.put(region, subnet); - } - } - - @AfterClass - public void deleteSubnets() { - for (String region : api.getConfiguredRegions()) { - NetworkApi networkApi = api.getNetworkApi(region); - SubnetApi subnetApi = api.getSubnetApi(region); - - try { - Subnet subnet = subnets.get(region); - if (subnet != null) { - assertTrue(subnetApi.delete(subnet.getId())); - } - } finally { - Network network = networks.get(region); - if (network != null) { - assertTrue(networkApi.delete(network.getId())); - } - } - } - } - - public void testCreateUpdateAndDeletePool() { - for (String region : api.getConfiguredRegions()) { - Optional<LBaaSApi> lbaasApiExtension = api.getLBaaSApi(region); - if (!lbaasApiExtension.isPresent()) { - continue; - } - LBaaSApi lbaasApi = lbaasApiExtension.get(); - - Subnet subnet = subnets.get(region); - Pool pool = null; - - try { - // Create - Pool.CreatePool createPool = Pool.createBuilder(subnet.getId(), Protocol.HTTP, Pool.ROUND_ROBIN) - .name("jclouds-lbaas-test-pool").description(null).healthMonitors(null).provider(null).adminStateUp(null).build(); - pool = lbaasApi.createPool(createPool); - assertNotNull(pool); - assertNotNull(pool.getId()); - assertEquals(pool.getTenantId(), subnet.getTenantId()); - assertNull(pool.getVIPId()); - assertEquals(pool.getName(), "jclouds-lbaas-test-pool"); - assertEquals(pool.getDescription(), ""); - assertEquals(pool.getSubnetId(), subnet.getId()); - assertEquals(pool.getProtocol(), Protocol.HTTP); - assertNotNull(pool.getProvider()); - assertEquals(pool.getLBMethod(), Pool.ROUND_ROBIN); - assertNotNull(pool.getHealthMonitors()); - assertTrue(pool.getHealthMonitors().isEmpty()); - assertNotNull(pool.getHealthMonitorsStatus()); - assertTrue(pool.getHealthMonitorsStatus().isEmpty()); - assertNotNull(pool.getMembers()); - assertTrue(pool.getMembers().isEmpty()); - assertEquals(pool.getAdminStateUp(), Boolean.TRUE); - assertTrue(pool.getStatus() == LBaaSStatus.PENDING_CREATE || pool.getStatus() == LBaaSStatus.ACTIVE); - assertNull(pool.getStatusDescription()); - - // List and Get - Pools pools = lbaasApi.listPools(PaginationOptions.Builder.queryParameters(ImmutableMap.of("name", "jclouds-lbaas-test-pool").asMultimap())); - assertNotNull(pools); - assertFalse(pools.isEmpty()); - Pool poolList = pools.first().get(); - Pool poolGet = lbaasApi.getPool(poolList.getId()); - assertNotNull(poolGet); - assertEquals(poolGet, poolList); - - poolGet = lbaasApi.getPool(pool.getId()); - assertNotNull(poolGet); - assertEquals(poolGet.getName(), pool.getName()); - assertEquals(poolGet.getId(), pool.getId()); - - // Update - Pool.UpdatePool updatePool = Pool.updateBuilder().name("jclouds-lbaas-test-pool-renamed").description("new description").lbMethod(Pool.ROUND_ROBIN) - .healthMonitors(null).adminStateUp(Boolean.FALSE).build(); - Pool poolUpdate = lbaasApi.updatePool(pool.getId(), updatePool); - assertNotNull(poolUpdate); - assertEquals(poolUpdate.getName(), "jclouds-lbaas-test-pool-renamed"); - assertEquals(poolUpdate.getLBMethod(), Pool.ROUND_ROBIN); - assertNotNull(poolUpdate.getHealthMonitors()); - assertTrue(poolUpdate.getHealthMonitors().isEmpty()); - assertNotNull(poolUpdate.getHealthMonitorsStatus()); - assertTrue(poolUpdate.getHealthMonitorsStatus().isEmpty()); - assertEquals(poolUpdate.getAdminStateUp(), Boolean.FALSE); - - poolGet = lbaasApi.getPool(pool.getId()); - assertNotNull(poolGet); - assertEquals(poolGet.getId(), pool.getId()); - assertEquals(poolGet.getTenantId(), subnet.getTenantId()); - assertNull(poolGet.getVIPId()); - assertEquals(poolGet.getName(), "jclouds-lbaas-test-pool-renamed"); - assertEquals(poolGet.getDescription(), "new description"); - assertEquals(poolGet.getSubnetId(), subnet.getId()); - assertEquals(poolGet.getProtocol(), Protocol.HTTP); - assertNotNull(poolGet.getProvider()); - assertEquals(poolGet.getLBMethod(), Pool.ROUND_ROBIN); - assertNotNull(poolGet.getHealthMonitors()); - assertTrue(poolGet.getHealthMonitors().isEmpty()); - assertNotNull(poolGet.getHealthMonitorsStatus()); - assertTrue(poolGet.getHealthMonitorsStatus().isEmpty()); - assertNotNull(poolGet.getMembers()); - assertTrue(poolGet.getMembers().isEmpty()); - assertEquals(poolGet.getAdminStateUp(), Boolean.FALSE); - assertTrue(poolGet.getStatus() == LBaaSStatus.PENDING_UPDATE || poolGet.getStatus() == LBaaSStatus.ACTIVE); - assertNull(poolGet.getStatusDescription()); - } finally { - if (pool != null) { - // Delete - assertTrue(lbaasApi.deletePool(pool.getId())); - Pool poolGet = lbaasApi.getPool(pool.getId()); - assertNull(poolGet); - } - } - } - } - - public void testCreateUpdateAndDeleteMember() throws InterruptedException { - for (String region : api.getConfiguredRegions()) { - Optional<LBaaSApi> lbaasApiExtension = api.getLBaaSApi(region); - if (!lbaasApiExtension.isPresent()) { - continue; - } - LBaaSApi lbaasApi = lbaasApiExtension.get(); - - Subnet subnet = subnets.get(region); - Pool pool1 = null; - Pool pool2 = null; - Member member = null; - - try { - // Create pools - Pool.CreateBuilder createBuilder = Pool.createBuilder(subnet.getId(), Protocol.HTTP, Pool.ROUND_ROBIN) - .name("jclouds-lbaas-test-member-pool-1").description(null).healthMonitors(null).provider(null).adminStateUp(null); - pool1 = lbaasApi.createPool(createBuilder.build()); - assertNotNull(pool1); - createBuilder.name("jclouds-lbaas-test-member-pool-2"); - pool2 = lbaasApi.createPool(createBuilder.build()); - assertNotNull(pool2); - - // Create - Member.CreateMember createMember = Member.createBuilder(pool1.getId(), "10.0.0.100", 80) - .weight(null).adminStateUp(null).build(); - member = lbaasApi.createMember(createMember); - assertNotNull(member); - assertNotNull(member.getId()); - assertEquals(member.getTenantId(), subnet.getTenantId()); - assertEquals(member.getPoolId(), pool1.getId()); - assertEquals(member.getAddress(), "10.0.0.100"); - assertEquals(member.getProtocolPort(), Integer.valueOf(80)); - assertEquals(member.getWeight(), Integer.valueOf(1)); - assertEquals(member.getAdminStateUp(), Boolean.TRUE); - assertTrue(member.getStatus() == LBaaSStatus.PENDING_CREATE || member.getStatus() == LBaaSStatus.ACTIVE); - assertNull(member.getStatusDescription()); - - // List and Get - Thread.sleep(5000); - Uninterruptibles.sleepUninterruptibly(5, TimeUnit.SECONDS); - Members members = lbaasApi.listMembers(PaginationOptions.Builder.queryParameters(ImmutableMap.of("tenant_id", subnet.getTenantId()).asMultimap())); - assertNotNull(members); - assertFalse(members.isEmpty()); - Member memberList = members.first().get(); - Member memberGet = lbaasApi.getMember(memberList.getId()); - assertNotNull(memberGet); - assertEquals(memberGet, memberList); - - memberGet = lbaasApi.getMember(member.getId()); - assertNotNull(memberGet); - assertEquals(memberGet.getId(), member.getId()); - - // Verify member appears in pool1 and not in pool2 - Pool pool1Get = lbaasApi.getPool(pool1.getId()); - assertNotNull(pool1Get); - assertNotNull(pool1Get.getMembers()); - assertFalse(pool1Get.getMembers().isEmpty()); - assertEquals(pool1Get.getMembers().iterator().next(), member.getId()); - Pool pool2Get = lbaasApi.getPool(pool2.getId()); - assertNotNull(pool2Get); - assertNotNull(pool2Get.getMembers()); - assertTrue(pool2Get.getMembers().isEmpty()); - - // Update - Member.UpdateMember updateMember = Member.updateBuilder() - .poolId(pool2.getId()).weight(2).adminStateUp(Boolean.FALSE).build(); - Member memberUpdate = lbaasApi.updateMember(member.getId(), updateMember); - assertNotNull(memberUpdate); - assertEquals(memberUpdate.getPoolId(), pool2.getId()); - assertEquals(memberUpdate.getWeight(), Integer.valueOf(2)); - assertEquals(memberUpdate.getAdminStateUp(), Boolean.FALSE); - - memberGet = lbaasApi.getMember(member.getId()); - assertNotNull(memberGet); - assertNotNull(memberGet.getId()); - assertEquals(memberGet.getTenantId(), subnet.getTenantId()); - assertEquals(memberGet.getPoolId(), pool2.getId()); - assertEquals(member.getAddress(), "10.0.0.100"); - assertEquals(memberGet.getProtocolPort(), Integer.valueOf(80)); - assertEquals(memberGet.getWeight(), Integer.valueOf(2)); - assertEquals(memberGet.getAdminStateUp(), Boolean.FALSE); - assertTrue(memberGet.getStatus() == LBaaSStatus.PENDING_UPDATE || memberGet.getStatus() == LBaaSStatus.ACTIVE); - assertNull(memberGet.getStatusDescription()); - - // Verify member appears in pool2 and not in pool1 - pool1Get = lbaasApi.getPool(pool1.getId()); - assertNotNull(pool1Get); - assertNotNull(pool1Get.getMembers()); - assertTrue(pool1Get.getMembers().isEmpty()); - pool2Get = lbaasApi.getPool(pool2.getId()); - assertNotNull(pool2Get); - assertNotNull(pool2Get.getMembers()); - assertFalse(pool2Get.getMembers().isEmpty()); - assertEquals(pool2Get.getMembers().iterator().next(), member.getId()); - } finally { - if (member != null) { - // Delete - assertTrue(lbaasApi.deleteMember(member.getId())); - Member memberGet = lbaasApi.getMember(member.getId()); - assertNull(memberGet); - - // Verify member does not appear in pool1 and in pool2 - Pool pool1Get = lbaasApi.getPool(pool1.getId()); - assertNotNull(pool1Get); - assertNotNull(pool1Get.getMembers()); - assertTrue(pool1Get.getMembers().isEmpty()); - Pool pool2Get = lbaasApi.getPool(pool2.getId()); - assertNotNull(pool2Get); - assertNotNull(pool2Get.getMembers()); - assertTrue(pool2Get.getMembers().isEmpty()); - } - if (pool2 != null) { - assertTrue(lbaasApi.deletePool(pool2.getId())); - } - if (pool1 != null) { - assertTrue(lbaasApi.deletePool(pool1.getId())); - } - } - } - } - - public void testCreateUpdateAndDeleteVIP() { - for (String region : api.getConfiguredRegions()) { - Optional<LBaaSApi> lbaasApiExtension = api.getLBaaSApi(region); - if (!lbaasApiExtension.isPresent()) { - continue; - } - LBaaSApi lbaasApi = lbaasApiExtension.get(); - - Subnet subnet = subnets.get(region); - Pool pool1 = null; - Pool pool2 = null; - VIP vip = null; - - try { - // Create pools - Pool.CreateBuilder createBuilder = Pool.createBuilder(subnet.getId(), Protocol.HTTP, Pool.ROUND_ROBIN) - .name("jclouds-lbaas-test-vip-pool-1").description(null).healthMonitors(null).provider(null).adminStateUp(null); - pool1 = lbaasApi.createPool(createBuilder.build()); - assertNotNull(pool1); - createBuilder.name("jclouds-lbaas-test-vip-pool-2"); - pool2 = lbaasApi.createPool(createBuilder.build()); - assertNotNull(pool2); - - // Create - VIP.CreateVIP createVIP = VIP.createBuilder(subnet.getId(), Protocol.HTTP, 80, pool1.getId()) - .name("jclouds-lbaas-test-vip").description(null).address(null).sessionPersistence(null).connectionLimit(null).build(); - vip = lbaasApi.createVIP(createVIP); - assertNotNull(vip); - assertNotNull(vip.getId()); - assertEquals(vip.getTenantId(), subnet.getTenantId()); - assertEquals(vip.getName(), "jclouds-lbaas-test-vip"); - assertEquals(vip.getDescription(), ""); - assertEquals(vip.getSubnetId(), subnet.getId()); - assertNotNull(vip.getAddress()); - assertNotNull(vip.getPortId()); - assertEquals(vip.getProtocol(), Protocol.HTTP); - assertEquals(vip.getProtocolPort(), Integer.valueOf(80)); - assertEquals(vip.getPoolId(), pool1.getId()); - assertNull(vip.getSessionPersistence()); - assertEquals(vip.getConnectionLimit(), Integer.valueOf(-1)); - assertEquals(vip.getAdminStateUp(), Boolean.TRUE); - assertTrue(vip.getStatus() == LBaaSStatus.PENDING_CREATE || vip.getStatus() == LBaaSStatus.ACTIVE); - assertNull(vip.getStatusDescription()); - - // List and Get - VIPs vips = lbaasApi.listVIPs(PaginationOptions.Builder.queryParameters(ImmutableMap.of("tenant_id", subnet.getTenantId()).asMultimap())); - assertNotNull(vips); - assertFalse(vips.isEmpty()); - VIP vipList = vips.first().get(); - VIP vipGet = lbaasApi.getVIP(vipList.getId()); - assertNotNull(vipGet); - assertEquals(vipGet, vipList); - - vipGet = lbaasApi.getVIP(vip.getId()); - assertNotNull(vipGet); - assertEquals(vipGet.getId(), vip.getId()); - - // Verify VIP appears in pool1 and not in pool2 - Pool pool1Get = lbaasApi.getPool(pool1.getId()); - assertNotNull(pool1Get); - assertEquals(pool1Get.getVIPId(), vip.getId()); - Pool pool2Get = lbaasApi.getPool(pool2.getId()); - assertNotNull(pool2Get); - assertNotEquals(pool2Get.getVIPId(), vip.getId()); - - // Update - SessionPersistence sessionPersistence = SessionPersistence.builder().type(SessionPersistence.Type.HTTP_COOKIE).cookieName(null).build(); - VIP.UpdateVIP updateVIP = VIP.updateBuilder() - .name("jclouds-lbaas-test-vip-renamed").description("new description").poolId(pool2.getId()) - .sessionPersistence(sessionPersistence).connectionLimit(2).adminStateUp(Boolean.FALSE).build(); - VIP vipUpdate = lbaasApi.updateVIP(vip.getId(), updateVIP); - assertNotNull(vipUpdate); - assertEquals(vipUpdate.getName(), "jclouds-lbaas-test-vip-renamed"); - assertEquals(vipUpdate.getDescription(), "new description"); - assertEquals(vipUpdate.getPoolId(), pool2.getId()); - assertEquals(vipUpdate.getSessionPersistence(), sessionPersistence); - assertEquals(vipUpdate.getConnectionLimit(), Integer.valueOf(2)); - assertEquals(vipUpdate.getAdminStateUp(), Boolean.FALSE); - - vipGet = lbaasApi.getVIP(vip.getId()); - assertNotNull(vipGet); - assertNotNull(vipGet.getId()); - assertEquals(vipGet.getTenantId(), subnet.getTenantId()); - assertEquals(vipGet.getName(), "jclouds-lbaas-test-vip-renamed"); - assertEquals(vipGet.getDescription(), "new description"); - assertEquals(vipGet.getSubnetId(), subnet.getId()); - assertNotNull(vipGet.getAddress()); - assertNotNull(vipGet.getPortId()); - assertEquals(vipGet.getProtocol(), Protocol.HTTP); - assertEquals(vipGet.getProtocolPort(), Integer.valueOf(80)); - assertEquals(vipGet.getPoolId(), pool2.getId()); - assertEquals(vipGet.getSessionPersistence(), sessionPersistence); - assertEquals(vipGet.getConnectionLimit(), Integer.valueOf(2)); - assertEquals(vipGet.getAdminStateUp(), Boolean.FALSE); - assertTrue(vipGet.getStatus() == LBaaSStatus.PENDING_UPDATE || vipGet.getStatus() == LBaaSStatus.ACTIVE); - assertNull(vipGet.getStatusDescription()); - - // Verify VIP appears in pool2 and not in pool1 - pool1Get = lbaasApi.getPool(pool1.getId()); - assertNotNull(pool1Get); - assertNotEquals(pool1Get.getVIPId(), vip.getId()); - pool2Get = lbaasApi.getPool(pool2.getId()); - assertNotNull(pool2Get); - assertEquals(pool2Get.getVIPId(), vip.getId()); - } finally { - if (vip != null) { - // Delete - assertTrue(lbaasApi.deleteVIP(vip.getId())); - VIP vipGet = lbaasApi.getVIP(vip.getId()); - assertNull(vipGet); - - // Verify VIP does not appear in pool1 and in pool2 - Pool pool1Get = lbaasApi.getPool(pool1.getId()); - assertNotNull(pool1Get); - assertNotEquals(pool1Get.getVIPId(), vip.getId()); - Pool pool2Get = lbaasApi.getPool(pool2.getId()); - assertNotNull(pool2Get); - assertNotEquals(pool2Get.getVIPId(), vip.getId()); - } - if (pool2 != null) { - assertTrue(lbaasApi.deletePool(pool2.getId())); - } - if (pool1 != null) { - assertTrue(lbaasApi.deletePool(pool1.getId())); - } - } - } - } - - public void testCreateUpdateAndDeleteHealthMonitor() { - for (String region : api.getConfiguredRegions()) { - Optional<LBaaSApi> lbaasApiExtension = api.getLBaaSApi(region); - if (!lbaasApiExtension.isPresent()) { - continue; - } - LBaaSApi lbaasApi = lbaasApiExtension.get(); - - Subnet subnet = subnets.get(region); - HealthMonitor healthMonitor = null; - - try { - // Create - HealthMonitor.CreateHealthMonitor createHealthMonitor = HealthMonitor.createBuilder(ProbeType.HTTP, Integer.valueOf(1), Integer.valueOf(1), Integer.valueOf(1)) - .httpMethod(null).urlPath(null).expectedCodes(null).adminStateUp(null).build(); - healthMonitor = lbaasApi.createHealthMonitor(createHealthMonitor); - assertNotNull(healthMonitor); - assertNotNull(healthMonitor.getId()); - assertEquals(healthMonitor.getTenantId(), subnet.getTenantId()); - assertEquals(healthMonitor.getType(), ProbeType.HTTP); - assertEquals(healthMonitor.getDelay(), Integer.valueOf(1)); - assertEquals(healthMonitor.getTimeout(), Integer.valueOf(1)); - assertEquals(healthMonitor.getMaxRetries(), Integer.valueOf(1)); - assertEquals(healthMonitor.getHttpMethod(), HttpMethod.GET); - assertEquals(healthMonitor.getUrlPath(), "/"); - assertEquals(healthMonitor.getExpectedCodes(), "200"); - assertNotNull(healthMonitor.getPools()); - assertTrue(healthMonitor.getPools().isEmpty()); - assertEquals(healthMonitor.getAdminStateUp(), Boolean.TRUE); - //assertEquals(healthMonitor.getStatus(), LBaaSStatus.PENDING_CREATE); - assertNull(healthMonitor.getStatus()); - assertNull(healthMonitor.getStatusDescription()); - - // List and Get - HealthMonitors healthMonitors = lbaasApi.listHealthMonitors(PaginationOptions.Builder.queryParameters(ImmutableMap.of("tenant_id", subnet.getTenantId()).asMultimap())); - assertNotNull(healthMonitors); - assertFalse(healthMonitors.isEmpty()); - HealthMonitor healthMonitorList = healthMonitors.first().get(); - HealthMonitor healthMonitorGet = lbaasApi.getHealthMonitor(healthMonitorList.getId()); - assertNotNull(healthMonitorGet); - assertEquals(healthMonitorGet, healthMonitorList); - - healthMonitorGet = lbaasApi.getHealthMonitor(healthMonitor.getId()); - assertNotNull(healthMonitorGet); - assertEquals(healthMonitorGet.getId(), healthMonitor.getId()); - - // Update - HealthMonitor.UpdateHealthMonitor updateHealthMonitor = HealthMonitor.updateBuilder().delay(Integer.valueOf(2)).timeout(Integer.valueOf(2)).maxRetries(Integer.valueOf(2)) - .httpMethod(HttpMethod.HEAD).urlPath("/index.html").expectedCodes("201").adminStateUp(Boolean.FALSE).build(); - HealthMonitor healthMonitorUpdate = lbaasApi.updateHealthMonitor(healthMonitor.getId(), updateHealthMonitor); - assertNotNull(healthMonitorUpdate); - assertEquals(healthMonitorUpdate.getDelay(), Integer.valueOf(2)); - assertEquals(healthMonitorUpdate.getTimeout(), Integer.valueOf(2)); - assertEquals(healthMonitorUpdate.getMaxRetries(), Integer.valueOf(2)); - assertEquals(healthMonitorUpdate.getHttpMethod(), HttpMethod.HEAD); - assertEquals(healthMonitorUpdate.getUrlPath(), "/index.html"); - assertEquals(healthMonitorUpdate.getExpectedCodes(), "201"); - assertEquals(healthMonitorUpdate.getAdminStateUp(), Boolean.FALSE); - - healthMonitorGet = lbaasApi.getHealthMonitor(healthMonitor.getId()); - assertNotNull(healthMonitorGet); - assertNotNull(healthMonitorGet.getId()); - assertEquals(healthMonitorGet.getTenantId(), subnet.getTenantId()); - assertEquals(healthMonitorGet.getType(), ProbeType.HTTP); - assertEquals(healthMonitorGet.getDelay(), Integer.valueOf(2)); - assertEquals(healthMonitorGet.getTimeout(), Integer.valueOf(2)); - assertEquals(healthMonitorGet.getMaxRetries(), Integer.valueOf(2)); - assertEquals(healthMonitorGet.getHttpMethod(), HttpMethod.HEAD); - assertEquals(healthMonitorGet.getUrlPath(), "/index.html"); - assertEquals(healthMonitorGet.getExpectedCodes(), "201"); - assertNotNull(healthMonitorGet.getPools()); - assertTrue(healthMonitorGet.getPools().isEmpty()); - assertEquals(healthMonitorGet.getAdminStateUp(), Boolean.FALSE); - //assertEquals(healthMonitorGet.getStatus(), LBaaSStatus.PENDING_UPDATE); - assertNull(healthMonitorGet.getStatus()); - assertNull(healthMonitorGet.getStatusDescription()); - } finally { - if (healthMonitor != null) { - // Delete - assertTrue(lbaasApi.deleteHealthMonitor(healthMonitor.getId())); - HealthMonitor healthMonitorGet = lbaasApi.getHealthMonitor(healthMonitor.getId()); - assertNull(healthMonitorGet); - } - } - } - } - - public void testAssociateAndDisassociateHealthMonitorWithPool() { - for (String region : api.getConfiguredRegions()) { - Optional<LBaaSApi> lbaasApiExtension = api.getLBaaSApi(region); - if (!lbaasApiExtension.isPresent()) { - continue; - } - LBaaSApi lbaasApi = lbaasApiExtension.get(); - - Subnet subnet = subnets.get(region); - Pool pool = null; - HealthMonitor healthMonitor = null; - - try { - // Create pool - Pool.CreatePool poolCreateOptions = Pool.createBuilder(subnet.getId(), Protocol.TCP, Pool.ROUND_ROBIN) - .name("jclouds-lbaas-test-pool-association").build(); - pool = lbaasApi.createPool(poolCreateOptions); - assertNotNull(pool); - assertNotNull(pool.getId()); - assertNotNull(pool.getHealthMonitors()); - assertTrue(pool.getHealthMonitors().isEmpty()); - assertNotNull(pool.getHealthMonitorsStatus()); - assertTrue(pool.getHealthMonitorsStatus().isEmpty()); - - // Create health monitor - HealthMonitor.CreateHealthMonitor healthMonitorCreateOptions = HealthMonitor.createBuilder(ProbeType.HTTP, Integer.valueOf(1), Integer.valueOf(1), Integer.valueOf(1)).build(); - healthMonitor = lbaasApi.createHealthMonitor(healthMonitorCreateOptions); - assertNotNull(healthMonitor); - assertNotNull(healthMonitor.getId()); - assertNotNull(healthMonitor.getPools()); - assertTrue(healthMonitor.getPools().isEmpty()); - - // Associate health monitor with pool - HealthMonitor healthMonitorAssociated = lbaasApi.associateHealthMonitor(pool.getId(), healthMonitor.getId()); - assertNotNull(healthMonitorAssociated); - - // Verify health monitor is associated with pool - Pool poolGet = lbaasApi.getPool(pool.getId()); - assertNotNull(poolGet); - assertNotNull(poolGet.getHealthMonitors()); - assertEquals(poolGet.getHealthMonitors().size(), 1); - assertEquals(poolGet.getHealthMonitors().iterator().next(), healthMonitor.getId()); - assertNotNull(poolGet.getHealthMonitorsStatus()); - assertEquals(poolGet.getHealthMonitorsStatus().size(), 1); - assertEquals(poolGet.getHealthMonitorsStatus().iterator().next().getId(), healthMonitor.getId()); - - HealthMonitor healthMonitorGet = lbaasApi.getHealthMonitor(healthMonitor.getId()); - assertNotNull(healthMonitorGet); - assertNotNull(healthMonitorGet.getPools()); - assertEquals(healthMonitorGet.getPools().size(), 1); - assertEquals(healthMonitorGet.getPools().iterator().next().getId(), pool.getId()); - - // Disassociate health monitor from pool - assertTrue(lbaasApi.disassociateHealthMonitor(pool.getId(), healthMonitor.getId())); - - // Verify health monitor is disassociated from pool - poolGet = lbaasApi.getPool(pool.getId()); - assertNotNull(poolGet); - assertNotNull(poolGet.getHealthMonitors()); - assertTrue(poolGet.getHealthMonitors().isEmpty()); - assertNotNull(poolGet.getHealthMonitorsStatus()); - assertTrue(poolGet.getHealthMonitorsStatus().isEmpty()); - - healthMonitorGet = lbaasApi.getHealthMonitor(healthMonitor.getId()); - assertNotNull(healthMonitorGet); - assertNotNull(healthMonitorGet.getPools()); - assertTrue(healthMonitorGet.getPools().isEmpty()); - } finally { - if (healthMonitor != null) { - assertTrue(lbaasApi.deleteHealthMonitor(healthMonitor.getId())); - } - if (pool != null) { - assertTrue(lbaasApi.deletePool(pool.getId())); - } - } - } - } - -}
http://git-wip-us.apache.org/repos/asf/jclouds-labs-openstack/blob/35142182/openstack-neutron/src/test/java/org/jclouds/openstack/neutron/v2/extensions/lbaas/v1/LBaaSApiMockTest.java ---------------------------------------------------------------------- diff --git a/openstack-neutron/src/test/java/org/jclouds/openstack/neutron/v2/extensions/lbaas/v1/LBaaSApiMockTest.java b/openstack-neutron/src/test/java/org/jclouds/openstack/neutron/v2/extensions/lbaas/v1/LBaaSApiMockTest.java deleted file mode 100644 index ce5dc66..0000000 --- a/openstack-neutron/src/test/java/org/jclouds/openstack/neutron/v2/extensions/lbaas/v1/LBaaSApiMockTest.java +++ /dev/null @@ -1,1055 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You 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.jclouds.openstack.neutron.v2.extensions.lbaas.v1; - -import static org.testng.Assert.assertEquals; -import static org.testng.Assert.assertNotNull; -import static org.testng.Assert.assertNull; -import static org.testng.Assert.assertTrue; - -import java.io.IOException; -import java.util.List; - -import org.jclouds.openstack.neutron.v2.NeutronApi; -import org.jclouds.openstack.neutron.v2.domain.lbaas.v1.HealthMonitor; -import org.jclouds.openstack.neutron.v2.domain.lbaas.v1.HealthMonitors; -import org.jclouds.openstack.neutron.v2.domain.lbaas.v1.HttpMethod; -import org.jclouds.openstack.neutron.v2.domain.lbaas.v1.LBaaSStatus; -import org.jclouds.openstack.neutron.v2.domain.lbaas.v1.Member; -import org.jclouds.openstack.neutron.v2.domain.lbaas.v1.Members; -import org.jclouds.openstack.neutron.v2.domain.lbaas.v1.Pool; -import org.jclouds.openstack.neutron.v2.domain.lbaas.v1.Pools; -import org.jclouds.openstack.neutron.v2.domain.lbaas.v1.ProbeType; -import org.jclouds.openstack.neutron.v2.domain.lbaas.v1.Protocol; -import org.jclouds.openstack.neutron.v2.domain.lbaas.v1.SessionPersistence; -import org.jclouds.openstack.neutron.v2.domain.lbaas.v1.VIP; -import org.jclouds.openstack.neutron.v2.domain.lbaas.v1.VIPs; -import org.jclouds.openstack.neutron.v2.internal.BaseNeutronApiMockTest; -import org.jclouds.openstack.v2_0.options.PaginationOptions; -import org.testng.annotations.Test; - -import com.google.common.base.Optional; -import com.google.common.collect.ImmutableSet; -import com.squareup.okhttp.mockwebserver.MockResponse; -import com.squareup.okhttp.mockwebserver.MockWebServer; - -@Test -public class LBaaSApiMockTest extends BaseNeutronApiMockTest { - - public void testWhenNamespaceInExtensionsLBaaSPresent() throws IOException { - MockWebServer server = mockOpenStackServer(); - server.enqueue(addCommonHeaders(new MockResponse().setBody(stringFromResource("/access.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/extension_list_with_lbaas_v1_response.json")))); - - try { - NeutronApi neutronApi = api(server.getUrl("/").toString(), "openstack-neutron", overrides); - Optional<LBaaSApi> lbaasApiExtension = neutronApi.getLBaaSApi("RegionOne"); - - assertAuthentication(server); - - /* - * Check response - */ - assertNotNull(lbaasApiExtension); - assertEquals(lbaasApiExtension.isPresent(), true, "LBaaS API Version 1 is expected to be available"); - } finally { - server.shutdown(); - } - } - - public void testWhenNamespaceNotInExtensionsListLBaaSNotPresent() throws IOException { - MockWebServer server = mockOpenStackServer(); - server.enqueue(addCommonHeaders(new MockResponse().setBody(stringFromResource("/access.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/extension_list_without_lbaas_v1_response.json")))); - - try { - NeutronApi neutronApi = api(server.getUrl("/").toString(), "openstack-neutron", overrides); - Optional<LBaaSApi> lbaasApiExtension = neutronApi.getLBaaSApi("RegionOne"); - - assertAuthentication(server); - - /* - * Check response - */ - assertNotNull(lbaasApiExtension); - assertEquals(lbaasApiExtension.isPresent(), false, "LBaaS API Version 1 is expected to be unavailable"); - } finally { - server.shutdown(); - } - } - - public void testCreatePool() throws IOException, InterruptedException { - MockWebServer server = mockOpenStackServer(); - server.enqueue(addCommonHeaders(new MockResponse().setBody(stringFromResource("/access.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/extension_list_with_lbaas_v1_response.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(201).setBody(stringFromResource("/lbaas/v1/pool_create_response.json")))); - - try { - NeutronApi neutronApi = api(server.getUrl("/").toString(), "openstack-neutron", overrides); - LBaaSApi lbaasApi = neutronApi.getLBaaSApi("RegionOne").get(); - - Pool.CreatePool createPool = Pool.createBuilder("8032909d-47a1-4715-90af-5153ffe39861", Protocol.TCP, Pool.ROUND_ROBIN) - .name("NewPool").description(null).healthMonitors(null).provider(null).adminStateUp(null).build(); - - Pool pool = lbaasApi.createPool(createPool); - - /* - * Check request - */ - assertAuthentication(server); - server.takeRequest(); - assertRequest(server.takeRequest(), "POST", uriApiVersion + "/lb/pools", "/lbaas/v1/pool_create_request.json"); - - /* - * Check response - */ - assertNotNull(pool); - assertNotNull(pool.getId()); - assertEquals(pool.getTenantId(), "83657cfcdfe44cd5920adaf26c48ceea"); - assertNull(pool.getVIPId()); - assertEquals(pool.getName(), "NewPool"); - assertEquals(pool.getDescription(), ""); - assertEquals(pool.getSubnetId(), "8032909d-47a1-4715-90af-5153ffe39861"); - assertEquals(pool.getProtocol(), Protocol.TCP); - assertEquals(pool.getProvider(), "HAPROXY"); - assertEquals(pool.getLBMethod(), Pool.ROUND_ROBIN); - assertNotNull(pool.getMembers()); - assertTrue(pool.getMembers().isEmpty()); - assertNotNull(pool.getHealthMonitors()); - assertTrue(pool.getHealthMonitors().isEmpty()); - assertNotNull(pool.getHealthMonitorsStatus()); - assertTrue(pool.getHealthMonitorsStatus().isEmpty()); - assertEquals(pool.getAdminStateUp(), Boolean.TRUE); - assertEquals(pool.getStatus(), LBaaSStatus.PENDING_CREATE); - assertNull(pool.getStatusDescription()); - } finally { - server.shutdown(); - } - } - - public void testListSpecificPagePool() throws IOException, InterruptedException { - MockWebServer server = mockOpenStackServer(); - server.enqueue(addCommonHeaders(new MockResponse().setBody(stringFromResource("/access.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/extension_list_with_lbaas_v1_response.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(201).setBody(stringFromResource("/lbaas/v1/pool_list_response_paged1.json")))); - - try { - NeutronApi neutronApi = api(server.getUrl("/").toString(), "openstack-neutron", overrides); - LBaaSApi lbaasApi = neutronApi.getLBaaSApi("RegionOne").get(); - - Pools pools = lbaasApi.listPools(PaginationOptions.Builder.limit(2).marker("abcdefg")); - - /* - * Check request - */ - assertAuthentication(server); - server.takeRequest(); - assertRequest(server.takeRequest(), "GET", uriApiVersion + "/lb/pools?limit=2&marker=abcdefg"); - - /* - * Check response - */ - assertNotNull(pools); - assertEquals(pools.size(), 1); - assertEquals(pools.first().get().getId(), "72741b06-df4d-4715-b142-276b6bce75ab"); - } finally { - server.shutdown(); - } - } - - public void testListPagedPool() throws IOException, InterruptedException { - MockWebServer server = mockOpenStackServer(); - server.enqueue(addCommonHeaders(new MockResponse().setBody(stringFromResource("/access.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/extension_list_with_lbaas_v1_response.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/lbaas/v1/pool_list_response_paged1.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/lbaas/v1/pool_list_response_paged2.json")))); - - try { - NeutronApi neutronApi = api(server.getUrl("/").toString(), "openstack-neutron", overrides); - LBaaSApi lbaasApi = neutronApi.getLBaaSApi("RegionOne").get(); - - // Note: Lazy! Have to actually look at the collection. - List<Pool> pools = lbaasApi.listPools().concat().toList(); - - /* - * Check request - */ - assertEquals(server.getRequestCount(), 4); - assertAuthentication(server); - server.takeRequest(); - assertRequest(server.takeRequest(), "GET", uriApiVersion + "/lb/pools"); - assertRequest(server.takeRequest(), "GET", uriApiVersion + "/lb/pools?marker=71c1e68c-171a-4aa2-aca5-50ea153a3718"); - - /* - * Check response - */ - assertNotNull(pools); - assertEquals(pools.size(), 2); - assertEquals(pools.get(0).getId(), "72741b06-df4d-4715-b142-276b6bce75ab"); - assertEquals(pools.get(1).getId(), "72741b06-df4d-4715-b142-276b6bce75ab_2"); - } finally { - server.shutdown(); - } - } - - public void testGetPool() throws IOException, InterruptedException { - MockWebServer server = mockOpenStackServer(); - server.enqueue(addCommonHeaders(new MockResponse().setBody(stringFromResource("/access.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/extension_list_with_lbaas_v1_response.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(201).setBody(stringFromResource("/lbaas/v1/pool_get_response.json")))); - - try { - NeutronApi neutronApi = api(server.getUrl("/").toString(), "openstack-neutron", overrides); - LBaaSApi lbaasApi = neutronApi.getLBaaSApi("RegionOne").get(); - - Pool pool = lbaasApi.getPool("72741b06-df4d-4715-b142-276b6bce75ab"); - - /* - * Check request - */ - assertAuthentication(server); - server.takeRequest(); - assertRequest(server.takeRequest(), "GET", uriApiVersion + "/lb/pools/72741b06-df4d-4715-b142-276b6bce75ab"); - - /* - * Check response - */ - assertNotNull(pool); - assertEquals(pool.getId(), "72741b06-df4d-4715-b142-276b6bce75ab"); - assertEquals(pool.getTenantId(), "83657cfcdfe44cd5920adaf26c48ceea"); - assertNotNull(pool.getVIPId()); - assertEquals(pool.getName(), "app_pool"); - assertEquals(pool.getDescription(), ""); - assertEquals(pool.getSubnetId(), "8032909d-47a1-4715-90af-5153ffe39861"); - assertEquals(pool.getProtocol(), Protocol.HTTP); - assertEquals(pool.getProvider(), "HAPROXY"); - assertEquals(pool.getLBMethod(), Pool.ROUND_ROBIN); - assertNotNull(pool.getMembers()); - assertEquals(pool.getMembers().size(), 2); - assertNotNull(pool.getHealthMonitors()); - assertEquals(pool.getHealthMonitors().size(), 2); - assertNotNull(pool.getHealthMonitorsStatus()); - assertEquals(pool.getHealthMonitorsStatus().size(), 2); - assertEquals(pool.getAdminStateUp(), Boolean.TRUE); - assertEquals(pool.getStatus(), LBaaSStatus.ACTIVE); - assertNull(pool.getStatusDescription()); - } finally { - server.shutdown(); - } - } - - public void testUpdatePool() throws IOException, InterruptedException { - MockWebServer server = mockOpenStackServer(); - server.enqueue(addCommonHeaders(new MockResponse().setBody(stringFromResource("/access.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/extension_list_with_lbaas_v1_response.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(201).setBody(stringFromResource("/lbaas/v1/pool_update_response.json")))); - - try { - NeutronApi neutronApi = api(server.getUrl("/").toString(), "openstack-neutron", overrides); - LBaaSApi lbaasApi = neutronApi.getLBaaSApi("RegionOne").get(); - - Pool.UpdatePool updatePool = Pool.updateBuilder().name("new_name").description("new description").lbMethod("NEW_LB_METHOD") - .healthMonitors(ImmutableSet.of("5d4b5228-33b0-4e60-b225-9b727c1a20e7")).adminStateUp(Boolean.FALSE).build(); - - Pool pool = lbaasApi.updatePool("72741b06-df4d-4715-b142-276b6bce75ab", updatePool); - - /* - * Check request - */ - assertAuthentication(server); - server.takeRequest(); - assertRequest(server.takeRequest(), "PUT", uriApiVersion + "/lb/pools/72741b06-df4d-4715-b142-276b6bce75ab", "/lbaas/v1/pool_update_request.json"); - - /* - * Check response - */ - assertNotNull(pool); - assertEquals(pool.getId(), "72741b06-df4d-4715-b142-276b6bce75ab"); - assertEquals(pool.getTenantId(), "83657cfcdfe44cd5920adaf26c48ceea"); - assertNotNull(pool.getVIPId()); - assertEquals(pool.getName(), "new_name"); - assertEquals(pool.getDescription(), "new description"); - assertEquals(pool.getSubnetId(), "8032909d-47a1-4715-90af-5153ffe39861"); - assertEquals(pool.getProtocol(), Protocol.HTTP); - assertEquals(pool.getProvider(), "HAPROXY"); - assertEquals(pool.getLBMethod(), "NEW_LB_METHOD"); - assertNotNull(pool.getMembers()); - assertEquals(pool.getMembers().size(), 2); - assertNotNull(pool.getHealthMonitors()); - assertEquals(pool.getHealthMonitors().size(), 1); - assertEquals(pool.getHealthMonitors().iterator().next(), "5d4b5228-33b0-4e60-b225-9b727c1a20e7"); - assertNotNull(pool.getHealthMonitorsStatus()); - assertEquals(pool.getHealthMonitorsStatus().size(), 1); - assertEquals(pool.getHealthMonitorsStatus().iterator().next().getId(), "5d4b5228-33b0-4e60-b225-9b727c1a20e7"); - assertEquals(pool.getAdminStateUp(), Boolean.FALSE); - assertEquals(pool.getStatus(), LBaaSStatus.ACTIVE); - assertNull(pool.getStatusDescription()); - } finally { - server.shutdown(); - } - } - - public void testDeletePool() throws IOException, InterruptedException { - MockWebServer server = mockOpenStackServer(); - server.enqueue(addCommonHeaders(new MockResponse().setBody(stringFromResource("/access.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/extension_list_with_lbaas_v1_response.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(204))); - - try { - NeutronApi neutronApi = api(server.getUrl("/").toString(), "openstack-neutron", overrides); - LBaaSApi lbaasApi = neutronApi.getLBaaSApi("RegionOne").get(); - - boolean result = lbaasApi.deletePool("72741b06-df4d-4715-b142-276b6bce75ab"); - - /* - * Check request - */ - assertAuthentication(server); - server.takeRequest(); - assertRequest(server.takeRequest(), "DELETE", uriApiVersion + "/lb/pools/72741b06-df4d-4715-b142-276b6bce75ab"); - - /* - * Check response - */ - assertTrue(result); - } finally { - server.shutdown(); - } - } - - public void testCreateMember() throws IOException, InterruptedException { - MockWebServer server = mockOpenStackServer(); - server.enqueue(addCommonHeaders(new MockResponse().setBody(stringFromResource("/access.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/extension_list_with_lbaas_v1_response.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(201).setBody(stringFromResource("/lbaas/v1/member_create_response.json")))); - - try { - NeutronApi neutronApi = api(server.getUrl("/").toString(), "openstack-neutron", overrides); - LBaaSApi lbaasApi = neutronApi.getLBaaSApi("RegionOne").get(); - - Member.CreateMember createMember = Member.createBuilder("72741b06-df4d-4715-b142-276b6bce75ab", null, 80) - .weight(null).adminStateUp(null).build(); - - Member member = lbaasApi.createMember(createMember); - - /* - * Check request - */ - assertAuthentication(server); - server.takeRequest(); - assertRequest(server.takeRequest(), "POST", uriApiVersion + "/lb/members", "/lbaas/v1/member_create_request.json"); - - /* - * Check response - */ - assertNotNull(member); - assertNotNull(member.getId()); - assertEquals(member.getTenantId(), "83657cfcdfe44cd5920adaf26c48ceea"); - assertEquals(member.getPoolId(), "72741b06-df4d-4715-b142-276b6bce75ab"); - assertNotNull(member.getAddress()); - assertEquals(member.getProtocolPort(), Integer.valueOf(80)); - assertEquals(member.getWeight(), Integer.valueOf(1)); - assertEquals(member.getAdminStateUp(), Boolean.TRUE); - assertEquals(member.getStatus(), LBaaSStatus.PENDING_CREATE); - assertNull(member.getStatusDescription()); - } finally { - server.shutdown(); - } - } - - public void testListSpecificPageMember() throws IOException, InterruptedException { - MockWebServer server = mockOpenStackServer(); - server.enqueue(addCommonHeaders(new MockResponse().setBody(stringFromResource("/access.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/extension_list_with_lbaas_v1_response.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(201).setBody(stringFromResource("/lbaas/v1/member_list_response_paged1.json")))); - - try { - NeutronApi neutronApi = api(server.getUrl("/").toString(), "openstack-neutron", overrides); - LBaaSApi lbaasApi = neutronApi.getLBaaSApi("RegionOne").get(); - - Members members = lbaasApi.listMembers(PaginationOptions.Builder.limit(2).marker("abcdefg")); - - /* - * Check request - */ - assertAuthentication(server); - server.takeRequest(); - assertRequest(server.takeRequest(), "GET", uriApiVersion + "/lb/members?limit=2&marker=abcdefg"); - - /* - * Check response - */ - assertNotNull(members); - assertEquals(members.size(), 1); - assertEquals(members.first().get().getId(), "48a471ea-64f1-4eb6-9be7-dae6bbe40a0f"); - } finally { - server.shutdown(); - } - } - - public void testListPagedMember() throws IOException, InterruptedException { - MockWebServer server = mockOpenStackServer(); - server.enqueue(addCommonHeaders(new MockResponse().setBody(stringFromResource("/access.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/extension_list_with_lbaas_v1_response.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/lbaas/v1/member_list_response_paged1.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/lbaas/v1/member_list_response_paged2.json")))); - - try { - NeutronApi neutronApi = api(server.getUrl("/").toString(), "openstack-neutron", overrides); - LBaaSApi lbaasApi = neutronApi.getLBaaSApi("RegionOne").get(); - - // Note: Lazy! Have to actually look at the collection. - List<Member> members = lbaasApi.listMembers().concat().toList(); - - /* - * Check request - */ - assertEquals(server.getRequestCount(), 4); - assertAuthentication(server); - server.takeRequest(); - assertRequest(server.takeRequest(), "GET", uriApiVersion + "/lb/members"); - assertRequest(server.takeRequest(), "GET", uriApiVersion + "/lb/members?marker=396f12f8-521e-4b91-8e21-2e003500433a"); - - /* - * Check response - */ - assertNotNull(members); - assertEquals(members.size(), 2); - assertEquals(members.get(0).getId(), "48a471ea-64f1-4eb6-9be7-dae6bbe40a0f"); - assertEquals(members.get(1).getId(), "701b531b-111a-4f21-ad85-4795b7b12af6"); - } finally { - server.shutdown(); - } - } - - public void testGetMember() throws IOException, InterruptedException { - MockWebServer server = mockOpenStackServer(); - server.enqueue(addCommonHeaders(new MockResponse().setBody(stringFromResource("/access.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/extension_list_with_lbaas_v1_response.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(201).setBody(stringFromResource("/lbaas/v1/member_get_response.json")))); - - try { - NeutronApi neutronApi = api(server.getUrl("/").toString(), "openstack-neutron", overrides); - LBaaSApi lbaasApi = neutronApi.getLBaaSApi("RegionOne").get(); - - Member member = lbaasApi.getMember("48a471ea-64f1-4eb6-9be7-dae6bbe40a0f"); - - /* - * Check request - */ - assertAuthentication(server); - server.takeRequest(); - assertRequest(server.takeRequest(), "GET", uriApiVersion + "/lb/members/48a471ea-64f1-4eb6-9be7-dae6bbe40a0f"); - - /* - * Check response - */ - assertNotNull(member); - assertEquals(member.getId(), "48a471ea-64f1-4eb6-9be7-dae6bbe40a0f"); - assertEquals(member.getTenantId(), "83657cfcdfe44cd5920adaf26c48ceea"); - assertEquals(member.getPoolId(), "72741b06-df4d-4715-b142-276b6bce75ab"); - assertEquals(member.getAddress(), "10.0.0.5"); - assertEquals(member.getProtocolPort(), Integer.valueOf(80)); - assertEquals(member.getWeight(), Integer.valueOf(1)); - assertEquals(member.getAdminStateUp(), Boolean.TRUE); - assertEquals(member.getStatus(), LBaaSStatus.ACTIVE); - assertNull(member.getStatusDescription()); - } finally { - server.shutdown(); - } - } - - public void testUpdateMember() throws IOException, InterruptedException { - MockWebServer server = mockOpenStackServer(); - server.enqueue(addCommonHeaders(new MockResponse().setBody(stringFromResource("/access.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/extension_list_with_lbaas_v1_response.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(201).setBody(stringFromResource("/lbaas/v1/member_update_response.json")))); - - try { - NeutronApi neutronApi = api(server.getUrl("/").toString(), "openstack-neutron", overrides); - LBaaSApi lbaasApi = neutronApi.getLBaaSApi("RegionOne").get(); - - Member.UpdateMember updateMember = Member.updateBuilder().poolId("new_pool_id").weight(2) - .adminStateUp(Boolean.FALSE).build(); - - Member member = lbaasApi.updateMember("48a471ea-64f1-4eb6-9be7-dae6bbe40a0f", updateMember); - - /* - * Check request - */ - assertAuthentication(server); - server.takeRequest(); - assertRequest(server.takeRequest(), "PUT", uriApiVersion + "/lb/members/48a471ea-64f1-4eb6-9be7-dae6bbe40a0f", "/lbaas/v1/member_update_request.json"); - - /* - * Check response - */ - assertNotNull(member); - assertEquals(member.getId(), "48a471ea-64f1-4eb6-9be7-dae6bbe40a0f"); - assertEquals(member.getTenantId(), "83657cfcdfe44cd5920adaf26c48ceea"); - assertEquals(member.getPoolId(), "new_pool_id"); - assertEquals(member.getAddress(), "10.0.0.5"); - assertEquals(member.getProtocolPort(), Integer.valueOf(80)); - assertEquals(member.getWeight(), Integer.valueOf(2)); - assertEquals(member.getAdminStateUp(), Boolean.FALSE); - assertEquals(member.getStatus(), LBaaSStatus.ACTIVE); - assertNull(member.getStatusDescription()); - } finally { - server.shutdown(); - } - } - - public void testDeleteMember() throws IOException, InterruptedException { - MockWebServer server = mockOpenStackServer(); - server.enqueue(addCommonHeaders(new MockResponse().setBody(stringFromResource("/access.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/extension_list_with_lbaas_v1_response.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(204))); - - try { - NeutronApi neutronApi = api(server.getUrl("/").toString(), "openstack-neutron", overrides); - LBaaSApi lbaasApi = neutronApi.getLBaaSApi("RegionOne").get(); - - boolean result = lbaasApi.deleteMember("48a471ea-64f1-4eb6-9be7-dae6bbe40a0f"); - - /* - * Check request - */ - assertAuthentication(server); - server.takeRequest(); - assertRequest(server.takeRequest(), "DELETE", uriApiVersion + "/lb/members/48a471ea-64f1-4eb6-9be7-dae6bbe40a0f"); - - /* - * Check response - */ - assertTrue(result); - } finally { - server.shutdown(); - } - } - - public void testCreateVIP() throws IOException, InterruptedException { - MockWebServer server = mockOpenStackServer(); - server.enqueue(addCommonHeaders(new MockResponse().setBody(stringFromResource("/access.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/extension_list_with_lbaas_v1_response.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(201).setBody(stringFromResource("/lbaas/v1/vip_create_response.json")))); - - try { - NeutronApi neutronApi = api(server.getUrl("/").toString(), "openstack-neutron", overrides); - LBaaSApi lbaasApi = neutronApi.getLBaaSApi("RegionOne").get(); - - VIP.CreateVIP createVIP = VIP.createBuilder("8032909d-47a1-4715-90af-5153ffe39861", Protocol.HTTP, 80, "61b1f87a-7a21-4ad3-9dda-7f81d249944f") - .name("NewVip").description(null).address(null).sessionPersistence(null).connectionLimit(null).build(); - - VIP vip = lbaasApi.createVIP(createVIP); - - /* - * Check request - */ - assertAuthentication(server); - server.takeRequest(); - assertRequest(server.takeRequest(), "POST", uriApiVersion + "/lb/vips", "/lbaas/v1/vip_create_request.json"); - - /* - * Check response - */ - assertNotNull(vip); - assertNotNull(vip.getId()); - assertEquals(vip.getTenantId(), "83657cfcdfe44cd5920adaf26c48ceea"); - assertEquals(vip.getName(), "NewVip"); - assertEquals(vip.getDescription(), ""); - assertEquals(vip.getSubnetId(), "8032909d-47a1-4715-90af-5153ffe39861"); - assertEquals(vip.getAddress(), "10.0.0.11"); - assertEquals(vip.getPortId(), "f7e6fe6a-b8b5-43a8-8215-73456b32e0f5"); - assertEquals(vip.getProtocol(), Protocol.HTTP); - assertEquals(vip.getProtocolPort(), Integer.valueOf(80)); - assertEquals(vip.getPoolId(), "61b1f87a-7a21-4ad3-9dda-7f81d249944f"); - assertNull(vip.getSessionPersistence()); - assertEquals(vip.getConnectionLimit(), Integer.valueOf(-1)); - assertEquals(vip.getAdminStateUp(), Boolean.TRUE); - assertEquals(vip.getStatus(), LBaaSStatus.PENDING_CREATE); - assertNull(vip.getStatusDescription()); - } finally { - server.shutdown(); - } - } - - public void testListSpecificPageVIP() throws IOException, InterruptedException { - MockWebServer server = mockOpenStackServer(); - server.enqueue(addCommonHeaders(new MockResponse().setBody(stringFromResource("/access.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/extension_list_with_lbaas_v1_response.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(201).setBody(stringFromResource("/lbaas/v1/vip_list_response_paged1.json")))); - - try { - NeutronApi neutronApi = api(server.getUrl("/").toString(), "openstack-neutron", overrides); - LBaaSApi lbaasApi = neutronApi.getLBaaSApi("RegionOne").get(); - - VIPs vips = lbaasApi.listVIPs(PaginationOptions.Builder.limit(2).marker("abcdefg")); - - /* - * Check request - */ - assertAuthentication(server); - server.takeRequest(); - assertRequest(server.takeRequest(), "GET", uriApiVersion + "/lb/vips?limit=2&marker=abcdefg"); - - /* - * Check response - */ - assertNotNull(vips); - assertEquals(vips.size(), 1); - assertEquals(vips.first().get().getId(), "4ec89087-d057-4e2c-911f-60a3b47ee304"); - } finally { - server.shutdown(); - } - } - - public void testListPagedVIP() throws IOException, InterruptedException { - MockWebServer server = mockOpenStackServer(); - server.enqueue(addCommonHeaders(new MockResponse().setBody(stringFromResource("/access.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/extension_list_with_lbaas_v1_response.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/lbaas/v1/vip_list_response_paged1.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/lbaas/v1/vip_list_response_paged2.json")))); - - try { - NeutronApi neutronApi = api(server.getUrl("/").toString(), "openstack-neutron", overrides); - LBaaSApi lbaasApi = neutronApi.getLBaaSApi("RegionOne").get(); - - // Note: Lazy! Have to actually look at the collection. - List<VIP> vips = lbaasApi.listVIPs().concat().toList(); - - /* - * Check request - */ - assertEquals(server.getRequestCount(), 4); - assertAuthentication(server); - server.takeRequest(); - assertRequest(server.takeRequest(), "GET", uriApiVersion + "/lb/vips"); - assertRequest(server.takeRequest(), "GET", uriApiVersion + "/lb/vips?marker=396f12f8-521e-4b91-8e21-2e003500433a"); - - /* - * Check response - */ - assertNotNull(vips); - assertEquals(vips.size(), 2); - assertEquals(vips.get(0).getId(), "4ec89087-d057-4e2c-911f-60a3b47ee304"); - assertEquals(vips.get(1).getId(), "c987d2be-9a3c-4ac9-a046-e8716b1350e2"); - } finally { - server.shutdown(); - } - } - - public void testGetVIP() throws IOException, InterruptedException { - MockWebServer server = mockOpenStackServer(); - server.enqueue(addCommonHeaders(new MockResponse().setBody(stringFromResource("/access.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/extension_list_with_lbaas_v1_response.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(201).setBody(stringFromResource("/lbaas/v1/vip_get_response.json")))); - - try { - NeutronApi neutronApi = api(server.getUrl("/").toString(), "openstack-neutron", overrides); - LBaaSApi lbaasApi = neutronApi.getLBaaSApi("RegionOne").get(); - - VIP vip = lbaasApi.getVIP("4ec89087-d057-4e2c-911f-60a3b47ee304"); - - /* - * Check request - */ - assertAuthentication(server); - server.takeRequest(); - assertRequest(server.takeRequest(), "GET", uriApiVersion + "/lb/vips/4ec89087-d057-4e2c-911f-60a3b47ee304"); - - /* - * Check response - */ - assertNotNull(vip); - assertNotNull(vip.getId()); - assertEquals(vip.getTenantId(), "83657cfcdfe44cd5920adaf26c48ceea"); - assertEquals(vip.getName(), "my-vip"); - assertEquals(vip.getDescription(), ""); - assertEquals(vip.getSubnetId(), "8032909d-47a1-4715-90af-5153ffe39861"); - assertEquals(vip.getAddress(), "10.0.0.10"); - assertEquals(vip.getPortId(), "b5a743d6-056b-468b-862d-fb13a9aa694e"); - assertEquals(vip.getProtocol(), Protocol.HTTP); - assertEquals(vip.getProtocolPort(), Integer.valueOf(80)); - assertEquals(vip.getPoolId(), "72741b06-df4d-4715-b142-276b6bce75ab"); - SessionPersistence sessionPersistence = SessionPersistence.builder().type(SessionPersistence.Type.APP_COOKIE).cookieName("MyAppCookie").build(); - assertEquals(vip.getSessionPersistence(), sessionPersistence); - assertEquals(vip.getConnectionLimit(), Integer.valueOf(1000)); - assertEquals(vip.getAdminStateUp(), Boolean.TRUE); - assertEquals(vip.getStatus(), LBaaSStatus.ACTIVE); - assertNull(vip.getStatusDescription()); - } finally { - server.shutdown(); - } - } - - public void testUpdateVIP() throws IOException, InterruptedException { - MockWebServer server = mockOpenStackServer(); - server.enqueue(addCommonHeaders(new MockResponse().setBody(stringFromResource("/access.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/extension_list_with_lbaas_v1_response.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(201).setBody(stringFromResource("/lbaas/v1/vip_update_response.json")))); - - try { - NeutronApi neutronApi = api(server.getUrl("/").toString(), "openstack-neutron", overrides); - LBaaSApi lbaasApi = neutronApi.getLBaaSApi("RegionOne").get(); - - SessionPersistence sessionPersistence = SessionPersistence.builder().type(SessionPersistence.Type.APP_COOKIE).cookieName("MyNewAppCookie").build(); - VIP.UpdateVIP updateVIP = VIP.updateBuilder().name("new-name").description("new description").poolId("61b1f87a-7a21-4ad3-9dda-7f81d249944f") - .sessionPersistence(sessionPersistence).connectionLimit(50).adminStateUp(Boolean.FALSE).build(); - - VIP vip = lbaasApi.updateVIP("c987d2be-9a3c-4ac9-a046-e8716b1350e2", updateVIP); - - /* - * Check request - */ - assertAuthentication(server); - server.takeRequest(); - assertRequest(server.takeRequest(), "PUT", uriApiVersion + "/lb/vips/c987d2be-9a3c-4ac9-a046-e8716b1350e2", "/lbaas/v1/vip_update_request.json"); - - /* - * Check response - */ - assertNotNull(vip); - assertNotNull(vip.getId()); - assertEquals(vip.getTenantId(), "83657cfcdfe44cd5920adaf26c48ceea"); - assertEquals(vip.getName(), "new-name"); - assertEquals(vip.getDescription(), "new description"); - assertEquals(vip.getSubnetId(), "8032909d-47a1-4715-90af-5153ffe39861"); - assertEquals(vip.getAddress(), "10.0.0.11"); - assertEquals(vip.getPortId(), "f7e6fe6a-b8b5-43a8-8215-73456b32e0f5"); - assertEquals(vip.getProtocol(), Protocol.HTTP); - assertEquals(vip.getProtocolPort(), Integer.valueOf(80)); - assertEquals(vip.getPoolId(), "61b1f87a-7a21-4ad3-9dda-7f81d249944f"); - assertEquals(vip.getSessionPersistence(), sessionPersistence); - assertEquals(vip.getConnectionLimit(), Integer.valueOf(50)); - assertEquals(vip.getAdminStateUp(), Boolean.FALSE); - assertEquals(vip.getStatus(), LBaaSStatus.PENDING_UPDATE); - assertNull(vip.getStatusDescription()); - } finally { - server.shutdown(); - } - } - - public void testDeleteVIP() throws IOException, InterruptedException { - MockWebServer server = mockOpenStackServer(); - server.enqueue(addCommonHeaders(new MockResponse().setBody(stringFromResource("/access.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/extension_list_with_lbaas_v1_response.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(204))); - - try { - NeutronApi neutronApi = api(server.getUrl("/").toString(), "openstack-neutron", overrides); - LBaaSApi lbaasApi = neutronApi.getLBaaSApi("RegionOne").get(); - - boolean result = lbaasApi.deleteVIP("c987d2be-9a3c-4ac9-a046-e8716b1350e2"); - - /* - * Check request - */ - assertAuthentication(server); - server.takeRequest(); - assertRequest(server.takeRequest(), "DELETE", uriApiVersion + "/lb/vips/c987d2be-9a3c-4ac9-a046-e8716b1350e2"); - - /* - * Check response - */ - assertTrue(result); - } finally { - server.shutdown(); - } - } - - public void testCreateHealthMonitor() throws IOException, InterruptedException { - MockWebServer server = mockOpenStackServer(); - server.enqueue(addCommonHeaders(new MockResponse().setBody(stringFromResource("/access.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/extension_list_with_lbaas_v1_response.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(201).setBody(stringFromResource("/lbaas/v1/health_monitor_create_response.json")))); - - try { - NeutronApi neutronApi = api(server.getUrl("/").toString(), "openstack-neutron", overrides); - LBaaSApi lbaasApi = neutronApi.getLBaaSApi("RegionOne").get(); - - HealthMonitor.CreateHealthMonitor createHealthMonitor = HealthMonitor.createBuilder(ProbeType.HTTP, Integer.valueOf(1), Integer.valueOf(1), Integer.valueOf(1)) - .httpMethod(null).urlPath(null).expectedCodes(null).adminStateUp(null).build(); - - HealthMonitor healthMonitor = lbaasApi.createHealthMonitor(createHealthMonitor); - - /* - * Check request - */ - assertAuthentication(server); - server.takeRequest(); - assertRequest(server.takeRequest(), "POST", uriApiVersion + "/lb/health_monitors", "/lbaas/v1/health_monitor_create_request.json"); - - /* - * Check response - */ - assertNotNull(healthMonitor); - assertNotNull(healthMonitor.getId()); - assertEquals(healthMonitor.getTenantId(), "4fd44f30292945e481c7b8a0c8908869"); - assertEquals(healthMonitor.getType(), ProbeType.HTTP); - assertEquals(healthMonitor.getDelay(), Integer.valueOf(1)); - assertEquals(healthMonitor.getTimeout(), Integer.valueOf(1)); - assertEquals(healthMonitor.getMaxRetries(), Integer.valueOf(1)); - assertEquals(healthMonitor.getHttpMethod(), HttpMethod.GET); - assertEquals(healthMonitor.getUrlPath(), "/"); - assertEquals(healthMonitor.getExpectedCodes(), "200"); - assertNotNull(healthMonitor.getPools()); - assertTrue(healthMonitor.getPools().isEmpty()); - assertEquals(healthMonitor.getAdminStateUp(), Boolean.TRUE); - assertEquals(healthMonitor.getStatus(), LBaaSStatus.PENDING_CREATE); - assertNull(healthMonitor.getStatusDescription()); - } finally { - server.shutdown(); - } - } - - public void testListSpecificPageHealthMonitor() throws IOException, InterruptedException { - MockWebServer server = mockOpenStackServer(); - server.enqueue(addCommonHeaders(new MockResponse().setBody(stringFromResource("/access.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/extension_list_with_lbaas_v1_response.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(201).setBody(stringFromResource("/lbaas/v1/health_monitor_list_response_paged1.json")))); - - try { - NeutronApi neutronApi = api(server.getUrl("/").toString(), "openstack-neutron", overrides); - LBaaSApi lbaasApi = neutronApi.getLBaaSApi("RegionOne").get(); - - HealthMonitors healthMonitors = lbaasApi.listHealthMonitors(PaginationOptions.Builder.limit(2).marker("abcdefg")); - - /* - * Check request - */ - assertAuthentication(server); - server.takeRequest(); - assertRequest(server.takeRequest(), "GET", uriApiVersion + "/lb/health_monitors?limit=2&marker=abcdefg"); - - /* - * Check response - */ - assertNotNull(healthMonitors); - assertEquals(healthMonitors.size(), 1); - assertEquals(healthMonitors.first().get().getId(), "466c8345-28d8-4f84-a246-e04380b0461d"); - } finally { - server.shutdown(); - } - } - - public void testListPagedHealthMonitor() throws IOException, InterruptedException { - MockWebServer server = mockOpenStackServer(); - server.enqueue(addCommonHeaders(new MockResponse().setBody(stringFromResource("/access.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/extension_list_with_lbaas_v1_response.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/lbaas/v1/health_monitor_list_response_paged1.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/lbaas/v1/health_monitor_list_response_paged2.json")))); - - try { - NeutronApi neutronApi = api(server.getUrl("/").toString(), "openstack-neutron", overrides); - LBaaSApi lbaasApi = neutronApi.getLBaaSApi("RegionOne").get(); - - // Note: Lazy! Have to actually look at the collection. - List<HealthMonitor> healthMonitors = lbaasApi.listHealthMonitors().concat().toList(); - - /* - * Check request - */ - assertEquals(server.getRequestCount(), 4); - assertAuthentication(server); - server.takeRequest(); - assertRequest(server.takeRequest(), "GET", uriApiVersion + "/lb/health_monitors"); - assertRequest(server.takeRequest(), "GET", uriApiVersion + "/lb/health_monitors?marker=396f12f8-521e-4b91-8e21-2e003500433a"); - - /* - * Check response - */ - assertNotNull(healthMonitors); - assertEquals(healthMonitors.size(), 2); - assertEquals(healthMonitors.get(0).getId(), "466c8345-28d8-4f84-a246-e04380b0461d"); - assertEquals(healthMonitors.get(1).getId(), "5d4b5228-33b0-4e60-b225-9b727c1a20e7"); - } finally { - server.shutdown(); - } - } - - public void testGetHealthMonitor() throws IOException, InterruptedException { - MockWebServer server = mockOpenStackServer(); - server.enqueue(addCommonHeaders(new MockResponse().setBody(stringFromResource("/access.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/extension_list_with_lbaas_v1_response.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(201).setBody(stringFromResource("/lbaas/v1/health_monitor_get_response.json")))); - - try { - NeutronApi neutronApi = api(server.getUrl("/").toString(), "openstack-neutron", overrides); - LBaaSApi lbaasApi = neutronApi.getLBaaSApi("RegionOne").get(); - - HealthMonitor healthMonitor = lbaasApi.getHealthMonitor("5d4b5228-33b0-4e60-b225-9b727c1a20e7"); - - /* - * Check request - */ - assertAuthentication(server); - server.takeRequest(); - assertRequest(server.takeRequest(), "GET", uriApiVersion + "/lb/health_monitors/5d4b5228-33b0-4e60-b225-9b727c1a20e7"); - - /* - * Check response - */ - assertNotNull(healthMonitor); - assertEquals(healthMonitor.getId(), "5d4b5228-33b0-4e60-b225-9b727c1a20e7"); - assertEquals(healthMonitor.getTenantId(), "4fd44f30292945e481c7b8a0c8908869"); - assertEquals(healthMonitor.getType(), ProbeType.HTTP); - assertEquals(healthMonitor.getDelay(), Integer.valueOf(5)); - assertEquals(healthMonitor.getTimeout(), Integer.valueOf(2)); - assertEquals(healthMonitor.getMaxRetries(), Integer.valueOf(2)); - assertEquals(healthMonitor.getHttpMethod(), HttpMethod.GET); - assertEquals(healthMonitor.getUrlPath(), "/"); - assertEquals(healthMonitor.getExpectedCodes(), "200"); - assertNotNull(healthMonitor.getPools()); - assertTrue(healthMonitor.getPools().isEmpty()); - assertEquals(healthMonitor.getAdminStateUp(), Boolean.TRUE); - assertEquals(healthMonitor.getStatus(), LBaaSStatus.ACTIVE); - assertNull(healthMonitor.getStatusDescription()); - } finally { - server.shutdown(); - } - } - - public void testUpdateHealthMonitor() throws IOException, InterruptedException { - MockWebServer server = mockOpenStackServer(); - server.enqueue(addCommonHeaders(new MockResponse().setBody(stringFromResource("/access.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/extension_list_with_lbaas_v1_response.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(201).setBody(stringFromResource("/lbaas/v1/health_monitor_update_response.json")))); - - try { - NeutronApi neutronApi = api(server.getUrl("/").toString(), "openstack-neutron", overrides); - LBaaSApi lbaasApi = neutronApi.getLBaaSApi("RegionOne").get(); - - HealthMonitor.UpdateHealthMonitor updateHealthMonitor = HealthMonitor.updateBuilder().delay(Integer.valueOf(1)).timeout(Integer.valueOf(1)).maxRetries(Integer.valueOf(1)) - .httpMethod(HttpMethod.HEAD).urlPath("/index.html").expectedCodes("201").adminStateUp(Boolean.FALSE).build(); - - HealthMonitor healthMonitor = lbaasApi.updateHealthMonitor("466c8345-28d8-4f84-a246-e04380b0461d", updateHealthMonitor); - - /* - * Check request - */ - assertAuthentication(server); - server.takeRequest(); - assertRequest(server.takeRequest(), "PUT", uriApiVersion + "/lb/health_monitors/466c8345-28d8-4f84-a246-e04380b0461d", "/lbaas/v1/health_monitor_update_request.json"); - - /* - * Check response - */ - assertNotNull(healthMonitor); - assertEquals(healthMonitor.getId(), "466c8345-28d8-4f84-a246-e04380b0461d"); - assertEquals(healthMonitor.getTenantId(), "4fd44f30292945e481c7b8a0c8908869"); - assertEquals(healthMonitor.getType(), ProbeType.HTTP); - assertEquals(healthMonitor.getDelay(), Integer.valueOf(1)); - assertEquals(healthMonitor.getTimeout(), Integer.valueOf(1)); - assertEquals(healthMonitor.getMaxRetries(), Integer.valueOf(1)); - assertEquals(healthMonitor.getHttpMethod(), HttpMethod.HEAD); - assertEquals(healthMonitor.getUrlPath(), "/index.html"); - assertEquals(healthMonitor.getExpectedCodes(), "201"); - assertNotNull(healthMonitor.getPools()); - assertTrue(healthMonitor.getPools().isEmpty()); - assertEquals(healthMonitor.getAdminStateUp(), Boolean.FALSE); - assertEquals(healthMonitor.getStatus(), LBaaSStatus.ACTIVE); - assertNull(healthMonitor.getStatusDescription()); - } finally { - server.shutdown(); - } - } - - public void testDeleteHealthMonitor() throws IOException, InterruptedException { - MockWebServer server = mockOpenStackServer(); - server.enqueue(addCommonHeaders(new MockResponse().setBody(stringFromResource("/access.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/extension_list_with_lbaas_v1_response.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(204))); - - try { - NeutronApi neutronApi = api(server.getUrl("/").toString(), "openstack-neutron", overrides); - LBaaSApi lbaasApi = neutronApi.getLBaaSApi("RegionOne").get(); - - boolean result = lbaasApi.deleteHealthMonitor("466c8345-28d8-4f84-a246-e04380b0461d"); - - /* - * Check request - */ - assertAuthentication(server); - server.takeRequest(); - assertRequest(server.takeRequest(), "DELETE", uriApiVersion + "/lb/health_monitors/466c8345-28d8-4f84-a246-e04380b0461d"); - - /* - * Check response - */ - assertTrue(result); - } finally { - server.shutdown(); - } - } - - public void testAssociateHealthMonitorWithPool() throws IOException, InterruptedException { - MockWebServer server = mockOpenStackServer(); - server.enqueue(addCommonHeaders(new MockResponse().setBody(stringFromResource("/access.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/extension_list_with_lbaas_v1_response.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(201).setBody(stringFromResource("/lbaas/v1/pool_associate_health_monitor_response.json")))); - - try { - NeutronApi neutronApi = api(server.getUrl("/").toString(), "openstack-neutron", overrides); - LBaaSApi lbaasApi = neutronApi.getLBaaSApi("RegionOne").get(); - - HealthMonitor healthMonitor = lbaasApi.associateHealthMonitor("72741b06-df4d-4715-b142-276b6bce75ab", "5d4b5228-33b0-4e60-b225-9b727c1a20e7"); - - /* - * Check request - */ - assertAuthentication(server); - server.takeRequest(); - assertRequest(server.takeRequest(), "POST", uriApiVersion + "/lb/pools/72741b06-df4d-4715-b142-276b6bce75ab/health_monitors", "/lbaas/v1/pool_associate_health_monitor_request.json"); - - /* - * Check response - */ - assertNotNull(healthMonitor); - } finally { - server.shutdown(); - } - } - - public void testDisassociateHealthMonitorFromPool() throws IOException, InterruptedException { - MockWebServer server = mockOpenStackServer(); - server.enqueue(addCommonHeaders(new MockResponse().setBody(stringFromResource("/access.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(200).setBody(stringFromResource("/extension_list_with_lbaas_v1_response.json")))); - server.enqueue(addCommonHeaders(new MockResponse().setResponseCode(204))); - - try { - NeutronApi neutronApi = api(server.getUrl("/").toString(), "openstack-neutron", overrides); - LBaaSApi lbaasApi = neutronApi.getLBaaSApi("RegionOne").get(); - - boolean result = lbaasApi.disassociateHealthMonitor("72741b06-df4d-4715-b142-276b6bce75ab", "5d4b5228-33b0-4e60-b225-9b727c1a20e7"); - - /* - * Check request - */ - assertAuthentication(server); - server.takeRequest(); - assertRequest(server.takeRequest(), "DELETE", uriApiVersion + "/lb/pools/72741b06-df4d-4715-b142-276b6bce75ab/health_monitors/5d4b5228-33b0-4e60-b225-9b727c1a20e7"); - - /* - * Check response - */ - assertTrue(result); - } finally { - server.shutdown(); - } - } - -}
