import org.cloudfoundry.client.lib.domain.CloudRoute; //导入依赖的package包/类
/**
 * Delete routes that do not have any application which is assigned to them.
 *
 * @return deleted routes or an empty list if no routes have been found
 */
@Override
public List<CloudRoute> deleteOrphanedRoutes() {
    List<CloudRoute> orphanRoutes = new ArrayList<>();
    for (CloudDomain cloudDomain : getDomainsForOrg()) {
        orphanRoutes.addAll(fetchOrphanRoutes(cloudDomain.getName()));
    }

    List<CloudRoute> deletedCloudRoutes = new ArrayList<>();
    for (CloudRoute orphanRoute : orphanRoutes) {
        deleteRoute(orphanRoute.getHost(), orphanRoute.getDomain().getName());
        deletedCloudRoutes.add(orphanRoute);
    }

    return deletedCloudRoutes;
}
 

import org.cloudfoundry.client.lib.domain.CloudRoute; //导入依赖的package包/类
private List<CloudRoute> doGetRoutes(UUID domainGuid) {
    Map<String, Object> urlVars = new HashMap<String, Object>();
    String urlPath = "/v2";
    // TODO: NOT implemented ATM:
    // if (sessionSpace != null) {
    // urlVars.put("space", sessionSpace.getMeta().getGuid());
    // urlPath = urlPath + "/spaces/{space}";
    // }
    urlPath = urlPath + "/routes?inline-relations-depth=1";
    List<Map<String, Object>> allRoutes = getAllResources(urlPath, urlVars);
    List<CloudRoute> routes = new ArrayList<CloudRoute>();
    for (Map<String, Object> route : allRoutes) {
        // TODO: move space_guid to path once implemented (see above):
        UUID space = CloudEntityResourceMapper.getEntityAttribute(route, "space_guid", UUID.class);
        UUID domain = CloudEntityResourceMapper.getEntityAttribute(route, "domain_guid", UUID.class);
        if (sessionSpace.getMeta().getGuid().equals(space) && domainGuid.equals(domain)) {
            // routes.add(CloudEntityResourceMapper.getEntityAttribute(route, "host", String.class));
            routes.add(resourceMapper.mapResource(route, CloudRoute.class));
        }
    }
    return routes;
}
 

import org.cloudfoundry.client.lib.domain.CloudRoute; //导入依赖的package包/类
@Test
public void addAndDeleteRoute() {
    connectedClient.addDomain(TEST_DOMAIN);
    connectedClient.addRoute("my_route1", TEST_DOMAIN);
    connectedClient.addRoute("my_route2", TEST_DOMAIN);

    List<CloudRoute> routes = connectedClient.getRoutes(TEST_DOMAIN);
    assertNotNull(getRouteWithHost("my_route1", routes));
    assertNotNull(getRouteWithHost("my_route2", routes));

    connectedClient.deleteRoute("my_route2", TEST_DOMAIN);
    routes = connectedClient.getRoutes(TEST_DOMAIN);
    assertNotNull(getRouteWithHost("my_route1", routes));
    assertNull(getRouteWithHost("my_route2", routes));

    // test that removing domain that has routes throws exception
    try {
        connectedClient.deleteDomain(TEST_DOMAIN);
        fail("should have thrown exception");
    } catch (IllegalStateException ex) {
        assertTrue(ex.getMessage().contains("in use"));
    }
}
 

import org.cloudfoundry.client.lib.domain.CloudRoute; //导入依赖的package包/类
@Test
public void appsWithRoutesAreCounted() throws IOException {
    String appName = namespacedAppName("my_route3");
    CloudApplication app = createAndUploadSimpleTestApp(appName);
    List<String> uris = app.getUris();
    uris.add("my_route3." + TEST_DOMAIN);
    connectedClient.addDomain(TEST_DOMAIN);
    connectedClient.updateApplicationUris(appName, uris);

    List<CloudRoute> routes = connectedClient.getRoutes(TEST_DOMAIN);
    assertNotNull(getRouteWithHost("my_route3", routes));
    assertEquals(1, getRouteWithHost("my_route3", routes).getAppsUsingRoute());
    assertTrue(getRouteWithHost("my_route3", routes).inUse());

    List<CloudRoute> defaultDomainRoutes = connectedClient.getRoutes(defaultDomainName);
    assertNotNull(getRouteWithHost(appName, defaultDomainRoutes));
    assertEquals(1, getRouteWithHost(appName, defaultDomainRoutes).getAppsUsingRoute());
    assertTrue(getRouteWithHost(appName, defaultDomainRoutes).inUse());
}
 

