import org.springframework.cloud.servicebroker.model.GetLastServiceOperationResponse; //导入依赖的package包/类
GetLastServiceOperationResponse getLastOperation(JsonElement jsonElement) {
    JsonObject jo = jsonElement.getAsJsonObject();
    JsonElement state = jo.get("state");
    JsonElement id = jo.get("id");

    if (id == null) {
        return new GetLastServiceOperationResponse().withDescription("Unable to determine id of request.").withOperationState(OperationState.FAILED);
    }

    if (state == null) {
        return new GetLastServiceOperationResponse().withDescription("Unable to determine state of request: " + id).withOperationState(OperationState.FAILED);
    }

    String requestId = id.getAsString();
    String vrState = state.getAsString();

    LOG.info("vra status for request id: " + requestId + " : " + vrState);

    return new GetLastServiceOperationResponse().withDescription(requestId).withOperationState(vrStatusToOperationState(vrState));
}
 

import org.springframework.cloud.servicebroker.model.GetLastServiceOperationResponse; //导入依赖的package包/类
@Test
public void lastOperationHasInProgressStatus() throws Exception {
	when(serviceInstanceService.getLastOperation(eq(lastOperationRequest)))
			.thenReturn(GetLastServiceOperationResponse.builder()
					.operationState(OperationState.IN_PROGRESS)
					.description("working on it")
			.build());

	mockMvc.perform(get(buildUrl(lastOperationRequest, false)))
			.andExpect(status().isOk())
			.andExpect(jsonPath("$.state", is(OperationState.IN_PROGRESS.toString())))
			.andExpect(jsonPath("$.description", is("working on it")));

	GetLastServiceOperationRequest actualRequest = verifyLastOperation();
	assertNull(actualRequest.getCfInstanceId());
	assertNull(actualRequest.getApiInfoLocation());
	assertNull(actualRequest.getOriginatingIdentity());
}
 

import org.springframework.cloud.servicebroker.model.GetLastServiceOperationResponse; //导入依赖的package包/类
@Test
public void lastOperationHasSucceededStatusWithDeletionComplete() throws Exception {
	GetLastServiceOperationResponse response = GetLastServiceOperationResponse.builder()
			.operationState(OperationState.SUCCEEDED)
			.description("all gone")
			.deleteOperation(true)
			.build();

	when(serviceInstanceService.getLastOperation(eq(lastOperationRequest)))
			.thenReturn(response);

	mockMvc.perform(get(buildUrl(lastOperationRequest, false)))
			.andExpect(status().isGone())
			.andExpect(jsonPath("$.state", is(OperationState.SUCCEEDED.toString())))
			.andExpect(jsonPath("$.description", is("all gone")));
}
 

import org.springframework.cloud.servicebroker.model.GetLastServiceOperationResponse; //导入依赖的package包/类
public GetLastServiceOperationResponse getRequestStatus(VrServiceInstance si) {
    if (si == null || si.getServiceInstanceLastOperation() == null) {
        return new GetLastServiceOperationResponse().withDescription("Unable to get request status: invalid request.").withOperationState(OperationState.FAILED);
    }

    String requestId = si.getCurrentOperationRequestId();
    if (requestId == null) {
        return new GetLastServiceOperationResponse().withDescription("Unable to get requestId from last operation.").withOperationState(OperationState.FAILED);
    }

    return getRequestStatus(tokenService.getToken(), requestId);
}
 

import org.springframework.cloud.servicebroker.model.GetLastServiceOperationResponse; //导入依赖的package包/类
@Test
public void testGetRequestStatus() throws Exception {
    JsonParser parser = new JsonParser();
    JsonElement je = parser.parse(TestConfig
            .getContents("requestResponse.json"));

    GetLastServiceOperationResponse silo = client.getLastOperation(je);
    assertNotNull(silo);
    assertEquals(OperationState.IN_PROGRESS, silo.getState());
}
 

