import org.springframework.cloud.servicebroker.exception.ServiceInstanceDoesNotExistException; //导入依赖的package包/类
@Override
public void removeBinding(ServiceInstanceBinding binding)
        throws EcsManagementClientException, IOException {
    ServiceInstance instance = instanceRepository.find(instanceId);
    if (instance == null)
        throw new ServiceInstanceDoesNotExistException(instanceId);
    String bucketName = instance.getName();
    List<VolumeMount> volumes = binding.getVolumeMounts();
    if (volumes != null && volumes.size() > 0) {
        Map<String, Object> mountConfig = (
                    (SharedVolumeDevice) volumes.get(0).getDevice()
                ).getMountConfig();
        String unixId = (String) mountConfig.get("uid");
        LOG.error("Deleting user map of instance Id and Binding Id " +
                bucketName + " " + bindingId);
        try {
            ecs.deleteUserMap(bindingId, unixId);
        } catch (EcsManagementClientException e) {
            LOG.error("Error deleting user map: " + e.getMessage());
        }
    }

    ecs.removeUserFromBucket(bucketName, bindingId);
    ecs.deleteUser(bindingId);
}
 

import org.springframework.cloud.servicebroker.exception.ServiceInstanceDoesNotExistException; //导入依赖的package包/类
@Override
public Map<String, Object> getCredentials(String secretKey, Map<String, Object> parameters)
        throws IOException, EcsManagementClientException {
    ServiceInstance instance = instanceRepository.find(instanceId);
    if (instance == null)
        throw new ServiceInstanceDoesNotExistException(instanceId);
    String namespaceName = instance.getName();

    Map<String, Object> credentials = super.getCredentials(secretKey);

    // Get custom endpoint for namespace
    String endpoint = ecs.getNamespaceURL(ecs.prefix(namespaceName), service, plan,
            createRequest.getParameters());
    credentials.put("endpoint", endpoint);

    // Add s3 URL
    credentials.put("s3Url", getS3Url(endpoint, secretKey));

    return credentials;
}
 

import org.springframework.cloud.servicebroker.exception.ServiceInstanceDoesNotExistException; //导入依赖的package包/类
@Override
public DeleteServiceInstanceResponse deleteServiceInstance(final DeleteServiceInstanceRequest request) throws CloudKarafkaServiceException {
    final String instanceId = request.getServiceInstanceId();
    final ServiceInstance instance = repository.findOne(instanceId);

    if (instance == null) {
        throw new ServiceInstanceDoesNotExistException(instanceId);
    }

    cloudKarafkaAdminService.deleteBrokerInstance(instance.getCloudKarafkaId());
    repository.delete(instanceId);

    return new DeleteServiceInstanceResponse();
}
 

import org.springframework.cloud.servicebroker.exception.ServiceInstanceDoesNotExistException; //导入依赖的package包/类
@Override
public UpdateServiceInstanceResponse updateServiceInstance(final UpdateServiceInstanceRequest request) {
    final String instanceId = request.getServiceInstanceId();
    final ServiceInstance instance = repository.findOne(instanceId);

    if (instance == null) {
        throw new ServiceInstanceDoesNotExistException(instanceId);
    }

    if (request.equals(instance)) {
        throw new ServiceInstanceUpdateNotSupportedException("No changes in the change request");
    }

    // extract required values
    final String reqplan = request.getPlanId().split("_")[0];
    final String brkId = instance.getCloudKarafkaId();

    // change instance to a new plan
    cloudKarafkaAdminService.changeInstance(brkId, instance.getServiceInstanceId(), reqplan);
    instance.setPlanId(request.getPlanId());

    //replace old instance
    repository.delete(instanceId);
    repository.save(instance);

    return new UpdateServiceInstanceResponse();
}
 