import org.cloudfoundry.client.lib.domain.CloudRoute; //导入依赖的package包/类
@Test
public void deleteOrphanedRoutes() {
    connectedClient.addDomain(TEST_DOMAIN);
    connectedClient.addRoute("unbound_route", TEST_DOMAIN);

    List<CloudRoute> routes = connectedClient.getRoutes(TEST_DOMAIN);
    CloudRoute unboundRoute = getRouteWithHost("unbound_route", routes);
    assertNotNull(unboundRoute);
    assertEquals(0, unboundRoute.getAppsUsingRoute());

    List<CloudRoute> deletedRoutes = connectedClient.deleteOrphanedRoutes();
    assertNull(getRouteWithHost("unbound_route", connectedClient.getRoutes(TEST_DOMAIN)));

    assertTrue(deletedRoutes.size() > 0);
    boolean found = false;
    for (CloudRoute route : deletedRoutes) {
        if (route.getHost().equals("unbound_route")) {
            found = true;
        }
    }
    assertTrue(found);
}
 

import org.cloudfoundry.client.lib.domain.CloudRoute; //导入依赖的package包/类
public String getColumnText(Object element, int columnIndex) {
	String result = null;

	TableColumn column = viewer.getTable().getColumn(columnIndex);
	if (column != null) {
		switch (columnIndex) {
		case 0:
			result = getText(element);
			break;
		case 1:
			if (element instanceof CloudRoute) {
				result = ((CloudRoute) element).getDomain().getName();
			}
			break;
		case 2:
			if (element instanceof CloudRoute && ((CloudRoute) element).inUse()) {
				return IN_USE;
			}
			break;
		}

	}
	return result;
}
 

import org.cloudfoundry.client.lib.domain.CloudRoute; //导入依赖的package包/类
/**
 * 
 * @param updatedToRemove elements to remove. Passing a null or empty list
 * will clear the list of items to remove.
 */
protected void remove(List<?> updatedToRemove) {

	// If no change, then do nothing to avoid firing change events
	if (routesToRemove.equals(updatedToRemove)) {
		return;
	}

	routesToRemove.clear();

	if (updatedToRemove != null) {
		for (Object obj : updatedToRemove) {
			if (obj instanceof CloudRoute) {
				CloudRoute route = (CloudRoute) obj;
				if (!routesToRemove.contains(route)) {
					routesToRemove.add(route);
				}
			}
		}
	}

	notifyChange(new PartChangeEvent(routesToRemove, Status.OK_STATUS, ROUTES_REMOVED));

	refreshAll();

}
 

import org.cloudfoundry.client.lib.domain.CloudRoute; //导入依赖的package包/类
@Override
public void handleChange(PartChangeEvent event) {

	if (event.getSource() == CloudRoutePart.ROUTES_REMOVED) {
		Object data = event.getData();
		if (data instanceof List<?>) {
			List<?> routes = (List<?>) data;
			IStatus errorInUse = null;
			for (Object obj : routes) {
				if (obj instanceof CloudRoute) {
					CloudRoute rt = (CloudRoute) obj;
					if (rt.inUse()) {
						errorInUse = CloudFoundryPlugin.getStatus(
								NLS.bind(Messages.ERROR_ROUTE_IN_USE, rt.getName()), IStatus.ERROR);
					}
				}
			}
			if (errorInUse != null) {
				event = new PartChangeEvent(event.getData(), errorInUse, event.getSource());
			}

		}

	}
	super.handleChange(event);
}
 

import org.cloudfoundry.client.lib.domain.CloudRoute; //导入依赖的package包/类
public BaseClientRequest<?> deleteRoute(final List<CloudRoute> routes) throws CoreException {

		if (routes == null || routes.isEmpty()) {
			return null;
		}
		return new BehaviourRequest<Void>("Deleting routes", behaviour) { //$NON-NLS-1$
			@Override
			protected Void doRun(CloudFoundryOperations client, SubMonitor progress) throws CoreException {
				for (CloudRoute route : routes) {
					client.deleteRoute(route.getHost(), route.getDomain().getName());
				}
				return null;

			}
		};
	}
 