import org.springframework.cloud.servicebroker.model.GetLastServiceOperationResponse; //导入依赖的package包/类
@Test
@Ignore
public void testGetStatus() throws ServiceBrokerException {
    VrServiceInstance instance = TestConfig.getServiceInstance();
    LastOperation lo = new LastOperation(OperationState.IN_PROGRESS, REQ_ID, false);
    instance.withLastOperation(lo);
    GetLastServiceOperationResponse status = client.getRequestStatus(instance);
    assertNotNull(status);
    assertEquals(OperationState.SUCCEEDED, status.getState());
}
 

import org.springframework.cloud.servicebroker.model.GetLastServiceOperationResponse; //导入依赖的package包/类
@Test
@Ignore
public void testDelete() throws Exception {
    LOG.info("get a token.");
    String token = tokenService.getToken();
    assertNotNull(token);

    VrServiceInstance instance = getServiceInstanceToDelete();
    instance = client.deleteInstance(instance);

    String requestId = instance.getCurrentOperationRequestId();
    assertNotNull(requestId);
    LOG.info("delete request id: " + requestId);

    OperationState status = instance.getServiceInstanceLastOperation().getState();
    assertNotNull(status);
    LOG.info("delete request state: " + status);

    LOG.info("wait for delete request to complete....");

    GetLastServiceOperationResponse silo = client.getRequestStatus(token,
            requestId);
    assertNotNull(silo);
    while (silo.getState().equals(OperationState.IN_PROGRESS)) {
        TimeUnit.SECONDS.sleep(10);
        silo = client.getRequestStatus(token, requestId);
        LOG.info("state is: " + silo.getState() + ": "
                + silo.getDescription());
    }

    LOG.info("state is: "
            + client.getRequestStatus(token, requestId).getState());
}
 

import org.springframework.cloud.servicebroker.model.GetLastServiceOperationResponse; //导入依赖的package包/类
@Test
public void lastOperationHasSucceededStatus() throws Exception {
	lastOperationRequest.setApiInfoLocation(API_INFO_LOCATION);
	lastOperationRequest.setOriginatingIdentity(buildOriginatingIdentity());
	lastOperationRequest.setCfInstanceId(CF_INSTANCE_ID);

	GetLastServiceOperationResponse response = GetLastServiceOperationResponse.builder()
			.operationState(OperationState.SUCCEEDED)
			.description("all good")
			.build();

	when(serviceInstanceService.getLastOperation(eq(lastOperationRequest))).thenReturn(response);

	mockMvc.perform(get(buildUrl(lastOperationRequest, true))
			.header(API_INFO_LOCATION_HEADER, API_INFO_LOCATION)
			.header(ORIGINATING_IDENTITY_HEADER, buildOriginatingIdentityHeader()))
			.andExpect(status().isOk())
			.andExpect(jsonPath("$.state", is(OperationState.SUCCEEDED.toString())))
			.andExpect(jsonPath("$.description", is("all good")));

	GetLastServiceOperationRequest actualRequest = verifyLastOperation();
	assertEquals(CF_INSTANCE_ID, actualRequest.getCfInstanceId());
	assertEquals(API_INFO_LOCATION, actualRequest.getApiInfoLocation());
	assertEquals(ORIGINATING_IDENTITY_PLATFORM, actualRequest.getOriginatingIdentity().getPlatform());
	assertEquals(ORIGINATING_USER_VALUE, actualRequest.getOriginatingIdentity().getProperty(ORIGINATING_USER_KEY));
	assertEquals(ORIGINATING_EMAIL_VALUE, actualRequest.getOriginatingIdentity().getProperty(ORIGINATING_EMAIL_KEY));
}
 

import org.springframework.cloud.servicebroker.model.GetLastServiceOperationResponse; //导入依赖的package包/类
@Test
public void lastOperationHasFailedStatus() throws Exception {
	GetLastServiceOperationResponse response = GetLastServiceOperationResponse.builder()
			.operationState(OperationState.FAILED)
			.description("not so good")
			.build();

	when(serviceInstanceService.getLastOperation(eq(lastOperationRequest)))
			.thenReturn(response);

	mockMvc.perform(get(buildUrl(lastOperationRequest, false)))
			.andExpect(status().isOk())
			.andExpect(jsonPath("$.state", is(OperationState.FAILED.toString())))
			.andExpect(jsonPath("$.description", is("not so good")));
}
 