import org.springframework.cloud.servicebroker.exception.ServiceInstanceDoesNotExistException; //导入依赖的package包/类
@Override
public DeleteServiceInstanceResponse deleteServiceInstance(DeleteServiceInstanceRequest request) throws MongoServiceException {
	String instanceId = request.getServiceInstanceId();
	ServiceInstance instance = repository.findOne(instanceId);
	if (instance == null) {
		throw new ServiceInstanceDoesNotExistException(instanceId);
	}

	mongo.deleteDatabase(instanceId);
	repository.delete(instanceId);
	return new DeleteServiceInstanceResponse();
}
 

import org.springframework.cloud.servicebroker.exception.ServiceInstanceDoesNotExistException; //导入依赖的package包/类
@Override
public UpdateServiceInstanceResponse updateServiceInstance(UpdateServiceInstanceRequest request) {
	String instanceId = request.getServiceInstanceId();
	ServiceInstance instance = repository.findOne(instanceId);
	if (instance == null) {
		throw new ServiceInstanceDoesNotExistException(instanceId);
	}

	repository.delete(instanceId);
	ServiceInstance updatedInstance = new ServiceInstance(request);
	repository.save(updatedInstance);
	return new UpdateServiceInstanceResponse();
}
 

import org.springframework.cloud.servicebroker.exception.ServiceInstanceDoesNotExistException; //导入依赖的package包/类
@Test(expected = ServiceInstanceDoesNotExistException.class)
public void unknownServiceInstanceDeleteCallSuccessful() throws Exception {
	when(repository.findOne(any(String.class))).thenReturn(null);

	DeleteServiceInstanceRequest request = buildDeleteRequest();

	DeleteServiceInstanceResponse response = service.deleteServiceInstance(request);

	assertNotNull(response);
	assertFalse(response.isAsync());

	verify(mongo).deleteDatabase(request.getServiceInstanceId());
	verify(repository).delete(request.getServiceInstanceId());
}
 

import org.springframework.cloud.servicebroker.exception.ServiceInstanceDoesNotExistException; //导入依赖的package包/类
@Override
public GetLastServiceOperationResponse getLastOperation(GetLastServiceOperationRequest request) {
    VrServiceInstance si = getServiceInstance(request.getServiceInstanceId());
    if (si == null) {
        throw new ServiceInstanceDoesNotExistException(request.getServiceInstanceId());
    }

    return si.getServiceInstanceLastOperation().toResponse();
}
 

import org.springframework.cloud.servicebroker.exception.ServiceInstanceDoesNotExistException; //导入依赖的package包/类
@Override
public UpdateServiceInstanceResponse updateServiceInstance(UpdateServiceInstanceRequest request) {
    String serviceInstanceId = request.getServiceInstanceId();
    String serviceDefinitionId = request.getServiceDefinitionId();
    String planId = request.getPlanId();
    try {
        ServiceDefinitionProxy service = ecs
                .lookupServiceDefinition(serviceDefinitionId);
        ServiceInstance instance = repository.find(serviceInstanceId);
        if (instance == null)
            throw new ServiceInstanceDoesNotExistException(
                    serviceInstanceId);
        if (instance.getReferences().size() > 1)
            throw new ServiceInstanceUpdateNotSupportedException(
                    "Cannot change plan of service instance with remote references");

        InstanceWorkflow workflow = getWorkflow(service);
        LOG.info("changing instance plan");
        workflow.changePlan(serviceInstanceId, service, service.findPlan(planId), request.getParameters());

        LOG.info("updating service in repo");
        repository.delete(serviceInstanceId);
        instance.update(request);
        repository.save(instance);
        return new UpdateServiceInstanceResponse();
    } catch (Exception e) {
        throw new ServiceBrokerException(e);
    }
}
 

import org.springframework.cloud.servicebroker.exception.ServiceInstanceDoesNotExistException; //导入依赖的package包/类
@Override
public void checkIfUserExists() throws EcsManagementClientException, IOException {
    ServiceInstance instance = instanceRepository.find(instanceId);
    if (instance == null)
        throw new ServiceInstanceDoesNotExistException(instanceId);
    if (instance.remoteConnectionKeyExists(bindingId))
        throw new ServiceInstanceBindingExistsException(instanceId, bindingId);
}
 