import org.cloudfoundry.client.lib.domain.CloudRoute; //导入依赖的package包/类
/**
	 * Retrieves the orgs and spaces for the current server instance.
	 * @param monitor
	 * @return
	 * @throws CoreException if it failed to retrieve the orgs and spaces.
	 */
//	public CloudOrgsAndSpaces getCloudSpaces(IProgressMonitor monitor) throws CoreException {
//		return new BehaviourRequest<CloudOrgsAndSpaces>("Getting orgs and spaces") { //$NON-NLS-1$
//
//			@Override
//			protected CloudOrgsAndSpaces doRun(DockerClient client, SubMonitor progress) throws CoreException {
//				// return internalGetCloudSpaces(client);
//				return null;
//			}
//
//		}.run(monitor);
//	}

	public List<CloudRoute> getRoutes(final String domainName, IProgressMonitor monitor) throws CoreException {

		List<CloudRoute> routes = new BehaviourRequest<List<CloudRoute>>(NLS.bind(Messages.ROUTES, domainName)) {
			@Override
			protected List<CloudRoute> doRun(DockerClient client, SubMonitor progress) throws CoreException {
				// return client.getRoutes(domainName);
				return null;
			}
		}.run(monitor);

		return routes;
	}
 

import org.cloudfoundry.client.lib.domain.CloudRoute; //导入依赖的package包/类
public void deleteRoute(final List<CloudRoute> routes, IProgressMonitor monitor) throws CoreException {

		if (routes == null || routes.isEmpty()) {
			return;
		}
		new BehaviourRequest<Void>("Deleting routes") { //$NON-NLS-1$
			@Override
			protected Void doRun(DockerClient client, SubMonitor progress) throws CoreException {
				for (CloudRoute route : routes) {
					// client.deleteRoute(route.getHost(),
					// route.getDomain().getName());
				}
				return null;

			}
		}.run(monitor);
	}
 

import org.cloudfoundry.client.lib.domain.CloudRoute; //导入依赖的package包/类
public List<CloudRoute> getRoutes(String domainName) {
	UUID domainGuid = getDomainGuid(domainName, true);
	String urlPath = API_BASE+"/routes?inline-relations-depth=1";
	List<CloudRoute> routes = new ArrayList<CloudRoute>();
	// tbd


	//		for (Map<String, Object> route : allRoutes) {
	////			TODO: move space_guid to path once implemented (see above):
	//			UUID space = CloudEntityResourceMapper.getEntityAttribute(route, "space_guid", UUID.class);
	//			UUID domain = CloudEntityResourceMapper.getEntityAttribute(route, "domain_guid", UUID.class);
	//			if (sessionSpace.getMeta().getGuid().equals(space) && domainGuid.equals(domain)) {
	//				//routes.add(CloudEntityResourceMapper.getEntityAttribute(route, "host", String.class));
	//				routes.add(resourceMapper.mapResource(route, CloudRoute.class));
	//			}
	//		}
	log.severe(NYI+" "+urlPath+" "+domainGuid);
	return routes;
}
 

import org.cloudfoundry.client.lib.domain.CloudRoute; //导入依赖的package包/类
@Test
public void addAndDeleteRoute() throws CloudFoundryException {
	connectedClient.addDomain(TEST_DOMAIN);
	connectedClient.addRoute("my_route1", TEST_DOMAIN);
	connectedClient.addRoute("my_route2", TEST_DOMAIN);

	List<CloudRoute> routes = connectedClient.getRoutes(TEST_DOMAIN);
	assertNotNull(getRouteWithHost("my_route1", routes));
	assertNotNull(getRouteWithHost("my_route2", routes));

	connectedClient.deleteRoute("my_route2", TEST_DOMAIN);
	routes = connectedClient.getRoutes(TEST_DOMAIN);
	assertNotNull(getRouteWithHost("my_route1", routes));
	assertNull(getRouteWithHost("my_route2", routes));

	// test that removing domain that has routes throws exception
	try {
		connectedClient.deleteDomain(TEST_DOMAIN);
		fail("should have thrown exception");
	}
	catch (IllegalStateException ex) {
		assertTrue(ex.getMessage().contains("in use"));
	}
}
 