import org.springframework.cloud.servicebroker.model.GetLastServiceOperationResponse; //导入依赖的package包/类
@GetMapping(value = {
		"/{cfInstanceId}/v2/service_instances/{instanceId}/last_operation",
		"/v2/service_instances/{instanceId}/last_operation"
})
public ResponseEntity<?> getServiceInstanceLastOperation(@PathVariable Map<String, String> pathVariables,
														 @PathVariable("instanceId") String serviceInstanceId,
														 @RequestParam("service_id") String serviceDefinitionId,
														 @RequestParam("plan_id") String planId,
														 @RequestParam(value = "operation", required = false) String operation,
														 @RequestHeader(value = API_INFO_LOCATION_HEADER, required = false) String apiInfoLocation,
														 @RequestHeader(value = ORIGINATING_IDENTITY_HEADER, required = false) String originatingIdentityString) {
	GetLastServiceOperationRequest request = new GetLastServiceOperationRequest();
	request.setServiceDefinitionId(serviceDefinitionId);
	request.setServiceInstanceId(serviceInstanceId);
	request.setPlanId(planId);
	request.setOperation(operation);
	setCommonRequestFields(request, pathVariables.get("cfInstanceId"), apiInfoLocation, originatingIdentityString);

	log.debug("Getting service instance status: request={}", request);

	GetLastServiceOperationResponse response = service.getLastOperation(request);

	log.debug("Getting service instance status succeeded: serviceInstanceId={}, response={}",
			serviceInstanceId, response);

	boolean isSuccessfulDelete = response.getState().equals(OperationState.SUCCEEDED) && response.isDeleteOperation();

	return new ResponseEntity<>(response, isSuccessfulDelete ? HttpStatus.GONE : HttpStatus.OK);
}
 

import org.springframework.cloud.servicebroker.model.GetLastServiceOperationResponse; //导入依赖的package包/类
@Override
public GetLastServiceOperationResponse getLastOperation(GetLastServiceOperationRequest request) {
       try {
           OperationState serviceInstanceLastOperation = getServiceInstance(request.getServiceInstanceId()).getOperationState();
           LOG.info("getting last operation for {}: {}", request, serviceInstanceLastOperation);
           return new GetLastServiceOperationResponse().withOperationState(serviceInstanceLastOperation);
       } catch (Exception e) {
           LOG.info("exception thrown getting last operation for {}: {}", request, e);
           throw e;
       }
}
 

import org.springframework.cloud.servicebroker.model.GetLastServiceOperationResponse; //导入依赖的package包/类
@Override
public GetLastServiceOperationResponse getLastOperation(GetLastServiceOperationRequest request) {
	return new GetLastServiceOperationResponse().withOperationState(OperationState.SUCCEEDED);
}
 

import org.springframework.cloud.servicebroker.model.GetLastServiceOperationResponse; //导入依赖的package包/类
public static LastOperation fromResponse(GetLastServiceOperationResponse response) {
    return new LastOperation(response.getState(), response.getDescription(), response.isDeleteOperation());
}
 

import org.springframework.cloud.servicebroker.model.GetLastServiceOperationResponse; //导入依赖的package包/类
public GetLastServiceOperationResponse toResponse() {
    return new GetLastServiceOperationResponse().
            withDescription(getDescription()).
            withOperationState(getState()).
            withDeleteOperation(isDelete());
}
 