import org.springframework.cloud.servicebroker.exception.ServiceInstanceDoesNotExistException; //导入依赖的package包/类
@Override
public String createBindingUser() throws ServiceBrokerException, IOException, JAXBException {
    ServiceInstance instance = instanceRepository.find(instanceId);
    if (instance == null)
        throw new ServiceInstanceDoesNotExistException(instanceId);

    String secretKey = instance.addRemoteConnectionKey(bindingId);
    instanceRepository.save(instance);
    return secretKey;
}
 

import org.springframework.cloud.servicebroker.exception.ServiceInstanceDoesNotExistException; //导入依赖的package包/类
@Override
public void removeBinding(ServiceInstanceBinding binding)
        throws EcsManagementClientException, IOException, JAXBException {
    ServiceInstance instance = instanceRepository.find(instanceId);
    if (instance == null)
        throw new ServiceInstanceDoesNotExistException(instanceId);
    instance.removeRemoteConnectionKey(bindingId);
    instanceRepository.save(instance);
}
 

import org.springframework.cloud.servicebroker.exception.ServiceInstanceDoesNotExistException; //导入依赖的package包/类
@Override
public String createBindingUser() throws EcsManagementClientException, IOException, JAXBException {
    UserSecretKey userSecretKey = ecs.createUser(bindingId);
    Map<String, Object> parameters = createRequest.getParameters();
    ServiceInstance instance = instanceRepository.find(instanceId);
    if (instance == null)
        throw new ServiceInstanceDoesNotExistException(instanceId);

    String bucketName = instance.getName();
    String export = "";
    List<String> permissions = null;
    if (parameters != null) {
        permissions = (List<String>) parameters.get("permissions");
        export = (String) parameters.getOrDefault("export", "");
    }
    
    if (permissions == null) {
        ecs.addUserToBucket(bucketName, bindingId);
    } else {
        ecs.addUserToBucket(bucketName, bindingId, permissions);
    }

    if (ecs.getBucketFileEnabled(bucketName)) {
        volumeMounts = createVolumeExport(export,
                new URL(ecs.getObjectEndpoint()), parameters);
    }

    return userSecretKey.getSecretKey();
}
 

import org.springframework.cloud.servicebroker.exception.ServiceInstanceDoesNotExistException; //导入依赖的package包/类
@Override
public Map<String, Object> getCredentials(String secretKey, Map<String, Object> parameters)
        throws IOException, EcsManagementClientException {
    ServiceInstance instance = instanceRepository.find(instanceId);
    if (instance == null)
        throw new ServiceInstanceDoesNotExistException(instanceId);
    String bucketName = instance.getName();

    Map<String, Object> credentials = super.getCredentials(secretKey);

    // Add default broker endpoint
    String endpoint = ecs.getObjectEndpoint();
    credentials.put("endpoint", endpoint);

    // Add s3 URL
    URL baseUrl = new URL(endpoint);
    credentials.put("s3Url", getS3Url(baseUrl, secretKey, parameters));

    if (parameters != null && parameters.containsKey("path-style-access") &&
            ! (Boolean) parameters.get("path-style-access"))
    {
        credentials.put("path-style-access", false);
    } else {
        credentials.put("path-style-access", true);
    }

    // Add bucket name from repository
    credentials.put("bucket", ecs.prefix(bucketName));

    return credentials;
}
 

import org.springframework.cloud.servicebroker.exception.ServiceInstanceDoesNotExistException; //导入依赖的package包/类
@Override
public String createBindingUser() throws EcsManagementClientException, IOException, JAXBException {
    ServiceInstance instance = instanceRepository.find(instanceId);
    if (instance == null)
        throw new ServiceInstanceDoesNotExistException(instanceId);
    String namespaceName = instance.getName();
    return ecs.createUser(bindingId, namespaceName).getSecretKey();
}
 