import org.cloudfoundry.client.lib.domain.CloudRoute; //导入依赖的package包/类
@Test
public void appsWithRoutesAreCounted() throws IOException, CloudFoundryException {
	String appName = namespacedAppName("my_route3");
	CloudApplication app = createAndUploadSimpleTestApp(appName);
	List<String> uris = app.getUris();
	uris.add("my_route3." + TEST_DOMAIN);
	connectedClient.addDomain(TEST_DOMAIN);
	connectedClient.updateApplicationUris(appName, uris);

	List<CloudRoute> routes = connectedClient.getRoutes(TEST_DOMAIN);
	assertNotNull(getRouteWithHost("my_route3", routes));
	assertEquals(1, getRouteWithHost("my_route3", routes).getAppsUsingRoute());
	assertTrue(getRouteWithHost("my_route3", routes).inUse());

	List<CloudRoute> defaultDomainRoutes = connectedClient.getRoutes(defaultDomainName);
	assertNotNull(getRouteWithHost(appName, defaultDomainRoutes));
	assertEquals(1, getRouteWithHost(appName, defaultDomainRoutes).getAppsUsingRoute());
	assertTrue(getRouteWithHost(appName, defaultDomainRoutes).inUse());
}
 

import org.cloudfoundry.client.lib.domain.CloudRoute; //导入依赖的package包/类
@Override
public void deleteDomain(String domainName) {
    assertSpaceProvided("delete domain");
    UUID domainGuid = getDomainGuid(domainName, true);
    List<CloudRoute> routes = getRoutes(domainName);
    if (routes.size() > 0) {
        throw new IllegalStateException("Unable to remove domain that is in use --" + " it has " + routes.size() + " routes.");
    }
    doDeleteDomain(domainGuid);
}
 

import org.cloudfoundry.client.lib.domain.CloudRoute; //导入依赖的package包/类
private List<CloudRoute> fetchOrphanRoutes(String domainName) {
    List<CloudRoute> orphanRoutes = new ArrayList<>();
    for (CloudRoute cloudRoute : getRoutes(domainName)) {
        if (isOrphanRoute(cloudRoute)) {
            orphanRoutes.add(cloudRoute);
        }
    }

    return orphanRoutes;
}
 

import org.cloudfoundry.client.lib.domain.CloudRoute; //导入依赖的package包/类
private CloudRoute mapRouteResource(Map<String, Object> resource) {
    @SuppressWarnings("unchecked")
    List<Object> apps = getEntityAttribute(resource, "apps", List.class);
    String host = getEntityAttribute(resource, "host", String.class);
    CloudDomain domain = mapDomainResource(getEmbeddedResource(resource, "domain"));
    return new CloudRoute(getMeta(resource), host, domain, apps.size());
}
 

import org.cloudfoundry.client.lib.domain.CloudRoute; //导入依赖的package包/类
private void clearTestDomainAndRoutes() {
    CloudDomain domain = getDomainNamed(TEST_DOMAIN, connectedClient.getDomains());
    if (domain != null) {
        List<CloudRoute> routes = connectedClient.getRoutes(domain.getName());
        for (CloudRoute route : routes) {
            connectedClient.deleteRoute(route.getHost(), route.getDomain().getName());
        }
        connectedClient.deleteDomain(domain.getName());
    }
}
 

import org.cloudfoundry.client.lib.domain.CloudRoute; //导入依赖的package包/类
private CloudRoute getRouteWithHost(String hostName, List<CloudRoute> routes) {
    for (CloudRoute route : routes) {
        if (route.getHost().equals(hostName)) {
            return route;
        }
    }
    return null;
}
 

import org.cloudfoundry.client.lib.domain.CloudRoute; //导入依赖的package包/类
private void deleteApplicationRoutes(CloudApplication app, CloudFoundryOperations client) {
    getStepLogger().info(Messages.DELETING_APP_ROUTES, app.getName());
    List<CloudRoute> appRoutes = applicationRoutesGetter.getRoutes(client, app.getName());
    client.updateApplicationUris(app.getName(), Collections.emptyList());
    app.getUris().stream().forEach(uri -> deleteApplicationRoute(app, appRoutes, uri, client));
    getStepLogger().debug(Messages.DELETED_APP_ROUTES, app.getName());
}