import org.springframework.cloud.servicebroker.model.GetLastServiceOperationResponse; //导入依赖的package包/类
@Test
public void testGetLastOperation() throws Exception {
    JsonParser parser = new JsonParser();
    JsonElement je = parser.parse(TestConfig
            .getContents("submittedRequestResponse.json"));

    GetLastServiceOperationResponse silo = client.getLastOperation(je);
    assertNotNull(silo);
    assertEquals(OperationState.IN_PROGRESS, silo.getState());

    je = parser.parse(TestConfig
            .getContents("inProgressRequestResponse.json"));
    silo = client.getLastOperation(je);
    assertNotNull(silo);
    assertEquals(OperationState.IN_PROGRESS, silo.getState());

    je = parser.parse(TestConfig
            .getContents("pendingPreRequestResponse.json"));
    silo = client.getLastOperation(je);
    assertNotNull(silo);
    assertEquals(OperationState.IN_PROGRESS, silo.getState());

    je = parser.parse(TestConfig
            .getContents("pendingPostRequestResponse.json"));
    silo = client.getLastOperation(je);
    assertNotNull(silo);
    assertEquals(OperationState.IN_PROGRESS, silo.getState());

    je = parser.parse(TestConfig
            .getContents("successfulPostRequestResponse.json"));
    silo = client.getLastOperation(je);
    assertNotNull(silo);
    assertEquals(OperationState.SUCCEEDED, silo.getState());

    je = parser.parse(TestConfig
            .getContents("failedPostRequestResponse.json"));
    silo = client.getLastOperation(je);
    assertNotNull(silo);
    assertEquals(OperationState.FAILED, silo.getState());

    je = parser.parse(TestConfig
            .getContents("rejectedRequestResponse.json"));
    silo = client.getLastOperation(je);
    assertNotNull(silo);
    assertEquals(OperationState.FAILED, silo.getState());

    je = parser.parse(TestConfig
            .getContents("bogusStateRequestResponse.json"));
    silo = client.getLastOperation(je);
    assertNotNull(silo);
    assertEquals(OperationState.FAILED, silo.getState());

    je = parser.parse(TestConfig
            .getContents("missingStateRequestResponse.json"));
    silo = client.getLastOperation(je);
    assertNotNull(silo);
    assertEquals(OperationState.FAILED, silo.getState());
}
 

import org.springframework.cloud.servicebroker.model.GetLastServiceOperationResponse; //导入依赖的package包/类
@Test
@Ignore
public void testCreate() throws Exception {
    LOG.info("get a token.");
    String token = tokenService.getToken();
    assertNotNull(token);

    LOG.info("get a service def.");
    ServiceDefinition sd = catalogService
            .getServiceDefinition(TestConfig.SD_ID);
    assertNotNull(sd);

    LOG.info("submitting create request.");
    VrServiceInstance instance = client.createInstance(
            TestConfig.getCreateServiceInstanceRequest(sd, true), sd);

    Object requestId = instance.getCreateRequestId();
    assertNotNull(requestId);
    LOG.info("requestId: " + requestId);

    OperationState status = instance.getServiceInstanceLastOperation().getState();
    assertNotNull(status);

    LOG.info("request status is: " + status + " requestId is: " + requestId);

    Object location = instance.getLocation();
    assertNotNull(location);

    LOG.info("location: " + location);

    LOG.info("wait for create request to complete....");

    GetLastServiceOperationResponse silo = client.getRequestStatus(token,
            requestId.toString());
    assertNotNull(silo);
    while (silo.getState().equals(OperationState.IN_PROGRESS)) {
        TimeUnit.SECONDS.sleep(10);
        silo = client.getRequestStatus(token, requestId.toString());
        LOG.info("state is: " + silo.getState() + ": "
                + silo.getDescription());
    }

    LOG.info("state is: "
            + client.getRequestStatus(token, requestId.toString()).getState());

    while (true) {
        LOG.info("host is: " + instance.getHost());
        client.loadCredentials(instance);

        if (instance.getHost() != null) {
            break;
        }

        TimeUnit.SECONDS.sleep(10);
    }

    Map creds = instance.getCredentials();
    assertNotNull(creds);

    LOG.info("credentials: " + instance.getCredentials().toString());
    LOG.info("uri: " + instance.getCredentials().get(VrServiceInstance.URI));
}
 

import org.springframework.cloud.servicebroker.model.GetLastServiceOperationResponse; //导入依赖的package包/类
/**
 * Get the status of the last requested operation for a service instance.
 *
 * @param request containing the details of the request
 * @return the details of the completed request
 * @throws ServiceInstanceDoesNotExistException if a service instance with the given ID is not known to the broker
 */
GetLastServiceOperationResponse getLastOperation(GetLastServiceOperationRequest request);