import org.springframework.cloud.servicebroker.exception.ServiceInstanceDoesNotExistException; //导入依赖的package包/类
@Test
public void deleteServiceInstanceWithUnknownIdFails() throws Exception {
	when(serviceInstanceService.deleteServiceInstance(eq(syncDeleteRequest)))
			.thenThrow(new ServiceInstanceDoesNotExistException(syncDeleteRequest.getServiceInstanceId()));

	setupCatalogService(syncDeleteRequest.getServiceDefinitionId());

	mockMvc.perform(delete(buildUrl(syncDeleteRequest, false))
			.accept(MediaType.APPLICATION_JSON))
			.andExpect(status().isGone())
			.andExpect(jsonPath("$", is("{}")));
}
 

import org.springframework.cloud.servicebroker.exception.ServiceInstanceDoesNotExistException; //导入依赖的package包/类
@Test
public void updateServiceInstanceWithUnknownIdFails() throws Exception {
	when(serviceInstanceService.updateServiceInstance(eq(syncUpdateRequest)))
			.thenThrow(new ServiceInstanceDoesNotExistException(syncUpdateRequest.getServiceInstanceId()));

	setupCatalogService(syncUpdateRequest.getServiceDefinitionId());

	mockMvc.perform(patch(buildUrl(syncUpdateRequest, false))
			.content(DataFixture.toJson(syncUpdateRequest))
			.contentType(MediaType.APPLICATION_JSON)
			.accept(MediaType.APPLICATION_JSON))
			.andExpect(status().isUnprocessableEntity())
			.andExpect(content().contentTypeCompatibleWith(MediaType.APPLICATION_JSON))
			.andExpect(jsonPath("$.description", containsString(syncUpdateRequest.getServiceInstanceId())));
}
 

import org.springframework.cloud.servicebroker.exception.ServiceInstanceDoesNotExistException; //导入依赖的package包/类
@Test
public void lastOperationWithUnknownIdFails() throws Exception {
	when(serviceInstanceService.getLastOperation(eq(lastOperationRequest)))
			.thenThrow(new ServiceInstanceDoesNotExistException(lastOperationRequest.getServiceInstanceId()));

	mockMvc.perform(get(buildUrl(lastOperationRequest, false)))
			.andExpect(status().isUnprocessableEntity())
			.andExpect(jsonPath("$.description", containsString(lastOperationRequest.getServiceInstanceId())));
}
 

import org.springframework.cloud.servicebroker.exception.ServiceInstanceDoesNotExistException; //导入依赖的package包/类
@Test
public void createBindingWithUnknownServiceInstanceIdFails() throws Exception {
	when(serviceInstanceBindingService.createServiceInstanceBinding(eq(createRequest)))
			.thenThrow(new ServiceInstanceDoesNotExistException(createRequest.getServiceInstanceId()));

	setupCatalogService(createRequest.getServiceDefinitionId());

	mockMvc.perform(put(buildCreateUrl(false))
			.content(DataFixture.toJson(createRequest))
			.accept(MediaType.APPLICATION_JSON)
			.contentType(MediaType.APPLICATION_JSON))
			.andExpect(status().isUnprocessableEntity())
			.andExpect(jsonPath("$.description", containsString(createRequest.getServiceInstanceId())));
}
 

import org.springframework.cloud.servicebroker.exception.ServiceInstanceDoesNotExistException; //导入依赖的package包/类
@Test
public void deleteBindingWithUnknownInstanceIdFails() throws Exception {
	doThrow(new ServiceInstanceDoesNotExistException(deleteRequest.getServiceInstanceId()))
			.when(serviceInstanceBindingService).deleteServiceInstanceBinding(any(DeleteServiceInstanceBindingRequest.class));

	setupCatalogService(serviceDefinition.getId());

	mockMvc.perform(delete(buildDeleteUrl(false))
			.contentType(MediaType.APPLICATION_JSON))
			.andExpect(status().isUnprocessableEntity())
			.andExpect(jsonPath("$.description", containsString(deleteRequest.getServiceInstanceId())));
}